LumeWeb
/
relay-plugin-registry
Archived
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

*Always respond with a created message, and if the entry is not updated, respond with the existing entry

This commit is contained in:
Derrick Hammer 2022-12-31 16:38:54 -05:00
parent c7d963c9b1
commit 1b876bb78f
Signed by: pcfreak30
GPG Key ID: C997C339BE476FF2
1 changed files with 10 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
src/index.ts
View File

@ -108,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
); );
@ -124,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) => {