src/index.ts

@@ -91,7 +91,10 @@ const plugin: Plugin = {
     api = _api;
     setup();
 
-    if (api.pluginConfig.bool("store.memory")) {
+    if (
+      api.pluginConfig.bool("storememory") &&
+      !api.pluginConfig.bool("store")
+    ) {
       memStore = new NodeCache();
     }
 
@@ -108,15 +111,15 @@ const plugin: Plugin = {
       }
       let entry = (await getEntry(newEntry.pk)) as SignedRegistryEntry;
 
-      async function setAndRespond(entry: SignedRegistryEntry) {
+      async function setAndRespond() {
         await setEntry(newEntry);
         sendDirectOrBroadcast(
           Message.create({
             type: MessageType.CREATED,
-            pubkey: entry.pk,
+            pubkey: newEntry.pk,
-            revision: entry.revision,
+            revision: newEntry.revision,
-            signature: entry.signature,
+            signature: newEntry.signature,
-            data: entry.data,
+            data: newEntry.data,
           }),
           origin
         );
@@ -124,13 +127,11 @@ const plugin: Plugin = {
 
       if (entry) {
         if (newEntry.revision <= entry.revision) {
-          setAndRespond(newEntry);
+          setAndRespond();
-          return;
         }
-        setAndRespond(entry);
+      } else {
-        return;
+        setAndRespond();
       }
-      setAndRespond(newEntry);
     });
 
     events.on("query", async (query: Query, origin: Buffer) => {