Files
@ 30570d1297b1
Branch filter:
Location: FVDE/ennstatus/Scripts/update_server.py - annotation
30570d1297b1
4.1 KiB
text/x-python
Version bump
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 | 9bfee64f690e 9bfee64f690e 9bfee64f690e 9bfee64f690e 9bfee64f690e 9bfee64f690e 9bfee64f690e 9bfee64f690e 9bfee64f690e 0b39c4acbbdd a6b70b659863 a3e0d30e6906 c34648b1a4d6 a6b70b659863 b4d763546411 b4d763546411 9bfee64f690e 9bfee64f690e f051c683d048 9bfee64f690e 9bfee64f690e 9bfee64f690e 9bfee64f690e 9bfee64f690e 9bfee64f690e 9bfee64f690e 9bfee64f690e 9bfee64f690e 9bfee64f690e 9bfee64f690e 798160fd1198 9bfee64f690e 9bfee64f690e 023fce60e7bf 9bfee64f690e cbea64fc0225 f051c683d048 9bfee64f690e f051c683d048 9bfee64f690e f051c683d048 9bfee64f690e 9bfee64f690e 9bfee64f690e 9bfee64f690e de6292f200dc 9bfee64f690e 9bfee64f690e 9bfee64f690e 9bfee64f690e 9bfee64f690e 9bfee64f690e 9bfee64f690e 9bfee64f690e 9bfee64f690e 9bfee64f690e 9bfee64f690e a6b70b659863 9bfee64f690e 9bfee64f690e 9bfee64f690e 9bfee64f690e 9bfee64f690e 9bfee64f690e a6b70b659863 a6b70b659863 fd0f9336d6d8 a6b70b659863 a6b70b659863 a6b70b659863 a6b70b659863 fd0f9336d6d8 a6b70b659863 a6b70b659863 c34648b1a4d6 c34648b1a4d6 c34648b1a4d6 c34648b1a4d6 c34648b1a4d6 c34648b1a4d6 c34648b1a4d6 c34648b1a4d6 c34648b1a4d6 c34648b1a4d6 9bfee64f690e 9bfee64f690e 9bfee64f690e 9bfee64f690e 9bfee64f690e 10a3ee9cb0c8 9f47162bea1e 9bfee64f690e 7fe6198dff7e 9bfee64f690e e19e4b0ce714 9bfee64f690e 9bfee64f690e 9bfee64f690e 9bfee64f690e 9bfee64f690e 9bfee64f690e 9bfee64f690e 9bfee64f690e 9bfee64f690e 9bfee64f690e 9bfee64f690e a6b70b659863 9bfee64f690e 9bfee64f690e 9bfee64f690e 9bfee64f690e a6b70b659863 a6b70b659863 c34648b1a4d6 c34648b1a4d6 a6b70b659863 a6b70b659863 a6b70b659863 a6b70b659863 c34648b1a4d6 c34648b1a4d6 a6b70b659863 9bfee64f690e f934362f1db1 9bfee64f690e 9bfee64f690e 9bfee64f690e 9bfee64f690e 9bfee64f690e 9bfee64f690e 9bfee64f690e a6b70b659863 a6b70b659863 a6b70b659863 c34648b1a4d6 c34648b1a4d6 c34648b1a4d6 c34648b1a4d6 c34648b1a4d6 c34648b1a4d6 de6292f200dc 9bfee64f690e 9bfee64f690e 9bfee64f690e 9bfee64f690e 19eee9446f54 19eee9446f54 10a3ee9cb0c8 10a3ee9cb0c8 9bfee64f690e 9bfee64f690e 9bfee64f690e 9bfee64f690e 9bfee64f690e 9bfee64f690e 9bfee64f690e 9bfee64f690e 054c5e8fb877 054c5e8fb877 054c5e8fb877 054c5e8fb877 9bfee64f690e 054c5e8fb877 054c5e8fb877 054c5e8fb877 054c5e8fb877 054c5e8fb877 9bfee64f690e dc9fa1a9e864 dc9fa1a9e864 dc9fa1a9e864 a32f4bbed400 | import subprocess
import configparser
import re
import json
import requests
from ast import literal_eval
OBFS_REGEX = re.compile(r'^ServerTransportPlugin (obfs\d+|scramblesuit)')
FTEPROXY_REGEX = re.compile(r'^ServerTransportPlugin fte')
FLASHPROXY_REGEX = re.compile(r'^ServerTransportPlugin websocket')
MEEKPROXY_REGEX = re.compile(r'^ServerTransportPlugin meek')
IP_REGEX = re.compile(r'^(OutboundBindAddress)\ (\d{1,3}\.\d{1,3}\.\d{1,3}\.'
r'\d{1,3})')
def read_tor_config(configfile='/etc/tor/torrc'):
with open(configfile) as fb:
lines = {line[:-1] for line in fb if not line.startswith('#')}
lines = {line for line in filter(None, lines)}
return lines
def get_tor_status(name='tor'):
try:
pids = subprocess.check_output(['pidof', 'tor']).decode('utf-8')[:-1]
pids = pids.split(' ')
pid_file = '.'.join([name, 'pid'])
pid = open('/'.join(['/var', 'run', 'tor', pid_file])).readline()[:-1]
if str(pid) in pids:
return 'Online'
else:
return 'Offline'
except subprocess.CalledProcessError:
return 'Offline'
def get_tor_fingerprint(name='tor'):
fingerprint_file = '/'.join(['/var', 'lib', name, 'fingerprint'])
with open(fingerprint_file) as fb:
line = fb.readline()[:-1]
hostname, fingerprint = line.split(' ')
return hostname, fingerprint
def get_server_type(tor_config):
if 'BridgeRelay 1' in tor_config:
return 'Bridge'
elif 'ExitPolicy reject *:*' in tor_config:
return 'Relay', None
else:
return 'Exit', None
def get_obfs_proxy(tor_config):
return any(OBFS_REGEX.match(i) for i in tor_config)
def get_fte_proxy(tor_config):
return any(FTEPROXY_REGEX.match(i) for i in tor_config)
def get_flash_proxy(tor_config):
return any(FLASHPROXY_REGEX.match(i) for i in tor_config)
def get_meek_proxy(tor_config):
return any(MEEKPROXY_REGEX.match(i) for i in tor_config)
def get_ip(tor_config):
for i in tor_config:
match = IP_REGEX.match(i)
if match is not None:
return match.groups()[1]
return None
def get_config():
config = configparser.ConfigParser()
config.read('/etc/ennstatus_updater.conf')
return config
def create_server_json(tor_configfile='/etc/tor/torrc', name='tor'):
tor_config = read_tor_config(tor_configfile)
server_type = get_server_type(tor_config)
hostname, fingerprint = get_tor_fingerprint(name)
tor_status = get_tor_status(name)
ip = get_ip(tor_config)
obfs = None
fte = None
flash = None
meek = None
if server_type == 'Bridge':
obfs = get_obfs_proxy(tor_config)
fte = get_fte_proxy(tor_config)
flash = get_flash_proxy(tor_config)
meek = get_meek_proxy(tor_config)
dictionary = {'server_type': server_type, 'server_name': hostname,
'tor_status': tor_status, 'fingerprint': fingerprint}
if ip is not None:
dictionary['ip'] = ip
if obfs is not None:
dictionary['obfs'] = obfs
if fte is not None:
dictionary['fteproxy'] = fte
if flash is not None:
dictionary['flashproxy'] = flash
if meek is not None:
dictionary['meek'] = meek
return dictionary
def update_server(server_json, url):
headers = {'Content-type': 'application/json', 'Accept': 'text/plain'}
response = requests.post(url + '/api/update', data=json.dumps(server_json),
headers=headers)
return response.text
def main():
config = get_config()
ennstatus_url = config['main']['ennstatus_url']
if 'servers' in config['main']:
for server in literal_eval(config['main']['servers']):
server_json = create_server_json(config[server]['configfile'],
server)
response = update_server(server_json, ennstatus_url)
print(response, end='')
else:
server_json = create_server_json()
response = update_server(server_json, ennstatus_url)
print(response, end='')
if __name__ == '__main__':
main()
|