-
Notifications
You must be signed in to change notification settings - Fork 104
/
index.js
95 lines (85 loc) · 2.95 KB
/
index.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
var generateQueryString = require('./utils').generateQueryString,
request = require('request'),
parseXML = require('xml2js').parseString;
if (typeof Promise === 'undefined') {
Promise = require('es6-promise').Promise;
}
var runQuery = function (credentials, method) {
return function (query, cb) {
var req = query.request || request;
delete query.request;
var url = generateQueryString(query, method, credentials);
var p = new Promise(function(resolve, reject) {
var success = function(results) {
if (typeof cb === 'function') {
cb.apply(null, [null].concat(Array.prototype.slice.call(arguments)));
}else{
resolve(results);
}
};
var failure = function(err) {
if (typeof cb === 'function') {
cb.call(null, err);
} else {
reject(err);
}
};
req(url, function (err, response, body) {
if (err) {
failure(err);
} else if (!response) {
failure("No response (check internet connection)");
} else if (response.statusCode !== 200) {
parseXML(body, function (err, resp) {
if (err) {
failure(err);
} else {
failure(resp[method + 'ErrorResponse']);
}
});
} else {
parseXML(body, function (err, resp) {
if (err) {
failure(err);
} else {
var respObj = resp[method + 'Response'];
if (respObj.Items && respObj.Items.length > 0) {
// Request Error
if (respObj.Items[0].Request && respObj.Items[0].Request.length > 0 && respObj.Items[0].Request[0].Errors) {
failure(respObj.Items[0].Request[0].Errors);
} else if (respObj.Items[0].Item) {
success(
respObj.Items[0].Item,
respObj.Items
);
}
} else if (respObj.BrowseNodes && respObj.BrowseNodes.length > 0) {
// Request Error
if (respObj.BrowseNodes[0].Request && respObj.BrowseNodes[0].Request.length > 0 && respObj.BrowseNodes[0].Request[0].Errors) {
failure(respObj.BrowseNodes[0].Request[0].Errors);
} else if (respObj.BrowseNodes[0].BrowseNode) {
success(
respObj.BrowseNodes[0].BrowseNode,
respObj.BrowseNodes
);
}
}
}
});
}
});
});
if(typeof cb !== 'function') {
return p;
}
};
};
var createClient = function (credentials) {
return {
itemSearch: runQuery(credentials, 'ItemSearch'),
itemLookup: runQuery(credentials, 'ItemLookup'),
browseNodeLookup: runQuery(credentials, 'BrowseNodeLookup'),
similarityLookup: runQuery(credentials, 'SimilarityLookup')
};
};
exports.createClient = createClient;