63 lines
2.1 KiB
JavaScript
63 lines
2.1 KiB
JavaScript
import { Client, factory } from "@lumeweb/libkernel-universal";
|
|
import defer from "p-defer";
|
|
export class IPFSClient extends Client {
|
|
async ready() {
|
|
return this.callModuleReturn("ready");
|
|
}
|
|
async stat(cid, options) {
|
|
return this.callModuleReturn("stat", { cid, options });
|
|
}
|
|
ls(cid, options) {
|
|
return this.connectModuleGenerator("ls", { cid, options });
|
|
}
|
|
cat(cid, options) {
|
|
return this.connectModuleGenerator("cat", { cid, options });
|
|
}
|
|
async ipns(cid) {
|
|
return this.callModuleReturn("ipnsResolve", { cid });
|
|
}
|
|
async activePeers() {
|
|
return this.callModuleReturn("getActivePeers");
|
|
}
|
|
connectModuleGenerator(method, data) {
|
|
let pipe = defer();
|
|
const [update, result] = this.connectModule(method, data, (item) => {
|
|
pipe.resolve(item);
|
|
});
|
|
(async () => {
|
|
const ret = await result;
|
|
this.handleError(ret);
|
|
pipe.resolve(undefined);
|
|
})();
|
|
return {
|
|
abort() {
|
|
update("abort");
|
|
},
|
|
iterable() {
|
|
return {
|
|
[Symbol.asyncIterator]() {
|
|
return {
|
|
async next() {
|
|
const chunk = await pipe.promise;
|
|
if (chunk === undefined) {
|
|
return {
|
|
value: new Uint8Array(),
|
|
done: true,
|
|
};
|
|
}
|
|
pipe = defer();
|
|
update("next");
|
|
return {
|
|
value: chunk,
|
|
done: false,
|
|
};
|
|
},
|
|
};
|
|
},
|
|
};
|
|
},
|
|
};
|
|
}
|
|
}
|
|
export const createClient = factory(IPFSClient, "AAA0F0m8xP2YVcP0YZ-1QT8nLqYPZjgANotOQO3nGST1Bg");
|