ReaperOfVeriod/eventsub2
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

edit

Browse Source
This commit is contained in:
Reaper
2026-04-23 04:49:00 +02:00
parent b1b3152d9b
commit 12baf6a12b
13 changed files with 159 additions and 118 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
.gitignore vendored
View File

@@ -141,3 +141,6 @@ dist
vite.config.js.timestamp-*
vite.config.ts.timestamp-*
.vite/
token.json

9
src/config.js
View File

@@ -3,14 +3,5 @@ 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,
},
};

19
src/index.js
View File

@@ -1,20 +1,21 @@
const { startAuthServer } = require("./twitch/authServer");
const { connect } = require("./twitch/websocket");
const { initFromDisk } = require("./twitch/token");
const restored = initFromDisk();
if (restored) {
console.log("🚀 Using saved token, skipping login...");
connect();
} else {
const auth = startAuthServer();
// wait for login before starting Twitch connection
const wait = setInterval(() => {
const token = auth.getToken();
if (token) {
if (!token) return;
clearInterval(wait);
// inject token into runtime config
const config = require("./config");
config.token = token;
console.log("🚀 Starting Twitch connection...");
connect();
}
}, 1000);
}

4
src/rewards/Hydrate.js
View File

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

15
src/rewards/index.js
View File

@@ -1,29 +1,26 @@
const fs = require("fs");
const path = require("path");
const rewards = new Map();
const rewardMap = 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;
}
rewardMap.set(reward.name.toLowerCase(), reward.run);
rewards.set(reward.name.toLowerCase(), reward.run);
console.log(`📦 Loaded reward: ${reward.name}`);
}
}
function getReward(name) {
return rewards.get(name.toLowerCase());
return rewardMap.get(name.toLowerCase());
}
module.exports = { loadRewards, getReward };
loadRewards();
module.exports = { getReward };

4
src/rewards/sound.js
View File

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

45
src/twitch/authServer.js
View File

