amcgee/remjs

var express = require('express');
var _ = require('lodash');
var REMOptions = require('./options');
var actions = require('./actions');
var PermissionsManager = require('./plugins/permissions');

var REMResource = function(name, opt, parent) {
    this.router = express.Router();
    this.name = name;
    this.options = new REMOptions(this, opt, parent);
    this.permissions = new PermissionsManager(this);

    this.engine = opt.engine;
    if ( !this.engine ) {
        if ( !parent ) {
            throw new Error("No engine specified for resource '" + this.name + "'.");
        }
        else {
            this.engine = parent.engine;
        }
    }

    this.children = [];
    if ( this.options.type === 'container' ) {
        this.serveChildren();
        this.subRouter = new REMResource('*', _.extend( {}, {engine: this.engine}, {
            datasource: function(req) {
                return req.rem.subresource;
            }
        }));
        this.router.use( '/:subresource', function(req, res, next){ req.rem.subresource = req.params.subresource; next(); }, this.subRouter.router );
        return;
    }
    if ( !_.isFunction(this.options.datasource) ) {
        this.db = this.makeDB(this.options.datasource);
    }

    if ( !this.options.private ) {
        this.router.use( this.tagRequest.bind(this) );

        _.forEach( actions, function( action, action_name ) {
            if ( !_.contains(this.options.forbid, action_name) ) {
                if ( action.middleware ) {
                    this.router.use( action.path, action.middleware.bind(this) );
                }
                this.router[action.method]( action.path
                                            , this.permissions.apply.bind(this.permissions, action.type)
                                            , action.handler );
            }
        }.bind(this));

        this.serveChildren();
    }
};
REMResource.prototype.makeDB = function(datasource) {
    return this.engine.collection(datasource); // TODO: Robustify
};
REMResource.prototype.tagRequest = function(req, res, next) {
    req.rem.resource = this;
    req.rem.db = this.db || this.makeDB( this.options.datasource(req) );
    next();
};
REMResource.prototype.serveChildren = function() {
    var child_middleware = require('./actions/helpers/save-id').bind(this);
    _.forEach( this.options.children, function(child_options, child_name) {
        this.children[child_name] = new REMResource(child_name, child_options, this);
        this.router.use( '/:id/' + child_name, child_middleware, this.children[child_name].router );
    }.bind(this));
};

module.exports = REMResource;