.env.development

@@ -1,2 +0,0 @@
-PORT=
-CORS_ORIGIN=

.eslintrc.json

@@ -1,3 +0,0 @@
-{
-  "extends": "@excalidraw/eslint-config"
-}

.github/dependabot.yml

@@ -1,8 +0,0 @@
-version: 2
-updates:
-  - package-ecosystem: npm
-    directory: /
-    schedule:
-      interval: weekly
-      day: sunday
-      time: "01:00"

.github/workflows/lint.yml

@@ -2,17 +2,23 @@ name: Lint
 
 on:
   push:
+    branches:
+      - master
+  pull_request:
 
 jobs:
   lint:
     runs-on: ubuntu-latest
+
     steps:
       - uses: actions/checkout@v1
-      - name: Setup Node.js 14.x
+
+      - name: Setup Node.js 12.x
         uses: actions/setup-node@v1
         with:
-          node-version: 14.x
+          node-version: 12.x
-      - name: Install dependencies
+
-        run: yarn --frozen-lockfile
+      - name: Install and lint
-      - name: Lint
+        run: |
-        run: yarn test:other
+          yarn
+          yarn lint

.github/workflows/publish-docker.yml

@@ -8,6 +8,7 @@ on:
 jobs:
   publish-docker:
     runs-on: ubuntu-latest
+
     steps:
       - uses: actions/checkout@v2
       - uses: docker/build-push-action@v1

.github/workflows/test.yml

@@ -1,20 +0,0 @@
-name: Test & Build
-
-on:
-  push:
-
-jobs:
-  test:
-    runs-on: ubuntu-latest
-    steps:
-      - uses: actions/checkout@v1
-      - name: Setup Node.js 14.x
-        uses: actions/setup-node@v1
-        with:
-          node-version: 14.x
-      - name: Install dependencies
-        run: yarn --frozen-lockfile
-      - name: Test and Build
-        run: |
-          yarn test:code
-          yarn build

.gitignore

@@ -71,7 +71,6 @@ typings/
 # dotenv environment variables file
 .env
 .env.test
-.env.production
 
 # parcel-bundler cache (https://parceljs.org/)
 .cache

.prettierrc

@@ -0,0 +1 @@
+{}

README.md

@@ -1,27 +1,3 @@
-# Example of excalidraw collaboration server
+# collab-server
 
-Collaboration server for Excalidraw
+Excalidraw collaboration server
-
-If you need to use cluster mode with pm2. Checkout: https://socket.io/docs/v4/pm2/
-
-If you are not familiar with pm2: https://pm2.keymetrics.io/docs/usage/quick-start/
-
-# Development
-
-- install
-
-  ```sh
-  yarn
-  ```
-
-- run development server
-
-  ```sh
-  yarn start:dev
-  ```
-
-# Start with pm2
-
-```
-pm2 start pm2.production.json
-```

package.json

@@ -1,39 +1,72 @@
 {
-  "dependencies": {
+  "name": "excalidraw-room",
-    "@excalidraw/eslint-config": "1.0.1",
+  "version": "1.0.0",
-    "@excalidraw/prettier-config": "1.0.2",
+  "description": "Excalidraw collaboration server",
-    "@types/debug": "4.1.5",
+  "main": "index.js",
-    "@types/express": "4.17.11",
-    "@types/node": "14.14.31",
-    "@typescript-eslint/eslint-plugin": "4.16.1",
-    "@typescript-eslint/parser": "4.16.1",
-    "cross-env": "^7.0.3",
-    "debug": "4.3.1",
-    "dotenv": "^10.0.0",
-    "eslint": "7.21.0",
-    "eslint-config-prettier": "8.1.0",
-    "eslint-plugin-prettier": "3.3.1",
-    "express": "4.17.1",
-    "prettier": "2.2.1",
-    "socket.io": "^4.6.1",
-    "ts-node-dev": "^1.1.8",
-    "typescript": "4.2.3"
-  },
-  "license": "MIT",
-  "main": "dist/index.js",
-  "name": "excalidraw-portal",
-  "prettier": "@excalidraw/prettier-config",
   "scripts": {
     "build": "tsc",
-    "fix:code": "yarn test:code --fix",
+    "fix": "yarn prettier --write",
-    "fix:other": "yarn prettier --write",
+    "lint": "yarn prettier --list-different",
-    "fix": "yarn fix:other && yarn fix:code",
+    "prettier": "prettier \"**/*.{ts,md,json,yaml,yml}\"",
-    "prettier": "prettier . --ignore-path=.gitignore",
     "start": "node dist/index.js",
-    "start:dev": "cross-env NODE_ENV=development ts-node-dev --respawn --transpile-only src/index.ts",
+    "test": "yarn lint"
-    "test:code": "eslint --ext .ts .",
-    "test:other": "yarn prettier --list-different",
-    "test": "yarn test:other && yarn test:code"
   },
-  "version": "1.0.0"
+  "repository": {
+    "type": "git",
+    "url": "git+https://github.com/excalidraw/excalidraw-room.git"
+  },
+  "keywords": [],
+  "author": "",
+  "license": "MIT",
+  "bugs": {
+    "url": "https://github.com/excalidraw/excalidraw-room/issues"
+  },
+  "homepage": "https://github.com/excalidraw/excalidraw-room#readme",
+  "dependencies": {
+    "debug": "4.1.1",
+    "eslint": "7.3.1",
+    "eslint-config-prettier": "6.11.0",
+    "eslint-plugin-prettier": "3.1.4",
+    "express": "4.17.1",
+    "prettier": "2.0.5",
+    "socket.io": "2.3.0"
+  },
+  "devDependencies": {
+    "@types/socket.io": "2.1.11",
+    "@types/debug": "4.1.5",
+    "@types/express": "4.17.7",
+    "@types/node": "13.9.8",
+    "typescript": "4.0.2"
+  },
+  "eslintConfig": {
+    "extends": [
+      "prettier"
+    ],
+    "plugins": [
+      "prettier"
+    ],
+    "rules": {
+      "curly": "warn",
+      "no-console": [
+        "warn",
+        {
+          "allow": [
+            "warn",
+            "error",
+            "info"
+          ]
+        }
+      ],
+      "no-else-return": "warn",
+      "no-useless-return": "warn",
+      "prefer-const": [
+        "warn",
+        {
+          "destructuring": "all"
+        }
+      ],
+      "prefer-template": "warn",
+      "prettier/prettier": "warn"
+    }
+  }
 }

pm2.json

@@ -1,14 +0,0 @@
-{
-  "name": "excalidraw-collab-dev",
-  "script": "./dist/index.js",
-  "watch": ["src/"],
-  "ignore_watch": ["node_modules", "public"],
-  "autorestart": false,
-  "exec_mode": "fork_mode",
-  "instances": 1,
-  "env": {
-    "NODE_ENV": "development",
-    "TZ": "Europe/London"
-  },
-  "node_args": ["--inspect=127.0.0.1:9320"]
-}

pm2.production.json

@@ -1,15 +0,0 @@
-{
-  "name": "excalidraw-collab",
-  "script": "./dist/index.js",
-  "ignore_watch": ["node_modules", "public"],
-  "max_memory_restart": "4G",
-  "watch": false,
-  "wait_ready": true,
-  "log_date_format": "YYYY-MM-DD HH:mm Z",
-  "autorestart": true,
-  "exec_mode": "fork_mode",
-  "instances": 1,
-  "env": {
-    "NODE_ENV": "production"
-  }
-}

src/index.ts

@@ -1,27 +1,14 @@
-import debug from "debug";
 import express from "express";
-import http from "http";
+import http, { ServerResponse } from "http";
-import { Server as SocketIO } from "socket.io";
+import socketIO from "socket.io";
+import debug from "debug";
 
 const serverDebug = debug("server");
 const ioDebug = debug("io");
 const socketDebug = debug("socket");
 
-require("dotenv").config(
-  process.env.NODE_ENV !== "development"
-    ? { path: ".env.production" }
-    : { path: ".env.development" },
-);
-
 const app = express();
-const port =
+const port = process.env.PORT || 80; // default port to listen
-  process.env.PORT || (process.env.NODE_ENV !== "development" ? 80 : 3002); // default port to listen
-
-app.use(express.static("public"));
-
-app.get("/", (req, res) => {
-  res.send("Excalidraw collaboration server is up :)");
-});
 
 const server = http.createServer(app);
 
@@ -29,34 +16,32 @@ server.listen(port, () => {
   serverDebug(`listening on port: ${port}`);
 });
 
-try {
+const io = socketIO(server, {
-  const io = new SocketIO(server, {
+  handlePreflightRequest: function (req, res) {
-    transports: ["websocket", "polling"],
+    var headers = {
-    cors: {
+      "Access-Control-Allow-Headers": "Content-Type, Authorization",
-      allowedHeaders: ["Content-Type", "Authorization"],
+      "Access-Control-Allow-Origin": req.header ? req.header.origin : "*",
-      origin: process.env.CORS_ORIGIN || "*",
+      "Access-Control-Allow-Credentials": true,
-      credentials: true,
+    };
+    res.writeHead(200, headers);
+    res.end();
   },
-    allowEIO3: true,
+});
-  });
 
-  io.on("connection", (socket) => {
+io.on("connection", (socket) => {
   ioDebug("connection established!");
   io.to(`${socket.id}`).emit("init-room");
-    socket.on("join-room", async (roomID) => {
+  socket.on("join-room", (roomID) => {
     socketDebug(`${socket.id} has joined ${roomID}`);
-      await socket.join(roomID);
+    socket.join(roomID);
-      const sockets = await io.in(roomID).fetchSockets();
+    if (io.sockets.adapter.rooms[roomID].length <= 1) {
-      if (sockets.length <= 1) {
       io.to(`${socket.id}`).emit("first-in-room");
     } else {
-        socketDebug(`${socket.id} new-user emitted to room ${roomID}`);
       socket.broadcast.to(roomID).emit("new-user", socket.id);
     }
-
     io.in(roomID).emit(
       "room-user-change",
-        sockets.map((socket) => socket.id),
+      Object.keys(io.sockets.adapter.rooms[roomID].sockets)
     );
   });
 
@@ -65,7 +50,7 @@ try {
     (roomID: string, encryptedData: ArrayBuffer, iv: Uint8Array) => {
       socketDebug(`${socket.id} sends update to ${roomID}`);
       socket.broadcast.to(roomID).emit("client-broadcast", encryptedData, iv);
-      },
+    }
   );
 
   socket.on(
@@ -75,30 +60,22 @@ try {
       socket.volatile.broadcast
         .to(roomID)
         .emit("client-broadcast", encryptedData, iv);
-      },
+    }
   );
 
-    socket.on("disconnecting", async () => {
+  socket.on("disconnecting", () => {
-      socketDebug(`${socket.id} has disconnected`);
+    const rooms = io.sockets.adapter.rooms;
     for (const roomID in socket.rooms) {
-        const otherClients = (await io.in(roomID).fetchSockets()).filter(
+      const clients = Object.keys(rooms[roomID].sockets).filter(
-          (_socket) => _socket.id !== socket.id,
+        (id) => id !== socket.id
-        );
-
-        if (otherClients.length > 0) {
-          socket.broadcast.to(roomID).emit(
-            "room-user-change",
-            otherClients.map((socket) => socket.id),
       );
+      if (clients.length > 0) {
+        socket.broadcast.to(roomID).emit("room-user-change", clients);
       }
     }
   });
 
   socket.on("disconnect", () => {
     socket.removeAllListeners();
-      socket.disconnect();
   });
-  });
+});
-} catch (error) {
-  console.error(error);
-}