diff --git a/src/RelayIngester.cpp b/src/RelayIngester.cpp
index 8b5634e..1d8d7c6 100644
--- a/src/RelayIngester.cpp
+++ b/src/RelayIngester.cpp
@@ -85,7 +85,7 @@ void RelayServer::ingesterProcessEvent(lmdb::txn &txn, uint64_t connId, secp256k
         auto existing = lookupEventById(txn, sv(flat->id()));
         if (existing) {
             LI << "Duplicate event, skipping";
-            sendOKResponse(connId, to_hex(sv(flat->id())), false, "duplicate: have this event");
+            sendOKResponse(connId, to_hex(sv(flat->id())), true, "duplicate: have this event");
             return;
         }
     }
diff --git a/src/RelayWriter.cpp b/src/RelayWriter.cpp
index 326525e..a082487 100644
--- a/src/RelayWriter.cpp
+++ b/src/RelayWriter.cpp
@@ -41,6 +41,7 @@ void RelayServer::runWriter(ThreadPool<MsgWriter>::Thread &thr) {
                 written = true;
             } else if (newEvent.status == EventWriteStatus::Duplicate) {
                 message = "duplicate: have this event";
+                written = true;
             } else if (newEvent.status == EventWriteStatus::Replaced) {
                 message = "replaced: have newer event";
             } else if (newEvent.status == EventWriteStatus::Deleted) {