Fix to health monitoring

tzConnectBerlin · Oct 21, 2022 · cd57078 · cd57078
1 parent cf99c90
commit cd57078
Show file tree

Hide file tree

Showing 4 changed files with 95 additions and 93 deletions.
diff --git a/app.mjs b/app.mjs
@@ -70,7 +70,7 @@ const main = async function() {
 	}
 
 	const heartbeat = async function() {
-		await queue.kill_canaries();
+		await queue.kill_canaries(address);
 
 		let ops = await queue.checkout(address, ~~(config.batchSize/batch_divider) + 1);
 		if (ops.length == 0) {

diff --git a/package-lock.json b/package-lock.json
diff --git a/package.json b/package.json
@@ -10,8 +10,8 @@
 	"author": "",
 	"license": "MIT",
 	"dependencies": {
-		"@taquito/signer": "^13.0.1",
-		"@taquito/taquito": "^13.0.1",
+		"@taquito/signer": "^14.0.0",
+		"@taquito/taquito": "^14.0.0",
 		"console-stamp": "^3.0.3",
 		"pg": "^8.7.1",
 	  "string-hex": "^1.0.0",

diff --git a/queue.mjs b/queue.mjs
@@ -26,7 +26,7 @@ export default function(db_connection) {
 		return pool.query(SENT_SQL, [op_hash, ids]);
 	};
 
-	const kill_canaries = function() {
+	const kill_canaries = function(originator) {
 		return pool.query(KILL_CANARIES_SQL, [ originator ]);
 	}
 
@@ -45,4 +45,4 @@ export default function(db_connection) {
 			kill_canaries,
 			state
 	};
-}
+}