Update watchers with fix for historical processing sync status update (…

…#40) * Update azimuth watcher with fix for historical processing sync status * Upgrade packages in all watchers * Upgrade package versions to 0.2.76 * Update watcher version to 0.1.2
cerc-io · Nov 24, 2023 · 5402445 · 5402445
1 parent fb76365
commit 5402445
Show file tree

Hide file tree

Showing 27 changed files with 190 additions and 79 deletions.
diff --git a/lerna.json b/lerna.json
@@ -3,6 +3,6 @@
     "packages/*"
   ],
   "useWorkspaces": true,
-  "version": "0.0.0",
+  "version": "0.1.2",
   "npmClient": "yarn"
 }
diff --git a/packages/azimuth-watcher/package.json b/packages/azimuth-watcher/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@cerc-io/azimuth-watcher",
-  "version": "0.1.0",
+  "version": "0.1.2",
   "description": "azimuth-watcher",
   "private": true,
   "main": "dist/index.js",
@@ -38,10 +38,10 @@
   "homepage": "https://github.com/cerc-io/watcher-ts#readme",
   "dependencies": {
     "@apollo/client": "^3.3.19",
-    "@cerc-io/cli": "^0.2.74",
-    "@cerc-io/ipld-eth-client": "^0.2.74",
-    "@cerc-io/solidity-mapper": "^0.2.74",
-    "@cerc-io/util": "^0.2.74",
+    "@cerc-io/cli": "^0.2.76",
+    "@cerc-io/ipld-eth-client": "^0.2.76",
+    "@cerc-io/solidity-mapper": "^0.2.76",
+    "@cerc-io/util": "^0.2.76",
     "@ethersproject/providers": "^5.4.4",
     "debug": "^4.3.1",
     "decimal.js": "^10.3.1",

diff --git a/packages/azimuth-watcher/src/database.ts b/packages/azimuth-watcher/src/database.ts
@@ -924,6 +924,12 @@ export class Database implements DatabaseInterface {
     return this._baseDatabase.updateSyncStatusIndexingError(repo, hasIndexingError);
   }
 
+  async updateSyncStatus (queryRunner: QueryRunner, syncStatus: DeepPartial<SyncStatus>): Promise<SyncStatus> {
+    const repo = queryRunner.manager.getRepository(SyncStatus);
+
+    return this._baseDatabase.updateSyncStatus(repo, syncStatus);
+  }
+
   async getSyncStatus (queryRunner: QueryRunner): Promise<SyncStatus | undefined> {
     const repo = queryRunner.manager.getRepository(SyncStatus);
 

diff --git a/packages/azimuth-watcher/src/indexer.ts b/packages/azimuth-watcher/src/indexer.ts
@@ -1747,6 +1747,10 @@ export class Indexer implements IndexerInterface {
     return this._baseIndexer.updateSyncStatusIndexingError(hasIndexingError);
   }
 
+  async updateSyncStatus (syncStatus: DeepPartial<SyncStatus>): Promise<SyncStatus> {
+    return this._baseIndexer.updateSyncStatus(syncStatus);
+  }
+
   async getEvent (id: string): Promise<Event | undefined> {
     return this._baseIndexer.getEvent(id);
   }

diff --git a/packages/censures-watcher/package.json b/packages/censures-watcher/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@cerc-io/censures-watcher",
-  "version": "0.1.0",
+  "version": "0.1.2",
   "description": "censures-watcher",
   "private": true,
   "main": "dist/index.js",
@@ -38,10 +38,10 @@
   "homepage": "https://github.com/cerc-io/watcher-ts#readme",
   "dependencies": {
     "@apollo/client": "^3.3.19",
-    "@cerc-io/cli": "^0.2.74",
-    "@cerc-io/ipld-eth-client": "^0.2.74",
-    "@cerc-io/solidity-mapper": "^0.2.74",
-    "@cerc-io/util": "^0.2.74",
+    "@cerc-io/cli": "^0.2.76",
+    "@cerc-io/ipld-eth-client": "^0.2.76",
+    "@cerc-io/solidity-mapper": "^0.2.76",
+    "@cerc-io/util": "^0.2.76",
     "@ethersproject/providers": "^5.4.4",
     "debug": "^4.3.1",
     "decimal.js": "^10.3.1",

diff --git a/packages/censures-watcher/src/database.ts b/packages/censures-watcher/src/database.ts
@@ -271,6 +271,12 @@ export class Database implements DatabaseInterface {
     return this._baseDatabase.updateSyncStatusIndexingError(repo, hasIndexingError);
   }
 
+  async updateSyncStatus (queryRunner: QueryRunner, syncStatus: DeepPartial<SyncStatus>): Promise<SyncStatus> {
+    const repo = queryRunner.manager.getRepository(SyncStatus);
+
+    return this._baseDatabase.updateSyncStatus(repo, syncStatus);
+  }
+
   async getSyncStatus (queryRunner: QueryRunner): Promise<SyncStatus | undefined> {
     const repo = queryRunner.manager.getRepository(SyncStatus);
 

diff --git a/packages/censures-watcher/src/indexer.ts b/packages/censures-watcher/src/indexer.ts
@@ -525,6 +525,10 @@ export class Indexer implements IndexerInterface {
     return this._baseIndexer.updateSyncStatusIndexingError(hasIndexingError);
   }
 
+  async updateSyncStatus (syncStatus: DeepPartial<SyncStatus>): Promise<SyncStatus> {
+    return this._baseIndexer.updateSyncStatus(syncStatus);
+  }
+
   async getEvent (id: string): Promise<Event | undefined> {
     return this._baseIndexer.getEvent(id);
   }

diff --git a/packages/claims-watcher/package.json b/packages/claims-watcher/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@cerc-io/claims-watcher",
-  "version": "0.1.0",
+  "version": "0.1.2",
   "description": "claims-watcher",
   "private": true,
   "main": "dist/index.js",
@@ -38,10 +38,10 @@
   "homepage": "https://github.com/cerc-io/watcher-ts#readme",
   "dependencies": {
     "@apollo/client": "^3.3.19",
-    "@cerc-io/cli": "^0.2.74",
-    "@cerc-io/ipld-eth-client": "^0.2.74",
-    "@cerc-io/solidity-mapper": "^0.2.74",
-    "@cerc-io/util": "^0.2.74",
+    "@cerc-io/cli": "^0.2.76",
+    "@cerc-io/ipld-eth-client": "^0.2.76",
+    "@cerc-io/solidity-mapper": "^0.2.76",
+    "@cerc-io/util": "^0.2.76",
     "@ethersproject/providers": "^5.4.4",
     "debug": "^4.3.1",
     "decimal.js": "^10.3.1",

diff --git a/packages/claims-watcher/src/database.ts b/packages/claims-watcher/src/database.ts
@@ -225,6 +225,12 @@ export class Database implements DatabaseInterface {
     return this._baseDatabase.updateSyncStatusIndexingError(repo, hasIndexingError);
   }
 
+  async updateSyncStatus (queryRunner: QueryRunner, syncStatus: DeepPartial<SyncStatus>): Promise<SyncStatus> {
+    const repo = queryRunner.manager.getRepository(SyncStatus);
+
+    return this._baseDatabase.updateSyncStatus(repo, syncStatus);
+  }
+
   async getSyncStatus (queryRunner: QueryRunner): Promise<SyncStatus | undefined> {
     const repo = queryRunner.manager.getRepository(SyncStatus);
 

diff --git a/packages/claims-watcher/src/indexer.ts b/packages/claims-watcher/src/indexer.ts
@@ -433,6 +433,10 @@ export class Indexer implements IndexerInterface {
     return this._baseIndexer.updateSyncStatusIndexingError(hasIndexingError);
   }
 
+  async updateSyncStatus (syncStatus: DeepPartial<SyncStatus>): Promise<SyncStatus> {
+    return this._baseIndexer.updateSyncStatus(syncStatus);
+  }
+
   async getEvent (id: string): Promise<Event | undefined> {
     return this._baseIndexer.getEvent(id);
   }

diff --git a/packages/conditional-star-release-watcher/package.json b/packages/conditional-star-release-watcher/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@cerc-io/conditional-star-release-watcher",
-  "version": "0.1.0",
+  "version": "0.1.2",
   "description": "conditional-star-release-watcher",
   "private": true,
   "main": "dist/index.js",
@@ -38,10 +38,10 @@
   "homepage": "https://github.com/cerc-io/watcher-ts#readme",
   "dependencies": {
     "@apollo/client": "^3.3.19",
-    "@cerc-io/cli": "^0.2.74",
-    "@cerc-io/ipld-eth-client": "^0.2.74",
-    "@cerc-io/solidity-mapper": "^0.2.74",
-    "@cerc-io/util": "^0.2.74",
+    "@cerc-io/cli": "^0.2.76",
+    "@cerc-io/ipld-eth-client": "^0.2.76",
+    "@cerc-io/solidity-mapper": "^0.2.76",
+    "@cerc-io/util": "^0.2.76",
     "@ethersproject/providers": "^5.4.4",
     "debug": "^4.3.1",
     "decimal.js": "^10.3.1",

diff --git a/packages/conditional-star-release-watcher/src/database.ts b/packages/conditional-star-release-watcher/src/database.ts
@@ -370,6 +370,12 @@ export class Database implements DatabaseInterface {
     return this._baseDatabase.updateSyncStatusIndexingError(repo, hasIndexingError);
   }
 
+  async updateSyncStatus (queryRunner: QueryRunner, syncStatus: DeepPartial<SyncStatus>): Promise<SyncStatus> {
+    const repo = queryRunner.manager.getRepository(SyncStatus);
+
+    return this._baseDatabase.updateSyncStatus(repo, syncStatus);
+  }
+
   async getSyncStatus (queryRunner: QueryRunner): Promise<SyncStatus | undefined> {
     const repo = queryRunner.manager.getRepository(SyncStatus);
 

diff --git a/packages/conditional-star-release-watcher/src/indexer.ts b/packages/conditional-star-release-watcher/src/indexer.ts
@@ -714,6 +714,10 @@ export class Indexer implements IndexerInterface {
     return this._baseIndexer.updateSyncStatusIndexingError(hasIndexingError);
   }
 
+  async updateSyncStatus (syncStatus: DeepPartial<SyncStatus>): Promise<SyncStatus> {
+    return this._baseIndexer.updateSyncStatus(syncStatus);
+  }
+
   async getEvent (id: string): Promise<Event | undefined> {
     return this._baseIndexer.getEvent(id);
   }

diff --git a/packages/delegated-sending-watcher/package.json b/packages/delegated-sending-watcher/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@cerc-io/delegated-sending-watcher",
-  "version": "0.1.0",
+  "version": "0.1.2",
   "description": "delegated-sending-watcher",
   "private": true,
   "main": "dist/index.js",
@@ -38,10 +38,10 @@
   "homepage": "https://github.com/cerc-io/watcher-ts#readme",
   "dependencies": {
     "@apollo/client": "^3.3.19",
-    "@cerc-io/cli": "^0.2.74",
-    "@cerc-io/ipld-eth-client": "^0.2.74",
-    "@cerc-io/solidity-mapper": "^0.2.74",
-    "@cerc-io/util": "^0.2.74",
+    "@cerc-io/cli": "^0.2.76",
+    "@cerc-io/ipld-eth-client": "^0.2.76",
+    "@cerc-io/solidity-mapper": "^0.2.76",
+    "@cerc-io/util": "^0.2.76",
     "@ethersproject/providers": "^5.4.4",
     "debug": "^4.3.1",
     "decimal.js": "^10.3.1",

diff --git a/packages/delegated-sending-watcher/src/database.ts b/packages/delegated-sending-watcher/src/database.ts
@@ -240,6 +240,12 @@ export class Database implements DatabaseInterface {
     return this._baseDatabase.updateSyncStatusIndexingError(repo, hasIndexingError);
   }
 
+  async updateSyncStatus (queryRunner: QueryRunner, syncStatus: DeepPartial<SyncStatus>): Promise<SyncStatus> {
+    const repo = queryRunner.manager.getRepository(SyncStatus);
+
+    return this._baseDatabase.updateSyncStatus(repo, syncStatus);
+  }
+
   async getSyncStatus (queryRunner: QueryRunner): Promise<SyncStatus | undefined> {
     const repo = queryRunner.manager.getRepository(SyncStatus);
 

diff --git a/packages/delegated-sending-watcher/src/indexer.ts b/packages/delegated-sending-watcher/src/indexer.ts
@@ -463,6 +463,10 @@ export class Indexer implements IndexerInterface {
     return this._baseIndexer.updateSyncStatusIndexingError(hasIndexingError);
   }
 
+  async updateSyncStatus (syncStatus: DeepPartial<SyncStatus>): Promise<SyncStatus> {
+    return this._baseIndexer.updateSyncStatus(syncStatus);
+  }
+
   async getEvent (id: string): Promise<Event | undefined> {
     return this._baseIndexer.getEvent(id);
   }

diff --git a/packages/ecliptic-watcher/package.json b/packages/ecliptic-watcher/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@cerc-io/ecliptic-watcher",
-  "version": "0.1.0",
+  "version": "0.1.2",
   "description": "ecliptic-watcher",
   "private": true,
   "main": "dist/index.js",
@@ -38,10 +38,10 @@
   "homepage": "https://github.com/cerc-io/watcher-ts#readme",
   "dependencies": {
     "@apollo/client": "^3.3.19",
-    "@cerc-io/cli": "^0.2.74",
-    "@cerc-io/ipld-eth-client": "^0.2.74",
-    "@cerc-io/solidity-mapper": "^0.2.74",
-    "@cerc-io/util": "^0.2.74",
+    "@cerc-io/cli": "^0.2.76",
+    "@cerc-io/ipld-eth-client": "^0.2.76",
+    "@cerc-io/solidity-mapper": "^0.2.76",
+    "@cerc-io/util": "^0.2.76",
     "@ethersproject/providers": "^5.4.4",
     "debug": "^4.3.1",
     "decimal.js": "^10.3.1",

diff --git a/packages/ecliptic-watcher/src/database.ts b/packages/ecliptic-watcher/src/database.ts
@@ -386,6 +386,12 @@ export class Database implements DatabaseInterface {
     return this._baseDatabase.updateSyncStatusIndexingError(repo, hasIndexingError);
   }
 
+  async updateSyncStatus (queryRunner: QueryRunner, syncStatus: DeepPartial<SyncStatus>): Promise<SyncStatus> {
+    const repo = queryRunner.manager.getRepository(SyncStatus);
+
+    return this._baseDatabase.updateSyncStatus(repo, syncStatus);
+  }
+
   async getSyncStatus (queryRunner: QueryRunner): Promise<SyncStatus | undefined> {
     const repo = queryRunner.manager.getRepository(SyncStatus);
 

diff --git a/packages/ecliptic-watcher/src/indexer.ts b/packages/ecliptic-watcher/src/indexer.ts
@@ -735,6 +735,10 @@ export class Indexer implements IndexerInterface {
     return this._baseIndexer.updateSyncStatusIndexingError(hasIndexingError);
   }
 
+  async updateSyncStatus (syncStatus: DeepPartial<SyncStatus>): Promise<SyncStatus> {
+    return this._baseIndexer.updateSyncStatus(syncStatus);
+  }
+
   async getEvent (id: string): Promise<Event | undefined> {
     return this._baseIndexer.getEvent(id);
   }

diff --git a/packages/gateway-server/package.json b/packages/gateway-server/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@cerc-io/gateway-server",
-  "version": "0.1.0",
+  "version": "0.1.2",
   "main": "index.js",
   "license": "AGPL-3.0",
   "private": true,
@@ -21,6 +21,7 @@
     "is-reachable": "^5.2.1"
   },
   "devDependencies": {
+    "@types/debug": "^4.1.5",
     "@types/node": "^18.11.18",
     "@typescript-eslint/eslint-plugin": "^5.47.1",
     "@typescript-eslint/parser": "^5.47.1",

diff --git a/packages/linear-star-release-watcher/package.json b/packages/linear-star-release-watcher/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@cerc-io/linear-star-release-watcher",
-  "version": "0.1.0",
+  "version": "0.1.2",
   "description": "linear-star-release-watcher",
   "private": true,
   "main": "dist/index.js",
@@ -38,10 +38,10 @@
   "homepage": "https://github.com/cerc-io/watcher-ts#readme",
   "dependencies": {
     "@apollo/client": "^3.3.19",
-    "@cerc-io/cli": "^0.2.74",
-    "@cerc-io/ipld-eth-client": "^0.2.74",
-    "@cerc-io/solidity-mapper": "^0.2.74",
-    "@cerc-io/util": "^0.2.74",
+    "@cerc-io/cli": "^0.2.76",
+    "@cerc-io/ipld-eth-client": "^0.2.76",
+    "@cerc-io/solidity-mapper": "^0.2.76",
+    "@cerc-io/util": "^0.2.76",
     "@ethersproject/providers": "^5.4.4",
     "debug": "^4.3.1",
     "decimal.js": "^10.3.1",

diff --git a/packages/linear-star-release-watcher/src/database.ts b/packages/linear-star-release-watcher/src/database.ts
@@ -255,6 +255,12 @@ export class Database implements DatabaseInterface {
     return this._baseDatabase.updateSyncStatusIndexingError(repo, hasIndexingError);
   }
 
+  async updateSyncStatus (queryRunner: QueryRunner, syncStatus: DeepPartial<SyncStatus>): Promise<SyncStatus> {
+    const repo = queryRunner.manager.getRepository(SyncStatus);
+
+    return this._baseDatabase.updateSyncStatus(repo, syncStatus);
+  }
+
   async getSyncStatus (queryRunner: QueryRunner): Promise<SyncStatus | undefined> {
     const repo = queryRunner.manager.getRepository(SyncStatus);
 

diff --git a/packages/linear-star-release-watcher/src/indexer.ts b/packages/linear-star-release-watcher/src/indexer.ts
@@ -493,6 +493,10 @@ export class Indexer implements IndexerInterface {
     return this._baseIndexer.updateSyncStatusIndexingError(hasIndexingError);
   }
 
+  async updateSyncStatus (syncStatus: DeepPartial<SyncStatus>): Promise<SyncStatus> {
+    return this._baseIndexer.updateSyncStatus(syncStatus);
+  }
+
   async getEvent (id: string): Promise<Event | undefined> {
     return this._baseIndexer.getEvent(id);
   }

diff --git a/packages/polls-watcher/package.json b/packages/polls-watcher/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@cerc-io/polls-watcher",
-  "version": "0.1.0",
+  "version": "0.1.2",
   "description": "polls-watcher",
   "private": true,
   "main": "dist/index.js",
@@ -38,10 +38,10 @@
   "homepage": "https://github.com/cerc-io/watcher-ts#readme",
   "dependencies": {
     "@apollo/client": "^3.3.19",
-    "@cerc-io/cli": "^0.2.74",
-    "@cerc-io/ipld-eth-client": "^0.2.74",
-    "@cerc-io/solidity-mapper": "^0.2.74",
-    "@cerc-io/util": "^0.2.74",
+    "@cerc-io/cli": "^0.2.76",
+    "@cerc-io/ipld-eth-client": "^0.2.76",
+    "@cerc-io/solidity-mapper": "^0.2.76",
+    "@cerc-io/util": "^0.2.76",
     "@ethersproject/providers": "^5.4.4",
     "debug": "^4.3.1",
     "decimal.js": "^10.3.1",

diff --git a/packages/polls-watcher/src/database.ts b/packages/polls-watcher/src/database.ts
@@ -316,6 +316,12 @@ export class Database implements DatabaseInterface {
     return this._baseDatabase.updateSyncStatusIndexingError(repo, hasIndexingError);
   }
 
+  async updateSyncStatus (queryRunner: QueryRunner, syncStatus: DeepPartial<SyncStatus>): Promise<SyncStatus> {
+    const repo = queryRunner.manager.getRepository(SyncStatus);
+
+    return this._baseDatabase.updateSyncStatus(repo, syncStatus);
+  }
+
   async getSyncStatus (queryRunner: QueryRunner): Promise<SyncStatus | undefined> {
     const repo = queryRunner.manager.getRepository(SyncStatus);
 

diff --git a/packages/polls-watcher/src/indexer.ts b/packages/polls-watcher/src/indexer.ts
@@ -615,6 +615,10 @@ export class Indexer implements IndexerInterface {
     return this._baseIndexer.updateSyncStatusIndexingError(hasIndexingError);
   }
 
+  async updateSyncStatus (syncStatus: DeepPartial<SyncStatus>): Promise<SyncStatus> {
+    return this._baseIndexer.updateSyncStatus(syncStatus);
+  }
+
   async getEvent (id: string): Promise<Event | undefined> {
     return this._baseIndexer.getEvent(id);
   }