feat: enable replication count selector, error handling

src/application/index.js

@@ -37,6 +37,13 @@ class Application extends EventEmitter {
     this.run();
   }
 
+  setReplicationCount(value) {
+    this.replicationCount = value;
+    if (this.replicator) {
+      this.replicator.setReplicationCount(this.replicationCount);
+    }
+  }
+
   run() {
     this.devicesManager = new DevicesManager({devicesPath: this.devicesPath})
       .on(DevicesManager.EVENTS.ERROR, (message) => this.logger.error(`[DevicesManager] ${message}`))
@@ -69,10 +76,11 @@ class Application extends EventEmitter {
       this.replicator.onFileUpdate(dev, relativePath)
     );
 
-    this.logger.info('application is ready');
-    this.emit(Application.EVENTS.READY);
-
-    this.startFtpServer();
+    setTimeout(() => {
+      this.logger.info('application is ready');
+      this.emit(Application.EVENTS.READY);
+      //this.startFtpServer();
+    }, 100);
   }
 
   startFtpServer() {
@@ -91,8 +99,8 @@ class Application extends EventEmitter {
       getRoot: () => '/'
     });
 
-    this.ftpServer.on('error', (error) => {
-      this.logger.error('FTP Server error:', error);
+    this.ftpServer.on('error', (error, a, b) => {
+      this.logger.error('FTP Server error:', error, a, b);
     });
 
     this.ftpServer.on('client:connected', (connection) => {

src/hardware/Display.js

@@ -42,7 +42,7 @@ class Display extends PhatDisplayWrapper {
   _startUpdater() {
     this._stopUpdater();
     this._updaterInterval = setInterval(() => {
-      if (this.buffer[this.selected]) {
+      if (typeof this.buffer[this.selected] !== 'undefined') {
         this.writeString(this.buffer[this.selected]);
       } else {
         this.writeString(`?${this.selected}`);
@@ -92,6 +92,14 @@ class Display extends PhatDisplayWrapper {
     clearInterval(this._clockInterval);
     this._clockInterval = null;
   }
+
+  destroy() {
+    this._stopClock();
+    this._stopScrollIp();
+    this._stopUpdater();
+
+    super.destroy();
+  }
 }
 
 module.exports = Display;

src/hardware/SelectorReplications.js

@@ -20,11 +20,6 @@ class SelectorReplications extends Selector {
   constructor() {
     super(PIN_MAP);
   }
-
-  getValue() {
-    const pin = super.getSelected();
-    return OPTIONS[pin];
-  }
 }
 
 SelectorReplications.OPTIONS = OPTIONS;

src/hardware/drivers/Led.js

@@ -1,6 +1,7 @@
 const rpio = require('rpio');
 
-const BLINK_ONCE_DURATION = 500;
+const BLINK_DURATION = 500;
+const BLINK_ONCE_DURATION = 333;
 
 class Led {
   constructor(pin) {
@@ -41,8 +42,8 @@ class Led {
         clearTimeout(this._blinkTimeout);
         this._blinkTimeout = setTimeout(() => {
           rpio.write(this.pin, rpio.LOW);
-        }, 0);
-      }, 10);
+        }, BLINK_DURATION);
+      }, BLINK_DURATION * 2);
     } else {
       rpio.write(this.pin, rpio.LOW);
     }

src/hardware/drivers/PhatDisplayWrapper.js

@@ -56,7 +56,7 @@ class PhatDisplayWrapper {
 
   destroy() {
     this.clear();
-    this._pythonDriverProcess.kill();
+    setTimeout(() => this._pythonDriverProcess.kill(), 100);
   }
 }
 

src/hardware/drivers/Selector.js

@@ -29,7 +29,8 @@ class Selector extends EventEmitter {
       rpio.open(pin, rpio.INPUT, rpio.PULL_DOWN);
       rpio.poll(pin, () => this._onSelect(pin), rpio.POLL_HIGH);
       if (rpio.read(pin)) {
-        setTimeout(() => this._onSelect(pin), 10);
+        this.selectedPin = pin;
+        //setTimeout(() => this._onSelect(pin), 10);
       }
     });
   }
@@ -38,6 +39,10 @@ class Selector extends EventEmitter {
     return this.selectedPin;
   }
 
+  getValue() {
+    return this.pinsMap[this.selectedPin];
+  }
+
   _onSelect(pin) {
     if (this.selectedPin !== pin) {
       this.selectedPin = pin;

src/hardware/drivers/Switch.js

@@ -27,10 +27,10 @@ class Switch extends EventEmitter {
     }
     rpio.open(this.pin, rpio.INPUT, rpio.PULL_DOWN);
     rpio.poll(this.pin, () => this._onSwitch(), rpio.POLL_BOTH);
-    //setTimeout(() => this._onSwitch(), 10);
+    this.isOn = rpio.read(this.pin);
   }
 
-  getState() {
+  getValue() {
     return this.isOn;
   }
 

src/hardware/index.js

@@ -48,9 +48,9 @@ class Hardware extends EventEmitter {
     });
 
     this.selectorReplications = new SelectorReplications();
-    this.selectorReplications.on('select', (operation) => {
-      this.display.writeString(`RS:${operation}`); // debug
-    });
+    // this.selectorReplications.on('select', (operation) => {
+    //   this.display.writeString(`RS:${operation}`); // debug
+    // });
 
     this.switchOnOff = new SwitchOnOff();
     this.switchOnOff.on('switch', (value) => {

src/index.js

@@ -4,28 +4,43 @@ const {version, description, homepage} = require('../package.json');
 const logger = require('./logger');
 const Hardware = require('./hardware');
 const Application = require('./application');
+const Replicator = require('./application/replicator');
 const parseCliArgs = require('./parseCliArgs');
 
 let hardware;
 let application;
 
 function onUnhandledError(err) {
+  try {
+    hardware.display.writeString('panic');
+  } catch (e) {
+    const message = 'WARN: cannot use display:';
+    try {
+      logger.warn(message, e);
+    } catch (loggerE) {
+      console.log(message, e);
+    }
+  }
   try {
     cleanUp();
     logger.error(err);
   } catch (e) {
     console.log('LOGGER ERROR', e); //eslint-disable-line no-console
     console.log('ERROR', err); //eslint-disable-line no-console
   }
-  process.exit(1);
+  setTimeout(() => {
+    process.exit(1);
+  }, 1000);
 }
 
 process.on('unhandledRejection', onUnhandledError);
 process.on('uncaughtException', onUnhandledError);
 process.on('SIGINT', function() {
   logger.info('Exit...');
   cleanUp();
-  process.exit();
+  setTimeout(() => {
+    process.exit();
+  }, 1000);
 });
 
 function cleanUp() {
@@ -66,7 +81,8 @@ parseCliArgs(
     let replicationCount;
     if (rpi) {
       hardware = new Hardware();
-      hardware.ledIO.setValue(true);
+      hardware.ledIO.setBlink(true);
+      hardware.display.setMode(hardware.selectorDisplay.getValue());
       replicationCount = hardware.selectorReplications.getValue();
     }
 
@@ -77,7 +93,12 @@ parseCliArgs(
     });
     application.on(Application.EVENTS.READY, () => {
       if (rpi) {
-        hardware.ledIO.setValue(false);
+        if (hardware.switchOnOff.getValue()) {
+          application.startFtpServer();
+        }
+        hardware.ledIO.setBlink(false);
+      } else {
+        application.startFtpServer();
       }
     });
 
@@ -96,6 +117,15 @@ parseCliArgs(
           }, 1000);
         }
       });
+
+      application.replicator
+        .on(Replicator.EVENTS.REPLICATION_STARTED, () => hardware.ledIO.setBlink(true))
+        .on(Replicator.EVENTS.REPLICATION_STARTED, () => hardware.ledIO.setBlink(false));
+
+      hardware.selectorReplications.on('select', (value) => {
+        logger.info(`[USER] changed replication count: ${value}`);
+        application.setReplicationCount(value);
+      });
     }
   }
 );