Windshaft-cartodb/lib/cartodb/backends/analysis.js

var camshaft = require('camshaft');
var fs = require('fs');

function AnalysisBackend (options) {
    options = options || {};
    this.setBatchConfig(options.batch);
    this.setLoggerConfig(options.logger);
}

module.exports = AnalysisBackend;

AnalysisBackend.prototype.setBatchConfig = function (options) {
    var batchConfig = options || {};
    batchConfig.endpoint = batchConfig.endpoint || 'http://127.0.0.1:8080/api/v1/sql/job';
    batchConfig.inlineExecution = batchConfig.inlineExecution || false;
    batchConfig.hostHeaderTemplate = batchConfig.hostHeaderTemplate || '{{=it.username}}.localhost.lan';
    this.batchConfig = batchConfig;
};

AnalysisBackend.prototype.setLoggerConfig = function (options) {
    var loggerConfig = options || {};
    loggerConfig.filename = loggerConfig.filename;

    this.loggerConfig = loggerConfig;
};

AnalysisBackend.prototype.create = function(analysisConfiguration, analysisDefinition, callback) {
    analysisConfiguration.batch.endpoint = this.batchConfig.endpoint;
    analysisConfiguration.batch.inlineExecution = this.batchConfig.inlineExecution;
    analysisConfiguration.batch.hostHeaderTemplate = this.batchConfig.hostHeaderTemplate;
    analysisConfiguration.logger = {
        stream: this.loggerConfig.filename ? fs.createWriteStream(this.loggerConfig.filename) : process.stdout
    };

    camshaft.create(analysisConfiguration, analysisDefinition, callback);
};