Reduce input during on-boarding

.eslintrc.js

@@ -17,7 +17,7 @@ module.exports = {
     '@typescript-eslint/no-parameter-properties': 'off',
     '@typescript-eslint/no-use-before-define': 'off',
     'import/no-unresolved': 'off',
-    camelcase: 'warn',
+    'camelcase': 'warn',
     'simple-import-sort/sort': 'warn',
     'sort-imports': 'off',
     'import/first': 'warn',
@@ -42,5 +42,11 @@ module.exports = {
         ],
       },
     },
+    {
+      files: '**/*.js',
+      env: {
+        node: true,
+      },
+    },
   ],
 };

angular.json

@@ -3,7 +3,7 @@
   "version": 1,
   "newProjectRoot": "projects",
   "projects": {
-    "OctoPrintDash": {
+    "OctoDash": {
       "projectType": "application",
       "schematics": {
         "@schematics/angular:component": {
@@ -18,6 +18,7 @@
           "builder": "@angular-devkit/build-angular:browser",
           "options": {
             "aot": true,
+            "allowedCommonJsDependencies": ["angular-svg-round-progressbar"],
             "outputPath": "dist",
             "index": "src/index.html",
             "main": "src/main.ts",
@@ -40,9 +41,7 @@
                 "output": "/"
               }
             ],
-            "styles": [
-              "src/styles.scss"
-            ],
+            "styles": ["src/styles.scss"],
             "scripts": []
           },
           "configurations": {
@@ -79,18 +78,18 @@
         "serve": {
           "builder": "@angular-devkit/build-angular:dev-server",
           "options": {
-            "browserTarget": "OctoPrintDash:build"
+            "browserTarget": "OctoDash:build"
           },
           "configurations": {
             "production": {
-              "browserTarget": "OctoPrintDash:build:production"
+              "browserTarget": "OctoDash:build:production"
             }
           }
         },
         "extract-i18n": {
           "builder": "@angular-devkit/build-angular:extract-i18n",
           "options": {
-            "browserTarget": "OctoPrintDash:build"
+            "browserTarget": "OctoDash:build"
           }
         },
         "test": {
@@ -100,47 +99,35 @@
             "polyfills": "src/polyfills.ts",
             "tsConfig": "tsconfig.spec.json",
             "karmaConfig": "karma.conf.js",
-            "assets": [
-              "src/favicon.ico",
-              "src/assets",
-              "src/assets/icon/icon-main-title.svg"
-            ],
-            "styles": [
-              "src/styles.scss"
-            ],
+            "assets": ["src/favicon.ico", "src/assets", "src/assets/icon/icon-main-title.svg"],
+            "styles": ["src/styles.scss"],
             "scripts": []
           }
         },
         "lint": {
           "builder": "@angular-devkit/build-angular:tslint",
           "options": {
-            "tsConfig": [
-              "tsconfig.app.json",
-              "tsconfig.spec.json",
-              "tsconfig.json"
-            ],
-            "exclude": [
-              "**/node_modules/**"
-            ]
+            "tsConfig": ["tsconfig.app.json", "tsconfig.spec.json", "tsconfig.json"],
+            "exclude": ["**/node_modules/**"]
           }
         },
         "e2e": {
           "builder": "@angular-devkit/build-angular:protractor",
           "options": {
             "protractorConfig": "e2e/protractor.conf.js",
-            "devServerTarget": "OctoPrintDash:serve"
+            "devServerTarget": "OctoDash:serve"
           },
           "configurations": {
             "production": {
-              "devServerTarget": "OctoPrintDash:serve:production"
+              "devServerTarget": "OctoDash:serve:production"
             }
           }
         }
       }
     }
   },
-  "defaultProject": "OctoPrintDash",
+  "defaultProject": "OctoDash",
   "cli": {
     "analytics": "e1569209-2b82-4195-9c15-0669a78feccb"
   }
-}
+}

helper/discover.js

