cocaine - npm Package Compare versions

Comparing version 0.4.0 to 0.4.1-1

lib/client/base_service.js

@@ -32,2 +32,6 @@
     },
+    removeSession: function(s){
+      var id = s._id
+      delete this._sessions[id]
+    },
     _resetSessions: function(errno){
@@ -34,0 +38,0 @@ Object.keys(this._sessions).forEach(function(sid){

lib/client/methods/callback.js

@@ -30,2 +30,6 @@
     _this._done = true
+    if(_this._owner){
+      _this._owner.removeSession(_this)
+      _this._owner = null
+    }
     var err = new Error('call timeout')
@@ -32,0 +36,0 @@ _this._cb(err)

lib/client/methods/fibers.js

@@ -33,2 +33,6 @@
       _this._done = true
+      if(_this._owner){
+        _this._owner.removeSession(_this)
+        _this._owner = null
+      }
       var err = new Error('call timeout')
@@ -35,0 +39,0 @@ _this.fiber.throwInto(err)

lib/client/methods/promises.js

@@ -33,2 +33,6 @@
       _this._done = true
+      if(_this._owner){
+        _this._owner.removeSession(_this)
+        _this._owner = null
+      }
       var err = new Error('call timeout')
@@ -35,0 +39,0 @@ Promise.reject(_this.deferred, err)

lib/client/methods/streaming_method.js

@@ -25,2 +25,6 @@
     _this._done = true
+    if(_this._owner){
+      _this._owner.removeSession(_this)
+      _this._owner = null
+    }
     var err = new Error('call timeout')
@@ -27,0 +31,0 @@ }

lib/worker/worker.js

@@ -270,3 +270,3 @@
           if(s){
-            s.pushError(code, msg)
+            s.pushError(code, message)
             delete s._sessions[sid]
@@ -273,0 +273,0 @@ }

package.json

 {
   "name": "cocaine",
-  "version": "0.4.0",
+  "version": "0.4.1-1",
   "description": "Node.js framework for Cocaine platform",
@@ -5,0 +5,0 @@ "author": "Cocaine Project <[e-mail]>",

README.md

@@ -179,3 +179,3 @@
 var cli = new require('cocaine').Client()
-var app = cli.Service('the_app')
+var app = cli.Service('the_app', 'app')
 
@@ -185,9 +185,34 @@ app.connect()
 app.on('connect', function(){
-    app.enqueue('handle','anydata', function(err, result){
-        if(err) {
-           console.log('app error', err)
-        } else {
-          console.log('app response is', result)
-        }
-    })
+  var s = app.enqueue(
+    'http', 
+    mp.pack(['GET',       // http method
+             '/',         // uri
+             'HTTP/1.0',  // http version
+             [['some-header','value']],  // tuple of header-value pairs
+             '']))  // body of request
+
+  var header
+  var body = []
+
+  s.on('data', function(chunk){
+    console.log('reply chunk', chunk)
+    var data = mp.unpack(chunk)
+    console.log('  which decodes', data)
+    if(header === undefined){
+      console.log('header')
+      header = data
+    } else {
+      console.log('body chunk')
+      body.push(data)
+    }
+  })
+
+  s.on('end', function(){
+    console.log('reply done')
+  })
+
+  s.on('error', function(err){
+    console.log('reply error', err)
+  })
+  
 })
@@ -194,0 +219,0 @@

sample/client.1.js

 
 var mp = require('msgpack')
 
-var cli = new (require('../lib/client/client').Client)(['apefront.tst.ape.yandex.net', 10053])
+var cli = new (require('../lib/client/client').Client)(['coca', 10053])
 
@@ -6,0 +6,0 @@

Fixed alerts

Network access

Supply chain risk

This module accesses the network.

Found 1 instance in 1 package

Environment variable access

Supply chain risk

Package accesses environment variables, which may be a sign of credential stuffing or data theft.

Found 3 instances in 1 package

Improved metrics

Number of lines in readme file

224

increased by12.56%

Number of low supply chain risk alerts

4

decreased by-42.86%

Number of medium supply chain risk alerts

4

decreased by-60%

Worsened metrics

Total package byte prevSize

112921

decreased by-97.76%

Number of package files

38

decreased by-36.67%

Lines of code

3208

decreased by-29.99%

No dependency changes