diff options
author | Adam Hovorka <[email protected]> | 2019-07-17 19:32:57 -0600 |
---|---|---|
committer | Adam Hovorka <[email protected]> | 2019-07-17 19:32:57 -0600 |
commit | 138ddfbed3746fe7cb03a1fcdc46fc610c098ec3 (patch) | |
tree | 3549e63ecea9b4d8d2c4e9d60271294ada2f50b1 | |
parent | 6bb3e72df331ef45a69fe7f76ed4b7e7babe021a (diff) |
Add basic WebSocket connection
-rw-r--r-- | app.js | 12 | ||||
-rw-r--r-- | public/main.js | 4 |
2 files changed, 12 insertions, 4 deletions
@@ -1,8 +1,8 @@ "use strict" -const http = require("http"); -const fs = require("fs"); -const ws = require("ws"); +const WebSocket = require("ws"); +const http = require("http"); +const fs = require("fs"); const Router = require("./lib/router"); const Static = require("./lib/static"); @@ -14,6 +14,7 @@ const PORT = Math.clamp(+process.env.PORT||8080, 1, 65535); const HOST = "0.0.0.0"; const server = http.createServer(); +const wss = new WebSocket.Server({server}); const stat = new Static("./public"); const app = new Router(); @@ -37,6 +38,11 @@ app.get("/hist.json", (req, res) => sj(res, [])); // req.pipe(fs.createWriteStream("./static/"+path[1])); //}); +wss.on("connection", ws => { + ws.on("message", msg => console.log("msg", msg)); + ws.send("hello"); +}); + server.on("request", (req, res) => { console.log(`${Date.now()} ${req.method} ${req.url}`); app.route(req, res) || stat.route(req, res); diff --git a/public/main.js b/public/main.js index eae1d63..da4083e 100644 --- a/public/main.js +++ b/public/main.js @@ -1,7 +1,9 @@ document.addEventListener("DOMContentLoaded", async () => { "use strict" const $ = s => document.querySelector(s); +const sock = new WebSocket(`ws://${location.host}/ws`); -// TODO +sock.onmessage = e => console.log("sock", e); +sock.onopen = () => sock.send("yay"); }); |