winsdominoes/bkk-raindar-discord
winsdominoes
/
bkk-raindar-discord
1
0
Fork 1
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Compare commits

base: winsdominoes:thaithai
Branches Tags
winsdominoes:master
winsdominoes:thaithai
winsdominoes:update
..
compare: winsdominoes:master
Branches Tags
winsdominoes:thaithai
winsdominoes:update
winsdominoes:master

No commits in common. "thaithai" and "master" have entirely different histories.
thaithai ... master

5 changed files with 81 additions and 113 deletions
Show Stats Expand all files Collapse all files

4
.gitignore vendored
View File

@ -132,7 +132,3 @@ dist
# config # config
config/config.json config/config.json
# data
data/current_radar.gif
data/current_radar.jpg

4
config/config.json.example
View File

@ -1,6 +1,4 @@
{ {
"room": "", "room": "",
"history": "", "token": ""
"token": "",
"timezone": "",
} }

BIN
data/current_radar.jpg Normal file
View File

Binary file not shown.
Side by Side

After

Width:  |  Height:  |  Size: 279 KiB

144
src/index.js
View File

@ -15,7 +15,7 @@ import {
} from 'node-html-parser'; } from 'node-html-parser';
import { import {
pipeline pipeline
} from 'node:stream/promises'; } from 'node:stream/promises';
import path from 'node:path'; import path from 'node:path';
@ -26,141 +26,87 @@ const client = new Client({
const config = JSON.parse(fs.readFileSync(path.resolve("config", "config.json"))); const config = JSON.parse(fs.readFileSync(path.resolve("config", "config.json")));
process.env.TZ = config.timezone;
client.once(Events.ClientReady, readyClient => { client.once(Events.ClientReady, readyClient => {
console.log(`Ready! Logged in as ${readyClient.user.tag}`); console.log(`Ready! Logged in as ${readyClient.user.tag}`);
}); });
async function get_rain_image() { async function get_rain_image() {
try { try {
let radar_src = "https://weather.bangkok.go.th/Images/Radar/radarh.jpg" const radar_image = await axios.get('https://weather.bangkok.go.th/Images/Radar/radarh.jpg', {
const radar_image = await axios.get(radar_src, { responseType: "stream"
responseType: "stream" });
});
const radar_image_size = radar_image.headers['content-length']; const radar_image_size = radar_image.headers['content-length'];
console.log("Got Radar Data"); console.log("Got Radar Data");
return [radar_image, radar_image_size]; return [radar_image, radar_image_size];
} catch (error) { } catch (error) {
console.error(error); console.error(error);
return [error]; return [error];
} }
} }
async function get_radar_caption() { async function get_radar_caption() {
const response = await axios.get('https://weather.bangkok.go.th/Radar/RadarHighResolution.aspx'); const response = await axios.get('https://weather.bangkok.go.th/Radar/RadarHighResolution.aspx');
let root = parse(response.data); let root = parse(response.data);
console.log("Got Radar Caption") console.log("Got Radar Caption")
return root.querySelector('#repeaDaily_lblDESCRIPTION_0').childNodes[0]._rawText; return root.querySelector('#repeaDaily_lblDESCRIPTION_0').childNodes[0]._rawText;
} }
const curr_image_path = path.resolve("data", "current_radar.jpg"); const curr_image_path = path.resolve("data", "current_radar.jpg");
client.on('ready', () => { client.on('ready', () => {
(async () => { (async () => {
const channel = client.channels.cache.get(config.room); const channel = client.channels.cache.get(config.room);
const webhooks = await channel.fetchWebhooks();
const webhook = webhooks.first();
let radar_image = await get_rain_image(); let radar_image = await get_rain_image();
let radar_caption = await get_radar_caption(); let radar_caption = await get_radar_caption();
await pipeline( await pipeline(
radar_image[0].data, radar_image[0].data,
fs.createWriteStream(curr_image_path) fs.createWriteStream(curr_image_path)
); );
console.log("File Saved"); console.log("File Saved");
console.log("Updating on boot"); console.log("Updating on boot");
let message = await channel.send({
content: radar_caption,
files: [curr_image_path]
});
console.log(`Sent: ${message.content}`);
let date = new Date().toLocaleString('th-TH'); setInterval(async () => {
let curr_image_size = fs.statSync(curr_image_path).size;
let caption = `# Raindar Update\n## ${date}\n${radar_caption}\n\nLeft: Current Observation\nRight: 3 hour forecast` let radar_image = await get_rain_image();
let radar_caption = await get_radar_caption();
let message = await channel.send({
content: caption,
files: [curr_image_path, "https://dds.bangkok.go.th/Radar/radar_rain.gif"]
});
let message_id = message.id;
console.log(`Sent ${message.id}: ${message.content}`);
await webhook.send({
content: caption,
files: [curr_image_path, "https://dds.bangkok.go.th/Radar/radar_rain.gif"],
threadId: config.history,
});
console.log(`Sent message to history`)
setInterval(async () => {
let curr_image_size = fs.statSync(curr_image_path).size;
let radar_image = await get_rain_image();
let radar_caption = await get_radar_caption();
await pipeline( await pipeline(
radar_image[0].data, radar_image[0].data,
fs.createWriteStream(curr_image_path) fs.createWriteStream(curr_image_path)
); );
console.log("File Saved"); console.log("File Saved");
let radar_image_size = radar_image[1]; let radar_image_size = radar_image[1];
console.log("Current: " + curr_image_size); console.log("Current: " + curr_image_size);
console.log("New: " + radar_image_size); console.log("New: " + radar_image_size);
if (radar_image_size != curr_image_size) { if(radar_image_size != curr_image_size) {
console.log("File change detected!"); console.log("File change detected!");
channel.messages
.fetch(message_id)
.then((fetchedMessage) => {
console.log('Message exists');
fetchedMessage
.delete()
.then(() => console.log('Message deleted successfully'))
.catch((err) => console.log('Could not delete the message', err));
})
.catch((err) => {
if (err.httpStatus === 404) {
console.log('Message already deleted');
} else {
console.log(err);
}
});
let date = new Date().toLocaleString('th-TH');
let caption = `# Raindar Update\n## ${date}\n${radar_caption}\n\nLeft: Current Observation\nRight: 3 hour forecast`
let message = await channel.send({ let message = await channel.send({
content: caption, content: radar_caption,
files: [curr_image_path, "https://dds.bangkok.go.th/Radar/radar_rain.gif"] files: [curr_image_path]
}); });
console.log(`Sent: ${message.content}`);
console.log(`Sent ${message.id}: ${message.content}`);
message_id = message.id;
await webhook.send({
content: caption,
files: [curr_image_path, "https://dds.bangkok.go.th/Radar/radar_rain.gif"],
threadId: config.history,
});
console.log(`Sent message to history`)
} else { } else {
console.log("No change in data, go on."); console.log("No change in data, go on.");
} }
}, 60000); }, 60000);
})(); })();
}); });
client.on(Events.ShardError, error => { client.on(Events.ShardError, error => {
console.log('A websocket connection encountered an error: ', error); console.log('A websocket connection encountered an error: ', error);
}); });
process.on('unhandledRejection', error => { process.on('unhandledRejection', error => {

28
test.js Normal file
View File

@ -0,0 +1,28 @@
import axios from "axios";
import { parse } from 'node-html-parser';
axios.get('https://weather.bangkok.go.th/Radar/RadarHighResolution.aspx')
.then(function(response) {
// console.log(response);
const root = parse(response.data);
//console.log(root.firstChild.structure);
// ul#list
// li
// #text
console.log(root.querySelector('#repeaDaily_lblDESCRIPTION_0').childNodes[0]._rawText);
// { tagName: 'ul',
// rawAttrs: 'id="list"',
// childNodes:
// [ { tagName: 'li',
// rawAttrs: '',
// childNodes: [Object],
// classNames: [] } ],
// id: 'list',
// classNames: [] }
//console.log(root.toString());
})
//<span id="repeaDaily_lblDESCRIPTION_0">(.*?)<\/span>