mirror of
https://gitlab.torproject.org/tpo/core/tor.git
synced 2024-12-06 19:41:15 +01:00
teor
108 lines
2.9 KiB
Python
108 lines
2.9 KiB
Python
from __future__ import print_function
|
|
|
|
import sys
|
|
import subprocess
|
|
import socket
|
|
import os
|
|
import time
|
|
import random
|
|
import errno
|
|
|
|
def fail(msg):
|
|
print('FAIL')
|
|
sys.exit(msg)
|
|
|
|
def try_connecting_to_socksport():
|
|
socks_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
|
|
if socks_socket.connect_ex(('127.0.0.1', socks_port)):
|
|
tor_process.terminate()
|
|
fail('Cannot connect to SOCKSPort')
|
|
socks_socket.close()
|
|
|
|
def wait_for_log(s):
|
|
while True:
|
|
l = tor_process.stdout.readline()
|
|
if s in l.decode('utf8'):
|
|
return
|
|
|
|
def pick_random_port():
|
|
port = 0
|
|
random.seed()
|
|
|
|
for i in range(8):
|
|
port = random.randint(10000, 60000)
|
|
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
|
|
if s.connect_ex(('127.0.0.1', port)) == 0:
|
|
s.close()
|
|
else:
|
|
break
|
|
|
|
if port == 0:
|
|
fail('Could not find a random free port between 10000 and 60000')
|
|
|
|
return port
|
|
|
|
if sys.hexversion < 0x02070000:
|
|
fail("ERROR: unsupported Python version (should be >= 2.7)")
|
|
|
|
if sys.hexversion > 0x03000000 and sys.hexversion < 0x03010000:
|
|
fail("ERROR: unsupported Python3 version (should be >= 3.1)")
|
|
|
|
control_port = pick_random_port()
|
|
socks_port = pick_random_port()
|
|
|
|
assert control_port != 0
|
|
assert socks_port != 0
|
|
|
|
if not os.path.exists(sys.argv[1]):
|
|
fail('ERROR: cannot find tor at %s' % sys.argv[1])
|
|
|
|
tor_path = sys.argv[1]
|
|
|
|
tor_process = subprocess.Popen([tor_path,
|
|
'-ControlPort', '127.0.0.1:{}'.format(control_port),
|
|
'-SOCKSPort', '127.0.0.1:{}'.format(socks_port),
|
|
'-FetchServerDescriptors', '0'],
|
|
stdout=subprocess.PIPE,
|
|
stderr=subprocess.PIPE)
|
|
|
|
if tor_process == None:
|
|
fail('ERROR: running tor failed')
|
|
|
|
if len(sys.argv) < 2:
|
|
fail('Usage: %s <path-to-tor>' % sys.argv[0])
|
|
|
|
wait_for_log('Opened Control listener on')
|
|
|
|
try_connecting_to_socksport()
|
|
|
|
control_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
|
|
if control_socket.connect_ex(('127.0.0.1', control_port)):
|
|
tor_process.terminate()
|
|
fail('Cannot connect to ControlPort')
|
|
|
|
control_socket.sendall('AUTHENTICATE \r\n'.encode('utf8'))
|
|
control_socket.sendall('SETCONF SOCKSPort=0.0.0.0:{}\r\n'.format(socks_port).encode('utf8'))
|
|
wait_for_log('Opened Socks listener')
|
|
|
|
try_connecting_to_socksport()
|
|
|
|
control_socket.sendall('SETCONF SOCKSPort=127.0.0.1:{}\r\n'.format(socks_port).encode('utf8'))
|
|
wait_for_log('Opened Socks listener')
|
|
|
|
try_connecting_to_socksport()
|
|
|
|
control_socket.sendall('SIGNAL HALT\r\n'.encode('utf8'))
|
|
|
|
wait_for_log('exiting cleanly')
|
|
print('OK')
|
|
|
|
try:
|
|
tor_process.terminate()
|
|
except OSError as e:
|
|
if e.errno == errno.ESRCH: # errno 3: No such process
|
|
# assume tor has already exited due to SIGNAL HALT
|
|
print("Tor has already exited")
|
|
else:
|
|
raise
|