Optional compression (#35)

* parameterize compression flag

* make compression flaggable

Author: kchengsf

lib/client/signalflow/request_manager.js

@@ -234,7 +234,6 @@ function RequestManager(endPoint) {
   }
 
   function streamComputationWebsocket(params, requestId, cb, requestType, isRetryPatchMode) {
-    //hack, obviously
     if (!wsConnectionOpen) {
       pendingWSRequests.push({
         params: params,
@@ -243,7 +242,6 @@ function RequestManager(endPoint) {
         requestType: requestType,
         isRetryPatchMode: isRetryPatchMode});
     } else {
-      params.compress = conf.COMPRESS_SIGNALFLOW_WEBSOCKET_MESSAGES;
       addComputation(params, requestId, transports.WEBSOCKET, cb, requestType, isRetryPatchMode);
       var jobObject = getJobObject(params, requestType);
       jobObject.type = requestType;
@@ -330,6 +328,7 @@ function RequestManager(endPoint) {
       console.error('Too many active jobs open!  Stop one of the returned IDs to proceed.  ');
       return Object.keys(knownComputations);
     }
+    params.compress = typeof params.compress === 'undefined' ? conf.COMPRESS_SIGNALFLOW_WEBSOCKET_MESSAGES : params.compress;
     var requestId = overrideRequestId || getRequestIdAndIncrement();
     //todo : deep copy params?
 

package.json

@@ -1,6 +1,6 @@
 {
   "name": "signalfx",
-  "version": "5.0.0",
+  "version": "5.0.1",
   "description": "Node.js client library for SignalFx",
   "homepage": "https://signalfx.com",
   "repository": "https://github.com/signalfx/signalfx-nodejs",