1 | var request;
|
2 |
|
3 | request = require('browser-request');
|
4 |
|
5 | module.exports = function(opts) {
|
6 | var destinationUrl;
|
7 | destinationUrl = opts.urls[0];
|
8 | if (destinationUrl.indexOf("ws") === 0) {
|
9 | return new WebSocket(opts.urls[0]);
|
10 | }
|
11 | return {
|
12 | send: function(message) {
|
13 | message.url = destinationUrl + message.url;
|
14 | return request[message.verb.toLowerCase()](message, function(err, res, body) {
|
15 | var result;
|
16 | result = {};
|
17 | if (err) {
|
18 | result.error = err;
|
19 | } else {
|
20 | result.text = body;
|
21 | result.statusCode = res.statusCode;
|
22 | result.responseHeaders = res.headers;
|
23 | }
|
24 | if (message.callback) {
|
25 | return message.callback(result);
|
26 | }
|
27 | });
|
28 | }
|
29 | };
|
30 | };
|