export socks.js for require

AUTHORS

@@ -1,2 +1,3 @@
 Gert Van Gool <gertvangool@gmail.com>
 John Cant <a.johncant@gmail.com>
+Tom Zhou <iwebpp@gmail.com>

README.md

@@ -0,0 +1,20 @@
+SOCKS v4/v4a/v5 server implementation with user/pass authentication node.js
+=============================================================================
+
+A simple SOCKS v5/v4/v4a server implementation and demo proxy.
+
+You can run it easily as::
+
+  node proxy.js
+
+This will create a proxy at ``127.0.0.1`` on port ``8888``.
+
+You can use this as a good starting point for writing a proxy or a tunnel!
+
+### Install
+- npm install socks5
+
+
+### License
+
+(The MIT License)

package.json

@@ -1,8 +1,24 @@
 {
-    "name": "node-socks"
-  , "version": "0.1.0"
-  , "description": "A simple SOCKS implementation and demo proxy"
-  , "author": "Gert Van Gool <gertvangool@gmail.com>"
+    "name": "socks5"
+  , "version": "1.0.1"
+  , "description": "A simple SOCKS 5/4/4a implementation and demo proxy"
+  , "author": [
+    "Gert Van Gool <gertvangool@gmail.com>",
+    "Tom Zhou <iwebpp@gmail.com>"
+  ]
+  , "repository": {
+    "type": "git",
+    "url": "git://github.com/sequoiar/socks5.git"
+  }
+  , "keywords": [
+    "socks",
+    "socks5",
+    "socks4",
+    "socks4a",
+    "proxy",
+    "http"
+  ]
+  , "main": "socks.js"
   , "dependencies": {
   }
 }

proxy.js

@@ -0,0 +1,100 @@
+
+var net = require('net'),
+    socks = require('./socks.js'),
+    info = console.log.bind(console);
+
+// Create server
+// The server accepts SOCKS connections. This particular server acts as a proxy.
+var HOST='127.0.0.1',
+    PORT='8888',
+    server = socks.createServer(function(socket, port, address, proxy_ready) {
+
+      // Implement your own proxy here! Do encryption, tunnelling, whatever! Go flippin' mental!
+      // I plan to tunnel everything including SSH over an HTTP tunnel. For now, though, here is the plain proxy:
+
+      var proxy = net.createConnection({port:port, host:address,localAddress:process.argv[2]||undefined}, proxy_ready);
+      var localAddress,localPort;
+      proxy.on('connect', function(){
+        info('%s:%d <== %s:%d ==> %s:%d',socket.remoteAddress,socket.remotePort,
+              proxy.localAddress,proxy.localPort,proxy.remoteAddress,proxy.remotePort);
+        localAddress=proxy.localAddress;
+        localPort=proxy.localPort;
+      }.bind(this));
+      proxy.on('data', function(d) {
+        try {
+          //console.log('receiving ' + d.length + ' bytes from proxy');
+          if (!socket.write(d)) {
+              proxy.pause();
+
+              socket.on('drain', function(){
+                  proxy.resume();
+              });
+              setTimeout(function(){
+                  proxy.resume();    
+              }, 100);
+          }
+        } catch(err) {
+        }
+      });
+      socket.on('data', function(d) {
+        // If the application tries to send data before the proxy is ready, then that is it's own problem.
+        try {
+          //console.log('sending ' + d.length + ' bytes to proxy');
+          if (!proxy.write(d)) {
+              socket.pause();
+
+              proxy.on('drain', function(){
+                  socket.resume();
+              });
+              setTimeout(function(){
+                  socket.resume();    
+              }, 100);
+          }
+        } catch(err) {
+        }
+      });
+
+      proxy.on('error', function(err){
+          //console.log('Ignore proxy error');
+      });
+      proxy.on('close', function(had_error) {
+        try {
+          if(localAddress && localPort)
+            console.log('The proxy %s:%d closed', localAddress, localPort);
+          else 
+            console.error('Connect to %s:%d failed', address, port);
+          socket.end();
+        } catch (err) {
+        }
+      }.bind(this));
+
+      socket.on('error', function(err){
+          //console.log('Ignore socket error');
+      });
+      socket.on('close', function(had_error) {
+        try {
+          if (this.proxy !== undefined) {
+            proxy.removeAllListeners('data');
+            proxy.end();
+          }
+          //console.error('The socket %s:%d closed',socket.remoteAddress,socket.remotePort);
+        } catch (err) {
+        }
+      }.bind(this));
+
+    }, process.argv[3]&&process.argv[4]&&{username:process.argv[3],password:process.argv[4]});
+
+server.on('error', function (e) {
+    console.error('SERVER ERROR: %j', e);
+    if (e.code == 'EADDRINUSE') {
+        console.log('Address in use, retrying in 10 seconds...');
+        setTimeout(function () {
+            console.log('Reconnecting to %s:%s', HOST, PORT);
+            server.close();
+            server.listen(PORT, HOST);
+        }, 10000);
+    }
+});
+server.listen(PORT, HOST);
+
+// vim: set filetype=javascript syntax=javascript :