initial thaithai bot

.gitignore

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

config/config.json.example

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

src/index.js

@@ -26,13 +26,16 @@ 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 {
-		const radar_image = await axios.get('https://weather.bangkok.go.th/Images/Radar/radarh.jpg', {
+        let radar_src = "https://weather.bangkok.go.th/Images/Radar/radarh.jpg"
+        const radar_image = await axios.get(radar_src, {
             responseType: "stream"
         });
 
@@ -58,6 +61,8 @@ const curr_image_path = path.resolve("data", "current_radar.jpg");
 client.on('ready', () => {
     (async () => {
         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();
@@ -69,11 +74,25 @@ client.on('ready', () => {
         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: radar_caption,
-	        files: [curr_image_path]
+            content: caption,
+            files: [curr_image_path, "https://dds.bangkok.go.th/Radar/radar_rain.gif"]
         });
-	    console.log(`Sent: ${message.content}`);
+
+        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;
@@ -88,16 +107,51 @@ client.on('ready', () => {
             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!");
-                let message = await channel.send({
-                	content: radar_caption,
-                	files: [curr_image_path]
+
+                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);
+                        }
                     });
-                console.log(`Sent: ${message.content}`);
+
+                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"]
+                });
+
+                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.");
             }

test.js

@@ -1,28 +0,0 @@
-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>