MoSiren/IEM-Alert
1
0
Fork 0
forked from ChrisChrome/weather-bot
Code Pull requests Activity

Add priority system to events

Browse source
This commit is contained in:
Christopher Cookman 2024-05-09 00:17:22 -06:00
parent fbc37c90a8
commit 1ad9c477ee
Signed by: ChrisChrome
GPG key ID: A023A26E42C33A42
3 changed files with 1525 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
config.json.template
View file

@ -1,4 +1,11 @@
{ {
"priorityColors": {
"1": "#00AFFF",
"2": "#00FF00",
"3": "#FFFF00",
"4": "#FFA500",
"5": "#FF0000"
},
"discord": { "discord": {
"token": "YOUR_TOKEN", "token": "YOUR_TOKEN",
"owner": "your_user_id", "owner": "your_user_id",

1510
events.json Normal file
View file

File diff suppressed because it is too large Load diff

10
index.js
View file

@ -1,6 +1,7 @@
// Requires // Requires
const config = require("./config.json"); const config = require("./config.json");
const wfos = require("./wfos.json"); const wfos = require("./wfos.json");
const events = require("./events.json");
const { client, xml } = require("@xmpp/client"); const { client, xml } = require("@xmpp/client");
const fetch = require("node-fetch"); const fetch = require("node-fetch");
const html = require("html-entities") const html = require("html-entities")
@ -216,6 +217,11 @@ xmpp.on("stanza", (stanza) => {
const bodyData = getFirstURL(body); const bodyData = getFirstURL(body);
// get product id from "x" tag // get product id from "x" tag
const product_id = parseProductID(stanza.getChild("x").attrs.product_id); const product_id = parseProductID(stanza.getChild("x").attrs.product_id);
var evt = events[product_id.pil.substring(0, 3)];
if (!evt) {
evt = { name: "Unknown", priority: 3}
console.log(`${colors.red("[ERROR]")} Unknown event type: ${product_id.pil.substring(0, 3)}. Fix me`);
}
const product_id_raw = stanza.getChild("x").attrs.product_id; const product_id_raw = stanza.getChild("x").attrs.product_id;
// Check timestamp, if not within 3 minutes, ignore it // Check timestamp, if not within 3 minutes, ignore it
const now = new Date(); const now = new Date();
@ -230,7 +236,7 @@ xmpp.on("stanza", (stanza) => {
"topic": `${config.ntfy.prefix}${fromChannel}`, "topic": `${config.ntfy.prefix}${fromChannel}`,
"message": bodyData.string, "message": bodyData.string,
"tags": [`Timestamp: ${product_id.timestamp}`, `Station: ${product_id.station}`, `WMO: ${product_id.wmo}`, `PIL: ${product_id.pil}`, `Channel: ${fromChannel}`], "tags": [`Timestamp: ${product_id.timestamp}`, `Station: ${product_id.station}`, `WMO: ${product_id.wmo}`, `PIL: ${product_id.pil}`, `Channel: ${fromChannel}`],
"priority": 3, "priority": evt.priority,
"actions": [{ "action": "view", "label": "Product", "url": bodyData.url }, { "action": "view", "label": "Product Text", "url": `https://mesonet.agron.iastate.edu/api/1/nwstext/${product_id_raw}` }] "actions": [{ "action": "view", "label": "Product", "url": bodyData.url }, { "action": "view", "label": "Product Text", "url": `https://mesonet.agron.iastate.edu/api/1/nwstext/${product_id_raw}` }]
} }
if (stanza.getChild("x").attrs.twitter_media) { if (stanza.getChild("x").attrs.twitter_media) {
@ -254,7 +260,7 @@ xmpp.on("stanza", (stanza) => {
// Send discord msg // Send discord msg
let embed = { let embed = {
description: bodyData.string, description: bodyData.string,
color: 0x00ff00, color: parseInt(config.priorityColors[evt.priority].replace("#", ""), 16) || 0x000000,
timestamp: product_id.timestamp, timestamp: product_id.timestamp,
footer: { footer: {
text: `Station: ${product_id.station} WMO: ${product_id.wmo} PIL: ${product_id.pil} Channel: ${fromChannel}` text: `Station: ${product_id.station} WMO: ${product_id.wmo} PIL: ${product_id.pil} Channel: ${fromChannel}`