edit

src/config.js

@@ -3,8 +3,12 @@ require("dotenv").config();
 module.exports = {
   clientId: process.env.CLIENT_ID,
   clientSecret: process.env.CLIENT_SECRET,
+
   broadcasterId: process.env.BROADCASTER_ID,
 
+  // THIS becomes your USER token after login
+  token: null,
+
   rewards: {
     HYDRATE: process.env.REWARD_HYDRATE_ID,
     SOUND: process.env.REWARD_SOUND_ID,

src/index.js

@@ -3,14 +3,16 @@ const { connect } = require("./twitch/websocket");
 
 const auth = startAuthServer();
 
-// wait until token exists before starting twitch
-const waitForToken = setInterval(() => {
+// wait for login before starting Twitch connection
+const wait = setInterval(() => {
   const token = auth.getToken();
 
   if (token) {
-    clearInterval(waitForToken);
+    clearInterval(wait);
 
-    process.env.APP_ACCESS_TOKEN = token;
+    // inject token into runtime config
+    const config = require("./config");
+    config.token = token;
 
     console.log("🚀 Starting Twitch connection...");
     connect();

src/rewards/Hydrate.js

@@ -0,0 +1,6 @@
+module.exports = {
+  name: "Hydrate",
+  run: (event) => {
+    console.log("💧 Hydration triggered for", event.user_name);
+  }
+};

src/rewards/hydrate.js

@@ -1,3 +0,0 @@
-module.exports = (event) => {
-  console.log("💧 Hydrate triggered by", event.user_name);
-};

src/rewards/index.js

@@ -0,0 +1,29 @@
+const fs = require("fs");
+const path = require("path");
+
+const rewards = new Map();
+
+function loadRewards() {
+  const files = fs.readdirSync(__dirname);
+
+  for (const file of files) {
+    if (file === "index.js") continue;
+    if (!file.endsWith(".js")) continue;
+
+    const reward = require(path.join(__dirname, file));
+
+    if (!reward.name || !reward.run) {
+      console.warn(`⚠️ Invalid reward file: ${file}`);
+      continue;
+    }
+
+    rewards.set(reward.name.toLowerCase(), reward.run);
+    console.log(`📦 Loaded reward: ${reward.name}`);
+  }
+}
+
+function getReward(name) {
+  return rewards.get(name.toLowerCase());
+}
+
+module.exports = { loadRewards, getReward };

src/rewards/sound.js

@@ -1,5 +1,6 @@
-module.exports = (event) => {
-  console.log("🔊 Sound triggered by", event.user_name);
-
-  // later: play sound, trigger OBS, etc.
+module.exports = {
+  name: "Sound",
+  run: (event) => {
+    console.log("🔊 Sound triggered for", event.user_name);
+  }
 };

src/twitch/auth.js

@@ -1,35 +0,0 @@
-const axios = require("axios");
-const config = require("../config");
-
-let tokenCache = null;
-let expiresAt = 0;
-
-async function getAppToken() {
-  const now = Date.now();
-
-  // reuse token if still valid
-  if (tokenCache && now < expiresAt) {
-    return tokenCache;
-  }
-
-  const res = await axios.post(
-    "https://id.twitch.tv/oauth2/token",
-    null,
-    {
-      params: {
-        client_id: config.clientId,
-        client_secret: config.clientSecret,
-        grant_type: "client_credentials",
-      },
-    }
-  );
-
-  tokenCache = res.data.access_token;
-  expiresAt = now + res.data.expires_in * 1000 - 60000; // refresh 1 min early
-
-  console.log("🔐 New Twitch App Token generated");
-
-  return tokenCache;
-}
-
-module.exports = { getAppToken };

src/twitch/authServer.js

@@ -1,22 +1,29 @@
 const http = require("http");
 const axios = require("axios");
 const config = require("../config");
+const { setTokens, startAutoRefresh } = require("./token");
 
-let accessToken = null;
+let authServerStarted = false;
 
 function startAuthServer() {
+  if (authServerStarted) return;
+  authServerStarted = true;
+
   const server = http.createServer(async (req, res) => {
     const url = new URL(req.url, "http://localhost:3000");
 
+    // OAuth callback endpoint
     if (url.pathname === "/callback") {
       const code = url.searchParams.get("code");
 
       if (!code) {
-        res.end("Missing code");
+        res.writeHead(400);
+        res.end("Missing OAuth code");
         return;
       }
 
       try {
+        // Exchange code for tokens
         const tokenRes = await axios.post(
           "https://id.twitch.tv/oauth2/token",
           null,
@@ -31,35 +38,42 @@ function startAuthServer() {
           }
         );
 
-        accessToken = tokenRes.data.access_token;
+        const accessToken = tokenRes.data.access_token;
+        const refreshToken = tokenRes.data.refresh_token;
+        const expiresIn = tokenRes.data.expires_in;
 
-        console.log("🔐 Twitch user token acquired!");
+        // Store tokens globally in auth system
+        setTokens(accessToken, refreshToken);
 
-        res.end("Auth successful! You can close this tab.");
+        // Start auto-refresh loop
+        startAutoRefresh();
+
+        console.log("🔐 Twitch authentication successful");
+        console.log(`⏱ Token expires in: ${expiresIn}s`);
+
+        res.writeHead(200, { "Content-Type": "text/plain" });
+        res.end("Authentication successful. You can close this window.");
 
       } catch (err) {
-        console.error(err.response?.data || err.message);
-        res.end("Auth failed");
+        console.error("OAuth token exchange failed:", err.response?.data || err.message);
+
+        res.writeHead(500);
+        res.end("Authentication failed. Check terminal logs.");
       }
     }
   });
 
   server.listen(3000, () => {
-    console.log("\n👉 Open this URL to login:\n");
-
-    const url =
-      `https://id.twitch.tv/oauth2/authorize` +
+    const authUrl =
+      "https://id.twitch.tv/oauth2/authorize" +
       `?client_id=${config.clientId}` +
       `&redirect_uri=http://localhost:3000/callback` +
       `&response_type=code` +
       `&scope=channel:read:redemptions`;
 
-    console.log(url + "\n");
+    console.log("\n👉 Twitch Login URL:");
+    console.log(authUrl + "\n");
   });
-
-  return {
-    getToken: () => accessToken,
-  };
 }
 
 module.exports = { startAuthServer };

src/twitch/handler.js

@@ -1,9 +1,6 @@
-const config = require("../config");
+const { loadRewards, getReward } = require("../rewards");
 
-const hydrate = require("../rewards/hydrate");
-const sound = require("../rewards/sound");
-
-const seen = new Set();
+loadRewards();
 
 function handleEvent(payload) {
   const { subscription, event } = payload;
@@ -15,24 +12,18 @@ function handleEvent(payload) {
     return;
   }
 
-  if (seen.has(event.id)) return;
-  seen.add(event.id);
-  setTimeout(() => seen.delete(event.id), 60000);
+  const rewardName = event.reward.title;
 
-  console.log(`🎁 ${event.user_name} → ${event.reward.title}`);
+  console.log(`🎁 ${event.user_name} → ${rewardName}`);
 
-  switch (event.reward.id) {
-    case config.rewards.HYDRATE:
-      hydrate(event);
-      break;
+  const reward = getReward(rewardName);
 
-    case config.rewards.SOUND:
-      sound(event);
-      break;
-
-    default:
-      console.log("Unknown reward:", event.reward.id);
+  if (!reward) {
+    console.log("Unknown reward:", rewardName);
+    return;
   }
+
+  reward(event);
 }
 
 module.exports = { handleEvent };

src/twitch/subscriptions.js

@@ -1,12 +1,12 @@
 const axios = require("axios");
 const config = require("../config");
-const { getAppToken } = require("./auth");
+const { getAccessToken } = require("./token");
 
 async function createSubscription(sessionId) {
   try {
-    const token = await getAppToken();
+    const token = getAccessToken();
 
-    await axios.post(
+    const res = await axios.post(
       "https://api.twitch.tv/helix/eventsub/subscriptions",
       {
         type: "channel.channel_points_custom_reward_redemption.add",
@@ -30,10 +30,7 @@ async function createSubscription(sessionId) {
 
     console.log("📡 Subscription created");
   } catch (err) {
-    console.error(
-      "❌ Subscription error:",
-      err.response?.data || err.message
-    );
+    console.error("❌ Subscription error:", err.response?.data || err.message);
   }
 }
 

src/twitch/token.js

@@ -0,0 +1,52 @@
+const axios = require("axios");
+const config = require("../config");
+
+let accessToken = null;
+let refreshToken = null;
+
+function setTokens(initialAccess, initialRefresh) {
+  accessToken = initialAccess;
+  refreshToken = initialRefresh;
+}
+
+function getAccessToken() {
+  return accessToken;
+}
+
+async function refreshAccessToken() {
+  if (!refreshToken) return;
+
+  const res = await axios.post(
+    "https://id.twitch.tv/oauth2/token",
+    null,
+    {
+      params: {
+        grant_type: "refresh_token",
+        refresh_token: refreshToken,
+        client_id: config.clientId,
+        client_secret: config.clientSecret,
+      },
+    }
+  );
+
+  accessToken = res.data.access_token;
+  refreshToken = res.data.refresh_token;
+
+  console.log("🔄 Twitch token refreshed");
+
+  return accessToken;
+}
+
+function startAutoRefresh() {
+  // refresh every 3 hours (safe before expiry)
+  setInterval(() => {
+    refreshAccessToken().catch(console.error);
+  }, 3 * 60 * 60 * 1000);
+}
+
+module.exports = {
+  setTokens,
+  getAccessToken,
+  refreshAccessToken,
+  startAutoRefresh,
+};

src/twitch/websocket.js

@@ -25,6 +25,7 @@ function connect(url = reconnectUrl) {
           payload.session.reconnect_url ||
           "wss://eventsub.wss.twitch.tv/ws";
 
+        // IMPORTANT: must be immediate
         await createSubscription(sessionId);
         break;
       }