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

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

### Reverts

* Revert "*Process the queue in reverse" ([f38c6f5](f38c6f53cf))

.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,6 @@
+## [0.0.2-develop.1](https://git.lumeweb.com/LumeWeb/kernel-rpc-client/compare/v0.0.1...v0.0.2-develop.1) (2023-07-05)
+
+
+### Reverts
+
+* Revert "*Process the queue in reverse" ([f38c6f5](https://git.lumeweb.com/LumeWeb/kernel-rpc-client/commit/f38c6f53cfa68d3866d0614ea9490aef9f47bca7))

LICENSE

@@ -1,6 +1,6 @@
 MIT License
 
-Copyright (c) 2022 Lume Web
+Copyright (c) 2023 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

package.json

@@ -0,0 +1,31 @@
+{
+    "name": "@lumeweb/kernel-rpc-client",
+    "version": "0.0.2-develop.1",
+    "type": "module",
+    "main": "lib/index.js",
+    "repository": {
+        "type": "git",
+        "url": "gitea@git.lumeweb.com:LumeWeb/kernel-rpc-client.git"
+    },
+    "devDependencies": {
+        "@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/interface-relay": "^0.0.2-develop.1",
+        "@lumeweb/libkernel": "^0.1.0-develop.14",
+        "@lumeweb/rpc-client": "^0.0.2-develop.4"
+    },
+    "files": [
+        "lib"
+    ],
+    "publishConfig": {
+        "access": "public"
+    }
+}

src/index.ts

@@ -0,0 +1,138 @@
+import { ErrTuple } from "@lumeweb/libkernel";
+import type {
+  RPCRequest,
+  RPCResponse,
+  ClientRPCRequest,
+} from "@lumeweb/interface-relay";
+import { RpcQueryOptions } from "@lumeweb/rpc-client";
+import { Buffer } from "buffer";
+import { Client, factory } from "@lumeweb/libkernel/module";
+
+const RPC_MODULE = "fAAKlPuoD2FgKq27nhNILSmf7nTYmI9mMmOfTujwXma-1g";
+
+export class RpcNetwork extends Client {
+  private _def: boolean;
+
+  constructor(module: string, def: boolean = true) {
+    super(module);
+    this._def = def;
+  }
+
+  private _networkId: number = 0;
+
+  get networkId(): number {
+    return this._networkId;
+  }
+
+  get ready(): Promise<ErrTuple> {
+    if (this._def) {
+      this._networkId = 1;
+    } else {
+      Promise.resolve()
+        .then(() => this.callModuleReturn(RPC_MODULE, "createNetwork"))
+        .then((ret: ErrTuple) => (this._networkId = ret[0]));
+    }
+
+    return this.callModuleReturn("ready", {
+      network: this._networkId,
+    });
+  }
+
+  public simpleQuery({
+    relay,
+    query,
+    options = {},
+  }: {
+    relay?: Buffer | string;
+    query: ClientRPCRequest;
+    options?: RpcQueryOptions;
+  }): SimpleRpcQuery {
+    return createSimpleRpcQuery({
+      network: this,
+      relay,
+      query,
+      options,
+    }).run();
+  }
+}
+
+export abstract class RpcQueryBase extends Client {
+  protected _promise?: Promise<any>;
+  protected _network: RpcNetwork;
+  protected _query: RPCRequest;
+  protected _options: RpcQueryOptions;
+  protected _queryType: string;
+
+  constructor(
+    module: string,
+    network: RpcNetwork,
+    query: RPCRequest,
+    options: RpcQueryOptions = {},
+    queryType: string,
+  ) {
+    super(module);
+    this._network = network;
+    this._query = query;
+    this._options = options;
+    this._queryType = queryType;
+  }
+
+  get result(): Promise<RPCResponse> {
+    return (this._promise as Promise<any>)
+      .then((result: ErrTuple): RPCResponse => {
+        return result[0];
+      })
+      .catch((error: Error) => {
+        return { error: error.message };
+      });
+  }
+
+  public run(): this {
+    this._promise = this.callModule(this._queryType, {
+      query: this._query,
+      options: this._options,
+      network: this._network.networkId,
+    });
+
+    return this;
+  }
+}
+
+export class SimpleRpcQuery extends RpcQueryBase {
+  protected _relay?: string | Buffer;
+
+  constructor(
+    module: string,
+    {
+      network,
+      relay,
+      query,
+      options,
+    }: {
+      network: RpcNetwork;
+      relay?: string | Buffer;
+      query: RPCRequest;
+      options?: RpcQueryOptions;
+    },
+  ) {
+    super(module, network, query, options, "simpleQuery");
+    this._relay = relay;
+  }
+
+  public run(): this {
+    this._promise = this.callModule(this._queryType, {
+      relay: this._relay,
+      query: this._query,
+      options: this._options,
+      network: this._network.networkId,
+    });
+
+    return this;
+  }
+}
+
+export const createClient = factory<RpcNetwork>(RpcNetwork, RPC_MODULE);
+const createSimpleRpcQuery = factory<SimpleRpcQuery>(
+  SimpleRpcQuery,
+  RPC_MODULE,
+);