Dockerize monitoring script (#1267)

* Set TreatMissingData explict to BREACHING

* Add contract abi

* Add docker file

* Add docker-compose file

* Cleanup

* Mount volumn as /config

* Revert copy contracts

* Add a main entrypoint

* Fix breaching

web/.dockerignore

@@ -0,0 +1,3 @@
+.vscode
+packages/operations/config
+packages/operations/.env

web/monitor-docker-compose.yaml

@@ -0,0 +1,11 @@
+version: "3"
+services:
+  minitor-service:
+    image: snowbridge-monitor
+    build:
+      context: .
+      dockerfile: monitor.Dockerfile
+    command: cron
+    container_name: snowbridge-monitor-1
+    volumes:
+      - ./packages/operations/config:/config

web/monitor.Dockerfile

@@ -0,0 +1,13 @@
+FROM node:20
+RUN corepack enable
+COPY . /app
+WORKDIR /app
+
+RUN pnpm install && pnpm build
+RUN rm -rf /app/packages/contracts && rm -rf /app/packages/test && rm -rf /app/packages/test-helpers
+
+WORKDIR /app/packages/operations
+VOLUME /config
+ENV DOTENV_CONFIG_PATH=/config/.env
+ENTRYPOINT ["node", "./dist/src/main.js"]
+

web/packages/operations/.env.example

@@ -1,7 +1,18 @@
+# Network config
 NODE_ENV=rococo_sepolia
-REACT_APP_INFURA_KEY=
+
+# AWS Config
 AWS_ACCESS_KEY_ID=
 AWS_SECRET_ACCESS_KEY=
 AWS_REGION=eu-central-1
 BRIDGE_STALE_SNS_TOPIC=arn:aws:sns:eu-central-1:232374692033:PD
 ACCOUNT_BALANCE_SNS_TOPIC=arn:aws:sns:eu-central-1:232374692033:PD-WALLET
+
+# INFURA Key config
+REACT_APP_INFURA_KEY=
+
+# GRAPHQL config
+GRAPHQL_API_URL=https://data.snowbridge.network/graphql
+
+# Scan interval(in minutes)
+SCAN_INTERVAL=30 

web/packages/operations/.gitignore

@@ -1,3 +1,4 @@
 node_modules
 dist
 .env
+config

web/packages/operations/package.json

@@ -11,9 +11,10 @@
   "scripts": {
     "build": "tsc",
     "lint": "eslint src/*",
-    "initialize": "npx ts-node src/init.ts",
-    "start": "npx ts-node src/start.ts",
-    "cron": "npx ts-node src/cron.ts",
+    "initialize": "npx ts-node src/main.ts init",
+    "initializeFromContainer": "docker run -v $(pwd)/config:/config --rm snowbridge-monitor:latest init",
+    "start": "npx ts-node src/main.ts start",
+    "cron": "npx ts-node src/main.ts cron",
     "server": "npx ts-node src/server.ts",
     "format": "prettier src --write"
   },

web/packages/operations/src/alarm.ts

@@ -227,6 +227,7 @@ export const initializeAlarms = async () => {
     let alarmCommandSharedInput = {
         Namespace: CLOUD_WATCH_NAME_SPACE + "-" + name,
         Threshold: 0,
+        TreatMissingData: "breaching",
     }
 
     // Alarm for stale bridge

web/packages/operations/src/main.ts

@@ -0,0 +1,28 @@
+import "dotenv/config"
+import cron from "node-cron"
+import { monitor } from "./monitor"
+import { initializeAlarms } from "./alarm"
+
+if (process.argv.length != 3) {
+    console.error("Expected one argument with Enum from `start|cron|init`")
+    process.exit(1)
+}
+
+if (process.argv[2] == "start") {
+    monitor()
+        .then(() => process.exit(0))
+        .catch((error) => {
+            console.error("Error:", error)
+            process.exit(1)
+        })
+} else if (process.argv[2] == "cron") {
+    let interval = parseInt(process.env["SCAN_INTERVAL"] || "") || 30
+    cron.schedule(`*/${interval} * * * *`, monitor)
+} else if (process.argv[2] == "init") {
+    initializeAlarms()
+        .then(() => process.exit(0))
+        .catch((error) => {
+            console.error("Error:", error)
+            process.exit(1)
+        })
+}