@@ -1,8 +1,11 @@
const http = require("http");
const axios = require("axios");
const config = require("../config");
const { setTokens, startAutoRefresh } = require("./token");
const { setTokens, startAutoRefresh } = require("./token");
const { saveTokenData } = require("./tokenStore");
let accessToken = null;
let authServerStarted = false;
function startAuthServer() {
@@ -12,8 +15,8 @@ function startAuthServer() {
const server = http.createServer(async (req, res) => {
const url = new URL(req.url, "http://localhost:3000");
// OAuth callback endpoint
if (url.pathname === "/callback") {
if (url.pathname !== "/callback") return;
const code = url.searchParams.get("code");
if (!code) {
@@ -38,29 +41,37 @@ function startAuthServer() {
}
);
const accessToken = tokenRes.data.access_token;
const refreshToken = tokenRes.data.refresh_token;
const expiresIn = tokenRes.data.expires_in;
const access = tokenRes.data.access_token;
const refresh = tokenRes.data.refresh_token;
// Store tokens globally in auth system
setTokens(accessToken, refreshToken);
// Start auto-refresh loop
// Update runtime token system
setTokens(access, refresh);
startAutoRefresh();
// Persist to disk
saveTokenData({
accessToken: access,
refreshToken: refresh,
savedAt: Date.now(),
});
accessToken = access;
console.log("🔐 Twitch authentication successful");
console.log(`⏱ Token expires in: ${expiresIn}s`);
console.log("💾 Tokens saved to disk");
res.writeHead(200, { "Content-Type": "text/plain" });
res.end("Authentication successful. You can close this window.");
res.end("Authentication successful. You can close this tab.");
} catch (err) {
console.error("OAuth token exchange failed:", err.response?.data || err.message);
console.error(
"OAuth token exchange failed:",
err.response?.data || err.message
);
res.writeHead(500);
res.end("Authentication failed. Check terminal logs.");
}
}
});
server.listen(3000, () => {
@@ -71,9 +82,13 @@ function startAuthServer() {
`&response_type=code` +
`&scope=channel:read:redemptions`;
console.log("\n👉 Twitch Login URL:");
console.log("\n👉 Twitch Login URL:\n");
console.log(authUrl + "\n");
});
return {
getToken: () => accessToken,
};
}
module.exports = { startAuthServer };

19
src/twitch/handler.js
View File

@@ -1,29 +1,20 @@
const { loadRewards, getReward } = require("../rewards");
loadRewards();
const rewards = require("../rewards");
function handleEvent(payload) {
const { subscription, event } = payload;
if (
subscription.type !==
"channel.channel_points_custom_reward_redemption.add"
) {
return;
}
const event = payload.event;
const rewardName = event.reward.title;
console.log(`🎁 ${event.user_name} → ${rewardName}`);
const reward = getReward(rewardName);
const handler = rewards.getReward(rewardName);
if (!reward) {
if (!handler) {
console.log("Unknown reward:", rewardName);
return;
}
reward(event);
handler(event);
}
module.exports = { handleEvent };

11
src/twitch/subscriptionState.js Normal file
View File

@@ -0,0 +1,11 @@
const sessions = new Set();
function hasSession(id) {
return sessions.has(id);
}
function markSession(id) {
sessions.add(id);
}
module.exports = { hasSession, markSession };

7
src/twitch/subscriptions.js
View File

@@ -6,7 +6,7 @@ async function createSubscription(sessionId) {
try {
const token = getAccessToken();
const res = await axios.post(
await axios.post(
"https://api.twitch.tv/helix/eventsub/subscriptions",
{
type: "channel.channel_points_custom_reward_redemption.add",
@@ -23,14 +23,13 @@ async function createSubscription(sessionId) {
headers: {
"Client-ID": config.clientId,
Authorization: `Bearer ${token}`,
"Content-Type": "application/json",
},
}
);
console.log("📡 Subscription created");
} catch (err) {
console.error("❌ Subscription error:", err.response?.data || err.message);
} catch (e) {
console.error("❌ Subscription error:", e.response?.data || e.message);
}
}

36
src/twitch/token.js
View File

@@ -1,15 +1,35 @@
const axios = require("axios");
const config = require("../config");
const { saveTokenData, loadTokenData } = require("./tokenStore");
let accessToken = null;
let refreshToken = null;
function setTokens(initialAccess, initialRefresh) {
accessToken = initialAccess;
refreshToken = initialRefresh;
function initFromDisk() {
const data = loadTokenData();
if (!data) return false;
accessToken = data.accessToken;
refreshToken = data.refreshToken;
console.log("💾 Loaded token from disk");
return true;
}
function setTokens(at, rt) {
accessToken = at;
refreshToken = rt;
saveTokenData({
accessToken,
refreshToken,
savedAt: Date.now(),
});
}
function getAccessToken() {
if (!accessToken) throw new Error("Token not ready");
return accessToken;
}
@@ -29,16 +49,12 @@ async function refreshAccessToken() {
}
);
accessToken = res.data.access_token;
refreshToken = res.data.refresh_token;
setTokens(res.data.access_token, res.data.refresh_token);
console.log("🔄 Twitch token refreshed");
return accessToken;
console.log("🔄 Token refreshed + saved");
}
function startAutoRefresh() {
// refresh every 3 hours (safe before expiry)
setInterval(() => {
refreshAccessToken().catch(console.error);
}, 3 * 60 * 60 * 1000);
@@ -47,6 +63,6 @@ function startAutoRefresh() {
module.exports = {
setTokens,
getAccessToken,
refreshAccessToken,
startAutoRefresh,
initFromDisk,
};

23
src/twitch/tokenStore.js Normal file
View File

@@ -0,0 +1,23 @@
const fs = require("fs");
const path = require("path");
const FILE = path.join(__dirname, "../../token.json");
function saveTokenData(data) {
fs.writeFileSync(FILE, JSON.stringify(data, null, 2));
}
function loadTokenData() {
if (!fs.existsSync(FILE)) return null;
try {
return JSON.parse(fs.readFileSync(FILE, "utf-8"));
} catch (e) {
return null;
}
}
module.exports = {
saveTokenData,
loadTokenData,
};

22
src/twitch/websocket.js
View File

@@ -1,6 +1,7 @@
const WebSocket = require("ws");
const { createSubscription } = require("./subscriptions");
const { handleEvent } = require("./handler");
const { createSubscription } = require("./subscriptions");
const { markSession, hasSession } = require("./subscriptionState");
let reconnectUrl = "wss://eventsub.wss.twitch.tv/ws";
@@ -19,13 +20,14 @@ function connect(url = reconnectUrl) {
case "session_welcome": {
const sessionId = payload.session.id;
console.log("🟢 Session:", sessionId);
if (hasSession(sessionId)) return;
markSession(sessionId);
reconnectUrl =
payload.session.reconnect_url ||
"wss://eventsub.wss.twitch.tv/ws";
payload.session.reconnect_url || reconnectUrl;
console.log("🟢 Session:", sessionId);
// IMPORTANT: must be immediate
await createSubscription(sessionId);
break;
}
@@ -35,12 +37,8 @@ function connect(url = reconnectUrl) {
break;
case "session_reconnect":
console.log("♻️ Reconnecting...");
ws.close();
connect(payload?.session?.reconnect_url || reconnectUrl);
break;
case "session_keepalive":
connect(payload.session.reconnect_url);
break;
}
});
@@ -49,10 +47,6 @@ function connect(url = reconnectUrl) {
console.log("❌ Disconnected. Reconnecting...");
setTimeout(() => connect(), 3000);
});
ws.on("error", (err) => {
console.error("WebSocket error:", err.message);
});
}
module.exports = { connect };