cylon/lib/api.js

126 lines
3.0 KiB
JavaScript
Raw Normal View History

/*
* Cylon API
* cylonjs.com
*
* Copyright (c) 2013-2014 The Hybrid Group
* Licensed under the Apache 2.0 license.
*/
"use strict";
2014-06-05 02:37:15 +08:00
var fs = require('fs'),
path = require('path');
2014-06-05 02:06:02 +08:00
var express = require('express'),
bodyParser = require('body-parser');
2014-04-04 03:28:27 +08:00
var Logger = require('./logger');
2014-05-08 06:19:23 +08:00
var API = module.exports = function API(opts) {
var self = this;
2014-05-08 06:19:23 +08:00
if (opts == null) {
opts = {};
}
2014-04-04 03:28:27 +08:00
2014-06-05 02:37:15 +08:00
for (var d in this.defaults) {
this[d] = opts.hasOwnProperty(d) ? opts[d] : this.defaults[d];
}
this.createServer();
2014-05-08 06:19:23 +08:00
this.server.set('title', 'Cylon API Server');
2014-06-05 04:39:30 +08:00
this.server.use(self.setupAuth());
this.server.use(bodyParser());
2014-05-08 06:19:23 +08:00
this.server.use(express["static"](__dirname + "/../node_modules/robeaux/"));
2014-06-05 04:39:30 +08:00
// set CORS headers for API requests
this.server.use(function(req, res, next) {
res.set("Access-Control-Allow-Origin", self.CORS || "*");
res.set("Access-Control-Allow-Headers", "Content-Type");
res.set('Content-Type', 'application/json');
return next();
});
// extracts command params from request
this.server.use(function(req, res, next) {
var method = req.method.toLowerCase(),
container = {};
req.commandParams = [];
if (method === 'get' || Object.keys(req.query).length > 0) {
container = req.query;
} else if (typeof(req.body) === 'object') {
container = req.body;
}
for (var p in container) {
req.commandParams.push(container[p]);
};
return next();
});
2014-06-05 04:39:30 +08:00
// load route definitions
this.server.use('/', require('./api/routes'))
2014-05-08 06:19:23 +08:00
};
2014-06-05 02:37:15 +08:00
API.prototype.defaults = {
host: '127.0.0.1',
port: '3000',
auth: false,
CORS: '',
ssl: {
2014-06-05 02:58:54 +08:00
key: path.normalize(__dirname + "/api/ssl/server.key"),
cert: path.normalize(__dirname + "/api/ssl/server.crt")
2014-06-05 02:37:15 +08:00
}
};
API.prototype.createServer = function createServer() {
this.server = express();
//configure ssl if requested
if (this.ssl && typeof(this.ssl) === 'object') {
var https = require('https');
this.server.node = https.createServer({
key: fs.readFileSync(this.ssl.key),
cert: fs.readFileSync(this.ssl.cert)
}, this.server);
} else {
Logger.warn("API using insecure connection. We recommend using an SSL certificate with Cylon.")
this.server.node = this.server;
}
};
API.prototype.setupAuth = function setupAuth() {
var authfn = function auth(req, res, next) { next(); };
if (typeof(this.auth) === 'object' && this.auth.type) {
var type = this.auth.type,
module = "./api/auth/" + type,
filename = path.normalize(__dirname + "/" + module + ".js"),
exists = fs.existsSync(filename);
if (exists) {
authfn = require(filename)(this.auth);
}
};
return authfn;
};
2014-05-08 06:19:23 +08:00
API.prototype.listen = function() {
var self = this;
this.server.node.listen(this.port, this.host, null, function() {
var title = self.server.get('title');
var protocol = self.ssl ? "https" : "http";
Logger.info(title + " is now online.");
Logger.info("Listening at " + protocol + "://" + self.host + ":" + self.port);
});
};