cylon/lib/api.js

/*
 * api
 * cylonjs.com
 *
 * Copyright (c) 2013-2014 The Hybrid Group
 * Licensed under the Apache 2.0 license.
*/

"use strict";

var express = require('express.io');
var namespace = require('node-namespace');

namespace("Cylon", function() {
  // The Cylon API Server provides an interface to communicate with master class
  // and retrieve information about the robots being controlled.
  this.ApiServer = (function() {
    var master;

    master = null;

    function ApiServer(opts) {
      var _this = this;
      if (opts == null) {
        opts = {};
      }
      this.host = opts.host || "127.0.0.1";
      this.port = opts.port || "3000";
      master = opts.master;
      this.server = express().http().io();
      this.server.set('title', 'Cylon API Server');
      this.server.use(express.json());
      this.server.use(express.urlencoded());
      this.server.use(express["static"](__dirname + "/../node_modules/robeaux/"));
      this.server.get("/*", function(req, res, next) {
        res.set('Content-Type', 'application/json');
        return next();
      });
      this.configureRoutes();
      this.server.listen(this.port, this.host, function() {
        return Logger.info("" + (_this.server.get('title')) + " is listening on " + _this.host + ":" + _this.port);
      });
    }

    // Parses req to extract params to be used for commands.
    //
    // Returns an array of params
    ApiServer.prototype.parseCommandParams = function(req) {
      var param_container, params, v, _;
      params = [];
      param_container = {};
      if (req.method === 'GET' || Object.keys(req.query).length > 0) {
        param_container = req.query;
      } else if (typeof req.body === 'object') {
        param_container = req.body;
      }
      for (_ in param_container) {
        v = param_container[_];
        params.push(v);
      }
      return params;
    };

    ApiServer.prototype.configureRoutes = function() {
      var _this = this;

      this.server.get("/robots", function(req, res) {
        var robot;
        return res.json((function() {
          var _i, _len, _ref, _results;
          _ref = master.robots();
          _results = [];
          for (_i = 0, _len = _ref.length; _i < _len; _i++) {
            robot = _ref[_i];
            _results.push(robot.data());
          }
          return _results;
        })());
      });

      this.server.get("/robots/:robotname", function(req, res) {
        return master.findRobot(req.params.robotname, function(err, robot) {
          return res.json(err ? err : robot.data());
        });
      });

      this.server.get("/robots/:robotname/commands", function(req, res) {
        return master.findRobot(req.params.robotname, function(err, robot) {
          return res.json(err ? err : robot.data().commands);
        });
      });

      this.server.all("/robots/:robotname/commands/:commandname", function(req, res) {
        var params;
        params = _this.parseCommandParams(req);
        return master.findRobot(req.params.robotname, function(err, robot) {
          var result;
          if (err) {
            return res.json(err);
          }
          result = robot[req.params.commandname].apply(robot, params);
          return res.json({
            result: result
          });
        });
      });

      this.server.get("/robots/:robotname/devices", function(req, res) {
        return master.findRobot(req.params.robotname, function(err, robot) {
          return res.json(err ? err : robot.data().devices);
        });
      });

      this.server.get("/robots/:robotname/devices/:devicename", function(req, res) {
        var devicename, robotname, _ref;
        _ref = [req.params.robotname, req.params.devicename], robotname = _ref[0], devicename = _ref[1];
        return master.findRobotDevice(robotname, devicename, function(err, device) {
          return res.json(err ? err : device.data());
        });
      });

      this.server.get("/robots/:robotname/devices/:devicename/commands", function(req, res) {
        var devicename, robotname, _ref;
        _ref = [req.params.robotname, req.params.devicename], robotname = _ref[0], devicename = _ref[1];
        return master.findRobotDevice(robotname, devicename, function(err, device) {
          return res.json(err ? err : device.data().commands);
        });
      });

      this.server.all("/robots/:robot/devices/:device/commands/:commandname", function(req, res) {
        var commandname, devicename, params, robotname;
        params = [req.params.robot, req.params.device, req.params.commandname];
        robotname = params[0], devicename = params[1], commandname = params[2];
        params = _this.parseCommandParams(req);
        return master.findRobotDevice(robotname, devicename, function(err, device) {
          var result;
          if (err) {
            return res.json(err);
          }
          result = device[commandname].apply(device, params);
          return res.json({
            result: result
          });
        });
      });

      this.server.get("/robots/:robotname/connections", function(req, res) {
        return master.findRobot(req.params.robotname, function(err, robot) {
          return res.json(err ? err : robot.data().connections);
        });
      });

      this.server.get("/robots/:robot/connections/:connection", function(req, res) {
        var connectionname, robotname, _ref;
        _ref = [req.params.robot, req.params.connection], robotname = _ref[0], connectionname = _ref[1];
        return master.findRobotConnection(robotname, connectionname, function(err, connection) {
          return res.json(err ? err : connection.data());
        });
      });

      this.server.get("/robots/:robotname/devices/:devicename/events", function(req, res) {
        return req.io.route('events');
      });

      return this.server.io.route('events', function(req) {
        var devicename, robotname, _ref;
        _ref = [req.params.robotname, req.params.devicename], robotname = _ref[0], devicename = _ref[1];
        return master.findRobotDevice(robotname, devicename, function(err, device) {
          if (err) {
            req.io.respond(err);
          }
          return device.on('update', function(data) {
            return req.io.emit('update', {
              data: data
            });
          });
        });
      });
    };

    return ApiServer;

  })();
});

module.exports = Cylon.ApiServer;