:sparkles: Add self updater that actually does something (maybe)

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);
+    });
 }
 
 /**