Changeset 527 for Dev/trunk/src/server/util/request.js

Timestamp:

03/23/14 17:26:12 (11 years ago)

Author:

hendrikvanantwerpen

Message:

• Dropped request module for a simple one we wrote ourselves using the native Node modules. Hopefully this one will not suffer from the problem that sometimes empty bodies are returned even when the statuscode and content-length of the request are ok & present.
• Handle exceptions better in HTTPResult chain, they were hoisted in unknown responses before. Should we not include them in default processing, because they are special?

File:

• Dev/trunk/src/server/util/request.js (modified) (2 diffs)

Dev/trunk/src/server/util/request.js

@@ -1 +1 @@
 var HTTPResult = require('./http-result')
-  , request = require('request')
-  , url = require('url')
+  , HTTP = require('http')
+  , HTTPS = require('https')
+  , URL = require('url')
   , _ = require('underscore')
   ;
@@ -9 +10 @@
     var result = new HTTPResult();
     
-    options = options ? _.clone(options) : {};
-    options.uri = url || options.uri;
-    
-    request(options,function(err,res,body){
-        if ( err ) {
-            result.set(-1,err);
-        } else {
-            result.set(res.statusCode,body);
-        }
+    var body = options.body;
+    delete options.body;
+
+    var json = options.json;
+    delete options.json;
+
+    var reqOpts = _.isString(url) ? URL.parse(url) : url;
+    _.extend(reqOpts,options);
+    if ( json === true ) {
+        options.headers = options.headers || {};
+        _.extend(options.headers,{
+            'Content-Type': 'application/json',
+            'Accepts': 'application/json'
+        });
+    }
+
+    var protocol = reqOpts.protocol;
+    var httpModule;
+    if ( protocol === 'http:' ) {
+        httpModule = HTTP;
+    } else if ( protocol === 'https:' ) {
+        httpModule = HTTPS;
+    } else {
+        throw new Error("Unknown protocol "+protocol);
+    }
+
+    var req = httpModule.request(reqOpts);
+    req.on('response', function(response) {
+        var data = "";
+        response.setEncoding('utf8');
+        response.on('data', function(chunk) {
+            data += chunk;
+        });
+        response.on('end', function() {
+            var body;
+            try {
+                if ( json ) {
+                    if ( data ) { body = JSON.parse(data); }
+                } else {
+                    body = data;
+                }
+                result.set(response.statusCode,body);
+            } catch (ex) {
+                console.log('error',data);
+                result.set(-1,ex);
+            }
+        });
+        response.on('error', function(error) {
+            result.set(-1,error);
+        });
     });
+    req.on('error', function(error){
+        result.set(-1,error);
+    });
+
+    if ( body ) {
+        req.write(json ? JSON.stringify(body) : body);
+    }
+    req.end();
 
     return result;