@syndicate-lang/socks - npm Package Compare versions

Comparing version 0.0.13 to 0.0.14

lib/service.js

@@ -262,33 +262,15 @@ "use strict";
                     docker.listContainers(Dataspace.wrapExternal(function (err, containers) {
-                      if (err) throw err;
+                      if (err) {
+                        if (err.code === 'ECONNREFUSED') {
+                          debug('Connection refused contacting docker daemon; will retry'); // Docker not running, or no access. We'll come about
+                          // again in a few seconds; maybe something will have
+                          // changed then.
 
-                      _Dataspace._currentFacet.actor.addFacet(_Dataspace._currentFacet, function () {
-                        _Dataspace._currentFacet.addEndpoint(function () {
-                          var _c19 = PeriodicTick(5000);
+                          return;
+                        } else {
+                          throw err;
+                        }
+                      }
 
-                          var _assn6 = _Syndicate.Observe(_c19);
-
-                          var _handler6 = {
-                            skeleton: null,
-                            constPaths: _Syndicate.fromJS([_Syndicate.fromJS([])]),
-                            constVals: _Syndicate.fromJS([_c19]),
-                            capturePaths: _Syndicate.fromJS([]),
-                            assertion: _assn6,
-                            callback: _Dataspace.wrap(function (_evt6, _vs6) {
-                              if (_evt6 === _Skeleton.EVENT_MESSAGE) {
-                                _Dataspace._currentFacet.actor.scheduleScript(function () {
-                                  _Dataspace._currentFacet.stop(function () {
-                                    scan();
-                                  });
-                                });
-                              }
-                            })
-                          };
-                          return [_assn6, _handler6];
-                        }, true);
-
-                        _Dataspace._currentFacet.addStartScript(function () {
-                          _Dataspace.send(DockerContainers(containers));
-                        });
-                      }, true);
+                      _Dataspace.send(DockerContainers(containers));
                     }));
@@ -304,2 +286,24 @@ };
                   _Dataspace._currentFacet.addEndpoint(function () {
+                    var _c19 = PeriodicTick(5000);
+
+                    var _assn6 = _Syndicate.Observe(_c19);
+
+                    var _handler6 = {
+                      skeleton: null,
+                      constPaths: _Syndicate.fromJS([_Syndicate.fromJS([])]),
+                      constVals: _Syndicate.fromJS([_c19]),
+                      capturePaths: _Syndicate.fromJS([]),
+                      assertion: _assn6,
+                      callback: _Dataspace.wrap(function (_evt6, _vs6) {
+                        if (_evt6 === _Skeleton.EVENT_MESSAGE) {
+                          _Dataspace._currentFacet.actor.scheduleScript(function () {
+                            scan();
+                          });
+                        }
+                      })
+                    };
+                    return [_assn6, _handler6];
+                  }, true);
+
+                  _Dataspace._currentFacet.addEndpoint(function () {
                     var _assn7 = _Syndicate.Observe(DockerContainers(_Syndicate.Capture(_Syndicate.Discard._instance)));
@@ -306,0 +310,0 @@

package.json

 {
   "name": "@syndicate-lang/socks",
-  "version": "0.0.13",
+  "version": "0.0.14",
   "description": "SOCKS5 gateway and service registration",
@@ -23,7 +23,7 @@ "repository": "github:syndicate-lang/syndicate-js",
   "dependencies": {
-    "@syndicate-lang/core": "^0.2.8",
-    "@syndicate-lang/driver-mdns": "^0.2.9",
-    "@syndicate-lang/driver-streams-node": "^0.2.9",
-    "@syndicate-lang/driver-timer": "^0.2.9",
-    "@syndicate-lang/server": "^0.2.11",
+    "@syndicate-lang/core": "^0.2.9",
+    "@syndicate-lang/driver-mdns": "^0.2.10",
+    "@syndicate-lang/driver-streams-node": "^0.2.10",
+    "@syndicate-lang/driver-timer": "^0.2.10",
+    "@syndicate-lang/server": "^0.2.12",
     "debug": "^4.1.1",
@@ -36,3 +36,3 @@ "dockerode": "^2.5.8"
   },
-  "gitHead": "403e0d7b927866349b7fab6b221d296619051167"
+  "gitHead": "881b5ba9b2d3a2db6485a2c25020c3be49beda80"
 }

src/service.js

@@ -84,10 +84,18 @@ // https://www.ietf.org/rfc/rfc1928.txt
       docker.listContainers(Dataspace.wrapExternal((err, containers) => {
-        if (err) throw err;
-        react {
-          stop on message PeriodicTick(5000) scan();
-          on start send DockerContainers(containers);
+        if (err) {
+          if (err.code === 'ECONNREFUSED') {
+            debug('Connection refused contacting docker daemon; will retry');
+            // Docker not running, or no access. We'll come about
+            // again in a few seconds; maybe something will have
+            // changed then.
+            return;
+          } else {
+            throw err;
+          }
         }
+        send DockerContainers(containers);
       }));
     }
     on start scan();
+    on message PeriodicTick(5000) scan();
 
@@ -94,0 +102,0 @@ on message DockerContainers($containers0) {

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

199344

increased by0.16%

Lines of code

2685

increased by0.41%

Dependency changes

• Updated@syndicate-lang/core@^0.2.9

• Updated@syndicate-lang/driver-mdns@^0.2.10

• Updated@syndicate-lang/driver-streams-node@^0.2.10

• Updated@syndicate-lang/driver-timer@^0.2.10

• Updated@syndicate-lang/server@^0.2.12