tClient will now try to successfully reconnect and NOT crash the entire app

.env.sample

@@ -1,3 +1,3 @@
-mongo_uri=
+MONGO_URI=
-mongo_db=
+MONGO_DB=
-prefix=
+PREFIX=

.gitignore

@@ -1 +1,2 @@
 .env
+TODO.txt

clients.js

@@ -2,15 +2,22 @@
 const { MongoClient } = require('mongodb');
 const { Client, GatewayIntentBits } = require('discord.js');
 const tmi = require('tmi.js');
-const channels = ['x__hel__x','desq_blocki']
+const channels = ['x__hel__x', 'desq_blocki'];
+
+let mClient, dClient, tClient; // Global references
 
 const initializeClients = async () => {
+    // Disconnect existing clients if they exist
+    if (tClient) await tClient.disconnect().catch(() => {});
+    if (dClient) await dClient.destroy().catch(() => {});
+    if (mClient) await mClient.close().catch(() => {});
+
     // Initialize MongoDB Client
-    const mClient = new MongoClient(process.env.mongo_uri);
+    mClient = new MongoClient(process.env.MONGO_URI);
     await mClient.connect();
 
     // Initialize Discord Client
-    const dClient = new Client({
+    dClient = new Client({
         intents: [
             GatewayIntentBits.Guilds,
             GatewayIntentBits.GuildMembers,
@@ -18,31 +25,24 @@ const initializeClients = async () => {
         ],
     });
 
-    // Fetch Discord credentials from the database
+    const db = mClient.db(process.env.MONGO_DB);
-    const db = mClient.db(process.env.mongo_db);
     const credentialCollection = db.collection('credentials');
     const dCreds = await credentialCollection.findOne({ service: 'discord' });
-
     const tCreds = await credentialCollection.findOne({ service: 'twitch' });
 
     await dClient.login(dCreds.token);
 
     // Initialize Twitch Client
-    const tClient = new tmi.Client({
+    let tClient = new tmi.Client({
         options: { debug: false },
-        connection: {
+        connection: { reconnect: true, secure: true },
-            reconnect: true,
-            secure: true,
-        },
         identity: {
             username: tCreds.username,
             password: `oauth:${tCreds.token.access_token}`,
         },
-        channels: channels, // Replace with your channel
+        channels: channels,
     });
     
-    await tClient.connect();
-
     return { mClient, dClient, tClient };
 };
 

events/Twitch/Message.js

@@ -3,7 +3,7 @@ module.exports = {
     name: 'Twitch/Message',
     once: false,
     async execute(channel, userstate, message, self, tClient) {
-        const { dClient, mClient } = require('../../index')
+        const { dClient, mClient, makeTwitchRequest } = require('../../index')
         const knownBots = new Set(['streamlabs', 'nightbot', 'moobot', 'soundalerts', 'streamelements', 'remasuri_bot', 'commanderroot', 'x__hel_bot__x'])
         async function updateChatMode(userID, setTo) {
             let state
@@ -14,7 +14,7 @@ async function updateChatMode(userID, setTo) {
             } else {
                 return
             }
-    await Helix.chat.updateSettings(userID, process.env.mod_id, {
+            await Helix.chat.updateSettings(userID, process.env.MOD_ID, {
                 follower_mode: state,
                 follower_mode_duration: 0,
                 subscriber_mode: state,
@@ -23,10 +23,12 @@ async function updateChatMode(userID, setTo) {
 
         }
         async function getIDByName(user) {
+            // Function to convert Names to ID
             const result = await Helix.users.get(user);
             return result.data[0].id
         }
         async function verifyUser(channel, username) {
+            // Function checks if user is a target to shout out, default target: VIPs
             let db = mClient.db("shoutouts")
             let col = db.collection(channel)
 
@@ -39,40 +41,8 @@ async function verifyUser(channel, username) {
                 })
             }
         }
-        if (self) { return }
+        async function sendPositivity() {
-        if (knownBots.has(userstate.username)) { return }
+            // Function sends a random string of predetermined positivity, Donothon Top Donator Reward
-
-        if (message.toLowerCase().includes('caw')) {
-            tClient.say(channel, 'CAW!')
-        } else if (message.toLowerCase().includes('kweh')) {
-            tClient.say(channel, 'KWEH!')
-        } else if (message.toLowerCase().includes('kaw')) {
-            tClient.say(channel, 'KAW!')
-        }
-
-        
-        if (message.startsWith(process.env.prefix)) {
-            const args = message.substring(1).split(" ")
-            const cmd = args[0]
-            switch (cmd) {
-                // case "test":
-                //     tClient.say(channel, "/me This is a test message")
-                //     break;
-                case "mode":
-                    if (userstate.badges.moderator != 1 && userstate.badges.broadcaster != 1) { break } // return stops all further operations, so you should just break out of switch
-                    let regex = /^(on|off)$/
-                    if (!args[1].match(regex)) { break }
-                    updateChatMode(await getIDByName(channel.substring(1)), args[1])
-                    break;
-                // case "donate":
-                //     const links = ["https://bit.ly/heltwittergoals", "https://bit.ly/donatetohel","http://bit.ly/donothon_goals"]
-                //     tClient.say(channel, "Hel is currently celebrating her birthday with a donathon!")
-                //     tClient.say(channel, `You can see goals and incentives here: ${links[0]}`)
-                //     tClient.say(channel, `You can donate here: ${links[1]}`)
-                //     tClient.say(channel, `Terms, conditions, rules and how rewards work are found here: ${links[2]}`)
-                //     tClient.say(channel, `All donations and gifts are greatly appreciated, but please do so responsibly!`)
-                //     break;
-                case "positivity":
             let positive_Messages = ["You are so very worthy of all the love and support that may come your way.",
                 "There are many things which draw us together. In this time and place, that lovely subject is you, Hel.",
                 "The happiness and joy you add to the world is worth more than most anything.",
@@ -88,16 +58,59 @@ async function verifyUser(channel, username) {
                 "Watching you succeed and achieve your heart's desires gives me so much motivation and I am very grateful for it."]
 
             let rdm = Math.floor(Math.random() * positive_Messages.length)
-                    tClient.say(channel, positive_Messages[rdm])
+            return tClient.say(channel, positive_Messages[rdm])
+        }
+        async function sendDonationAd() {
+            const links = ["https://bit.ly/heltwittergoals", "https://bit.ly/donatetohel", "http://bit.ly/donothon_goals"]
+            tClient.say(channel, "Hel is currently celebrating her birthday with a donathon!")
+            tClient.say(channel, `You can see goals and incentives here: ${links[0]}`)
+            tClient.say(channel, `You can donate here: ${links[1]}`)
+            tClient.say(channel, `Terms, conditions, rules and how rewards work are found here: ${links[2]}`)
+            tClient.say(channel, `All donations and gifts are greatly appreciated, but please do so responsibly!`)
+        }
 
+        if (self) { return }
+        if (knownBots.has(userstate.username)) { return }
+
+        if (message.toLowerCase().includes('caw')) {
+            tClient.say(channel, 'CAW!')
+        } else if (message.toLowerCase().includes('kweh')) {
+            tClient.say(channel, 'KWEH!')
+        } else if (message.toLowerCase().includes('kaw')) {
+            tClient.say(channel, 'KAW!')
+        }
+
+
+        if (message.startsWith(process.env.PREFIX)) {
+            const args = message.substring(1).split(" ")
+            const cmd = args[0]
+            switch (cmd) {
+                // case "test":
+                //     tClient.say(channel, "/me This is a test message")
+                //     break;
+                case "mode":
+                    if (userstate.badges.moderator != 1 && userstate.badges.broadcaster != 1) { break } // return stops all further operations, so you should just break out of switch
+                    let regex = /^(on|off)$/
+                    if (!args[1].match(regex)) { break }
+                    updateChatMode(await getIDByName(channel.substring(1)), args[1])
+                    break;
+                case "donate":
+                    sendDonationAd()
+                    break;
+                case "test":
+                    console.log(await makeTwitchRequest('games/top'))
+                    break;
+                case "positivity":
+                    sendPositivity()
                     break;
                 default:
                     break;
             }
         }
+
         // ---------------VIP Handler-------------------
-        if (!userstate.badges?.vip) { return }
+        // if (!userstate.badges?.vip) { return }
-        verifyUser(channel, userstate.username)
+        // verifyUser(channel, userstate.username)
         // ---------------------------------------------
     }
 

index.js

@@ -200,7 +200,7 @@ async function tLogin() {
         return;
     }
 
-    const tClient = new tmi.Client({
+    var tClient = new tmi.Client({
         options: { debug: false },
         connection: {
             reconnect: true,
@@ -233,18 +233,48 @@ async function tLogin() {
         dClient.emit('Twitch/Subscribers', channel, enabled, tClient);
     });
 
-    tClient.on('disconnected', (reason) => {
+    tClient.on('disconnected', async (reason) => {
-        console.log('Twitch client disconnected:', reason);
+        console.log('Twitch disconnected:', reason);
         if (reason.includes('Login authentication failed')) {
-            refreshAccessToken()
+            try {
-                .then(() => tClient.connect())
+                await refreshAccessToken();
-                .catch((error) => {
+                console.log('Reinitializing Twitch client after token refresh...');
-                    console.error('Failed to refresh token and reconnect:', error);
+
+                try {
+                    await tClient.disconnect();
+                } catch (err) {
+                    console.warn('Twitch client already disconnected:', err.message);
+                }
+
+                const db = mClient.db(process.env.MONGO_DB);
+                const credentialCollection = db.collection('credentials');
+                const tCreds = await credentialCollection.findOne({ service: 'twitch' });
+
+                // Recreate the client
+                tClient = new tmi.Client({
+                    options: { debug: false },
+                    connection: { reconnect: true, secure: true },
+                    identity: {
+                        username: tCreds.username,
+                        password: `oauth:${tCreds.token.access_token}`,
+                    },
+                    channels: channels,
                 });
+
+                await tClient.connect();
+                console.log('Twitch client reconnected successfully.');
+            } catch (error) {
+                console.error('Failed to refresh token and reconnect:', error);
+            }
         }
     });
 }
 
 tLogin();
 
-module.exports = { mClient, dClient };
+process.on('unhandledRejection', (reason, promise) => {
+    console.error('Unhandled Rejection at:', promise, 'reason:', reason);
+    // Prevent app from crashing
+});
+
+module.exports = { mClient, dClient, makeTwitchRequest };