.gitignore

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

config/config.json.example

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

src/index.js

@@ -14,8 +14,8 @@ import {
     parse
 } from 'node-html-parser';
 
-import {
+import { 
-    pipeline
+	pipeline 
 } from 'node:stream/promises';
 
 import path from 'node:path';
@@ -26,145 +26,91 @@ const client = new Client({
 
 const config = JSON.parse(fs.readFileSync(path.resolve("config", "config.json")));
 
-process.env.TZ = config.timezone;
-
 client.once(Events.ClientReady, readyClient => {
     console.log(`Ready! Logged in as ${readyClient.user.tag}`);
 });
 
 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() {
-    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");
 
 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_caption = await get_radar_caption();
 
-        let radar_image = await get_rain_image();
+		await pipeline(
-        let radar_caption = await get_radar_caption();
+			radar_image[0].data,
+			fs.createWriteStream(curr_image_path)
+		);
+		console.log("File Saved");
+			
+		console.log("Updating on boot");
+		let message = await channel.send({
+			content: radar_caption,
+	        files: [curr_image_path]
+	    });
+	    console.log(`Sent: ${message.content}`);
+		
+		setInterval(async () => {
+		 	let curr_image_size = fs.statSync(curr_image_path).size;
 
-        await pipeline(
+		 	let radar_image = await get_rain_image();
-            radar_image[0].data,
+		 	let radar_caption = await get_radar_caption();
-            fs.createWriteStream(curr_image_path)
-        );
-        console.log("File Saved");
-
-        console.log("Updating on boot");
-
-        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({
-            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(
-                radar_image[0].data,
+            	radar_image[0].data,
-                fs.createWriteStream(curr_image_path)
+            	fs.createWriteStream(curr_image_path)
             );
             console.log("File Saved");
 
             let radar_image_size = radar_image[1];
-
             console.log("Current: " + curr_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(sentMessage.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({
-                    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 {
                 console.log("No change in data, go on.");
             }
-        }, 60000);
+		}, 60000); 
-    })();
+	})();
 });
 
 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 => {
-    console.error(error);
+    console.error(error); 
 });
 
 client.login(config.token);

test.js

@@ -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>