paystack-callback

Sleeping

App Files Files Community

Pepguy commited on Jun 25, 2025

Commit

d3bdf51

verified ·

1 Parent(s): a001cf8

Update app.js

Browse files

Files changed (1) hide show

app.js +65 -74

app.js CHANGED Viewed

@@ -1,16 +1,17 @@
-// server.js
-const express = require('express');
-const http = require('http');
-const WebSocket = require('ws');
-const app    = express();
-const server = http.createServer(app);
-const wss    = new WebSocket.Server({ server });
-const rooms = new Map();
-app.get('/', (req, res) => {
-  res.send(`<!doctype html>
 <html>
 <head>
   <title>Dubem Realtime Rooms</title>
@@ -22,7 +23,6 @@ app.get('/', (req, res) => {
   </style>
 </head>
 <body>
-<p>Trying</p>
   <h2>Join a Room & Send Messages</h2>
   <input id="room" placeholder="Room ID" />
   <button onclick="joinRoom()">Join Room</button>
@@ -38,27 +38,18 @@ app.get('/', (req, res) => {
       const scheme = location.protocol === 'https:' ? 'wss' : 'ws';
       ws = new WebSocket(\`\${scheme}://\${location.host}\`);
-      ws.onopen = () => {
-        log('🔌 Connected to server');
-      };
-      ws.onmessage = ({ data }) => {
         const msg = JSON.parse(data);
         log(\`[\${msg.roomId}] \${msg.message}\`);
       };
-      ws.onclose = () => {
-        log('❌ Disconnected from server');
-      };
-      ws.onerror = err => {
-        log('⚠️ WebSocket error: ' + err.message);
-      };
     });
     function joinRoom() {
       const roomId = document.getElementById('room').value.trim();
       if (!roomId) return alert('Please enter a room ID');
-      if (!ws || ws.readyState !== WebSocket.OPEN) {
-        return alert('Socket not open yet!');
-      }
       ws.send(JSON.stringify({ action: 'join', roomId }));
       currentRoom = roomId;
       log('➡️ Joined room: ' + roomId);
@@ -67,17 +58,8 @@ app.get('/', (req, res) => {
     function sendMsg() {
       const txt = document.getElementById('msg').value.trim();
       if (!txt) return;
-      if (!ws || ws.readyState !== WebSocket.OPEN) {
-        return alert('Socket not open yet!');
-      }
-      if (!currentRoom) {
-        return alert('Please join a room first');
-      }
-      ws.send(JSON.stringify({
-        action: 'post',
-        roomId: currentRoom,
-        message: txt
-      }));
       document.getElementById('msg').value = '';
     }
@@ -88,51 +70,60 @@ app.get('/', (req, res) => {
     }
   </script>
 </body>
-</html>`);
-});
-wss.on('connection', ws => {
-  // When a client sends a 'join', we remove it from ALL rooms first
-  ws.on('message', raw => {
-    let msg;
-    try { msg = JSON.parse(raw); } catch { return; }
-    if (msg.action === 'join' && msg.roomId) {
-      // leave all existing rooms
-      for (const clients of rooms.values()) {
-        clients.delete(ws);
       }
-      // join the new room
-      const room = msg.roomId;
-      if (!rooms.has(room)) rooms.set(room, new Set());
-      rooms.get(room).add(ws);
-      return;
-    }
-    if (msg.action === 'post' && msg.roomId && msg.message) {
-      const clients = rooms.get(msg.roomId);
-      if (!clients) return;
-      const payload = JSON.stringify({
-        roomId: msg.roomId,
-        message: msg.message,
-        timestamp: Date.now()
-      });
-      for (const client of clients) {
-        if (client.readyState === WebSocket.OPEN) {
-          client.send(payload);
         }
       }
-    }
-  });
-  ws.on('close', () => {
-    // remove from all rooms on disconnect
-    for (const clients of rooms.values()) {
-      clients.delete(ws);
-    }
-  });
 });
-const PORT = process.env.PORT ||
-  7860;
-server.listen(PORT, () => console.log(`✅ Activity server running at http://localhost:${PORT}`));

+// server.js (for Bun)
+import { serve } from "bun";
+const rooms = new Map(); // roomId → Set<WebSocket>
+serve({
+  port: Number(process.env.PORT) || 7860,
+  // Serve the HTML page at “/”
+  async fetch(req) {
+    const url = new URL(req.url);
+    if (url.pathname !== "/") return new Response("Not Found", { status: 404 });
+    return new Response(`<!doctype html>
 <html>
 <head>
   <title>Dubem Realtime Rooms</title>
   </style>
 </head>
 <body>
   <h2>Join a Room & Send Messages</h2>
   <input id="room" placeholder="Room ID" />
   <button onclick="joinRoom()">Join Room</button>
       const scheme = location.protocol === 'https:' ? 'wss' : 'ws';
       ws = new WebSocket(\`\${scheme}://\${location.host}\`);
+      ws.onopen = () => log('🔌 Connected to server');
+      ws.onmessage = ({data}) => {
         const msg = JSON.parse(data);
         log(\`[\${msg.roomId}] \${msg.message}\`);
       };
+      ws.onclose  = () => log('❌ Disconnected');
+      ws.onerror  = err => log('⚠️ WebSocket error: ' + err.message);
     });
     function joinRoom() {
       const roomId = document.getElementById('room').value.trim();
       if (!roomId) return alert('Please enter a room ID');
       ws.send(JSON.stringify({ action: 'join', roomId }));
       currentRoom = roomId;
       log('➡️ Joined room: ' + roomId);
     function sendMsg() {
       const txt = document.getElementById('msg').value.trim();
       if (!txt) return;
+      if (!currentRoom) return alert('Join a room first');
+      ws.send(JSON.stringify({ action: 'post', roomId: currentRoom, message: txt }));
       document.getElementById('msg').value = '';
     }
     }
   </script>
 </body>
+</html>`, {
+      headers: { "Content-Type": "text/html; charset=utf-8" },
+    });
+  },
+  // Hook into Bun's WebSocket handling
+  websocket: {
+    open(ws) {
+      // no-op here; clients join via “join” action
+    },
+    message(ws, raw) {
+      let msg;
+      try {
+        msg = JSON.parse(raw.toString());
+      } catch {
+        return;
       }
+      if (msg.action === "join" && msg.roomId) {
+        // remove from all rooms
+        for (const clients of rooms.values()) {
+          clients.delete(ws);
         }
+        // add to new room
+        const roomSet = rooms.get(msg.roomId) || new Set();
+        roomSet.add(ws);
+        rooms.set(msg.roomId, roomSet);
+        return;
       }
+      if (msg.action === "post" && msg.roomId && msg.message) {
+        const clients = rooms.get(msg.roomId);
+        if (!clients) return;
+        const payload = JSON.stringify({
+          roomId: msg.roomId,
+          message: msg.message,
+          timestamp: Date.now(),
+        });
+        for (const client of clients) {
+          if (client.readyState === 1) { // OPEN
+            client.send(payload);
+          }
+        }
+      }
+    },
+    close(ws) {
+      // on disconnect, remove from all rooms
+      for (const clients of rooms.values()) {
+        clients.delete(ws);
+      }
+    },
+  },
 });
+console.log("✅ Bun realtime server running on port " + (process.env.PORT || 7860));