index.js

#!/usr/bin/env node

/**
 * Module dependencies.
 */

var program = require('commander');
var colors = require('colors');
var Opent2tHelper = require("./Opent2tHelper");
var fs = require('fs');
var path = require('path');
var inquirer = require('inquirer');
var q = require('q');
var helpers = require('./helpers');
var opent2tHelper = new Opent2tHelper();
var MainController = require("./controllers/mainController");
var configRoot = process.cwd();

// set theme 
colors.setTheme({
    silly: 'rainbow',
    header: 'cyan',
    state: 'yellow'
});

program
    .version('1.0.0')
    .option('-o --onboarding [Translator Package Name]', 'Do onboarding for specified thing')
    .option('-h --hub [Hub Name]', 'Gets devices for the given hub')
    .option('-r --refreshAuthToken [Translator Package Name]', 'Refresh the oauth token for the given hub')
    .option('-x --deauthorizeToken [Translator Package Name]', 'Deauthorize the oauth token for the given hub')

    .option('-t --translator [Translator Package Name]', 'Do get property for specified thing, requires -p')
    .option('-i --id [Control id]', 'Control id you want to use')
    .option('-d --di [Device id]', 'Device id of the resource you want to control')
    .option('-g --get [RAML property name]', 'Property name to GET for -t')
    .option('-s --set [RAML property name]', 'Property name to SET for -t')
    .option('-v --value [value]', 'Stringified JSON value to pass in')
    .option('-m --menu', 'Launch interactive menu')
    .parse(process.argv);

console.log('Open Translators to Things CLI:');
console.log('');

if (program.menu) {
    prompt({ currentController: new MainController(), controllerStack: [] });
}

else if (program.onboarding) {
    if (program.hub === undefined) {
        console.log("Need to provide hub name, -h <hub name>");
        return;
    }

    console.log("------ Doing onboarding for %j".header, program.onboarding);

    let fileName = path.join(configRoot, helpers.createOnboardingFileName(program.hub));

    opent2tHelper.doOnboarding(program.onboarding).then(info => {
        let configData = helpers.createConfigData(program.hub, program.onboarding, info);
        let data = JSON.stringify(configData);
        helpers.logObject(info);
        console.log("------ Saving onboardingInfo to: " + fileName);
        fs.writeFile(fileName, data, function (err) {
            if (err) {
                console.log(err);
                return console.log(err);
            }
            console.log("Saved!");
        });
    }).catch(err => {
        helpers.logError(err);
    });
}

// this is for devices which communicate via a hub translator (hub device or central cloud)
else if (program.translator && program.hub) {
    console.log("------ Hub + translator for %j %j".header, program.hub, program.translator);

    if (program.id === undefined) {
        console.log("Need to provide id, -i <id>");
        return;
    }

    let fileName = path.join(configRoot, helpers.createOnboardingFileName(program.hub));
    helpers.readFile(fileName, "Please complete onboarding -o").then(data => {
        var configInfo = JSON.parse(data);
        var deviceInfo = configInfo.authInfo;
        opent2tHelper.createTranslator(configInfo.translatorPackageName, deviceInfo).then(hub => {
            var fileName = path.join(configRoot, helpers.createHubDeviceFileName(program.translator, program.id));
            console.log(fileName);
            helpers.readFile(fileName, "Please complete hub -h before calling -t").then(data => {
                var deviceInfo = JSON.parse(data);
                var dInfo = { 'deviceInfo': deviceInfo, 'hub': hub };

                if (program.get) {

                    // If a device/entity id was provided, then pass it, otherwise pass expand=true
                    var value = true;
                    if (program.di) {
                        value = program.di;
                    }

                    opent2tHelper.getProperty(program.translator, dInfo, program.get, value).then(info => {
                        helpers.logObject(info);
                    }).catch(error => {
                        helpers.logError(error);
                    });
                }
                else if (program.set) {
                    var parsedValue = undefined;
                    try {
                        parsedValue = JSON.parse(program.value);
                    } catch (e) {
                        helpers.logError("Failed to parse JSON: " + program.value);
                        return;
                    }

                    opent2tHelper.setProperty(program.translator, dInfo, program.set, program.di, parsedValue).then(info => {
                        helpers.logObject(info)
                    }).catch(error => {
                        helpers.logError(error);
                    });
                }
            });
        });
    }).catch(error => {
        helpers.logError(error);
    });
}

