*Create getCID helper and have all api calls use it
This commit is contained in:
parent
bc10722539
commit
3955ff2c29
41
src/index.ts
41
src/index.ts
|
@ -238,7 +238,10 @@ async function handleStat(aq: ActiveQuery) {
|
||||||
aq.respond(
|
aq.respond(
|
||||||
JSON.parse(
|
JSON.parse(
|
||||||
JSON.stringify(
|
JSON.stringify(
|
||||||
await fs.stat(aq.callerInput.cid, aq.callerInput.options ?? {})
|
await fs.stat(
|
||||||
|
getCID(aq.callerInput.cid),
|
||||||
|
aq.callerInput.options ?? {}
|
||||||
|
)
|
||||||
)
|
)
|
||||||
)
|
)
|
||||||
);
|
);
|
||||||
|
@ -260,7 +263,10 @@ async function handleLs(aq: ActiveQuery) {
|
||||||
aborted = true;
|
aborted = true;
|
||||||
});
|
});
|
||||||
|
|
||||||
const iterable = fs.ls(aq.callerInput.cid, aq.callerInput.options ?? {});
|
const iterable = fs.ls(
|
||||||
|
getCID(aq.callerInput.cid),
|
||||||
|
aq.callerInput.options ?? {}
|
||||||
|
);
|
||||||
|
|
||||||
for await (const item of iterable) {
|
for await (const item of iterable) {
|
||||||
if (aborted) {
|
if (aborted) {
|
||||||
|
@ -286,7 +292,10 @@ async function handleCat(aq: ActiveQuery) {
|
||||||
aborted = true;
|
aborted = true;
|
||||||
});
|
});
|
||||||
|
|
||||||
const iterable = fs.cat(aq.callerInput.cid, aq.callerInput.options ?? {});
|
const iterable = fs.cat(
|
||||||
|
getCID(aq.callerInput.cid),
|
||||||
|
aq.callerInput.options ?? {}
|
||||||
|
);
|
||||||
|
|
||||||
for await (const chunk of iterable) {
|
for await (const chunk of iterable) {
|
||||||
if (aborted) {
|
if (aborted) {
|
||||||
|
@ -315,20 +324,13 @@ async function handleIpnsResolve(aq: ActiveQuery) {
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
const prefix = substr(aq.callerInput.cid, 0, 1);
|
|
||||||
|
|
||||||
if (!(prefix in basesByPrefix)) {
|
|
||||||
aq.reject("invalid multibase found in CID");
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
const base = basesByPrefix[prefix];
|
|
||||||
const cid = CID.parse(aq.callerInput.cid, base);
|
|
||||||
|
|
||||||
try {
|
try {
|
||||||
return aq.respond(
|
return aq.respond(
|
||||||
(
|
(
|
||||||
await IPNS.resolve(peerIdFromCID(cid), aq.callerInput?.options)
|
await IPNS.resolve(
|
||||||
|
peerIdFromCID(getCID(aq.callerInput.cid)),
|
||||||
|
aq.callerInput?.options
|
||||||
|
)
|
||||||
).asCID.toString()
|
).asCID.toString()
|
||||||
);
|
);
|
||||||
} catch (e: any) {
|
} catch (e: any) {
|
||||||
|
@ -336,6 +338,17 @@ async function handleIpnsResolve(aq: ActiveQuery) {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
function getCID(cid: string): CID {
|
||||||
|
const prefix = substr(cid, 0, 1);
|
||||||
|
|
||||||
|
if (!(prefix in basesByPrefix)) {
|
||||||
|
throw new Error("invalid multibase found in CID");
|
||||||
|
}
|
||||||
|
|
||||||
|
const base = basesByPrefix[prefix];
|
||||||
|
return CID.parse(cid, base);
|
||||||
|
}
|
||||||
|
|
||||||
async function handleGetActivePeers(aq: ActiveQuery) {
|
async function handleGetActivePeers(aq: ActiveQuery) {
|
||||||
await ready();
|
await ready();
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue