Add auto clips posting

AlexPresso · Jan 21, 2024 · e541072 · e541072
1 parent 354a955
commit e541072
Show file tree

Hide file tree

Showing 4 changed files with 41 additions and 4 deletions.
diff --git a/classes/Judy.js b/classes/Judy.js
@@ -37,7 +37,8 @@ module.exports = class Judy {
             tempChannelsCounters: new Map(),
             twitch: {
                 prevState: null,
-                scheduledEvent: null
+                scheduledEvent: null,
+                lastExecTime: null
             }
         }
 
@@ -70,9 +71,11 @@ module.exports = class Judy {
             const scheduledTask = require(`../scheduled/${file}`),
                 name = file.split('.')[0];
 
-            schedule.scheduleJob(scheduledTask.schedule, () => {
+            schedule.scheduleJob(scheduledTask.schedule, async () => {
                 try {
-                    scheduledTask.task(this._client);
+                    this._client.logger.debug(`Running ${name} scheduled task.`)
+                    await scheduledTask.task(this._client);
+                    this._client.logger.debug(`Done running ${name} scheduled task.`)
                 } catch (e) {
                     console.error(e);
                 }

diff --git a/config.example.json b/config.example.json
@@ -22,11 +22,13 @@
     }
   },
   "twitch": {
+    "enable": false,
     "message": "%userName% is live!",
     "channel": "YourChannel",
     "userId": "YourUserID",
     "liveDiscordChannel": "123456789",
     "replayDiscordChannel": "123456789",
+    "clipDiscordChannel": "123456789",
     "clientId": "",
     "clientSecret": ""
   },

diff --git a/scheduled/twitchLive.js b/scheduled/twitchLive.js
@@ -6,7 +6,7 @@ module.exports = {
     schedule: "* * * * *",
     task: async client => {
         const config = client.config.twitch || {};
-        if(!config.channel)
+        if(!config.channel || !config.enable)
             return;
 
         const token = await Twitch.getToken(config.clientId, config.clientSecret)
@@ -17,6 +17,8 @@ module.exports = {
         if(!response)
             return;
 
+        postClips(client, token.data.access_token);
+
         const newState = response.data.data[0];
         const oldState = client._state.twitch.prevState;
 
@@ -103,6 +105,24 @@ async function postReplay(client, twitchToken)  {
     client.channels.resolve(client.config.twitch.replayDiscordChannel)?.send(videos.data.data[0].url)
 }
 
+async function postClips(client, token) {
+    const clips = await Twitch.getClips(
+        client.config.twitch.userId,
+        client._state.twitch.lastExecTime || new Date().toISOString(),
+        client.config.twitch.clientId,
+        token
+    );
+
+    if(!clips || !clips.data)
+        return;
+
+    for(const clip of (clips.data.data || [])) {
+        client.channels.resolve(client.config.twitch.clipDiscordChannel)?.send(clip.url);
+    }
+
+    client._state.twitch.lastExecTime = new Date().toISOString();
+}
+
 async function getOrFetchPreviousEvent(client, manager) {
     if(client._state.twitch.scheduledEvent)
         return client._state.twitch.scheduledEvent;

diff --git a/utils/TwitchAPI.js b/utils/TwitchAPI.js
@@ -34,5 +34,17 @@ module.exports = {
                 }
             }
         ).catch(console.error)
+    },
+
+    getClips: (userId, startedAt, clientId, token) => {
+        return Axios.get(
+            `https://api.twitch.tv/helix/clips?broadcaster_id=${userId}&started_at=${startedAt}`,
+            {
+                headers: {
+                    "Client-ID": clientId,
+                    "Authorization": `Bearer ${token}`
+                }
+            }
+        ).catch(console.error)
     }
 }