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

refactor: errtuples are no longer used, and switch to using the CID class

This commit is contained in:
Derrick Hammer 2023-09-11 13:29:04 -04:00
parent 3eda1bbc37
commit e8b3e03e7b
Signed by: pcfreak30
GPG Key ID: C997C339BE476FF2
1 changed files with 21 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

36
src/index.ts
View File

@ -5,8 +5,6 @@ import * as process from "process";
import fs from "fs/promises"; import fs from "fs/promises";
import path from "path"; import path from "path";
import { import {
encodeRegistryCid,
encodeRegistryValue,
equalBytes, equalBytes,
hexToBytes, hexToBytes,
maybeInitDefaultPortals, maybeInitDefaultPortals,
@ -22,6 +20,7 @@ import { HDKey } from "ed25519-keygen/hdkey";
import { import {
BOOTSTRAP_NODES, BOOTSTRAP_NODES,
CID,
createKeyPair, createKeyPair,
createNode, createNode,
S5NodeConfig, S5NodeConfig,
@ -108,13 +107,16 @@ maybeInitDefaultPortals();
const fd = await fs.open(file as string); const fd = await fs.open(file as string);
const [cid, err] = await uploadObject( let cid;
fd.createReadStream(),
BigInt((await fd.stat()).size),
);
if (err) { try {
console.error("Failed to publish: ", err); cid = await uploadObject(
fd.createReadStream(),
BigInt((await fd.stat()).size),
);
} catch (e) {
console.error("Failed to publish: ", e.message);
process.exit();
} }
console.log( console.log(
@ -174,10 +176,12 @@ await peerDefer.promise;
revision = ret.revision + 1; revision = ret.revision + 1;
} }
let [newEntry, err] = encodeRegistryValue(cid); let newEntry;
try {
if (err) { newEntry = CID.decode(cid).toRegistryEntry();
throw new Error(err); } catch (e) {
console.error("Failed to publish: ", e.message);
process.exit();
} }
if (!equalBytes(ret?.data ?? new Uint8Array(), newEntry)) { if (!equalBytes(ret?.data ?? new Uint8Array(), newEntry)) {
@ -193,10 +197,12 @@ await peerDefer.promise;
} }
let resolverCid; let resolverCid;
[resolverCid, err] = encodeRegistryCid(sre.pk);
if (err) { try {
throw new Error(err); resolverCid = CID.fromRegistryPublicKey(sre.pk);
} catch (e) {
console.error("Failed to publish: ", e.message);
process.exit();
} }
console.log( console.log(