inspector/socket.js at master · aspctu/inspector · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
const ws = require("ws");
const wss = new ws.WebSocketServer({ port: 8085 });

function sendChange(change, filepath) {
  wss.clients.forEach(function each(client) {
    if (client.readyState === ws.WebSocket.OPEN) {
      client.send(
        JSON.stringify({ type: "change", change: change, fp: filepath })
      );
    }
  });
}

function sendAdd(filepath) {
  wss.clients.forEach(function each(client) {
    if (client.readyState === ws.WebSocket.OPEN) {
      client.send(
        JSON.stringify({ type: "add", change: "", fp: filepath })
      );
    }
  });
}


wss.on("connection", function connection(ws) {
  ws.on("message", function incoming(message) {
    log(message);
  });
});

module.exports = {
  sendChange,
  sendAdd
};