helenus - npm Package Compare versions

Comparing version 0.6.8 to 0.6.9

History.md

@@ -241,3 +241,3 @@ 0.0.1 / 2011-12-22
 
- 0.6.8 / 2013-12-15
+0.6.8 / 2013-12-15
 ==================
@@ -248,2 +248,9 @@
  * Add Date Type Support [ @tim-dev #131 ]
- 
+
+
+0.6.9 / 2014-03-20
+==================
+
+ * Fixes deserialize issue with collection types [ @Oleg12 #139]
+ * Bump helenus-thrift version [ @devdazed ]
+ * Adds a read-timeout wrapper around the thrift connection [ @devdazed ]

lib/connection.js

@@ -104,3 +104,3 @@
   }
-  
+
   if(val instanceof uuid.UUID){
@@ -116,3 +116,3 @@ return val.toString();
     // C* < 2.0.2 doesn't work with negative longs
-    if(_val<0){ 
+    if(_val<0){
       return "'" + val.getUTCFullYear()
@@ -393,3 +393,5 @@ + '-' + zero_pad(val.getUTCMonth() + 1)
       command = args.shift(),
-      callback = args.pop();
+      callback = args.pop(),
+      timer, calledBack = false,
+      self = this;
 
@@ -401,2 +403,10 @@ if(typeof callback !== 'function'){
 
+  timer = setTimeout(function(){
+    if(!calledBack){
+      calledBack = true;
+      callback(new Error('Read Timed Out'));
+      self._connection.connection.destroy();
+    }
+  }, this.timeout);
+
   /**
@@ -407,2 +417,8 @@ * Processes the return results of the query
   function onReturn(err, results){
+    clearTimeout(timer);
+    if(calledBack){
+      return;
+    }
+
+    calledBack = true;
     if(err){
@@ -409,0 +425,0 @@ callback(errors.create(err));

lib/marshal/index.js

@@ -236,2 +236,6 @@ var Serializers = require('./serializers'),
   return function(str){
+    if(str === null || str === undefined){
+        return null;
+    }
+
     var buf = new Buffer(str, 'binary'),
@@ -260,5 +264,9 @@ pos = 2, len, vals = [], key, value;
   return function(str){
+    if(str === null || str === undefined){
+        return null;
+    }
+
     var buf = new Buffer(str, 'binary'),
         pos = 2, len, vals = {}, key, value;
-      
+
     while( pos < buf.length){
@@ -265,0 +273,0 @@ len = buf.readUInt16BE(pos);

package.json

 {
     "name": "helenus"
-  , "version": "0.6.8"
+  , "version": "0.6.9"
   , "description": "NodeJS Bindings for Cassandra"
@@ -16,3 +16,3 @@ , "keywords": ["cassandra"]
   , "dependencies": {
-      "helenus-thrift": "0.7.3"
+      "helenus-thrift": "0.7.4"
     , "node-uuid": "1.3.3"
@@ -19,0 +19,0 @@ }

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

690220

increased by7.22%

Number of package files

55

increased by34.15%

Lines of code

15312

increased by0.13%

Dependency changes

• + Addedhelenus-thrift@0.7.4(transitive)

• - Removedhelenus-thrift@0.7.3(transitive)

• Updatedhelenus-thrift@0.7.4