From 39b0117e4f02550c9ac7b58961e83b2e82757b41 Mon Sep 17 00:00:00 2001 From: Derrick Hammer Date: Sat, 2 Sep 2023 08:54:45 -0400 Subject: [PATCH] fix: only submit a new registry entry if the data has changed --- src/index.ts | 36 +++++++++++++++++++++++------------- 1 file changed, 23 insertions(+), 13 deletions(-) diff --git a/src/index.ts b/src/index.ts index 3a02503..0476bf5 100644 --- a/src/index.ts +++ b/src/index.ts @@ -6,6 +6,7 @@ import fs from "fs/promises"; import path from "path"; import { concatBytes, + equalBytes, hexToBytes, maybeInitDefaultPortals, setActivePortalMasterKey, @@ -27,6 +28,7 @@ import { Logger, REGISTRY_TYPES, S5NodeConfig, + SignedRegistryEntry, } from "@lumeweb/libs5"; import { MemoryLevel } from "memory-level"; @@ -162,6 +164,7 @@ await peerDefer.promise; const key = hdKey as HDKey; let revision = 0; + let sre: SignedRegistryEntry; const ret = await node.services.registry.get( new KeyPairEd25519(key.privateKey).publicKey, @@ -170,20 +173,27 @@ await peerDefer.promise; if (ret) { revision = ret.revision + 1; } - const sre = node.services.registry.signRegistryEntry({ - kp: new KeyPairEd25519((hdKey as HDKey).privateKey), - data: concatBytes( - Uint8Array.from([ - REGISTRY_TYPES.CID, - CID_TYPES.RESOLVER, - CID_HASH_TYPES.BLAKE3, - ]), - cidBytes, - ), - revision, - }); - await node.services.registry.set(sre); + const newEntry = concatBytes( + Uint8Array.from([ + REGISTRY_TYPES.CID, + CID_TYPES.RESOLVER, + CID_HASH_TYPES.BLAKE3, + ]), + cidBytes, + ); + + if (!equalBytes(ret?.data ?? new Uint8Array(), newEntry)) { + sre = node.services.registry.signRegistryEntry({ + kp: new KeyPairEd25519((hdKey as HDKey).privateKey), + data: newEntry, + revision, + }); + + await node.services.registry.set(sre); + } else { + sre = ret as SignedRegistryEntry; + } console.log( util.format(