Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- const express = require("express");
- const cors = require("cors");
- const { intrument, instrument } = require("@socket.io/admin-ui");
- const app = express();
- const io = require("socket.io")(8080, {
- cors: {
- origin: ["http://localhost:3000", "https://admin.socket.io/"],
- methods: ["GET", "POST"],
- allowHeaders: ["my-custom-header"],
- addTrailingSlash: false,
- },
- });
- const PORT = 5000;
- app.use(cors());
- io.on("connection", (socket) => {
- socket.on("send-message", (msg, room) => {
- socket.broadcast.emit("r-m", msg);
- });
- socket.on("join-room", (roomID, callback) => {
- try {
- socket.join(roomID);
- console.log(`Socket ${socket.id} joined room ${roomID}`);
- callback({ success: true });
- } catch (error) {
- console.error("Not working");
- callback({ success: false });
- }
- });
- socket.on("update-url", (roomID, url) => {
- console.log(`RoomID: ${roomID}.\nurl: ${url}`);
- socket.to(roomID).emit("update-url", roomID, url);
- });
- socket.on("play-video", (roomID) => {
- socket.to(roomID).emit("play-video");
- });
- socket.on("pause-video", (roomID) => {
- socket.to(roomID).emit("pause-video");
- });
- socket.on("update-progress", (roomID, progress) => {
- socket.to(roomID).emit("update-progress");
- });
- // socket.on("create-room", (roomID, callback) => {
- // if (io.sockets.adapter.rooms.has(roomID)) {
- // console.log("Room already exists!");
- // callback({ success: false });
- // } else {
- // console.log(`Created a room with ID: ${roomID}`, socket.id);
- // socket.join(roomID);
- // callback({ success: true });
- // }
- // });
- });
- instrument(io, { auth: false });
- app.listen(PORT, () => {
- console.log(`Server started on port ${PORT}`);
- });
Advertisement
Add Comment
Please, Sign In to add comment