index.js

/*

To rebuild: $(npm bin)/electron-rebuild
https://github.com/electron/electron-rebuild
To run: npm start

 */

const electron = require('electron');
const {app, BrowserWindow, ipcMain} = electron;

const server = require("./Server/Server");
const device = require("./Device/Device");

let devices = [];

let mainWindow = null;
let currentServer = null;

function createWindow(){

    const {width, height} = electron.screen.getPrimaryDisplay().workAreaSize;

    mainWindow = new BrowserWindow({width, height, webPreferences:{
        nodeIntegration: true
        }
    });
    mainWindow.loadURL("file://" + __dirname + "/renderer/index.html");

    mainWindow.focus();
    //dev tools
   // mainWindow.webContents.openDevTools();

    ipcMain.on('startDevice', (evt, type, id) =>{
        console.log('type', type, 'device id', id);

        let newDevice = new (require('./Device/Devices/' + type))(id, type);
        newDevice.start();

        newDevice.onError = err => {
            console.log(err);
            evt.sender.send('startError', err);
        };

        devices.push(newDevice);

        devices.forEach(d => {
            d.onImage = (img, frameType) => {
                let id = d.id;
                // console.log("sending image from " + d.type);
                evt.sender.send('image', {device: d.type, id, img, frameType});
            };
        });

        evt.sender.send('startedDevice', type, id);

        console.log(`${devices.length} total Devices connected`);

    });

    ipcMain.on('startServer', (evt, port) => {
        let portNum = port;

        console.log('opening port', portNum);

        currentServer = new server.Server(portNum, () =>{
            console.log('server started on', portNum);
            evt.sender.send('startedServer', portNum);
        })
    });

    ipcMain.on('startDepth', (evt, type, id) =>{
        devices[id].getDepth();
    });

    ipcMain.on('stopDepth', (evt, type, id) =>{
        devices[id].depthFeed = false;
    });

    ipcMain.on('startColor', (evt, type, id) =>{
        devices[id].getColor();
    });

    ipcMain.on('stopColor', (evt, type, id) =>{
        devices[id].colorFeed = false;
    });

    ipcMain.on("setSize", (evt, type, id, w, h) => {
        devices[id].setSize(w, h)
    });

    ipcMain.on('close', (evt) => {
        //currentServer.stop();

        devices.forEach(d => {
            d.stop();
        });

        evt.sender.send('closed');

        devices = [];
    });

    // ipcMain.on('closeServer', (evt) => {
    //     currentServer.stop();
    //     evt.sender.send('closedServer');
    //
    //     console.log('server closed');
    // });

    ipcMain.on('closeDevice', (evt, id) => {
        devices[id].stop();
        console.log('closed device of id ' + id);
        evt.sender.send('closedDevice', id);
        devices.splice(id, 1);

        console.log(devices.length);
    });

    mainWindow.on('closed', function(){
        mainWindow = null;
    });
}

app.on('ready', createWindow);

app.on('activate', function(){
   if(mainWindow == null){
      createWindow();
   }
});

app.on('window-all-closed', function(){

    for(let i = 0; i < devices.length; i++){
        devices[i].stop();
    }

    app.removeAllListeners();
    app.quit();

    console.log('quit renderer');
});