LumeWeb
/
kernel-s5
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

feat: add getRegistryEntry, setRegistryEntry, registrySubscription

This commit is contained in:
Derrick Hammer 2023-09-01 08:33:32 -04:00
parent 8fa8a68b47
commit fa04bb5e30
Signed by: pcfreak30
GPG Key ID: C997C339BE476FF2
3 changed files with 100 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
npm-shrinkwrap.json generated
View File

@ -11,7 +11,7 @@
"@lumeweb/kernel-protomux-client": "^0.0.2-develop.16",
"@lumeweb/kernel-swarm-client": "^0.1.0-develop.5",
"@lumeweb/libkernel": "^0.1.0-develop.36",
"@lumeweb/libs5-transport-hyper": "^0.1.0-develop.10",
"@lumeweb/libs5-transport-hyper": "^0.1.0-develop.16",
"whatwg-url": "^13.0.0"
},
"devDependencies": {
@ -1747,9 +1747,9 @@
}
},
"node_modules/@lumeweb/libs5": {
"version": "0.1.0-develop.17",
"resolved": "https://registry.npmjs.org/@lumeweb/libs5/-/libs5-0.1.0-develop.17.tgz",
"integrity": "sha512-P+tno8umL8ir5ZxMnBG0SOn1Y9x5e6ar1jSDDJpj+gfyskvMFygzzqQlvcQa39pLHxLkQg48X6xjziPjEarVew==",
"version": "0.1.0-develop.24",
"resolved": "https://registry.npmjs.org/@lumeweb/libs5/-/libs5-0.1.0-develop.24.tgz",
"integrity": "sha512-d2QP9t6/+Cilzt102Jk1baJW/sSXKOOd0tFyR7EnkFVry6HA/6HCoOGXy6/V1IpFPo0JfH63M/bi4nLNfPfcjg==",
"dependencies": {
"@noble/curves": "^1.1.0",
"@noble/hashes": "^1.3.1",
@ -1761,11 +1761,11 @@
}
},
"node_modules/@lumeweb/libs5-transport-hyper": {
"version": "0.1.0-develop.10",
"resolved": "https://registry.npmjs.org/@lumeweb/libs5-transport-hyper/-/libs5-transport-hyper-0.1.0-develop.10.tgz",
"integrity": "sha512-LYuyWBOrbhg3jR18hF/ZttARApsqsXWrFTNYCbV/H3weYLahAZX+I5Ko943d3ApbWhUPTEFo0Gbe5T5/Ajc0Eg==",
"version": "0.1.0-develop.16",
"resolved": "https://registry.npmjs.org/@lumeweb/libs5-transport-hyper/-/libs5-transport-hyper-0.1.0-develop.16.tgz",
"integrity": "sha512-3Qo0lPF6oK3Uxh+cxxLSSyn+5ZyAd4zSp1SmJhifn76yypvhID5Rc9zwpAV+4m8EHWO4CBwu4xCn25wArLKKNA==",
"dependencies": {
"@lumeweb/libs5": "^0.1.0-develop.17",
"@lumeweb/libs5": "^0.1.0-develop.24",
"streamx": "^2.15.1"
}
},

2
package.json
View File

@ -16,7 +16,7 @@
"@lumeweb/kernel-protomux-client": "^0.0.2-develop.16",
"@lumeweb/kernel-swarm-client": "^0.1.0-develop.5",
"@lumeweb/libkernel": "^0.1.0-develop.36",
"@lumeweb/libs5-transport-hyper": "^0.1.0-develop.10",
"@lumeweb/libs5-transport-hyper": "^0.1.0-develop.16",
"whatwg-url": "^13.0.0"
},
"devDependencies": {

96
src/index.ts
View File

@ -1,4 +1,4 @@
import { concatBytes } from "@lumeweb/libkernel";
import { concatBytes, ensureBytes } from "@lumeweb/libkernel";
import {
addHandler,
defer,
@ -6,7 +6,10 @@ import {
handlePresentKey as handlePresentKeyModule,
} from "@lumeweb/libkernel/module";
import type { ActiveQuery } from "@lumeweb/libkernel/module";
import { createClient as createSwarmClient } from "@lumeweb/kernel-swarm-client";
import {
createClient as createSwarmClient,
SwarmClient,
} from "@lumeweb/kernel-swarm-client";
import Protomux from "@lumeweb/kernel-protomux-client";
import {
createKeyPair,
@ -14,7 +17,9 @@ import {
NodeId,
S5NodeConfig,
} from "@lumeweb/libs5";
import { mkeyEd25519 } from "@lumeweb/libs5/lib/constants.js";
import { mkeyEd25519 } from "@lumeweb/libs5";
import type { S5Node } from "@lumeweb/libs5";
import KeyPairEd25519 from "@lumeweb/libs5/lib/ed25519.js";
import { Level } from "level";
import HyperTransportPeer from "@lumeweb/libs5-transport-hyper";
@ -22,10 +27,16 @@ const PROTOCOL = "lumeweb.service.s5";
const moduleReadyDefer = defer();
let swarm;
let swarm: SwarmClient;
let node: S5Node;
addHandler("presentKey", handlePresentKey);
addHandler("ready", ready);
addHandler("getRegistryEntry", handleGetRegistryEntry);
addHandler("setRegistryEntry", handleSetRegistryEntry);
addHandler("registrySubscription", handleRegistrySubscription, {
receiveUpdates: true,
});
async function handlePresentKey(aq: ActiveQuery) {
handlePresentKeyModule({
@ -58,7 +69,7 @@ async function setup() {
await swarm.start();
await swarm.ready();
const node = createNode(config);
node = createNode(config);
await node.start();
@ -78,8 +89,83 @@ async function setup() {
node.services.p2p.onNewPeer(s5peer, true);
});
}
async function ready(aq: ActiveQuery) {
await moduleReadyDefer.promise;
aq.respond();
}
async function handleGetRegistryEntry(aq: ActiveQuery) {
if (!("pubkey" in aq.callerInput)) {
aq.reject("pubkey required");
}
await moduleReadyDefer.promise;
let { pubkey } = aq.callerInput;
pubkey = ensureBytes("registry entry ", pubkey, 32);
const ret = await node.services.registry.get(pubkey);
if (!ret) {
aq.reject("could not find registry entry");
return;
}
aq.respond(ret);
}
async function handleSetRegistryEntry(aq: ActiveQuery) {
for (const field of ["key", "data", "revision"]) {
if (!(field in aq.callerInput)) {
aq.reject(`${field} required`);
return;
}
}
await moduleReadyDefer.promise;
let { key, data, revision } = aq.callerInput;
key = ensureBytes("registry entry private key", key, 32);
const sre = node.services.registry.signRegistryEntry({
kp: new KeyPairEd25519(key),
data,
revision,
});
try {
await node.services.registry.set(sre);
aq.respond(sre);
} catch (e) {
aq.reject(e);
}
}
async function handleRegistrySubscription(aq: ActiveQuery) {
if (!("pubkey" in aq.callerInput)) {
aq.reject("pubkey required");
}
await moduleReadyDefer.promise;
let { pubkey } = aq.callerInput;
pubkey = ensureBytes("registry entry ", pubkey, 32);
const wait = defer();
const done = node.services.registry.listen(pubkey, (sre) => {
aq.sendUpdate(sre);
});
aq.setReceiveUpdate?.(() => {
done();
wait.resolve();
});
await wait.promise;
aq.respond();
}