dziban303/weather-bot
1
0
Fork 0
forked from ChrisChrome/weather-bot
Code Pull requests Activity

Add automatic retry to fetching product text for filtering

Browse source
This commit is contained in:
Christopher Cookman 2024-05-22 13:48:14 -06:00
parent 9393bf8f94
commit a31573b7c4
Signed by: ChrisChrome
GPG key ID: A023A26E42C33A42
1 changed files with 35 additions and 22 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

57
index.js
View file

@ -421,19 +421,26 @@ xmpp.on("stanza", (stanza) => {
if (!channel) return console.log(`${colors.red("[ERROR]")} Channel ${row.channelid} not found`); if (!channel) return console.log(`${colors.red("[ERROR]")} Channel ${row.channelid} not found`);
// fetch the product text // fetch the product text
fetch(`https://mesonet.agron.iastate.edu/api/1/nwstext/${product_id_raw}`).then((res) => { trySend = () => {
// If neither the body nor the product text contains the filter, ignore it fetch(`https://mesonet.agron.iastate.edu/api/1/nwstext/${product_id_raw}`).then((res) => {
res.text().then((text) => { // If neither the body nor the product text contains the filter, ignore it
if (!filters.some((filter) => body.toLowerCase().includes(filter)) && !filters.some((filter) => text.toLowerCase().includes(filter))) return; res.text().then((text) => {
thisMsg = JSON.parse(JSON.stringify(discordMsg)); if (!filters.some((filter) => body.toLowerCase().includes(filter)) && !filters.some((filter) => text.toLowerCase().includes(filter))) return;
thisMsg.content = row.custommessage || null; thisMsg = JSON.parse(JSON.stringify(discordMsg));
channel.send(thisMsg).catch((err) => { thisMsg.content = row.custommessage || null;
console.error(err); channel.send(thisMsg).catch((err) => {
}).then((msg) => { console.error(err);
if (msg.channel.type === Discord.ChannelType.GuildAnnouncement) msg.crosspost(); }).then((msg) => {
if (msg.channel.type === Discord.ChannelType.GuildAnnouncement) msg.crosspost();
});
}); });
}).catch((err) => {
setTimeout(() => {
console.log(`${colors.red("[ERROR]")} Failed to fetch product text, retrying... ${err}`)
trySend();
})
}); });
}); }
}); });
}); });
@ -460,18 +467,24 @@ xmpp.on("stanza", (stanza) => {
if (!user) return console.log(`${colors.red("[ERROR]")} User ${row.userid} not found`); if (!user) return console.log(`${colors.red("[ERROR]")} User ${row.userid} not found`);
// fetch the product text // fetch the product text
fetch(`https://mesonet.agron.iastate.edu/api/1/nwstext/${product_id_raw}`).then((res) => { trySend = () => {
// If neither the body nor the product text contains the filter, ignore it fetch(`https://mesonet.agron.iastate.edu/api/1/nwstext/${product_id_raw}`).then((res) => {
res.text().then((text) => { // If neither the body nor the product text contains the filter, ignore it
if (!filters.some((filter) => body.toLowerCase().includes(filter)) && !filters.some((filter) => text.toLowerCase().includes(filter))) return; res.text().then((text) => {
thisMsg = JSON.parse(JSON.stringify(discordMsg)); if (!filters.some((filter) => body.toLowerCase().includes(filter)) && !filters.some((filter) => text.toLowerCase().includes(filter))) return;
thisMsg.content = row.custommessage || null; thisMsg = JSON.parse(JSON.stringify(discordMsg));
user.send(thisMsg).catch((err) => { thisMsg.content = row.custommessage || null;
console.error(err); user.send(thisMsg).catch((err) => {
console.error(err);
});
}); });
}); }).catch((err) => {
}); setTimeout(() => {
console.log(`${colors.red("[ERROR]")} Failed to fetch product text, retrying... ${err}`)
trySend();
})
});;
}
}); });
}); });
} }