refactor: rewrite resolveModuleRegistryEntry to use decodeRegistryCid, decodeRegistryValue, and encodeCid

This commit is contained in:
Derrick Hammer 2023-09-04 04:09:46 -04:00
parent c5eeab0ba6
commit 867544e1c9
Signed by: pcfreak30
GPG Key ID: C997C339BE476FF2
1 changed files with 20 additions and 4 deletions

View File

@ -1,7 +1,10 @@
import { internalModuleCall, modules } from "./queries.js"; import { internalModuleCall, modules } from "./queries.js";
import { SignedRegistryEntry } from "@lumeweb/libs5"; import { SignedRegistryEntry } from "@lumeweb/libs5";
import { base58btc } from "multiformats/bases/base58"; import {
import { decodeCid } from "@lumeweb/libweb"; decodeRegistryValue,
encodeCid,
decodeRegistryCid,
} from "@lumeweb/libweb";
const CORE_MODULES = { const CORE_MODULES = {
swarm: "zdiLmwHCC15afFNLYzzT2DVV7m27SrBde7oXHdSzAe95GpFZXzdpatUN6b", swarm: "zdiLmwHCC15afFNLYzzT2DVV7m27SrBde7oXHdSzAe95GpFZXzdpatUN6b",
@ -32,7 +35,7 @@ function moduleLoaded(module: string) {
} }
export async function resolveModuleRegistryEntry(module: string) { export async function resolveModuleRegistryEntry(module: string) {
const [cid] = decodeCid(module); const [cid] = decodeRegistryCid(module);
const pubkey = cid.hash; const pubkey = cid.hash;
@ -42,5 +45,18 @@ export async function resolveModuleRegistryEntry(module: string) {
{ pubkey }, { pubkey },
)) as SignedRegistryEntry; )) as SignedRegistryEntry;
return base58btc.encode(signedEntry.data); let [decodedRegistry, err] = decodeRegistryValue(signedEntry.data);
if (err) {
throw new Error(err);
}
let rawEncCid;
[rawEncCid, err] = encodeCid(decodedRegistry);
if (err) {
throw new Error(err);
}
return rawEncCid;
} }