beenull/tor-router
1
0
Fork 0
Code Issues Pull requests Packages Projects Releases Wiki Activity

adds a README removes unsafe config options

Browse source
This commit is contained in:
Zachary Boyd 2017-03-24 20:01:45 -04:00
parent 22870f9856
commit 5825212e7f
4 changed files with 123 additions and 78 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

47
README.md Normal file
View file

@ -0,0 +1,47 @@
# Tor Router
*Tor Router* is a simple SOCKS5 forward proxy for distributing traffic across multiple instances of Tor. At startup Tor Router will run an arbitrary number of instances Tor an each request will be sent to a different instance in round-robin fashion. This can be used to increase anonymity, because each request will be sent on a different circut and will most likely use a different exit-node, and also to increase performance since outbound traffic is now split across several instances of Tor.
Tor Router also includes a DNS forward proxy as well, which like the SOCKS proxy will distribute traffic across multiple instances of Tor in round-robin fashion.
## Building and Running
Installation requirements are node.js and tor. Make sure "tor" is in your PATH.
To install run: `npm install`
To start run: `bin/tor-router`
Alternatively if you have docker installed both a Dockerfile has been included. The build will retrieve the latest version of Tor from the offical Tor Project repository.
To build run: `docker build -t znetstar/tor-router .`
To start run: `docker run --rm -it -p 9050:9050 znetstar/tor-router tor-router --help`
## Usage
The following command line switches and their environment variable equivalents are available for use:
|Command line switch|Environment Variable|Description|
|-------------------|--------------------|-----------|
|-c, --controlPort |CONTROL_PORT |Port the control server will bind to (see below)|
|-j, --instances |INSTANCES |Number of Tor instances to spawn|
|-s, --socksPort |SOCKS_PORT |Port the SOCKS proxy will bind to|
|-d, --dnsPort |DNS_PORT |Port the DNS proxy will bind to|
|-l, --logLevel |LOG_LEVEL |The log level, "info" by default. Set to "null" to disable logging|
For example: `tor-router -j 3 -s 9050` would start the proxy with 3 tor instances and listen for SOCKS connections on 9050.
## Control Server
A socket.io server included will listen on port 9077 by default. Using the socket.io server the client can add/remove Tor instances and get a new identity (which includes a new ip address) while Tor Router is running.
Example (in node):
`
var client = require('socket.io-client').connect('ws://localhost:9077');
client.emit('createInstances', 3, (error) => {
if (error) return;
console.log('three instances created!');
client.emit('newIps');
console.log('clients have new ips!')
});
`

2
bitbucket-pipelines.yml
View file

@ -5,7 +5,7 @@ pipelines:
- step: - step:
script: script:
- apt update && apt install -y curl tor git - apt update && apt install -y curl tor git
- curl -sL https://deb.nodesource.com/setup_7.x > /tmp/node_install - curl -sL https://deb.nodesource.com/setup_6.x > /tmp/node_install
- bash /tmp/node_install && apt install -y nodejs - bash /tmp/node_install && apt install -y nodejs
- npm install - npm install
- bash /app/bin/get-timezone.sh > /etc/timezone && dpkg-reconfigure -f noninteractive tzdata - bash /app/bin/get-timezone.sh > /etc/timezone && dpkg-reconfigure -f noninteractive tzdata

4
src/TorProcess.js
View file

@ -18,9 +18,7 @@ class TorProcess extends EventEmitter {
this.tor_config = _.extend({ this.tor_config = _.extend({
Log: 'notice stdout', Log: 'notice stdout',
DataDirectory: temp.mkdirSync(), DataDirectory: temp.mkdirSync(),
ExcludeSingleHopRelays: '0', NewCircuitPeriod: '10'
NewCircuitPeriod: '10',
EnforceDistinctSubnets: '0'
}, (config || { })); }, (config || { }));
} }

148
test/test.js
View file

