trigger-http.js

var url = require('url');
var request = require('request');
var zlib = require('zlib');

var serialize = function(obj, prefix) {
	var str = [];
	for(var p in obj) {
		if (obj.hasOwnProperty(p)) {
			var k = prefix ? prefix + "[" + p + "]" : p, v = obj[p];
			str.push(typeof v == "object" ?
			serialize(v, k) :
			encodeURIComponent(k) + "=" + encodeURIComponent(v));
		}
	}
	return str.join("&");
}

module.exports = function(log,sysopt,pathurl,tr,dockey,trkey,cbdone){
	try {
		tr.path = tr.path || "";
		var schema = ["http","https"].indexOf(tr.path.toLowerCase().split(":")[0]);
		var opt = {}, 
			parsedpath=url.parse(tr.path);
		log("... ["+schema+"] " + tr.path + ' --' + JSON.stringify(parsedpath));
		if (tr.path == "") {
			cbdone("REQUEST ERROR: Trigger parameter \"path\" does not exists or is not a string");
			return;
		}
		switch(schema) {
			case 0: // abolute path over http
				opt = parsedpath;
				opt.host=opt.hostname;
				opt.port = opt.port || 80; // overwrite
				break;
			case 1: // abolute path over https
				opt = parsedpath;
				opt.host=opt.hostname;
				opt.port = opt.port || 443; // overwrite
				break;
			default: // relative path
				opt = url.parse(pathurl);
				opt.path = (opt.path+'/'+parsedpath.path).replace(/\/\//g,'/');
				opt.pathname = (opt.pathname+'/'+parsedpath.pathname).replace(/\/\//g,'/');
				
				if (sysopt.headers&&sysopt.headers.authorization) {
					tr.headers = tr.headers?tr.headers:{};
					tr.headers.authorization = sysopt.headers.authorization;
				}
				break;
		}
		opt.host = opt.hostname + ':' + opt.port;
		
		opt.headers = tr.headers||{};
		opt.method = (tr.method||"PUT").toUpperCase();
		
		var ropt = { 
			method: opt.method
			, url:url.format(opt)
			, headers : opt.headers
			, gzip: tr.gzip||false
		};
		
		if (tr.form) ropt.form = tr.form;
		if (typeof tr.params=="object"){ 
			if(tr.asquery){
				ropt.body = serialize(tr.params)
			}
			else{
				ropt.body = JSON.stringify(tr.params);
			}
		}
		
		//log("PREP REQUEST: "+JSON.stringify({
		//	method: ropt.method
		//	, url:ropt.url
		//	, gzip:ropt.gzip
		//	, headers : ropt.headers
		//}));
		log("PREP REQUEST: "+JSON.stringify(ropt));
		
		request(ropt , function (error, response, body) {
			var e = (error||"").toString();
			if (e.length>0) {
				log("REQUEST EXCEPTION:"+e);
				cbdone("REQUEST EXCEPTION:"+e);
			} else {
				log("RESPONSE("+(response.statusCode||"").toString()+"):"+(body||"").substring(0,200));
				cbdone(response.statusCode,body);
			}
		});
	} catch(ex){
		log("TRIGGER HTTP EXCEPTION: " + ex);
	}
};