From d73fbaec86d51c069709a046d53923ef0c519958 Mon Sep 17 00:00:00 2001
From: Hri7566 <hri7566@gmail.com>
Date: Mon, 30 Oct 2023 18:03:46 -0400
Subject: [PATCH] Finish code

---
 .prettierrc   |   5 ++
 package.json  |  34 ++++++------
 src/client.js | 139 +++++++++++++++++++++++++----------------------
 src/index.js  |  24 ++++-----
 src/server.js | 147 +++++++++++++++++++++++++++-----------------------
 5 files changed, 188 insertions(+), 161 deletions(-)
 create mode 100644 .prettierrc

diff --git a/.prettierrc b/.prettierrc
new file mode 100644
index 0000000..797682e
--- /dev/null
+++ b/.prettierrc
@@ -0,0 +1,5 @@
+{
+    "arrowParens": "avoid",
+    "trailingComma": "none",
+    "tabWidth": 4
+}
diff --git a/package.json b/package.json
index ceef5dd..94f5bb7 100644
--- a/package.json
+++ b/package.json
@@ -1,17 +1,17 @@
-{
-  "name": "sync",
-  "version": "1.0.0",
-  "description": "",
-  "main": "src/index.js",
-  "scripts": {
-    "test": "echo \"Error: no test specified\" && exit 1"
-  },
-  "keywords": [],
-  "author": "",
-  "license": "ISC",
-  "dependencies": {
-    "chokidar": "^3.5.3",
-    "dotenv": "^16.3.1",
-    "ws": "^8.14.2"
-  }
-}
+{
+    "name": "sync",
+    "version": "1.0.0",
+    "description": "",
+    "main": "src/index.js",
+    "scripts": {
+        "test": "echo \"Error: no test specified\" && exit 1"
+    },
+    "keywords": [],
+    "author": "",
+    "license": "ISC",
+    "dependencies": {
+        "chokidar": "^3.5.3",
+        "dotenv": "^16.3.1",
+        "ws": "^8.14.2"
+    }
+}
diff --git a/src/client.js b/src/client.js
index b4b6072..ae92c37 100644
--- a/src/client.js
+++ b/src/client.js
@@ -2,79 +2,90 @@ const WebSocket = require("ws");
 const { EventEmitter } = require("events");
 
 class Client extends EventEmitter {
-  constructor() {
-    super();
-    this.bindEventListeners();
-  }
+    constructor() {
+        super();
+        this.bindEventListeners();
+    }
 
-  start() {
-    if (!this.started) return;
-    this.started = true;
+    start() {
+        if (!this.started) return;
+        this.started = true;
 
-    this.connect();
-  }
-
-  connect() {
-    this.ws = new WebSocket(process.env.SYNC_URI);
-
-    this.ws.on("open", () => {});
-
-    this.ws.addEventListener("close", (evt) => {
-      this.emit("disconnected");
-
-      setTimeout(() => {
         this.connect();
-      }, 1000);
-    });
-
-    this.ws.addEventListener("error", (evt) => {
-      this.emit("wserror", evt);
-      this.ws.close();
-    });
-
-    this.ws.addEventListener("message", (evt) => {
-      try {
-        const str = evt.data.toString();
-        const msg = JSON.parse(str);
-        this.emit(msg.m, msg);
-      } catch (err) {
-        this.emit("parse_error", err);
-      }
-    });
-  }
-
-  stop() {
-    this.started = false;
-
-    if (this.ws) {
-      this.ws.close();
-      delete this.ws;
     }
-  }
 
-  say(msg) {
-    try {
-      if (this.isConnected()) this.ws.send(JSON.stringify(msg));
-      return true;
-    } catch (err) {
-      console.error(err);
-      return false;
+    connect() {
+        this.ws = new WebSocket(process.env.SYNC_URI);
+
+        this.ws.on("open", () => {});
+
+        this.ws.addEventListener("close", evt => {
+            this.emit("disconnected");
+
+            setTimeout(() => {
+                this.connect();
+            }, 1000);
+        });
+
+        this.ws.addEventListener("error", evt => {
+            this.emit("wserror", evt);
+            this.ws.close();
+        });
+
+        this.ws.addEventListener("message", evt => {
+            try {
+                const str = evt.data.toString();
+                const msg = JSON.parse(str);
+                this.emit(msg.m, msg);
+            } catch (err) {
+                this.emit("parse_error", err);
+            }
+        });
     }
-  }
 
-  log(level, message) {
-    if (!this.isConnected()) return;
-  }
+    stop() {
+        this.started = false;
 
-  isConnected() {
-    return this.ws.readyState == WebSocket.OPEN;
-  }
+        if (this.ws) {
+            this.ws.close();
+            delete this.ws;
+        }
+    }
 
-  bindEventListeners() {
-    this.on("log", (msg) => {
-      console.log(`[${msg.level}] ${msg.message}`);
-    });
-  }
+    say(msg) {
+        try {
+            if (this.isConnected()) this.ws.send(JSON.stringify(msg));
+            return true;
+        } catch (err) {
+            console.error(err);
+            return false;
+        }
+    }
+
+    log(level, message) {
+        this.say({ m: "log", level, message });
+    }
+
+    broadcast(msg) {
+        this.say({ m: "broadcast", msg });
+    }
+
+    isConnected() {
+        return this.ws.readyState == WebSocket.OPEN;
+    }
+
+    bindEventListeners() {
+        this.on("log", msg => {
+            console.log(`[Server] [${msg.level}] ${msg.message}`);
+        });
+
+        setInterval(() => {
+            this.say({
+                m: "t",
+                e: Date.now()
+            });
+        }, 20000);
+    }
 }
 
 module.exports = { Client };
diff --git a/src/index.js b/src/index.js
index bf50336..bd25a79 100644
--- a/src/index.js
+++ b/src/index.js
@@ -1,25 +1,25 @@
 require("dotenv").config();
 
-// TODO Make this repo a module
-
 let isServer;
 
 process.argv.forEach((val, index, array) => {
-  if (val == "client") isServer = false;
-  if (val == "server") isServer = true;
+    if (val == "client") isServer = false;
+    if (val == "server") isServer = true;
 });
 
 if (typeof isServer == "undefined") {
-  // Incorrect arguments
-  console.log(`Usage: ${process.argv[0]} ${process.argv[1]} [client|server]`);
-  process.exit(1);
+    // Incorrect arguments
+    console.log(`Usage: ${process.argv[0]} ${process.argv[1]} [client|server]`);
+    process.exit(1);
 }
 
 if (isServer) {
-  const { Server } = require("./server");
-  Server.start();
+    const { Server } = require("./server");
+    Server.start();
 } else {
-  const { Client } = require("./client");
-  const cl = new Client();
-  cl.connect();
+    const { Client } = require("./client");
+    const cl = new Client();
+    cl.connect();
+
+    cl.log("DEBUG", "hello");
 }
diff --git a/src/server.js b/src/server.js
index b0526b5..211bcd8 100644
--- a/src/server.js
+++ b/src/server.js
@@ -2,82 +2,93 @@ const WebSocket = require("ws");
 const { EventEmitter } = require("events");
 
 function broadcast(msg) {
-  Server.wss.clients.forEach((ws) => {
-    ws.say(msg);
-  });
+    Server.wss.clients.forEach(ws => {
+        ws.say(msg);
+    });
 }
 
 function log(level, message) {
-  console.log(`[${level}] ${message}`);
-  broadcast({ m: "log", level, message });
+    console.log(`[${level}] ${message}`);
+    broadcast({ m: "log", level, message });
 }
 
 class Server {
-  static start() {
-    this.wss = new WebSocket.Server({
-      port: process.env.PORT || 10911,
-    });
-
-    this.wss.on("connection", (ws, req) => {
-      ws.preauth = new EventEmitter();
-      ws.evt = new EventEmitter();
-
-      ws.say = (msg) => {
-        ws.send(JSON.stringify(msg));
-      };
-
-      log("INFO", "Client connected at " + req.socket.remoteAddress);
-
-      ws.on("message", (data, isBinary) => {
-        try {
-          if (isBinary) return;
-
-          const str = data.toString();
-          const converted = JSON.parse(str);
-
-          if (converted.m) {
-            ws.preauth.emit(converted.m, converted);
-
-            if (ws.authed) {
-              ws.evt.emit(converted.m, converted);
-            }
-          }
-        } catch (err) {
-          console.error(err);
-        }
-      });
-
-      ws.preauth.on("hi", (msg) => {
-        if (!msg.project) return;
-
-        ws.authed = true;
-        ws.project = msg.project;
-      });
-
-      ws.evt.on("log", (msg) => {
-        if (!msg.level) return;
-        if (!msg.message) return;
-
-        log(msg.level, `From ${req.socket.remoteAddress}: ${msg.message}`);
-      });
-
-      ws.evt.on("broadcast", (msg) => {
-        if (!msg.msg) return;
-        if (typeof msg.msg !== "object") return;
-        if (!msg.msg.m) return;
-
-        broadcast({
-          m: "broadcast",
-          msg: msg.msg,
+    static start() {
+        this.wss = new WebSocket.Server({
+            port: process.env.PORT || 10911
         });
-      });
-    });
-  }
 
-  static stop() {
-    this.wss.close();
-    delete this.wss;
-  }
+        this.wss.on("connection", (ws, req) => {
+            ws.preauth = new EventEmitter();
+            ws.evt = new EventEmitter();
+
+            ws.say = msg => {
+                ws.send(JSON.stringify(msg));
+            };
+
+            log("INFO", "Client connected at " + req.socket.remoteAddress);
+
+            ws.on("message", (data, isBinary) => {
+                try {
+                    if (isBinary) return;
+
+                    const str = data.toString();
+                    const converted = JSON.parse(str);
+
+                    if (converted.m) {
+                        ws.preauth.emit(converted.m, converted);
+
+                        if (ws.authed) {
+                            ws.evt.emit(converted.m, converted);
+                        }
+                    }
+                } catch (err) {
+                    console.error(err);
+                }
+            });
+
+            ws.preauth.on("hi", msg => {
+                if (!msg.project) return;
+
+                ws.authed = true;
+                ws.project = msg.project;
+            });
+
+            ws.evt.on("log", msg => {
+                if (!msg.level) return;
+                if (!msg.message) return;
+
+                log(
+                    msg.level,
+                    `From ${req.socket.remoteAddress}: ${msg.message}`
+                );
+            });
+
+            ws.evt.on("broadcast", msg => {
+                if (!msg.msg) return;
+                if (typeof msg.msg !== "object") return;
+                if (!msg.msg.m) return;
+
+                broadcast({
+                    m: "broadcast",
+                    msg: msg.msg
+                });
+            });
+
+            ws.evt.on("t", msg => {
+                ws.say({
+                    m: "t",
+                    t: Date.now(),
+                    e: msg.e
+                });
+            });
+        });
+    }
+
+    static stop() {
+        this.wss.close();
+        delete this.wss;
+    }
 }
 
 module.exports = { Server };