fix: warm up AudioContext for raise hand chime, auto-end broadcast on disconnect, and guard server boot with INSTBYTE_BOOT flag

Author: mohitgauniyal

bin/instbyte.js

@@ -25,4 +25,5 @@ process.env.INSTBYTE_UPLOADS = uploadsDir;
 // ========================
 // BOOT
 // ========================
+process.env.INSTBYTE_BOOT = '1';
 require("../server/server.js");

client/js/app.js

@@ -15,6 +15,7 @@ let broadcastInterval = null;
 let lastFrameData = null;
 let broadcastChannel = 'general';
 let viewerCount = 0;
+let audioCtx = null;
 
 const seenObserver = new IntersectionObserver((entries) => {
     entries.forEach(entry => {
@@ -171,7 +172,7 @@ function escapeHtml(str) {
 
 function playChime() {
     try {
-        const ctx = new (window.AudioContext || window.webkitAudioContext)();
+        const ctx = audioCtx || new (window.AudioContext || window.webkitAudioContext)();
 
         const gain = ctx.createGain();
         gain.connect(ctx.destination);
@@ -1729,7 +1730,7 @@ async function startBroadcast() {
     const startRes = await fetch('/broadcast/start', {
         method: 'POST',
         headers: { 'Content-Type': 'application/json' },
-        body: JSON.stringify({ uploader, channel: broadcastChannel })
+        body: JSON.stringify({ uploader, channel: broadcastChannel, socketId: socket.id })
     });
 
     if (!startRes.ok) {
@@ -1742,6 +1743,12 @@ async function startBroadcast() {
     broadcastStream = stream;
     isBroadcasting = true;
 
+    // Warm up AudioContext while we have a user gesture
+    try {
+        audioCtx = new (window.AudioContext || window.webkitAudioContext)();
+        await audioCtx.resume();
+    } catch (e) { }
+
     // Set up canvas for frame capture
     broadcastCanvas = document.createElement('canvas');
     broadcastCtx = broadcastCanvas.getContext('2d');
@@ -1963,11 +1970,13 @@ socket.on('broadcast-reaction-received', ({ from }) => {
     // Only show to broadcaster
     if (!isBroadcasting) return;
 
+    playChime();
+
     const toast = document.createElement('div');
     toast.className = 'raise-hand-toast';
     toast.textContent = `✋ ${from} raised their hand`;
     document.body.appendChild(toast);
-    setTimeout(() => toast.remove(), 3000);
+    setTimeout(() => toast.remove(), 8000);
 });
 
 (async function init() {

server/server.js

@@ -833,14 +833,15 @@ app.get("/broadcast/status", (req, res) => {
 
 /* POST /broadcast/start */
 app.post("/broadcast/start", broadcastLimiter, (req, res) => {
+
   if (currentBroadcast) {
     return res.status(409).json({
       error: "Broadcast already in progress",
       uploader: currentBroadcast.uploader
     });
   }
 
-  const { uploader, channel } = req.body;
+  const { uploader, channel, socketId } = req.body;
   if (!uploader || !channel) {
     return res.status(400).json({ error: "uploader and channel required" });
   }
@@ -849,7 +850,8 @@ app.post("/broadcast/start", broadcastLimiter, (req, res) => {
     uploader,
     channel,
     startedAt: Date.now(),
-    lastFrame: null
+    lastFrame: null,
+    socketId
   };
 
   io.emit("broadcast-started", {
@@ -978,6 +980,12 @@ io.on("connection", (socket) => {
     connectedUsers--;
     console.log(username + " disconnected | total:", connectedUsers);
     io.emit("user-count", connectedUsers);
+
+    if (currentBroadcast && currentBroadcast.socketId === socket.id) {
+      currentBroadcast = null;
+      io.emit("broadcast-ended");
+      console.log("Broadcast ended — broadcaster disconnected");
+    }
   });
 });
 
@@ -1026,19 +1034,21 @@ const PREFERRED = parseInt(process.env.PORT) || config.server.port;
 const localIP = getLocalIP();
 
 let PORT;
-findFreePort(PREFERRED).then(p => {
-  PORT = p;
-  server.listen(PORT, () => {
-    console.log("\nInstbyte running");
-    console.log("Local:   http://localhost:" + PORT);
-    console.log("Network: http://" + localIP + ":" + PORT);
-    if (PORT !== PREFERRED) {
-      console.log(`(port ${PREFERRED} was busy, switched to ${PORT})`);
-    }
-    console.log("");
-    scanOrphans();
+if (process.env.INSTBYTE_BOOT === '1') {
+  findFreePort(PREFERRED).then(p => {
+    PORT = p;
+    server.listen(PORT, () => {
+      console.log("\nInstbyte running");
+      console.log("Local:   http://localhost:" + PORT);
+      console.log("Network: http://" + localIP + ":" + PORT);
+      if (PORT !== PREFERRED) {
+        console.log(`(port ${PREFERRED} was busy, switched to ${PORT})`);
+      }
+      console.log("");
+      scanOrphans();
+    });
   });
-});
+}
 
 module.exports = { app, server, sessions };