aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorAdam Hovorka <[email protected]>2019-07-17 19:32:57 -0600
committerAdam Hovorka <[email protected]>2019-07-17 19:32:57 -0600
commit138ddfbed3746fe7cb03a1fcdc46fc610c098ec3 (patch)
tree3549e63ecea9b4d8d2c4e9d60271294ada2f50b1
parent6bb3e72df331ef45a69fe7f76ed4b7e7babe021a (diff)
Add basic WebSocket connection
-rw-r--r--app.js12
-rw-r--r--public/main.js4
2 files changed, 12 insertions, 4 deletions
diff --git a/app.js b/app.js
index 56b3b82..e026555 100644
--- a/app.js
+++ b/app.js
@@ -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");
});