finished bitcoin

Author: troykessler

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@kyve/bitcoin",
-  "version": "0.2.3",
+  "version": "0.3.0",
   "license": "MIT",
   "scripts": {
     "build": "rimraf dist && tsc",
@@ -19,7 +19,7 @@
     "outputPath": "out"
   },
   "dependencies": {
-    "@kyve/core": "1.2.3",
+    "@kyve/core": "1.3.0",
     "axios": "^0.26.1",
     "nanoid": "^3.3.3"
   },

src/index.ts

@@ -1,75 +1,10 @@
-import KYVE, { Item } from "@kyve/core";
-import { Signature } from "./types";
-import { fetchBlock, fetchBlockHash } from "./utils";
-import { version } from "../package.json";
+import { Node, Arweave, Gzip, JsonFileCache } from "@kyve/core";
 
-process.env.KYVE_RUNTIME = "@kyve/bitcoin";
-process.env.KYVE_VERSION = version;
+import Bitcoin from "./runtime";
 
-KYVE.metrics.register.setDefaultLabels({
-  app: process.env.KYVE_RUNTIME,
-});
-
-class KyveBitcoin extends KYVE {
-  public async getDataItem(key: string): Promise<Item> {
-    let hash: string;
-    let block: any;
-
-    try {
-      hash = await fetchBlockHash(
-        this.pool.config.rpc,
-        +key,
-        await this.getSignature()
-      );
-    } catch (err) {
-      // The only time this should fail is if the height is out of range.
-
-      throw err;
-    }
-
-    try {
-      block = await fetchBlock(
-        this.pool.config.rpc,
-        hash,
-        await this.getSignature()
-      );
-    } catch (err) {
-      this.logger.warn(`Failed to fetch block ${key}. Retrying ...`);
-
-      throw err;
-    }
-
-    return { key, value: block };
-  }
-
-  public async getNextKey(key: string): Promise<string> {
-    if (key) {
-      return (parseInt(key) + 1).toString();
-    }
-
-    return "0";
-  }
-
-  public async formatValue(value: any): Promise<string> {
-    return value.hash;
-  }
-
-  private async getSignature(): Promise<Signature> {
-    const address = await this.sdk.wallet.getAddress();
-    const timestamp = new Date().valueOf().toString();
-
-    const message = `${address}//${this.poolId}//${timestamp}`;
-
-    const { signature, pub_key } = await this.sdk.signString(message);
-
-    return {
-      signature,
-      pubKey: pub_key.value,
-      poolId: this.poolId.toString(),
-      timestamp,
-    };
-  }
-}
-
-// noinspection JSIgnoredPromiseFromCall
-new KyveBitcoin().start();
+new Node()
+  .addRuntime(new Bitcoin())
+  .addStorageProvider(new Arweave())
+  .addCompression(new Gzip())
+  .addCache(new JsonFileCache())
+  .start();

src/runtime.ts

@@ -0,0 +1,57 @@
+import { DataItem, IRuntime, Node } from "@kyve/core";
+import { name, version } from "../package.json";
+import { fetchBlock, fetchBlockHash } from "./utils";
+
+export default class Bitcoin implements IRuntime {
+  public name = name;
+  public version = version;
+
+  public async getDataItem(core: Node, key: string): Promise<DataItem> {
+    let hash: string;
+    let block: any;
+
+    const headers = await this.generateCoinbaseCloudHeaders(core);
+
+    try {
+      hash = await fetchBlockHash(core.poolConfig.rpc, +key, headers);
+    } catch (err) {
+      // The only time this should fail is if the height is out of range.
+      throw err;
+    }
+
+    try {
+      block = await fetchBlock(core.poolConfig.rpc, hash, headers);
+    } catch (err) {
+      throw err;
+    }
+
+    return { key, value: block };
+  }
+
+  public async getNextKey(key: string): Promise<string> {
+    return (parseInt(key) + 1).toString();
+  }
+
+  public async formatValue(value: any): Promise<string> {
+    return value.hash;
+  }
+
+  private async generateCoinbaseCloudHeaders(core: Node): Promise<any> {
+    // requestSignature for coinbase cloud
+    const address = core.client.account.address;
+    const timestamp = new Date().valueOf().toString();
+    const poolId = core.pool.id;
+
+    const { signature, pub_key } = await core.client.signString(
+      `${address}//${poolId}//${timestamp}`
+    );
+
+    return {
+      "Content-Type": "application/json",
+      Signature: signature,
+      "Public-Key": pub_key,
+      "Pool-ID": poolId,
+      Timestamp: timestamp,
+    };
+  }
+}

src/utils.ts

@@ -1,13 +1,13 @@
 import axios from "axios";
 import { nanoid } from "nanoid";
-import { Response, Signature } from "./types";
+import { Response } from "./types";
 
 export async function fetchBlock(
   endpoint: string,
   hash: string,
-  signature: Signature
+  headers: any
 ): Promise<any> {
-  const block = await call<any>(endpoint, "getblock", [hash, 2], signature);
+  const block = await call<any>(endpoint, "getblock", [hash, 2], headers);
 
   // Remove confirmations to maintain determinism.
   delete block.confirmations;
@@ -18,16 +18,16 @@ export async function fetchBlock(
 export async function fetchBlockHash(
   endpoint: string,
   height: number,
-  signature: Signature
+  headers: any
 ): Promise<string> {
-  return await call<string>(endpoint, "getblockhash", [height], signature);
+  return await call<string>(endpoint, "getblockhash", [height], headers);
 }
 
 async function call<T>(
   endpoint: string,
   method: string,
   params: any[],
-  signature: Signature
+  headers: any
 ): Promise<T> {
   const { data } = await axios.get<Response<T>>(endpoint, {
     data: JSON.stringify({
@@ -36,13 +36,7 @@ async function call<T>(
       method,
       params,
     }),
-    headers: {
-      Signature: signature.signature,
-      "Public-Key": signature.pubKey,
-      "Pool-ID": signature.poolId,
-      Timestamp: signature.timestamp,
-      "Content-Type": "application/json",
-    },
+    headers,
   });
 
   return data.result;