tunnel-ssh - npm Package Compare versions

Comparing version 0.0.2 to 0.0.3

index.js

@@ -13,4 +13,3 @@ /**
     self._config = config;
-    self._shutdown = false;
-    if(callback){
+    if (callback) {
         self.connect(callback);
@@ -20,23 +19,2 @@ }
 
-SSHTunnel.prototype.create = function (callback) {
-    var self = this;
-    var remotePort = self._config.remotePort;
-    var c = new Connection();
-    c.on('ready', function () {
-        c.forwardOut('127.0.0.1', remotePort, '127.0.0.1', remotePort, callback);
-    });
-
-    c.on('error', function (err) {
-        self.log('Connection :: error :: ' + err);
-    });
-    c.on('end', function () {
-        self.log('Connection :: end');
-    });
-    c.on('close', function (err) {
-        self.log('Connection :: close');
-        c.end();
-    });
-    c.connect(self._config.sshConfig);
-};
-
 SSHTunnel.prototype.log = function () {
@@ -48,5 +26,10 @@ if (this._verbose) {
 
-SSHTunnel.prototype.end = function () {
+SSHTunnel.prototype.close = function (callback) {
     var self = this;
-    self.server.end();
+    this.server.close(function(error){
+        self.connection.end();
+        if(callback){
+            callback(error);
+        }
+    });
 };
@@ -56,24 +39,57 @@
     var self = this;
-    self.server = net.createServer(function (connection) {
-        self.create(function(error, stream){
-            connection.pipe(stream);
-            stream.pipe(connection);
+    var remotePort = self._config.remotePort;
+    var localPort = self._config.localPort;
+    var c = self.connection =  new Connection();
 
-            stream.on('data', function (data) {
-                self.log('TCP :: DATA: ' + data);
-            });
+    c.on('ready', function () {
 
-            stream.on('error', function (err) {
-                self.log('TCP :: ERROR: ' + err);
-                self.log('RECONNECTING');
-            });
+        self.server = net.createServer(function (connection) {
+            var buffers = [];
 
-            stream.on('close', function (err) {
-                console.log('STREAM::close');
+            var addBuffer = function (data) {
+                buffers.push(data);
+            };
+
+            connection.on('data', addBuffer);
+
+            c.forwardOut('', 0, '127.0.0.1', remotePort, function (error, ssh) {
+                while (buffers.length) {
+                    ssh.write(buffers.shift());
+                }
+                connection.removeListener('data', addBuffer);
+
+                ssh.on('data', function (buf) {
+                    connection.write(buf);
+                });
+                connection.on('data', function (buf) {
+                    ssh.write(buf);
+                });
+                connection.on('end', function () {
+                    self.log('connection::end');
+                    ssh.removeAllListeners();
+                    ssh.end();
+                });
+                ssh.on('end', function () {
+                    self.log('ssh::end');
+                    connection.removeAllListeners();
+                    connection.end();
+                });
             });
         });
+        self.server.listen(localPort, callback);
     });
-    self.server.listen(self._config.localPort, callback);
+
+    c.on('error', function (err) {
+        self.log('ssh2::error:: ' + err);
+    });
+    c.on('end', function () {
+        self.log('ssh2::end');
+    });
+    c.on('close', function (err) {
+        self.log('ssh2::close');
+    });
+
+    c.connect(self._config.sshConfig);
 };
 
 module.exports = SSHTunnel;

package.json

 {
   "name": "tunnel-ssh",
-  "version": "0.0.2",
+  "version": "0.0.3",
   "description": "Easy ssh tunneling",
@@ -5,0 +5,0 @@ "main": "index.js",

Readme.md

@@ -15,3 +15,3 @@ Tunnel-SSH
         verbose: true, // dump information to stdout
-        sshConfig: { //ssh2 configuration
+        sshConfig: { //ssh2 configuration (https://github.com/mscdex/ssh2)
             host: '<yourRemoteIp>',
@@ -25,9 +25,11 @@ port: 22,
 
-    var x = new Tunnel(config);
-    x.connect(function (error) {
+    var tunnel = new Tunnel(config);
+    tunnel.connect(function (error) {
         console.log(error);
-        // start useing the tunnel
-        // Bsp. Try mongo shell "#mongo"
+        //or start your remote connection here .... 
+        //mongoose.connect(...);
 
-        //or start your mongo connection here ....
+
+        //close tunnel to exit script 
+        tunnel.close();
     });

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

4661

increased by14.1%

Lines of code

95

increased by15.85%

Number of lines in readme file

34

increased by6.25%

No dependency changes