Merge pull request #11 from kyve-org/v0.5.0

V0.5.0

Author: troykessler

package.json

@@ -1,10 +1,10 @@
 {
   "name": "@kyve/evm",
-  "version": "1.1.0",
+  "version": "1.2.0",
   "license": "MIT",
   "scripts": {
     "build": "rimraf dist && tsc",
-    "build:binaries": "yarn build && rimraf out && pkg --output out/kyve package.json && node ./node_modules/@kyve/core/dist/src/checksum.js",
+    "build:binaries": "yarn build && rimraf out && pkg --no-bytecode --public-packages '*' --output out/kyve package.json && node ./node_modules/@kyve/core/dist/src/checksum.js",
     "start": "node ./dist/src/index.js",
     "format": "prettier --write ."
   },
@@ -22,7 +22,7 @@
     "singleQuote": true
   },
   "dependencies": {
-    "@kyve/core": "1.1.0",
+    "@kyve/core": "1.2.0",
     "ethers": "^5.6.5"
   },
   "devDependencies": {

src/index.ts

@@ -1,4 +1,4 @@
-import KYVE from '@kyve/core';
+import KYVE, { Item } from '@kyve/core';
 import { Network, Signature } from './types';
 import { fetchBlock } from './utils';
 import { name, version } from '../package.json';
@@ -11,7 +11,7 @@ KYVE.metrics.register.setDefaultLabels({
 });
 
 class KyveEvm extends KYVE {
-  public async getDataItem(key: number): Promise<{ key: number; value: any }> {
+  public async getDataItem(key: string): Promise<Item> {
     let block;
 
     try {
@@ -25,15 +25,12 @@ class KyveEvm extends KYVE {
 
       block = await fetchBlock(
         this.pool.config.rpc,
-        key,
+        +key,
         await this.getSignature(),
         network
       );
     } catch (err) {
-      this.logger.warn(
-        `⚠️  EXTERNAL ERROR: Failed to fetch block ${key}. Retrying ...`
-      );
-
+      this.logger.warn(` Failed to get data item from height ${key}`);
       throw err;
     }
 
@@ -42,6 +39,18 @@ class KyveEvm extends KYVE {
     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.timestamp.toString();
+  }
+
   private async getSignature(): Promise<Signature> {
     const address = await this.sdk.wallet.getAddress();
     const timestamp = new Date().valueOf().toString();