server.js

/* 
Copyright 2011 Hewlett-Packard Company. This library is free software;
you can redistribute it and/or modify it under the terms of the GNU
Lesser General Public License (LGPL) as published by the Free Software
Foundation; either version 2.1 of the License, or (at your option) any
later version.  This library is distributed in the hope that it will
be useful, but WITHOUT ANY WARRANTY; without even the implied warranty
of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
Lesser General Public License for more details.  You should have
received a copy of the GNU Lesser General Public License (LGPL) along
with this library; if not, write to the Free Software Foundation,
Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
Please contact the Hewlett-Packard Company <www.hp.com> for
information regarding how to obtain the source code for this library.
*/

/*global require, console, process */
"use strict";
var https = require("https");
var fs = require("fs");
var express = require("express");
var Q = require("q");
var caplib = require("./caplib");
var saver = require("./saver");
var log = function(text) {console.log(text);};

var domain;
var port;
var deferStart = Q.defer();
fs.readFile("capper.config", "utf8", function(err, data) {
    if (err) {log("bad capper.config file" + err); throw(err);}
    var config = JSON.parse(data);
    port = config.port;
    domain = config.protocol + "://" + config.domain + ":" + config.port + "/";
    log("config domain " + domain);
    deferStart.resolve(true);
});
var sslOptions = {
  key: fs.readFileSync('./ssl/server.key'),
  cert: fs.readFileSync('./ssl/server.crt'),
  ca: fs.readFileSync('./ssl/ca.crt'),
  requestCert: true,
  rejectUnauthorized: false
};
var app = express();
function parseBody(req, res, next) {
  req.rawBody = '';
  req.setEncoding('utf8');

  req.on('data', function(chunk) { 
    req.rawBody += chunk;
  });

  req.on('end', function() {
    try {req.body = JSON.parse(req.rawBody);} catch (e) {}
    next();
  });
}

function reviverToUIPath(reviver) {
    var revstring = "./apps/";
    var parts = reviver.split(".");
    revstring = revstring + parts[0] + "/ui/";
    var filename = parts.length > 1 ? parts[1] : "index";
    revstring += filename + ".html";
    return revstring;
}
function getObj(req) {
    var cred = req.query.s;
    var id = saver.credToId(cred);
    var reviver = saver.reviver(id);
    var live = saver.live(id);
    return {
        cred: cred,
        reviver: reviver,
        live: live,
        id: id,
        method: req.query.q
    };
}
/**
* webkeyToLive(wkeyObj) looks to see if the arg is a webkeyObject, if so, 
* returns a live ref, otherwise returns the arg unchanged
*/
function webkeyToLive(wkeyObj) {
    try {
        if (wkeyObj["@"]) {
            var cred = wkeyObj["@"].split("#s=")[1];
            //log("wkeyObj is webkey, cred is " + cred);
            return saver.live(saver.credToId(cred));
        } else {return wkeyObj;}
    } catch (err) {return wkeyObj;}
}
function idToWebkey(id) {
    return domain + "ocaps/#s=" + saver.idToCred(id);
}
app.get("/views/:filename", function(req, res) {
	res.sendfile("./views/" + req.params.filename);
});
app.get("/views/:path1/:filename", function(req, res) {
    res.sendfile("./views/" + req.params.path1 + "/" + req.params.filename);
});
app.get("/apps/:theapp/ui/:filename", function(req, res) {
    res.sendfile("./apps/" + req.params.theapp + "/ui/" + req.params.filename);
});
app.get('/', function(req, res) {
    res.sendfile('./views/index.html');
});
function showActor(req, res) {
    if (!req.query.s ) {
        res.sendfile("./bootstrap.html");
    } else {
        try {
            var objdata = getObj(req);
            if (!objdata.live) {res.send("no such object");}
            //res.setHeader("Content-Security-Policy", "default-src: 'self'");
            //log("set CSP header");
            //res.writeHead(200)
            res.sendfile(reviverToUIPath(objdata.reviver));
        } catch (err) {
            res.send("Object not Found");
            //res.close();
        }
    }
}
app.get("/ocaps/", showActor);

function vowAnsToVowJSONString(vowAns) {    
    return vowAns.then(function(ans) {
        var result = caplib.deepObjToJSON(ans, idToWebkey, saver);
        log(JSON.stringify(result))
        if (result !== null && typeof result === "object" && ("@" in result)) {
            return JSON.stringify(result);            
        } else {return JSON.stringify({"=": result});}     
   }, function(err){
        log("vowAnsToVowJSONString err " + err);
        return JSON.stringify({"!": err});
   });
}

function invokeActor(req, res){
    log("post query " + JSON.stringify(req.query));
    log("post body: " + JSON.stringify(req.body));
    var objdata = getObj(req);
    if (!objdata.live) {
        res.send(JSON.stringify({"!": "bad object invoked"}));
        log("bad object invoked: " + JSON.stringify(req.query));
        return;
    }
    var args = req.body; //body already parsed
    var translatedArgs = [objdata.id, objdata.method];
    args.forEach(function(next) {translatedArgs.push(webkeyToLive(next));});
    var vowAns = saver.deliver.apply(null, translatedArgs);
    vowAnsToVowJSONString(vowAns).then(function(jsonString){
        log("returning: " + jsonString);
        res.send(jsonString);
    });
}
app.post("/ocaps/", parseBody, invokeActor);

function wkeyStringToLive(keyString) {
    return webkeyToLive({"@": keyString});
}
deferStart.promise.then(function(){
    var argMap = caplib.argMap(process.argv, wkeyStringToLive);
    if ("-drop" in argMap) {
        saver.drop(saver.credToId(argMap["-drop"][0]));
        saver.checkpoint().then(function() {console.log("drop done");});
    } else if ("-make" in argMap){
        var obj = saver.make.apply(undefined, argMap["-make"]);
        if (!obj) {log("cannot find maker " + argMap["-make"]); return;}
        saver.checkpoint().then(function() {
            log(idToWebkey(saver.asId(obj)));
        });
    } else if ("-post" in argMap) {
        var args = argMap["-post"];
        if (typeof args[0] !== "object") {
            log("bad target object webkey; forget '@'?");
        } else if (typeof args[1] !== "string") {
            log("method to invoke is not a string");
        } else {
            args[0] = saver.asId(args[0]);
            var vowAns = saver.deliver.apply(undefined, args);
            vowAnsToVowJSONString(vowAns).then(function(answer){
                log(answer);
            });
        }
    } else {
        var s = https.createServer(sslOptions, app);
        s.listen(port);    
    }
});