chore(release): 0.0.2-develop.1 [skip ci]

## [0.0.2-develop.1](https://git.lumeweb.com/LumeWeb/kernel-ipfs-client/compare/v0.0.1...v0.0.2-develop.1) (2023-07-14)

.github/workflows/ci.yml

@@ -0,0 +1,13 @@
+name: Build/Publish
+
+on:
+    push:
+        branches:
+            - master
+            - develop
+            - develop-*
+
+jobs:
+    main:
+        uses: lumeweb/github-node-deploy-workflow/.github/workflows/main.yml@master
+        secrets: inherit

.presetterrc.json

@@ -0,0 +1,5 @@
+{
+  "preset": [
+    "@lumeweb/node-library-preset"
+  ]
+}

CHANGELOG.md

@@ -0,0 +1 @@
+## [0.0.2-develop.1](https://git.lumeweb.com/LumeWeb/kernel-ipfs-client/compare/v0.0.1...v0.0.2-develop.1) (2023-07-14)

LICENSE

@@ -1,6 +1,6 @@
 MIT License
 
-Copyright (c) 2022 Derrick Hammer
+Copyright (c) 2022 Hammer Technologies LLC
 
 Permission is hereby granted, free of charge, to any person obtaining a copy
 of this software and associated documentation files (the "Software"), to deal

README.md

@@ -0,0 +1,2 @@
+# kernel-ipfs-client
+IPFS client interface to @lumeweb/kernel-ipfs module

package.json

@@ -0,0 +1,31 @@
+{
+    "name": "@lumeweb/kernel-ipfs-client",
+    "version": "0.0.2-develop.1",
+    "type": "module",
+    "main": "lib/index.js",
+    "repository": {
+        "type": "git",
+        "url": "gitea@git.lumeweb.com:LumeWeb/kernel-ipfs-client.git"
+    },
+    "devDependencies": {
+        "@helia/unixfs": "^1.4.0",
+        "@lumeweb/node-library-preset": "^0.2.7",
+        "presetter": "*"
+    },
+    "readme": "ERROR: No README data found!",
+    "scripts": {
+        "prepare": "presetter bootstrap",
+        "build": "run build",
+        "semantic-release": "semantic-release"
+    },
+    "dependencies": {
+        "@lumeweb/libkernel": "^0.1.0-develop.16",
+        "p-defer": "^4.0.0"
+    },
+    "files": [
+        "lib"
+    ],
+    "publishConfig": {
+        "access": "public"
+    }
+}

src/index.ts

@@ -0,0 +1,89 @@
+import { Client, factory } from "@lumeweb/libkernel/module";
+import defer from "p-defer";
+import { CatOptions, LsOptions, StatOptions } from "@helia/unixfs";
+
+interface AbortableGenerator {
+  abort: () => void;
+  iterable: () => AsyncIterable<Uint8Array>;
+}
+
+export const MODULE =
+  "zduTW8neeep7BcgyJyysyH5pSNPcLfS1EgTxVf3zncYbrJJQLxu9wjvzZM";
+
+export class IPFSClient extends Client {
+  public async ready() {
+    return this.callModuleReturn("ready");
+  }
+
+  public async stat(cid: string, options?: Partial<StatOptions>) {
+    return this.callModuleReturn("stat", { cid, options });
+  }
+
+  public ls(cid: string, options?: Partial<LsOptions>): AbortableGenerator {
+    return this.connectModuleGenerator("ls", { cid, options });
+  }
+
+  public cat(cid: string, options?: Partial<CatOptions>): AbortableGenerator {
+    return this.connectModuleGenerator("cat", { cid, options });
+  }
+
+  public async ipns(cid: string): Promise<string> {
+    return this.callModuleReturn("ipnsResolve", { cid });
+  }
+
+  public async activePeers(): Promise<number> {
+    return this.callModuleReturn("getActivePeers");
+  }
+
+  private connectModuleGenerator(
+    method: string,
+    data: any,
+  ): AbortableGenerator {
+    let pipe = defer<Uint8Array>();
+
+    const [update, result] = this.connectModule(method, data, (item: any) => {
+      pipe.resolve(item);
+    });
+
+    (async () => {
+      const ret = await result;
+      this.handleError(ret);
+      pipe.resolve(undefined);
+    })();
+
+    return {
+      abort() {
+        update("abort");
+      },
+
+      iterable(): AsyncIterable<Uint8Array> {
+        return {
+          [Symbol.asyncIterator]() {
+            return {
+              async next(): Promise<IteratorResult<Uint8Array>> {
+                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>(IPFSClient, MODULE);