Skip to content
Snippets Groups Projects
Commit 77d2de66 authored by wactbprot's avatar wactbprot
Browse files

..

parent ea17d720
Branches
Tags
No related merge requests found
var _ = require("underscore")
, broker = require("sc-broker")
, qs = require('querystring')
, conf = require("./conf")
, mem = broker.createClient({port: conf.mem.port});
var _ = require("underscore"),
broker = require("sc-broker"),
qs = require('querystring'),
conf = require("./conf"),
mem = broker.createClient({
port: conf.mem.port
});
/**
......@@ -16,15 +18,18 @@ var _ = require("underscore")
* @param {String} id KD-id
* @return ObjectExpression
*/
var anselm = function(task, cb){
var con = conf.anselm
method = task.Value ? "POST":"GET";
cb(null, { hostname:con.server,
port: con.port,
path: "/" + task.RequestPath,
method : method,
headers: {'Content-Type': 'application/json; charset=utf-8' }
});
var anselm = function (task, cb) {
var con = conf.anselm,
method = task.Value ? "POST" : "GET";
cb(null, {
hostname: con.server,
port: con.port,
path: "/" + task.RequestPath,
method: method,
headers: {
'Content-Type': 'application/json; charset=utf-8'
}
});
}
exports.anselm = anselm;
......@@ -45,13 +50,16 @@ exports.anselm = anselm;
* die Anzahl der sockets auf 5 beschränkt.
* @method relay
*/
var relay = function(cb){
cb(null,{hostname: conf.relay.server,
port: conf.relay.port,
method: "POST",
agent: false,
headers: { 'Content-Type': 'application/json; charset=utf-8' }
});
var relay = function (cb) {
cb(null, {
hostname: conf.relay.server,
port: conf.relay.port,
method: "POST",
agent: false,
headers: {
'Content-Type': 'application/json; charset=utf-8'
}
});
};
exports.relay = relay;
......@@ -65,24 +73,25 @@ exports.relay = relay;
* @method task
* @return ObjectExpression
*/
var task = function(strdata, cb){
var ddb = conf.database
, ro = {hostname:ddb.server,
port: ddb.port,
path: "/"
+ ddb.name
+ "/_design/"
+ ddb.design
+ "/_list/"
+ ddb.taskslist
+ "/"
+ ddb.tasksview,
method : "POST",
headers: {
'Content-Type': 'application/json'
}
};
if(strdata && _.isString(strdata)){
var task = function (strdata, cb) {
var ddb = conf.database,
ro = {
hostname: ddb.server,
port: ddb.port,
path: "/" +
ddb.name +
"/_design/" +
ddb.design +
"/_list/" +
ddb.taskslist +
"/" +
ddb.tasksview,
method: "POST",
headers: {
'Content-Type': 'application/json'
}
};
if (strdata && _.isString(strdata)) {
ro.headers['Content-Length'] = Buffer.byteLength(strdata);
}
cb(null, ro);
......@@ -99,13 +108,14 @@ exports.task = task;
* @method checkdb
* @return ObjectExpression
*/
var checkdb = function(cb){
var checkdb = function (cb) {
var ddb = conf.database;
cb(null, {hostname:ddb.server,
port: ddb.port,
path: "/" + ddb.name,
method : "GET"
});
cb(null, {
hostname: ddb.server,
port: ddb.port,
path: "/" + ddb.name,
method: "GET"
});
};
exports.checkdb = checkdb;
......@@ -119,16 +129,19 @@ exports.checkdb = checkdb;
* @method replicatedb
* @param callback
*/
var replicatedb = function(cb){
var replicatedb = function (cb) {
var ddb = conf.database;
cb(null, {hostname:ddb.server,
port: ddb.port,
path: "/_replicate",
method : "POST",
headers: { 'Content-Type': 'application/json; charset=utf-8' }
});
cb(null, {
hostname: ddb.server,
port: ddb.port,
path: "/_replicate",
method: "POST",
headers: {
'Content-Type': 'application/json; charset=utf-8'
}
});
};
exports.replicatedb= replicatedb;
exports.replicatedb = replicatedb;
/**
* Die Funktion ```container()```
......@@ -141,20 +154,21 @@ exports.replicatedb= replicatedb;
* @param {} cont
* @return ObjectExpression
*/
var container = function(cont, cb){
var container = function (cont, cb) {
var ddb = conf.database;
cb(null, {hostname: ddb.server,
port: ddb.port,
path: "/"
+ ddb.name
+ "/_design/"
+ ddb.design
+ "/_list/"
+ ddb.containerlist
+ "/"
+ ddb.containerview,
method : "POST"
});
cb(null, {
hostname: ddb.server,
port: ddb.port,
path: "/" +
ddb.name +
"/_design/" +
ddb.design +
"/_list/" +
ddb.containerlist +
"/" +
ddb.containerview,
method: "POST"
});
};
exports.container = container;
......@@ -169,29 +183,32 @@ exports.container = container;
* @param {Object} task aufrufende Task
* @return con
*/
var list = function(task, cb){
var parstr = ""
, ddb = conf.database
, list = task.ListName
, view = task.ViewName
, con = { hostname:ddb.server
, port: ddb.port
, path: "/"
+ ddb.name
+'/_design/'
+ ddb.design
+'/_list/'
+ list
+ '/'
+ view,
method : 'GET',
headers: {'Content-Type': 'application/json; charset=utf-8' }
};
var list = function (task, cb) {
var parstr = "",
ddb = conf.database,
list = task.ListName,
view = task.ViewName,
con = {
hostname: ddb.server,
port: ddb.port,
path: "/" +
ddb.name +
'/_design/' +
ddb.design +
'/_list/' +
list +
'/' +
view,
method: 'GET',
headers: {
'Content-Type': 'application/json; charset=utf-8'
}
};
if(task.Param){
if(task.Param.keys){
if (task.Param) {
if (task.Param.keys) {
parstr = "keys=" + JSON.stringify(task.Param.keys);
}else{
} else {
parstr = qs.stringify(task.Param);
}
con.path = con.path + "?" + parstr;
......@@ -212,17 +229,20 @@ exports.list = list;
* @param {String} id KD-id
* @return ObjectExpression
*/
var wrtdoc = function(id, cb){
var wrtdoc = function (id, cb) {
var ddb = conf.database;
cb(null, { hostname:ddb.server,
port: ddb.port,
path: "/"
+ ddb.name
+'/'
+ id,
method : 'PUT',
headers: { 'Content-Type': 'application/json; charset=utf-8' }
});
cb(null, {
hostname: ddb.server,
port: ddb.port,
path: "/" +
ddb.name +
'/' +
id,
method: 'PUT',
headers: {
'Content-Type': 'application/json; charset=utf-8'
}
});
}
exports.wrtdoc = wrtdoc;
......@@ -237,17 +257,20 @@ exports.wrtdoc = wrtdoc;
* @param {String} id KD-id
* @return ObjectExpression
*/
var rddoc = function(id, cb){
var rddoc = function (id, cb) {
var ddb = conf.database;
cb(null, { hostname:ddb.server,
port: ddb.port,
path: "/"
+ ddb.name
+'/'
+ id,
method : 'GET',
headers: {'Content-Type': 'application/json; charset=utf-8' }
});
cb(null, {
hostname: ddb.server,
port: ddb.port,
path: "/" +
ddb.name +
'/' +
id,
method: 'GET',
headers: {
'Content-Type': 'application/json; charset=utf-8'
}
});
}
exports.rddoc = rddoc;
......@@ -262,20 +285,23 @@ exports.rddoc = rddoc;
* @param {String} id KD-id
* @return ObjectExpression
*/
var docinfo = function(id, cb){
var docinfo = function (id, cb) {
var ddb = conf.database;
cb(null, { hostname:ddb.server,
port: ddb.port,
path: "/"
+ ddb.name
+ "/_design/"
+ ddb.design
+ "/_show/"
+ ddb.docinfoshow
+"/"
+ id,
method : "GET",
headers: {'Content-Type': 'application/json; charset=utf-8' }
});
cb(null, {
hostname: ddb.server,
port: ddb.port,
path: "/" +
ddb.name +
"/_design/" +
ddb.design +
"/_show/" +
ddb.docinfoshow +
"/" +
id,
method: "GET",
headers: {
'Content-Type': 'application/json; charset=utf-8'
}
});
}
exports.docinfo = docinfo;
exports.docinfo = docinfo;
\ No newline at end of file
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment