OpenROV / openrov-cockpit

src/plugins/notifications/index.js

var logger;
const nedb = require('nedb');

'const' is available in ES6 (use 'esversion: 6') or Mozilla JS extensions (use moz).

const path = require('path');

'const' is available in ES6 (use 'esversion: 6') or Mozilla JS extensions (use moz).

const bluebird = require('bluebird');

'const' is available in ES6 (use 'esversion: 6') or Mozilla JS extensions (use moz).

const mkdirp = require('mkdirp');

'const' is available in ES6 (use 'esversion: 6') or Mozilla JS extensions (use moz).

const Listener = require('Listener');

'const' is available in ES6 (use 'esversion: 6') or Mozilla JS extensions (use moz).

var _announcementScheduled = false;
class Notifications {

'class' is available in ES6 (use 'esversion: 6') or Mozilla JS extensions (use moz).

    constructor(name, deps) {
        logger= deps.logger;

        logger.info("Loaded Notifications plugin");

        this.globalBus = deps.globalEventLoop; // This is the server-side messaging bus. The MCU sends messages to server plugins over this
        this.cockpitBus = deps.cockpit; // This is the server<->client messaging bus. This is how the server talks to the browser
        var self = this;
        this.db = null; //db not yet initialized

        this.listeners = {
            settings: new Listener(self.globalBus, 'settings-change.notifications', true, function(settings) {
                self.settings = settings.notifications;
                self.initDB()
                .then(self.announceNotices.bind(self));
            }),

            peristentNotices: new Listener(self.globalBus, 'notification', false, function(notice) {
                self.cockpitBus.emit('plugin.notification.notify', {
                    timestamp: Date.now(),
                    notice: notice
                });
                if (!self.db) {
                    return; //ignore persistening if the db is not ready
                }

                self.db.insert({
                    timestamp: Date.now(),
                    notice: notice
                });
            }),

            clear: new Listener(self.cockpitBus, 'plugin.notifications.clear', false, function() {
                self.db.removeAsync({}, {
                        multi: true
                    })
                    .then(function(numRemoved) {
                        trace(`Cleared ${numRemoved} notifications`);

'template literal syntax' is only available in ES6 (use 'esversion: 6').

                        self.announceNotices();
                    })

There should be a semicolon.

            })
        }

There should be a semicolon.

    }


    start() {
        // Enable the listeners!
        this.listeners.settings.enable();
        this.listeners.peristentNotices.enable();
        this.listeners.clear.enable();
        if (process.env.NODE_ENV == "development") {
          this.globalBus.emit("notification", "Notification service started");
        }
    }

    // This is called when the plugin is disabled
    stop() {
        // Disable listeners
        this.listeners.settings.disable();
        this.listeners.peristentNotices.disable();
        this.listeners.clear.disable();
    }

    announceNotices() {
        var self = this;
        if (_announcementScheduled) {
            return;
        }
        setTimeout(function() {
            self.getAllNotifications()
                .then(function(notices) {
                    self.cockpitBus.emit("plugin.notification.all-notices", notices);
                })
                .catch(function(ex) {
                    throw ex;
                })
                .then(function() {
                    _announcementScheduled = false;
                });
        }, 1000 * 60); //Throttle at 1 per minute

    }

    getAllNotifications() {
        return this.db.findAsync({});
    }

    initDB() {
        var self = this;
        return bluebird.try(function() {
            if (self.db){
                //Only initialize once, changes to settings used by nedb will requires a process restart.
                return;
            }
            if (process.env.NODE_ENV == "development") {
                self.db = new nedb();
                bluebird.promisifyAll(self.db);
                //This intentionally does not honor selective debug logging. 
                logger.warn('neDB intialized as inMemory -- ONLY USE FOR TESTING');
            } else {
                var nedbDir = process.env.DATADIR || '/etc'

There should be a semicolon.

                mkdirp.sync(path.join(nedbDir, 'OpenROV'));
                logger.debug('database: ' + path.join(nedbDir, 'OpenROV/notifications.db'));
                self.db = new nedb({
                    filename: path.join(nedbDir, 'OpenROV/notifications.db'),
                    autoload: true
                });
                bluebird.promisifyAll(self.db);
                self.db.persistence.setAutocompactionInterval(process.env.AutocompactionInterval || 1000 * 60 * 10);
            }

        })

There should be a semicolon.

    }

    // This is used to define user settings for the plugin. We populated some example properties below.
    // The UI for changing the settings is automatically generated in the Settings applet.
    getSettingSchema()
    {
        //from http://json-schema.org/examples.html
        return [{
            'title': 'Notification Settings',
            'type': 'object',
            'id': 'notifications',
            'properties': {
                'persistBetweenReboots': {
                    'type': 'boolean',
                    'default': true
                }
            }
        }];
    }

}

module.exports = function(name, deps) {
    return new Notifications(name, deps);
};