chore(release): 0.1.0-develop.10 [skip ci]

# [0.1.0-develop.10](https://git.lumeweb.com/LumeWeb/libethsync/compare/v0.1.0-develop.9...v0.1.0-develop.10) (2023-07-11)

CHANGELOG.md

@@ -1,3 +1,5 @@
+# [0.1.0-develop.10](https://git.lumeweb.com/LumeWeb/libethsync/compare/v0.1.0-develop.9...v0.1.0-develop.10) (2023-07-11)
+
 # [0.1.0-develop.9](https://git.lumeweb.com/LumeWeb/libethsync/compare/v0.1.0-develop.8...v0.1.0-develop.9) (2023-07-11)
 
 

npm-shrinkwrap.json

@@ -1,12 +1,12 @@
 {
     "name": "@lumeweb/libethclient",
-    "version": "0.1.0-develop.9",
+    "version": "0.1.0-develop.10",
     "lockfileVersion": 3,
     "requires": true,
     "packages": {
         "": {
             "name": "@lumeweb/libethclient",
-            "version": "0.1.0-develop.9",
+            "version": "0.1.0-develop.10",
             "dependencies": {
                 "@chainsafe/as-sha256": "^0.3.1",
                 "@chainsafe/bls": "7.1.1",

package.json

@@ -1,6 +1,6 @@
 {
     "name": "@lumeweb/libethsync",
-    "version": "0.1.0-develop.9",
+    "version": "0.1.0-develop.10",
     "type": "module",
     "repository": {
         "type": "git",

src/baseClient.ts

@@ -85,6 +85,21 @@ export default abstract class BaseClient {
     this.syncMutex.release();
   }
 
+  protected async subscribe(callback?: (ei: ExecutionInfo) => void) {
+    setInterval(async () => {
+      try {
+        await this._sync();
+        const ei = await this.getLatestExecution();
+        if (ei && ei.blockHash !== this.latestBlockHash) {
+          this.latestBlockHash = ei.blockHash;
+          return await callback?.(ei);
+        }
+      } catch (e) {
+        console.error(e);
+      }
+    }, POLLING_DELAY);
+  }
+
   public get store(): IStore {
     return this.options.store as IStore;
   }

src/client/client.ts

@@ -101,21 +101,6 @@ export default class Client extends BaseClient {
     return this.getCommittee(currentPeriod, lastCommitteeHash);
   }
 
-  private async subscribe(callback: (ei: ExecutionInfo) => void) {
-    setInterval(async () => {
-      try {
-        await this._sync();
-        const ei = await this.getLatestExecution();
-        if (ei && ei.blockHash !== this.latestBlockHash) {
-          this.latestBlockHash = ei.blockHash;
-          return await callback(ei);
-        }
-      } catch (e) {
-        console.error(e);
-      }
-    }, POLLING_DELAY);
-  }
-
   private async getCommittee(
     period: number,
     expectedCommitteeHash: Uint8Array | null,

src/node/client.ts

@@ -28,6 +28,11 @@ interface Config extends BaseClientOptions {
 }
 
 export default class Client extends BaseClient {
+  async sync(): Promise<void> {
+    await super.sync();
+
+    this.subscribe();
+  }
   private beaconUrl: string;
   private blockCache = new NodeCache({ stdTTL: 60 * 60 * 12 });
   private blockHashCache = new NodeCache({ stdTTL: 60 * 60 * 12 });