From 5cb0ff6cd91fd568638c4ed1b68739a5002198f4 Mon Sep 17 00:00:00 2001
From: ChrisChrome <christophercookman@gmail.com>
Date: Wed, 8 May 2024 00:44:03 -0600
Subject: [PATCH] Add NTFY push support

---
 index.js | 35 +++++++++++++++++++++++++++++++++--
 1 file changed, 33 insertions(+), 2 deletions(-)

diff --git a/index.js b/index.js
index bbce650..a8d0392 100644
--- a/index.js
+++ b/index.js
@@ -90,7 +90,7 @@ xmpp.on("offline", () => {
 
 
 xmpp.on("stanza", (stanza) => {
-	if(config.debug) console.log(stanza.toString());
+	if (config.debug >= 2) console.log(stanza.toString());
 	// Stops spam from getting old messages
 	if (startup) return;
 	// Get new messages and log them, ignore old messages
@@ -110,6 +110,37 @@ xmpp.on("stanza", (stanza) => {
 		const now = new Date();
 		const diff = (now - product_id.timestamp) / 1000 / 60;
 		if (diff > 3) return;
+		if (config.debug >= 1) console.log(`New message from ${fromChannel}`);
+		// Handle NTFY
+		if (config.ntfy.enabled) {
+			if(config.debug >= 1) console.log(`Sending NTFY for ${config.ntfy.prefix}${fromChannel}`)
+			ntfyBody = {
+				"topic": `${config.ntfy.prefix}${fromChannel}`,
+				"message": body,
+				"title": "New Alert",
+				"tags": [`Timestamp: ${product_id.timestamp}`, `Station: ${product_id.station}`, `WMO: ${product_id.wmo}`, `PIL: ${product_id.pil}`, `Channel: ${fromChannel}`],
+				"priority": 3,
+
+			}
+			if (stanza.getChild("x").attrs.twitter_media) {
+				ntfyBody.attach = stanza.getChild("x").attrs.twitter_media;
+			}
+			fetch(config.ntfy.server, {
+				method: 'POST',
+				body: JSON.stringify(ntfyBody),
+				headers: {
+					'Authorization': `Bearer ${config.ntfy.token}`
+				}
+			}).then((res) => {
+				if (config.debug >= 1) console.log(res.status)
+
+			}).catch((err) => {
+				console.error(err)
+			})
+		}
+
+
+		// Send discord msg
 		let embed = {
 			title: "New Alert",
 			description: body,
@@ -347,7 +378,7 @@ discord.on("interactionCreate", async (interaction) => {
 					let uniques = 0;
 					await db.get(`SELECT COUNT(*) as count FROM channels`, async (err, row) => {
 						channels = row.count
-						
+
 						await getUniqueChannels().then((unique) => {
 							uniques = unique;
 						});