Compare commits
2 Commits
4264ca099e
...
1b876bb78f
Author | SHA1 | Date |
---|---|---|
Derrick Hammer | 1b876bb78f | |
Derrick Hammer | c7d963c9b1 |
23
src/index.ts
23
src/index.ts
|
@ -91,10 +91,7 @@ const plugin: Plugin = {
|
||||||
api = _api;
|
api = _api;
|
||||||
setup();
|
setup();
|
||||||
|
|
||||||
if (
|
if (api.pluginConfig.bool("store.memory")) {
|
||||||
api.pluginConfig.bool("storememory") &&
|
|
||||||
!api.pluginConfig.bool("store")
|
|
||||||
) {
|
|
||||||
memStore = new NodeCache();
|
memStore = new NodeCache();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -111,15 +108,15 @@ const plugin: Plugin = {
|
||||||
}
|
}
|
||||||
let entry = (await getEntry(newEntry.pk)) as SignedRegistryEntry;
|
let entry = (await getEntry(newEntry.pk)) as SignedRegistryEntry;
|
||||||
|
|
||||||
async function setAndRespond() {
|
async function setAndRespond(entry: SignedRegistryEntry) {
|
||||||
await setEntry(newEntry);
|
await setEntry(newEntry);
|
||||||
sendDirectOrBroadcast(
|
sendDirectOrBroadcast(
|
||||||
Message.create({
|
Message.create({
|
||||||
type: MessageType.CREATED,
|
type: MessageType.CREATED,
|
||||||
pubkey: newEntry.pk,
|
pubkey: entry.pk,
|
||||||
revision: newEntry.revision,
|
revision: entry.revision,
|
||||||
signature: newEntry.signature,
|
signature: entry.signature,
|
||||||
data: newEntry.data,
|
data: entry.data,
|
||||||
}),
|
}),
|
||||||
origin
|
origin
|
||||||
);
|
);
|
||||||
|
@ -127,11 +124,13 @@ const plugin: Plugin = {
|
||||||
|
|
||||||
if (entry) {
|
if (entry) {
|
||||||
if (newEntry.revision <= entry.revision) {
|
if (newEntry.revision <= entry.revision) {
|
||||||
setAndRespond();
|
setAndRespond(newEntry);
|
||||||
|
return;
|
||||||
}
|
}
|
||||||
} else {
|
setAndRespond(entry);
|
||||||
setAndRespond();
|
return;
|
||||||
}
|
}
|
||||||
|
setAndRespond(newEntry);
|
||||||
});
|
});
|
||||||
|
|
||||||
events.on("query", async (query: Query, origin: Buffer) => {
|
events.on("query", async (query: Query, origin: Buffer) => {
|
||||||
|
|
Reference in New Issue