@@ -0,0 +1,41 @@
+/* eslint-disable @typescript-eslint/no-var-requires */
+/* eslint-disable import/no-commonjs */
+
+const mdns = require('mdns');
+const compareVersions = require('compare-versions');
+
+const minimumVersion = '1.3.5';
+let mdnsBrowser;
+let nodes = [];
+
+function discoverNodes(window) {
+  nodes = [];
+  mdnsBrowser = mdns.createBrowser(mdns.tcp('octoprint'));
+  mdnsBrowser.on('serviceUp', service => {
+    nodes.push({
+      id: service.interfaceIndex,
+      name: service.name,
+      version: service.txtRecord.version,
+      url: `http://${service.host.replace(/\.$/, '')}:${service.port}${service.txtRecord.path}api/`,
+      disable: compareVersions(minimumVersion, service.txtRecord.version) === -1,
+    });
+    sendNodes(window);
+  });
+
+  mdnsBrowser.on('serviceDown', service => {
+    nodes = nodes.filter(node => node.id !== service.interfaceIndex);
+    sendNodes(window);
+  });
+
+  mdnsBrowser.start();
+}
+
+function stopDiscovery() {
+  mdnsBrowser.stop();
+}
+
+function sendNodes(window) {
+  window.webContents.send('discoveredNodes', nodes);
+}
+
+module.exports = { discoverNodes, stopDiscovery };

helper/listener.js

@@ -0,0 +1,68 @@
+/* eslint-disable @typescript-eslint/no-var-requires */
+/* eslint-disable import/no-commonjs */
+
+const path = require('path');
+const url = require('url');
+
+const exec = require('child_process').exec;
+
+const sendCustomStyles = require('./styles');
+const { downloadUpdate, sendVersionInfo } = require('./update');
+const { discoverNodes, stopDiscovery } = require('./discover');
+
+function activateScreenSleepListener(ipcMain) {
+  ipcMain.on('screenSleep', () => {
+    exec('xset dpms force standby');
+  });
+
+  ipcMain.on('screenWakeup', () => {
+    exec('xset s off');
+    exec('xset -dpms');
+    exec('xset s noblank');
+  });
+}
+
+function activateReloadListener(ipcMain, window) {
+  ipcMain.on('reload', () => {
+    window.loadURL(
+      url.format({
+        pathname: path.join(__dirname, 'dist/index.html'),
+        protocol: 'file:',
+        slashes: true,
+      }),
+    );
+  });
+}
+
+function activateAppInfoListener(ipcMain, window, app) {
+  ipcMain.on('appInfo', () => {
+    sendCustomStyles(window);
+    sendVersionInfo(window, app);
+  });
+}
+
+function activateUpdateListener(ipcMain, window) {
+  ipcMain.on('update', (_, updateInfo) => {
+    downloadUpdate(updateInfo, window);
+  });
+}
+
+function activateDiscoverListener(ipcMain, window) {
+  ipcMain.on('discover', () => {
+    discoverNodes(window);
+  });
+
+  ipcMain.on('stopDiscover', () => {
+    stopDiscovery();
+  });
+}
+
+function activateListeners(ipcMain, window, app) {
+  activateAppInfoListener(ipcMain, window, app);
+  activateScreenSleepListener(ipcMain);
+  activateReloadListener(ipcMain, window);
+  activateUpdateListener(ipcMain, window);
+  activateDiscoverListener(ipcMain, window);
+}
+
+module.exports = activateListeners;

helper/styles.js

@@ -0,0 +1,28 @@
+/* eslint-disable @typescript-eslint/no-var-requires */
+/* eslint-disable import/no-commonjs */
+
+const fs = require('fs');
+const path = require('path');
+const { app } = require('electron');
+
+function sendCustomStyles(window) {
+  fs.readFile(path.join(app.getPath('userData'), 'custom-styles.css'), 'utf-8', (err, data) => {
+    if (err) {
+      if (err.code === 'ENOENT') {
+        fs.writeFile(path.join(app.getPath('userData'), 'custom-styles.css'), '', err => {
+          if (err) {
+            window.webContents.send('customStylesError', err);
+          } else {
+            window.webContents.send('customStyles', '');
+          }
+        });
+      } else {
+        window.webContents.send('customStylesError', err);
+      }
+    } else {
+      window.webContents.send('customStyles', data);
+    }
+  });
+}
+
+module.exports = sendCustomStyles;

helper/update.js

@@ -0,0 +1,103 @@
+/* eslint-disable no-sync */
+/* eslint-disable @typescript-eslint/no-var-requires */
+/* eslint-disable import/no-commonjs */
+
+const fs = require('fs');
+const got = require('got');
+const stream = require('stream');
+const { promisify } = require('util');
+const progress = require('progress-stream');
+
+const exec = require('child_process').exec;
+
+function downloadUpdate(updateInfo, window) {
+  const downloadPath = '/tmp/octodash.deb';
+
+  exec('arch', (err, stdout, stderr) => {
+    if (err || stderr) {
+      window.webContents.send('updateError', {
+        error: err || { message: stderr },
+      });
+    }
+    got(updateInfo.assetsURL)
+      .then(releaseFiles => {
+        const reducer = (accumulator, currentValue) => accumulator + currentValue;
+        const averageETA = [];
+        let downloadURL;
+        let packageSize;
+        for (const package of JSON.parse(releaseFiles.body)) {
+          if (package.name.includes(stdout.trim())) {
+            downloadURL = package.browser_download_url;
+            packageSize = package.size;
+          }
+        }
+        if (downloadURL) {
+          const downloadPipeline = promisify(stream.pipeline);
+          const downloadProgress = progress({
+            length: packageSize,
+            time: 300,
+          });
+
+          downloadProgress.on('progress', progress => {
+            averageETA.push(progress.eta);
+            if (averageETA.length > 4) averageETA.shift();
+            window.webContents.send('updateDownloadProgress', {
+              percentage: progress.percentage,
+              transferred: (progress.transferred / 100000).toFixed(1),
+              total: (progress.length / 1000000).toFixed(1),
+              remaining: (progress.remaining / 100000).toFixed(1),
+              eta: new Date(averageETA.reduce(reducer) * 1000).toISOString().substr(14, 5),
+              runtime: new Date(progress.runtime * 1000).toISOString().substr(14, 5),
+              delta: (progress.delta / 100000).toFixed(1),
+              speed: (progress.speed / 1000000).toFixed(2),
+            });
+          });
+
+          try {
+            if (fs.existsSync(downloadPath)) fs.unlinkSync(downloadPath);
+          } catch {
+            // no need to handle this properly
+          }
+
+          downloadPipeline(got.stream(downloadURL), downloadProgress, fs.createWriteStream(downloadPath))
+            .catch(error => {
+              window.webContents.send('updateError', {
+                error: {
+                  message: `Can't download package! ${error.message}.`,
+                },
+              });
+            })
+            .then(() => {
+              window.webContents.send('updateDownloadFinished');
+              exec('sudo ~/scripts/update-octodash', (err, _, stderr) => {
+                if (err || stderr) {
+                  window.webContents.send('updateError', {
+                    error: err || { message: stderr },
+                  });
+                } else {
+                  window.webContents.send('updateInstalled');
+                }
+              });
+            });
+        } else {
+          window.webContents.send('updateError', {
+            error: {
+              message: `Can't find matching package for architecture ${stdout}.`,
+            },
+          });
+        }
+      })
+      .catch(error => {
+        error.message = `Can't load releases. ${error.message}`;
+        window.webContents.send('updateError', { error });
+      });
+  });
+}
+
+function sendVersionInfo(window, app) {
+  window.webContents.send('versionInformation', {
+    version: app.getVersion(),
+  });
+}
+
+module.exports = { downloadUpdate, sendVersionInfo };