LumeWeb
/
libweb
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

refactor: move away from the tuple pattern

This commit is contained in:
Derrick Hammer 2023-09-07 19:15:33 -04:00
parent 6a285b54f1
commit 2300b07419
Signed by: pcfreak30
GPG Key ID: C997C339BE476FF2
1 changed files with 12 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
src/download.ts
View File

@ -1,5 +1,4 @@
import { getActivePortals } from "#portal.js"; import { getActivePortals } from "#portal.js";
import { ErrTuple } from "#types.js";
import { decodeCid, getVerifiableStream } from "@lumeweb/libportal"; import { decodeCid, getVerifiableStream } from "@lumeweb/libportal";
import { import {
readableStreamToUint8Array, readableStreamToUint8Array,
@ -8,13 +7,13 @@ import {
import { equalBytes } from "@noble/curves/abstract/utils"; import { equalBytes } from "@noble/curves/abstract/utils";
import { blake3 } from "@noble/hashes/blake3"; import { blake3 } from "@noble/hashes/blake3";
const NO_PORTALS_ERROR = [null, "no active portals"] as ErrTuple; const NO_PORTALS_ERROR = new Error("no active portals");
export async function downloadObject(cid: string): Promise<ErrTuple> { export async function downloadObject(cid: string): Promise<ReadableStream> {
const activePortals = getActivePortals(); const activePortals = getActivePortals();
if (!activePortals.length) { if (!activePortals.length) {
return NO_PORTALS_ERROR; throw NO_PORTALS_ERROR;
} }
for (const portal of activePortals) { for (const portal of activePortals) {
@ -35,20 +34,19 @@ export async function downloadObject(cid: string): Promise<ErrTuple> {
continue; continue;
} }
return [ return await getVerifiableStream(decodeCid(cid).hash, proof, stream);
await getVerifiableStream(decodeCid(cid).hash, proof, stream),
null,
];
} }
return NO_PORTALS_ERROR; throw NO_PORTALS_ERROR;
} }
export async function downloadSmallObject(cid: string): Promise<ErrTuple> { export async function downloadSmallObject(
cid: string,
): Promise<ReadableStream<Uint8Array>> {
const activePortals = getActivePortals(); const activePortals = getActivePortals();
if (!activePortals.length) { if (!activePortals.length) {
return NO_PORTALS_ERROR; throw NO_PORTALS_ERROR;
} }
for (const portal of activePortals) { for (const portal of activePortals) {
@ -72,11 +70,11 @@ export async function downloadSmallObject(cid: string): Promise<ErrTuple> {
const data = await readableStreamToUint8Array(stream); const data = await readableStreamToUint8Array(stream);
if (!equalBytes(blake3(data), CID.hash)) { if (!equalBytes(blake3(data), CID.hash)) {
return [null, "cid verification failed"]; throw new Error("cid verification failed");
} }
return [uint8ArrayToReadableStream(data), null]; return uint8ArrayToReadableStream(data);
} }
return NO_PORTALS_ERROR; throw NO_PORTALS_ERROR;
} }