add announcements MVP

handlers/events.js

@@ -0,0 +1,12 @@
+config = require("../config")
+const TwitchService = require('../services/twitch')
+
+class Events {
+    async sendEvents() {
+        if (config.twitch.channels.startsWith('m')) {
+            await TwitchService.sendAnnouncement(`28 y 29 de septiembre quedada en la Tarraco Manga`, 'orange')
+        }
+    }
+}
+
+module.exports = Events

handlers/index.js

@@ -4,12 +4,14 @@ const Train = require('./Train')
 const Stream = require('./Stream')
 const Birthday = require('./Birthday')
 const TempsDeFlors = require('./TempsDeFlors')
+const Events = require('./Events')
 
 module.exports = {
     generic: new Generic(),
     weather: new Weather(),
     train: new Train(),
     stream: new Stream(),
     birthday: new Birthday(),
-    tempsDeFlors: new TempsDeFlors()
+    tempsDeFlors: new TempsDeFlors(),
+    events: new Events()
 }

lib/notifier.js

@@ -23,6 +23,10 @@ class Notifier {
             await handlers.stream.refreshPage()
         })
 
+        cron.schedule('0/15 * * * *', async () => {
+            await handlers.events.sendEvents(this.twitchBot, this.target)
+        })
+
         return Promise.resolve()
     }
 

services/twitch.js

@@ -37,7 +37,6 @@ async function getStream() {
 async function getUnbanRequests () {
     let result
     const options = await _getHeaders()
-    options.
     const channel = await dbManager.getChannel(config.twitch.channels).lean()
     const endpoint = `${endpointPrefix}/moderation/unban_requests?broadcaster_id=${channel.roomId}&moderator_id=${config.twitch.userId}&status=pending`
 
@@ -53,23 +52,27 @@ async function getUnbanRequests () {
     return result
 }
 
-async function annunce() {
+async function sendAnnouncement(text, color) {
     let result
     const options = await _getHeaders()
     options.method = 'POST'
     const channel = await dbManager.getChannel(config.twitch.channels).lean()
     const endpoint = `${endpointPrefix}/chat/announcements?broadcaster_id=${channel.roomId}&moderator_id=${config.twitch.userId}`
-    try {
-        const response = await fetch(endpoint, options)
-        const data = await response.json()
-        result = data?.data ?? null
 
-    } catch {
-        result = null
+    const body = {
+        data : {
+            message: text,
+            color: color
+        }
     }
 
-    return result
+    options.body = JSON.stringify(body)
 
+    try {
+        await fetch(endpoint, options)
+    } catch {
+        result = null
+    }
 }
 
 async function getChannel () {
@@ -104,7 +107,8 @@ module.exports = {
     getChannel,
     saveLastUpdate,
     getUnbanRequests,
-    setActiveSpot
+    setActiveSpot,
+    sendAnnouncement
 }