aa storm feature / alert logic

alerting/.env.example

@@ -0,0 +1,9 @@
+PRISM_ALERTS_EMAIL_HOST=smtp.gmail.com
+[email protected]
+PRISM_ALERTS_EMAIL_PASSWORD=test
+
+POSTGRES_PORT=5432
+POSTGRES_HOST=localhost
+POSTGRES_USER=postgres
+POSTGRES_DB=postgres
+POSTGRES_PASSWORD="!ChangeMe!"

alerting/Dockerfile

@@ -1,8 +1,21 @@
-FROM node:16
+FROM node:20
+
+ARG CHROME_VERSION
 
 COPY ./alerting /app
 COPY ./common /common
 
+# Install dependencies and Chrome for puppeteer
+RUN set -e && \
+    apt-get update && apt-get install -y \
+    libnss3 libdbus-1-3 libatk1.0-0 libatk-bridge2.0-0 \
+    libcups2 libxcomposite1 libxdamage1 libgbm1 libxkbcommon-x11-0 \
+    libasound2 libxfixes3 libxrandr2 && \
+    apt-get clean && rm -rf /var/lib/apt/lists/*
+
+RUN npx @puppeteer/browsers install chrome@$CHROME_VERSION && \
+    npx @puppeteer/browsers install chromedriver@$CHROME_VERSION
+
 WORKDIR /common
 RUN yarn --frozen-lockfile
 

alerting/cron_aa_storm_alert_run.sh

@@ -0,0 +1,13 @@
+#!/bin/bash
+cd ~/prism-app/alerting
+
+# source secrets from AWS
+source ../api/set_envs.sh
+
+docker compose run --entrypoint 'yarn aa-storm-alert-worker' alerting-node 2>&1 | tee -a ~/prism-app/alerting/aa_storm_alert_worker.log
+
+## To set up the cron job, run the following command on the server:
+# crontab -e
+## and then add the following line to the crontab file:
+# 0 * * * * ~/prism-app/alerting/cron_aa_storm_alert_run.sh
+## This will run the alerting script every hour at minute 0.

alerting/cron_alert_run.sh

@@ -7,7 +7,7 @@ source ../api/set_envs.sh
 docker compose run --entrypoint 'yarn alert-worker' alerting-node 2>&1 | tee -a ~/prism-app/alerting/alert_worker.log
 
 ## To set up the cron job, run the following command on the server:
-# contrab -e
+# crontab -e
 ## and then add the following line to the crontab file:
 # 0 1 * * * ~/prism-app/alerting/cron_alert_run.sh
 ## This will run the alerting script every day at 1:00 AM.

alerting/docker-compose.yml

@@ -15,6 +15,8 @@ services:
     build:
       context: ../
       dockerfile: ./alerting/Dockerfile
+      args:
+        CHROME_VERSION: "126.0.6478.126"
     restart: always
     volumes:
       - ../alerting:/app

alerting/migration/1738249210356-create-anticipatory-action-alerts-table.ts

@@ -0,0 +1,22 @@
+import { MigrationInterface, QueryRunner } from 'typeorm';
+
+export class CreateAnticipatoryActionAlertsTable1738249210356
+  implements MigrationInterface
+{
+  public async up(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(`CREATE TABLE "anticipatory_action_alerts" (
+        "id" SERIAL NOT NULL,
+        "country" VARCHAR NOT NULL,
+        "emails" VARCHAR[] NOT NULL,
+        "prism_url" VARCHAR NOT NULL,
+        "last_triggered_at" TIMESTAMPTZ,
+        "last_ran_at" TIMESTAMPTZ DEFAULT CURRENT_TIMESTAMP,
+        "last_states" jsonb,
+        CONSTRAINT "PK_ad91cad659a3536465d564a4b3a" PRIMARY KEY ("id")
+      )`);
+  }
+
+  public async down(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(`DROP TABLE "anticipatory_action_alerts"`);
+  }
+}

alerting/ormconfig.ts

@@ -1,6 +1,6 @@
 import { SnakeNamingStrategy } from 'typeorm-naming-strategies';
 import { join } from 'path';
-import { DataSourceOptions } from 'typeorm';
+import { ConnectionOptions } from 'typeorm';
 
 // dotenv is a dev dependency, so conditionally import it (don't need it in Prod).
 try {
@@ -51,4 +51,4 @@ export = {
     migrationsDir: 'migration',
     subscribersDir: 'subscriber',
   },
-} as unknown as DataSourceOptions;
+} as unknown as ConnectionOptions;

alerting/package.json

@@ -22,6 +22,7 @@
     "migration:revert": "yarn typeorm migration:revert",
     "typeorm-seeding": "ts-node $(yarn bin typeorm-seeding)",
     "alert-worker": "yarn ts-node src/alert-worker.ts",
+    "aa-storm-alert-worker": "yarn ts-node src/aa-storm-alert-runner.ts",
     "docker-alert": "source ../api/set_envs.sh && docker compose run --entrypoint 'yarn alert-worker' alerting-node"
   },
   "dependencies": {
@@ -36,13 +37,14 @@
     "pg": "^8.5.1",
     "prism-common": "file:../common",
     "puppeteer": "^24.1.1",
-    "typeorm": "^0.3.0",
+    "typeorm": "0.2.31",
     "typeorm-naming-strategies": "^1.1.0",
     "xml-js": "^1.6.11"
   },
   "devDependencies": {
     "@types/ejs": "^3.1.5",
     "@types/jest": "^29.5.12",
+    "@types/node": "^22.13.0",
     "@types/node-fetch": "^2.5.8",
     "@types/nodemailer": "^6.4.1",
     "faker": "^4.1.0",

alerting/src/aa-storm-alert-runner.ts

@@ -0,0 +1,3 @@
+import { run } from './aa-storm-alert/worker';
+
+run();

alerting/src/aa-storm-alert/__snapshots__/alert.test.ts.snap

@@ -0,0 +1,65 @@
+// Jest Snapshot v1, https://goo.gl/fbAQLP
+
+exports[`alert mechanism buildEmailPayloads() does not return a payload when detailed report indicates that activation48 is triggered but there is no pilot activated districts for 48kt exposed 1`] = `Array []`;
+
+exports[`alert mechanism buildEmailPayloads() does not return a payload when detailed report indicates that activation64 is triggered but there is no pilot activated districts for 64kt exposed 1`] = `Array []`;
+
+exports[`alert mechanism buildEmailPayloads() returns a payload when detailed report indicates that activation48 is triggered and pilot activated districts for 48kt winds are parts of the exposed districts 1`] = `
+Array [
+  Object {
+    "activatedTriggers": Object {
+      "districts48kt": Array [
+        "Angoche",
+      ],
+      "districts64kt": Array [],
+      "windspeed": "",
+    },
+    "base64Image": "",
+    "cycloneName": "ELVIS",
+    "cycloneTime": "2025-01-31T06:00:00Z",
+    "email": "",
+    "readiness": false,
+    "redirectUrl": "",
+  },
+]
+`;
+
+exports[`alert mechanism buildEmailPayloads() returns a payload when detailed report indicates that activation64 is triggered and pilot activated districts for 64kt winds are parts of the exposed districts 1`] = `
+Array [
+  Object {
+    "activatedTriggers": Object {
+      "districts48kt": Array [],
+      "districts64kt": Array [
+        "Namacurra",
+      ],
+      "windspeed": "",
+    },
+    "base64Image": "",
+    "cycloneName": "ELVIS",
+    "cycloneTime": "2025-01-31T06:00:00Z",
+    "email": "",
+    "readiness": false,
+    "redirectUrl": "",
+  },
+]
+`;
+
+exports[`alert mechanism buildEmailPayloads() returns a payload when detailed report indicates that readiness is triggered 1`] = `
+Array [
+  Object {
+    "activatedTriggers": Object {
+      "districts48kt": Array [],
+      "districts64kt": Array [],
+      "windspeed": "",
+    },
+    "base64Image": "",
+    "cycloneName": "ELVIS",
+    "cycloneTime": "2025-01-31T06:00:00Z",
+    "email": "",
+    "readiness": true,
+    "redirectUrl": "",
+  },
+]
+`;
+
+exports[`alert mechanism buildEmailPayloads() returns no payload when detailed report indicates that activation is triggered but landfall already occured 1`] = `Array []`;