pumpbridge: app.js_to_pump.io-client-app

annotate app.js_to_pump.io-client-app_lib @ 22:b90e6df48d2d

eachLimit instead of each

author	Mathias Gebbe <mgebbe@intevation.de>
date	Mon, 16 Jun 2014 17:31:05 +0200
parents	f190abf340ef
children

rev	line source
0 b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	1 // app.js
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	2 //
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	3 // entrypoint for pump.io-enabled node.js apps
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	4 //
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	5 // Copyright 2013, E14N https://e14n.com/
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	6 //
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	7 // Licensed under the Apache License, Version 2.0 (the "License");
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	8 // you may not use this file except in compliance with the License.
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	9 // You may obtain a copy of the License at
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	10 //
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	11 // http://www.apache.org/licenses/LICENSE-2.0
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	12 //
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	13 // Unless required by applicable law or agreed to in writing, software
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	14 // distributed under the License is distributed on an "AS IS" BASIS,
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	15 // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	16 // See the License for the specific language governing permissions and
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	17 // limitations under the License.
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	18
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	19 var fs = require("fs"),
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	20 async = require("async"),
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	21 path = require("path"),
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	22 http = require("http"),
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	23 https = require("https"),
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	24 _ = require("underscore"),
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	25 express = require('express'),
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	26 DialbackClient = require("dialback-client"),
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	27 Logger = require("bunyan"),
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	28 routes = require('./routes'),
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	29 databank = require("databank"),
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	30 uuid = require("node-uuid"),
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	31 Databank = databank.Databank,
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	32 DatabankObject = databank.DatabankObject,
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	33 DatabankStore = require('connect-databank')(express),
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	34 RequestToken = require("./models/requesttoken"),
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	35 RememberMe = require("./models/rememberme"),
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	36 User = require("./models/user"),
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	37 Host = require("./models/host"),
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	38 site = require("./models/site"),
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	39 auth = require("./auth.js"),
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	40 defaults = {
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	41 port: 4000,
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	42 hostname: "localhost",
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	43 driver: "memory",
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	44 params: null,
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	45 name: "An unconfigured pump.io client",
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	46 description: "A pump.io client that is not correctly configured.",
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	47 logfile: null,
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	48 loglevel: "info",
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	49 nologger: false,
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	50 key: null,
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	51 cert: null,
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	52 sessionSecret: "insecure",
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	53 static: null,
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	54 address: null,
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	55 useCDN: true
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	56 };
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	57
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	58 var PumpIOClientApp = function(configArg) {
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	59
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	60 var clap = this,
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	61 config = _.defaults(configArg, defaults),
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	62 log,
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	63 db,
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	64 app,
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	65 setupLog = function() {
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	66 var logParams = {
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	67 serializers: {
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	68 req: Logger.stdSerializers.req,
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	69 res: Logger.stdSerializers.res,
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	70 err: Logger.stdSerializers.err
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	71 },
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	72 level: config.loglevel
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	73 };
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	74
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	75 if (config.logfile) {
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	76 logParams.streams = [{path: config.logfile}];
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	77 } else if (config.nologger) {
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	78 logParams.streams = [{path: "/dev/null"}];
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	79 } else {
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	80 logParams.streams = [{stream: process.stderr}];
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	81 }
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	82
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	83 logParams.name = config.name;
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	84
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	85 log = new Logger(logParams);
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	86
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	87 log.debug("Initializing");
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	88
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	89 // Configure the service object
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	90
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	91 log.debug({name: config.name,
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	92 description: config.description,
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	93 hostname: config.hostname},
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	94 "Initializing site object");
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	95 },
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	96 setupSite = function() {
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	97 site.name = config.name;
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	98 site.description = config.description;
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	99 site.hostname = config.hostname;
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	100
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	101 site.protocol = (config.key) ? "https" : "http";
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	102 },
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	103 setupDB = function(callback) {
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	104 if (!config.params) {
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	105 if (config.driver == "disk") {
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	106 config.params = {dir: "/var/lib/"+config.hostname+"/"};
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	107 } else {
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	108 config.params = {};
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	109 }
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	110 }
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	111
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	112 // Define the database schema
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	113
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	114 if (!config.params.schema) {
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	115 config.params.schema = {};
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	116 }
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	117
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	118 _.extend(config.params.schema, DialbackClient.schema);
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	119 _.extend(config.params.schema, DatabankStore.schema);
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	120
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	121 // Now, our stuff
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	122
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	123 _.each([User, Host, RequestToken, RememberMe], function(Cls) {
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	124 config.params.schema[Cls.type] = Cls.schema;
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	125 });
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	126
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	127 db = Databank.get(config.driver, config.params);
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	128
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	129 log.debug({driver: config.driver, params: config.params},
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	130 "Connecting to DB");
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	131
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	132 // Set global databank info
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	133
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	134 DatabankObject.bank = db;
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	135 },
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	136 requestLogger = function(log) {
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	137 return function(req, res, next) {
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	138 var weblog = log.child({"req_id": uuid.v4(), component: "web"});
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	139 var end = res.end;
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	140 req.log = weblog;
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	141 res.end = function(chunk, encoding) {
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	142 var rec;
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	143 res.end = end;
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	144 res.end(chunk, encoding);
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	145 rec = {req: req, res: res};
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	146 weblog.info(rec);
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	147 };
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	148 next();
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	149 };
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	150 },
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	151 setupApp = function() {
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	152 var client;
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	153
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	154 app = new express();
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	155
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	156 // Configuration
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	157
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	158 var dbstore = new DatabankStore(db, log, 60000);
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	159
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	160 log.debug("Configuring app");
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	161
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	162 app.configure(function(){
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	163 var serverVersion = site.userAgent() + ' express/'+express.version + ' node.js/'+process.version,
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	164 versionStamp = function(req, res, next) {
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	165 res.setHeader('Server', serverVersion);
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	166 next();
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	167 },
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	168 appObject = function(req, res, next) {
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	169 req.site = site;
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	170 res.locals.site = site;
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	171 res.locals.config = req.app.config;
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	172 next();
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	173 };
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	174
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	175 app.set('views', path.join(__dirname, '../../../views'));
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	176 app.set('view engine', 'jade');
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	177 app.use(requestLogger(log));
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	178 app.use(versionStamp);
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	179 app.use(appObject);
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	180 app.use(express.bodyParser());
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	181 app.use(express.cookieParser());
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	182 app.use(express.methodOverride());
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	183 app.use(express.session({secret: config.sessionSecret,
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	184 cookie: {path: '/', httpOnly: true},
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	185 store: dbstore}));
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	186 app.use(app.router);
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	187 if (config.static) {
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	188 app.use(express.static(config.static));
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	189 }
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	190 app.use(express.static(path.join(__dirname, 'public')));
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	191 });
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	192
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	193 app.configure('development', function(){
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	194 app.use(express.errorHandler({ dumpExceptions: true, showStack: true }));
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	195 });
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	196
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	197 app.configure('production', function(){
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	198 app.use(express.errorHandler());
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	199 });
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	200
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	201 // Routes
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	202
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	203 log.debug("Initializing routes");
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	204
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	205 app.get('/', auth.userAuth, auth.userOptional, routes.index);
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	206 app.get('/login', auth.userAuth, auth.noUser, routes.login);
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	207 app.post('/login', auth.userAuth, auth.noUser, routes.handleLogin);
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	208 app.post('/logout', auth.userAuth, auth.userRequired, routes.handleLogout);
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	209 app.get('/authorized/:hostname', routes.authorized);
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	210 app.get('/.well-known/host-meta.json', routes.hostmeta);
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	211
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	212 // Create a dialback client
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	213
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	214 log.debug("Initializing dialback client");
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	215
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	216 client = new DialbackClient({
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	217 hostname: config.hostname,
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	218 app: app,
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	219 bank: db,
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	220 userAgent: site.userAgent()
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	221 });
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	222
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	223 // Configure this global object
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	224
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	225 Host.dialbackClient = client;
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	226
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	227 // Let Web stuff get to config
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	228
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	229 app.config = config;
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	230
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	231 // For handling errors
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	232
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	233 app.log = function(obj) {
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	234 if (obj instanceof Error) {
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	235 log.error(obj);
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	236 } else {
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	237 log.info(obj);
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	238 }
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	239 };
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	240 };
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	241
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	242 // Dynamic default
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	243
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	244 if (!config.address) {
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	245 config.address = config.hostname;
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	246 }
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	247
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	248 // Set up aspects
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	249
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	250 setupLog();
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	251 setupSite();
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	252 setupDB();
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	253 setupApp();
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	254
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	255 // Delegate
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	256
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	257 _.each(_.functions(app), function(name) {
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	258 clap[name] = function() {
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	259 app[name].apply(app, arguments);
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	260 };
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	261 });
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	262
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	263 // Expose the log so clients can use it
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	264
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	265 clap.log = log;
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	266
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	267 // Expose the site so clients can use it
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	268
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	269 clap.site = site;
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	270
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	271 // Run
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	272
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	273 clap.run = function(callback) {
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	274
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	275 var srv,
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	276 bounce;
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	277
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	278 if (config.key) {
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	279
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	280 log.debug("Using SSL");
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	281
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	282 srv = https.createServer({key: fs.readFileSync(config.key),
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	283 cert: fs.readFileSync(config.cert)},
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	284 app);
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	285
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	286 bounce = http.createServer(function(req, res, next) {
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	287 var host = req.headers.host,
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	288 url = 'https://'+host+req.url;
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	289 res.writeHead(301, {'Location': url,
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	290 'Content-Type': 'text/html'});
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	291 res.end('<a href="'+url+'">'+url+'</a>');
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	292 });
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	293
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	294 } else {
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	295 log.debug("Not using SSL");
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	296 srv = http.createServer(app);
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	297 }
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	298
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	299 // Start the app
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	300
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	301 async.waterfall([
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	302 function(callback) {
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	303 db.connect(config.params, callback);
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	304 },
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	305 function(callback) {
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	306 // Wrapper function to give a callback-like interface to network servers
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	307 var listenBack = function(server, port, address, callback) {
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	308 var a,
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	309 removeListeners = function() {
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	310 server.removeListener("listening", listenSuccessHandler);
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	311 server.removeListener("error", listenErrorHandler);
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	312 },
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	313 listenErrorHandler = function(err) {
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	314 removeListeners();
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	315 callback(err);
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	316 },
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	317 listenSuccessHandler = function() {
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	318 removeListeners();
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	319 callback(null);
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	320 };
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	321 server.on("error", listenErrorHandler);
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	322 server.on("listening", listenSuccessHandler);
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	323 server.listen(port, address);
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	324 };
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	325
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	326 async.parallel([
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	327 function(callback) {
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	328 log.debug({port: config.port, address: config.address}, "Starting app listener");
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	329 listenBack(srv, config.port, config.address, callback);
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	330 },
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	331 function(callback) {
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	332 if (bounce) {
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	333 log.debug({port: 80, address: config.address}, "Starting bounce listener");
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	334 listenBack(bounce, 80, config.address, callback);
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	335 } else {
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	336 callback(null, null);
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	337 }
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	338 }
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	339 ], callback);
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	340 }
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	341 ], function(err, results) {
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	342 // Ignore meaningless results
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	343 callback(err);
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	344 });
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	345 };
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	346 };
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	347
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	348 // Export the auth methods
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	349
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	350 _.each(_.keys(auth), function(key) {
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	351 PumpIOClientApp[key] = auth[key];
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	352 });
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	353
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	354 // Export the model classes
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	355
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	356 PumpIOClientApp.User = User;
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	357 PumpIOClientApp.Host = Host;
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	358 PumpIOClientApp.RequestToken = RequestToken;
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	359 PumpIOClientApp.RememberMe = RememberMe;
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	360
b73191efc65b Initial import of pumpbridge (bloody bloody alpha) Mathias Gebbe <mgebbe@intevation.de> parents: diff changeset	361 module.exports = PumpIOClientApp;

Mercurial > pumpbridge

annotate app.js_to_pump.io-client-app_lib @ 22:b90e6df48d2d