diff options
Diffstat (limited to 'src/SocketIO/index.js')
| -rw-r--r-- | src/SocketIO/index.js | 22 |
1 files changed, 21 insertions, 1 deletions
diff --git a/src/SocketIO/index.js b/src/SocketIO/index.js index ec1cedf..6e71dbe 100644 --- a/src/SocketIO/index.js +++ b/src/SocketIO/index.js @@ -99,6 +99,10 @@ function createOpenSocketNamespace(io) { socket.on("disconnect", () => { logger.access(`SOCKET:open Client (${socket.id}@${socket.handshake.headers.host}) disconnected.`); }); + + if (neoModules.selfUpdater.updater.updating) { + socket.emit("updater", "start"); + } }); neoModules.neoRuntimeManager.event.on("change", (name, value) => { @@ -111,6 +115,12 @@ function createOpenSocketNamespace(io) { openNamespace.emit("var", name, value); } }); + neoModules.selfUpdater.updater.event.on("start", () => { + openNamespace.emit("updater", "start"); + }); + neoModules.selfUpdater.updater.event.on("end", () => { + openNamespace.emit("updater", "end"); + }); } /** @@ -194,7 +204,7 @@ function createAuthorizedNamespace(io) { fn({success: true}); }); socket.on("system:update_version", () => { - neoModules.selfUpdater.doUpdate(); + neoModules.selfUpdater.updater.forceUpdate(); }); /* SSLCert */ @@ -307,6 +317,16 @@ function createAuthorizedNamespace(io) { } }); }); + + neoModules.selfUpdater.updater.event.on("step", (step) => { + authorizedNamespace.emit("updater:step", step); + }); + neoModules.selfUpdater.updater.event.on("command", (command) => { + authorizedNamespace.emit("updater:command", command); + }); + neoModules.selfUpdater.updater.event.on("error", (updateLog) => { + authorizedNamespace.emit("updater:error", updateLog); + }); } /** |