autorun.js

// Copyright (C) 2013 - Texas Instruments, Jason Kridner
//
//
var fs = require('fs');
var child_process = require('child_process');
var winston = require('winston');

var ar = '/var/lib/cloud9/autorun';
var apps = {};

winston.info('Starting bonescript autorun service');

fs.exists(ar, arExists);

function arExists(exists) {
    if(!exists) fs.mkdir(ar, arWatch);
    else fs.readdir(ar, arFound);
}

function arFound(err, files) {
    if(err) {
        winston.err('Error reading directory: ' + err);
        arWatch();
        return;
    }
    var i = 0;
    arTestNext();

    function arTestNext() {
        if(i == files.length) {
            arWatch();
            return;
        }
        appStart(files[i]);
        i++;
        arTestNext();
    }
}

function appStart(file) {
    if(apps[file]) return;
    appTest();

    function appTest() {
        fs.exists(ar + '/' + file, appExists);
    }

    function appExists(exists) {
        function onStdout(data) {
            winston.info('stdout (' + file + '): ' + data);
        }
        function onStderr(data) {
            winston.info('stderr (' + file + '):' + data);
        }
                
        if(exists) {
            if(typeof apps[file] != 'undefined') {
                winston.info('already running: ' + file);
                return;
            }
            
            if(file.match(/\.js$/)) {
                winston.info('start: ' + file);
                apps[file] = child_process.spawn(process.argv[0], [ar + '/' + file]);
                apps[file].on('close', appClosed);
                apps[file].stdout.on('data', onStdout);
                apps[file].stderr.on('data', onStderr);
            } else if(file.match(/\.py$/)) {
                winston.info('start: ' + file);
                apps[file] = child_process.spawn('/usr/bin/python', [ar + '/' + file]);
                apps[file].on('close', appClosed);
                apps[file].stdout.on('data', onStdout);
                apps[file].stderr.on('data', onStderr);
            } else if(file.match(/\.ino$/)) {
                winston.info('start: ' + file);
                apps[file] = child_process.spawn('/usr/bin/make', 
                    [
                        "-f",
                        "/var/lib/cloud9/extras/Userspace-Arduino/Makefile",
                        "TARGET=" + file.replace(/\.ino$/, ''),
                        "LOCAL_INO_SRCS=" + file,
                        "LOCAL_C_SRCS=",
                        "LOCAL_CPP_SRCS=",
                        "LOCAL_PDE_SRCS=",
                        "LOCAL_AS_SRCS=",
                        "COMMON_DEPS="
                    ],
                    { 'cwd': ar }
                );
                apps[file].on('close', appClosed);
                apps[file].stdout.on('data', onStdout);
                apps[file].stderr.on('data', onStderr);
            }
        }
    }

    function appClosed(code, signal) {
        delete apps[file];
        if(signal == 'SIGTERM') setTimeout(appTest, 1000);
    }
}

function arWatch() {
    fs.watch(ar, arWatcher);
}

function arWatcher(event, filename) {
    if(event == 'change') {
        winston.info('change: ' + filename);
        appStop(filename);
        appStart(filename);
    } else if(event == 'rename') {
        winston.info('rename: ' + filename);
        appStop(filename);
        appStart(filename);
    }
}

function appStop(file) {
    if(typeof apps[file] != 'undefined') {
        winston.info('stop: ' + file + ' (pid: ' + apps[file].pid + ')');
        apps[file].kill('SIGTERM');
    }
}