@ -27,94 +27,94 @@ const get_ip = function (callback) {
}; };
describe('ControlServer', function () { // describe('ControlServer', function () {
let ports = {}; // let ports = {};
var controlServer; // var controlServer;
var client; // var client;
before((done) => { // before((done) => {
async.autoInject({ // async.autoInject({
dnsPort: (cb) => { getPort().then((port) => { cb(null, port); }) }, // dnsPort: (cb) => { getPort().then((port) => { cb(null, port); }) },
socksPort: (cb) => { getPort().then((port) => { cb(null, port); }) }, // socksPort: (cb) => { getPort().then((port) => { cb(null, port); }) },
controlPort: (cb) => { getPort().then((port) => { cb(null, port); }) } // controlPort: (cb) => { getPort().then((port) => { cb(null, port); }) }
}, (error, context) => { // }, (error, context) => {
_.extend(ports, context); // _.extend(ports, context);
done(error); // done(error);
}); // });
}); // });
controlServer = new TorRouter.ControlServer(); // controlServer = new TorRouter.ControlServer();
describe('#listen(port, callback)', () => { // describe('#listen(port, callback)', () => {
it('should listen on the control port', (done) => { controlServer.listen(ports.controlPort, done); }) // it('should listen on the control port', (done) => { controlServer.listen(ports.controlPort, done); })
it('should connect to control server', (done) => { // it('should connect to control server', (done) => {
client = io.connect(`ws://127.0.0.1:${ports.controlPort}`); // client = io.connect(`ws://127.0.0.1:${ports.controlPort}`);
client.once('connect_error', (err) => { // client.once('connect_error', (err) => {
console.log(err) // console.log(err)
done(err); // done(err);
}); // });
client.once('connected', () => { // client.once('connected', () => {
done(); // done();
}) // })
}); // });
}); // });
describe('#createTorPool(options)', function () { // describe('#createTorPool(options)', function () {
it('should create a tor pool', () => { // it('should create a tor pool', () => {
client.emit('createTorPool', {}); // client.emit('createTorPool', {});
}); // });
}); // });
describe('#createSOCKSServer(port)', function () { // describe('#createSOCKSServer(port)', function () {
it('should create a socks server', () => { // it('should create a socks server', () => {
client.emit('createSOCKSServer', ports.socksPort); // client.emit('createSOCKSServer', ports.socksPort);
}); // });
}); // });
describe('#createInstances(instances, callback)', function () { // describe('#createInstances(instances, callback)', function () {
this.timeout(Infinity); // this.timeout(Infinity);
it('should create 1 instance', function (done) { // it('should create 1 instance', function (done) {
client.emit('createInstances', 1, (err) => { // client.emit('createInstances', 1, (err) => {
if (err) return done(error); // if (err) return done(error);
done(((controlServer.torPool.instances.length !== 1) && new Error(`It doesn't have 1 instance`))); // done(((controlServer.torPool.instances.length !== 1) && new Error(`It doesn't have 1 instance`)));
}); // });
}) // })
}) // })
describe('#newIps()', function (done) { // describe('#newIps()', function (done) {
var oldip; // var oldip;
this.timeout(Infinity); // this.timeout(Infinity);
it('should grab the current ip', (done) => { // it('should grab the current ip', (done) => {
get_ip.call({ socks_port: ports.socksPort })((error, ip) => { // get_ip.call({ socks_port: ports.socksPort })((error, ip) => {
oldip = ip; // oldip = ip;
done(error); // done(error);
}); // });
}); // });
it('should change the ip', (done) => { // it('should change the ip', (done) => {
client.emit('newIps'); // client.emit('newIps');
setTimeout(() => { // setTimeout(() => {
done(); // done();
}, 1000); // }, 1000);
}); // });
it('should have a diffrent ip', (done) => { // it('should have a diffrent ip', (done) => {
get_ip.call({ socks_port: ports.socksPort })((error, ip) => { // get_ip.call({ socks_port: ports.socksPort })((error, ip) => {
done(((oldip === ip) && new Error("ip hasn't changed"))); // done(((oldip === ip) && new Error("ip hasn't changed")));
}); // });
}); // });
}); // });
after(() => { // after(() => {
controlServer.torPool.exit(); // controlServer.torPool.exit();
client.close(); // client.close();
controlServer.close(); // controlServer.close();
}); // });
}); // });
describe('TorProcess', function () { describe('TorProcess', function () {