forked from ChrisChrome/weather-bot
Compare commits
12 commits
dziban303-
...
main
Author | SHA1 | Date | |
---|---|---|---|
|
93ac9d14bf | ||
|
664e00b7f4 | ||
|
cce9b12645 | ||
|
c82ab68c1e | ||
|
a543386394 | ||
|
1ae72ac979 | ||
|
1a7c1735f4 | ||
|
5b487125aa | ||
|
770813b4a7 | ||
|
ded7a2373c | ||
|
79ae2f4c25 | ||
|
e02faaab18 |
|
@ -365,7 +365,7 @@
|
|||
},
|
||||
"FFW": {
|
||||
"text": "Flash Flood Warning",
|
||||
"priority": 4
|
||||
"priority": 5
|
||||
},
|
||||
"FLN": {
|
||||
"priority": 1,
|
||||
|
@ -1164,7 +1164,7 @@
|
|||
"text": "Tropical Cyclone Watch/Warning Break Points"
|
||||
},
|
||||
"TIB": {
|
||||
"priority": 4,
|
||||
"priority": 3,
|
||||
"text": "Tsunami Bulletin"
|
||||
},
|
||||
"TID": {
|
||||
|
@ -1308,7 +1308,7 @@
|
|||
"text": "Routine Space Environment Product Issued Weekly"
|
||||
},
|
||||
"WOU": {
|
||||
"priority": 4,
|
||||
"priority": 5,
|
||||
"text": "Tornado/Severe Thunderstorm Watch"
|
||||
},
|
||||
"WS1": {
|
||||
|
@ -1365,11 +1365,11 @@
|
|||
},
|
||||
"CFA": {
|
||||
"text": "Coastal Flood Watch",
|
||||
"priority": 4
|
||||
"priority": 3
|
||||
},
|
||||
"FLA": {
|
||||
"text": "Flood Watch",
|
||||
"priority": 2
|
||||
"priority": 3
|
||||
},
|
||||
"HWA": {
|
||||
"text": "High Wind Watch",
|
||||
|
@ -1389,7 +1389,7 @@
|
|||
},
|
||||
"SVA": {
|
||||
"text": "Severe Thunderstorm Watch",
|
||||
"priority": 4
|
||||
"priority": 5
|
||||
},
|
||||
"TOA": {
|
||||
"text": "Tornado Watch",
|
||||
|
@ -1405,7 +1405,7 @@
|
|||
},
|
||||
"TSA": {
|
||||
"text": "Tsunami Watch",
|
||||
"priority": 4
|
||||
"priority": 5
|
||||
},
|
||||
"TSW": {
|
||||
"text": "Tsunami Warning",
|
||||
|
|
|
@ -1,13 +1,13 @@
|
|||
{
|
||||
"convective": [
|
||||
"https://www.spc.noaa.gov/products/outlook/day1otlk.gif",
|
||||
"https://www.spc.noaa.gov/products/outlook/day2otlk.gif",
|
||||
"https://www.spc.noaa.gov/products/outlook/day3otlk.gif",
|
||||
"https://www.spc.noaa.gov/products/exper/day4-8/day4prob.gif",
|
||||
"https://www.spc.noaa.gov/products/exper/day4-8/day5prob.gif",
|
||||
"https://www.spc.noaa.gov/products/exper/day4-8/day6prob.gif",
|
||||
"https://www.spc.noaa.gov/products/exper/day4-8/day7prob.gif",
|
||||
"https://www.spc.noaa.gov/products/exper/day4-8/day8prob.gif"
|
||||
"https://weather.cod.edu/cdata/text/images/spc/co/day1/categorical/spccoday1.categorical.latest.png",
|
||||
"https://climate.cod.edu/data/text/images/spc/co/day2/categorical/spccoday2.categorical.latest.png",
|
||||
"https://climate.cod.edu/data/text/images/spc/co/day3/categorical/spccoday3.categorical.latest.png",
|
||||
"https://climate.cod.edu/data/text/images/spc/co/day4/severe/spccoday4.severe.latest.png",
|
||||
"https://climate.cod.edu/data/text/images/spc/co/day5/severe/spccoday5.severe.latest.png",
|
||||
"https://climate.cod.edu/data/text/images/spc/co/day6/severe/spccoday6.severe.latest.png",
|
||||
"https://climate.cod.edu/data/text/images/spc/co/day7/severe/spccoday7.severe.latest.png",
|
||||
"https://climate.cod.edu/data/text/images/spc/co/day8/severe/spccoday8.severe.latest.png"
|
||||
],
|
||||
"fire": [
|
||||
"https://www.spc.noaa.gov/products/exper/fire_wx/imgs/day1otlk_fire.gif",
|
||||
|
|
|
@ -590,5 +590,11 @@
|
|||
"fgf": {
|
||||
"room": "fgfchat",
|
||||
"location": "Grand_Forks"
|
||||
|
||||
},
|
||||
"hawaii": {
|
||||
"room": "hawaii",
|
||||
"location": "Hawaii"
|
||||
|
||||
}
|
||||
}
|
33
index.js
33
index.js
|
@ -377,13 +377,14 @@ 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(`${colors.magenta("[DEBUG]")} New message from ${fromChannel}`);
|
||||
// if (config.debug >= 1) console.log(`${colors.magenta("[DEBUG]")} New message from ${fromChannel}`);
|
||||
console.log(`${colors.cyan("[INFO]")} ${getWFOByRoom(fromChannel).location} - ${evt.text} - ${product_id.timestamp}`);
|
||||
messages++;
|
||||
|
||||
|
||||
// Handle NTFY
|
||||
if (config.ntfy.enabled) {
|
||||
if (config.debug >= 1) console.log(`${colors.magenta("[DEBUG]")} Sending NTFY for ${config.ntfy.prefix}${fromChannel}`)
|
||||
//if (config.debug >= 1) console.log(`${colors.magenta("[DEBUG]")} Sending NTFY for ${config.ntfy.prefix}${fromChannel}`)
|
||||
ntfyBody = {
|
||||
"topic": `${config.ntfy.prefix}${fromChannel}`,
|
||||
"message": bodyData.string,
|
||||
|
@ -401,7 +402,7 @@ xmpp.on("stanza", (stanza) => {
|
|||
'Authorization': `Bearer ${config.ntfy.token}`
|
||||
}
|
||||
}).then((res) => {
|
||||
if (config.debug >= 1) console.log(`${colors.magenta("[DEBUG]")} NTFY sent for ${config.ntfy.prefix}${fromChannel} with status ${res.status} ${res.statusText}`);
|
||||
//if (config.debug >= 1) console.log(`${colors.magenta("[DEBUG]")} NTFY sent for ${config.ntfy.prefix}${fromChannel} with status ${res.status} ${res.statusText}`);
|
||||
if (res.status !== 200) console.log(`${colors.red("[ERROR]")} NTFY failed for ${config.ntfy.prefix}${fromChannel} with status ${res.status} ${res.statusText}`);
|
||||
|
||||
|
||||
|
@ -522,6 +523,7 @@ xmpp.on("stanza", (stanza) => {
|
|||
}).catch((err) => {
|
||||
console.log(`${colors.red("[ERROR]")} Failed to send message to ${channel.guild.ownerId}`);
|
||||
}).then(() => {
|
||||
if (channel.guildId == config.discord.mainGuild) return;
|
||||
db.run(`DELETE FROM channels WHERE channelid = ? AND iemchannel = ?`, [channel.id, fromChannel], (err) => {
|
||||
if (err) {
|
||||
console.error(err.message);
|
||||
|
@ -575,6 +577,27 @@ xmpp.on("stanza", (stanza) => {
|
|||
thisMsg.content = row.custommessage || null;
|
||||
user.send(thisMsg).catch((err) => {
|
||||
console.error(err);
|
||||
}).catch((err) => {
|
||||
console.log(`${colors.yellow("[WARN]")} Failed to send message to ${user.tag} (${user.id})`);
|
||||
const logChannel = discord.guilds.cache.get(config.discord.mainGuild).channels.cache.get(config.discord.logChannel);
|
||||
logChannel.send({
|
||||
embeds: [
|
||||
{
|
||||
title: "Failed to send DM",
|
||||
description: `User may have DMs disabled, or bot doesnt' share a server anymore!.
|
||||
User: ${user.tag} (${user.id})
|
||||
Sub Info: \`\`\`json\n${JSON.stringify(row)}\`\`\``,
|
||||
color: 0xff0000
|
||||
}
|
||||
]
|
||||
}).then(() => {
|
||||
db.run(`DELETE FROM userAlerts WHERE userid = ? AND iemchannel = ?`, [user.id, fromChannel], (err) => {
|
||||
if (err) {
|
||||
console.error(err.message);
|
||||
}
|
||||
console.log(`${colors.cyan("[INFO]")} Deleted user ${user.id} from database`);
|
||||
});
|
||||
})
|
||||
});
|
||||
});
|
||||
}).catch((err) => {
|
||||
|
@ -1567,6 +1590,8 @@ discord.on("guildCreate", async (guild) => {
|
|||
]
|
||||
}
|
||||
]
|
||||
}).catch((err) => {
|
||||
console.log(`${colors.red("[ERROR]")} Failed to send message to user ${user.id}: ${err.message}`);
|
||||
})
|
||||
channel.send({
|
||||
embeds: [
|
||||
|
@ -1645,5 +1670,7 @@ process.on("uncaughtException", (error) => {
|
|||
return;
|
||||
});
|
||||
|
||||
|
||||
|
||||
// Login to discord
|
||||
discord.login(config.discord.token);
|
Loading…
Reference in a new issue