else if (program.hub) {
    console.log("------ Hub enumerate devices for %j".header, program.hub);

    let fileName = path.join(configRoot, helpers.createOnboardingFileName(program.hub));
    helpers.readFile(fileName, "Please complete onboarding -o").then(data => {
        var configInfo = JSON.parse(data);
        var deviceInfo = configInfo.authInfo;
        opent2tHelper.getProperty(configInfo.translatorPackageName, deviceInfo, 'getPlatforms').then(info => {
            helpers.logObject(info);
            helpers.writeArrayToFile(info.platforms, configRoot, "_device_", "controlId");
        }).catch(error => {
            helpers.logError(error);
        });
    }).catch(error => {
        helpers.logError(error);
    });
}
else if (program.refreshAuthToken) {
    console.log("------ Refreshing oAuth token for hub %j".header, program.refreshAuthToken);
    let fileName = path.join(configRoot, helpers.createOnboardingFileName(program.refreshAuthToken));
    helpers.readFile(fileName, "Please complete onboarding -o").then(data => {
        let configInfo = JSON.parse(data);
        let authInfo = configInfo.authInfo;
        opent2tHelper.loadTranslatorAndGetOnboardingAnswers(configInfo.translatorPackageName).then(answers => {
            opent2tHelper.getProperty(configInfo.translatorPackageName, authInfo, 'refreshAuthToken', answers).then(refreshedInfo => {
                helpers.logObject(refreshedInfo);
                console.log("------ Saving refreshed onboardingInfo to: " + fileName);
                let configData = helpers.createConfigData(configInfo.translator, configInfo.translatorPackageName, refreshedInfo);
                let refreshedData = JSON.stringify(configData);
                fs.writeFile(fileName, refreshedData, function (err) {
                    if (err) {
                        console.log(err);
                        return console.log(err);
                    }
                    console.log("Saved!");
                });

            }).catch(error => {
                helpers.logError(error);
            });
        });
    }).catch(error => {
        helpers.logError(error);
    });
} else if (program.deauthorizeToken) {
    console.log("------ Deauthorizing oAuth token for hub %j".header, program.deauthorizeToken);
    let fileName = path.join(configRoot, helpers.createOnboardingFileName(program.deauthorizeToken));
    helpers.readFile(fileName, "Please complete onboarding -o").then(data => {
        let configInfo = JSON.parse(data);
        let authInfo = configInfo.authInfo;
        opent2tHelper.loadTranslatorAndGetOnboardingAnswers(configInfo.translatorPackageName).then(answers => {
            opent2tHelper.getProperty(configInfo.translatorPackageName, authInfo, 'deauthorizeToken', answers).then(refreshedInfo => {
                console.log("Deauthorized token.");
            }).catch(error => {
                helpers.logError(error);
            });
        });
    }).catch(error => {
        helpers.logError(error);
    });
}

// this is for top level devices which don't require a hub
else if (program.translator) {
    console.log("------ Doing translator for %j".header, program.translator);

    var fileName = helpers.createHubDeviceFileName(program.translator, program.id);
    helpers.readFile(fileName, "Please complete onboarding -o").then(data => {
        var deviceInfo = JSON.parse(data);
        var dInfo = { 'deviceInfo': deviceInfo, 'hub': undefined };

        opent2tHelper.getProperty(program.translator, deviceInfo, program.get).then(info => {
            helpers.logObject(info);
        }).catch(error => {
            helpers.logError(error);
        });
    }).catch(error => {
        helpers.logError(error);
    });
}

else {
    program.outputHelp(make_red);
}

function make_red(txt) {
    //display the help text in red on the console
    return colors.red(txt);
}

function prompt(state) {
    state.currentController.logState(state);
    let operations = state.currentController.getOperations(state);

    let question = {
        type: 'rawlist',
        name: 'choice',
        message: 'What would you like to do?',
        choices: operations.map(o => o.name)
    };

    inquirer.prompt([question]).then(function (answers) {
        if (answers.choice !== 'Exit') {
            let choice = operations.find(o => o.name === answers.choice);
            if (choice !== undefined) {
                process.stdout.write('\033c');
                choice.operation(state).then(prompt)
                    .catch(err => {
                        helpers.logError(err);
                        prompt(state);
                    });
            }
            else {
                helpers.logError('Unknown operation');
                prompt(state);
            }
        }
        else {
            let question = {
                type: 'confirm',
                name: 'exit',
                message: 'Are you sure you want to exit?'
            };

            inquirer.prompt([question]).then(function (answers) {
                if (!answers.exit) {
                    prompt(state);
                }
            });
        }
    });
}