update scanner packages and ogmios config

.changeset/purple-ducks-whisper.md

@@ -0,0 +1,5 @@
+---
+'@rosen-bridge/watcher': patch
+---
+
+Stabalize ogmios connection by adding connection close handler

config/default.yaml

@@ -28,6 +28,7 @@ cardano:
   ogmios:
     host: '' # ogmios node host address
     port: 1337 # ogmios port
+    connectionRetrialInterval: 30 # ogmios connection retrial interval (in seconds)
     useTls: false # connect to ogmios using https or not
   blockfrost:
     url: '' # url to connect to blockfrost

package.json

@@ -74,21 +74,21 @@
   },
   "dependencies": {
     "@emurgo/cip14-js": "^3.0.1",
-    "@rosen-bridge/address-extractor": "^5.0.5",
+    "@rosen-bridge/address-extractor": "^5.0.6",
     "@rosen-bridge/asset-check": "^0.2.1",
-    "@rosen-bridge/bitcoin-esplora-scanner": "^0.1.10",
-    "@rosen-bridge/bitcoin-observation-extractor": "^4.0.1",
-    "@rosen-bridge/bitcoin-rpc-scanner": "^0.2.4",
+    "@rosen-bridge/bitcoin-esplora-scanner": "^0.1.12",
+    "@rosen-bridge/bitcoin-observation-extractor": "^4.0.4",
+    "@rosen-bridge/bitcoin-rpc-scanner": "^0.2.6",
     "@rosen-bridge/health-check": "^5.0.0",
     "@rosen-bridge/log-level-check": "^0.1.1",
     "@rosen-bridge/minimum-fee": "^2.1.0",
     "@rosen-bridge/node-sync-check": "^0.1.1",
-    "@rosen-bridge/observation-extractor": "^5.0.2",
+    "@rosen-bridge/observation-extractor": "^5.0.4",
     "@rosen-bridge/permit-check": "^0.1.1",
-    "@rosen-bridge/scanner": "^4.0.5",
+    "@rosen-bridge/scanner": "^4.1.1",
     "@rosen-bridge/scanner-sync-check": "^0.3.0",
     "@rosen-bridge/tokens": "^1.2.1",
-    "@rosen-bridge/watcher-data-extractor": "^7.0.0",
+    "@rosen-bridge/watcher-data-extractor": "^7.0.2",
     "@rosen-bridge/wid-check": "^0.1.1",
     "@rosen-bridge/winston-logger": "0.2.1",
     "@rosen-clients/cardano-koios": "^2.0.3",

src/config/config.ts

@@ -300,6 +300,7 @@ class CardanoConfig {
     port: number;
     initialSlot: number;
     initialHash: string;
+    connectionRetrialInterval: number;
     useTls?: boolean;
   };
   koios?: {
@@ -324,9 +325,19 @@ class CardanoConfig {
         const host = getRequiredString('cardano.ogmios.host');
         const port = getRequiredNumber('cardano.ogmios.port');
         const initialSlot = getRequiredNumber('cardano.initial.slot');
+        const connectionRetrialInterval = getRequiredNumber(
+          'cardano.initial.connectionRetrialInterval'
+        );
         const initialHash = getRequiredString('cardano.initial.hash');
         const useTls = config.get<boolean>('cardano.ogmios.useTls');
-        this.ogmios = { host, port, initialHash, initialSlot, useTls };
+        this.ogmios = {
+          host,
+          port,
+          initialHash,
+          initialSlot,
+          connectionRetrialInterval,
+          useTls,
+        };
       } else if (this.type === Constants.KOIOS_TYPE) {
         const url = getRequiredString('cardano.koios.url');
         const interval = getRequiredNumber('cardano.koios.interval');

src/utils/scanner.ts

@@ -185,6 +185,8 @@ class CreateScanner {
             dataSource: dataSource,
             initialHash: cardanoConfig.ogmios.initialHash,
             initialSlot: cardanoConfig.ogmios.initialSlot,
+            connectionRetrialInterval:
+              cardanoConfig.ogmios.connectionRetrialInterval * 1000,
           },
           loggers.scannerLogger
         );