From 6089cc3c98c0924dcf0f069980df273134c00a0f Mon Sep 17 00:00:00 2001 From: Kevin Froman Date: Wed, 19 Aug 2020 23:05:06 -0500 Subject: [PATCH] fix formatting in onionrservices --- src/onionrservices/__init__.py | 55 ++++++++++++++++++---------------- 1 file changed, 30 insertions(+), 25 deletions(-) diff --git a/src/onionrservices/__init__.py b/src/onionrservices/__init__.py index a17cd1bf..a9d81db0 100755 --- a/src/onionrservices/__init__.py +++ b/src/onionrservices/__init__.py @@ -1,9 +1,12 @@ -''' - Onionr - Private P2P Communication +"""Onionr - Private P2P Communication. - Onionr services provide the server component to direct connections -''' -''' +Onionr services provide the server component to direct connections +""" +import time +from . import connectionserver, bootstrapservice, serverexists +from onionrutils import stringvalidators, basicrequests +import config +""" This program is free software: you can redistribute it and/or modify it under the terms of the GNU General Public License as published by the Free Software Foundation, either version 3 of the License, or @@ -16,37 +19,39 @@ You should have received a copy of the GNU General Public License along with this program. If not, see . -''' -import time -import stem -from . import connectionserver, bootstrapservice, serverexists -from onionrutils import stringvalidators, basicrequests -import config +""" + server_exists = serverexists.server_exists + + class OnionrServices: - ''' - Create a client or server for connecting to peer interfaces - ''' + """Create a client or server for connecting to peer interfaces.""" def __init__(self): self.servers = {} self.clients = {} self.shutdown = False - + def create_server(self, peer, address, comm_inst): - ''' - When a client wants to connect, contact their bootstrap address and tell them our - ephemeral address for our service by creating a new ConnectionServer instance - ''' - if not stringvalidators.validate_transport(address): raise ValueError('address must be valid') - BOOTSTRAP_TRIES = 10 # How many times to attempt contacting the bootstrap server - TRY_WAIT = 3 # Seconds to wait before trying bootstrap again + """ + Create a server for direct connections + + When a client wants to connect, contact their bootstrap address and tell them our ephemeral address for our service by creating a new ConnectionServer instance + """ + if not stringvalidators.validate_transport(address): + raise ValueError('address must be valid') + # How many times to attempt contacting the bootstrap server + BOOTSTRAP_TRIES = 10 + # Seconds to wait before trying bootstrap again + TRY_WAIT = 3 # HTTP is fine because .onion/i2p is encrypted/authenticated base_url = 'http://%s/' % (address,) socks = config.get('tor.socksport') for x in range(BOOTSTRAP_TRIES): - if basicrequests.do_get_request(base_url + 'ping', port=socks, ignoreAPI=True) == 'pong!': + if basicrequests.do_get_request( + base_url + 'ping', port=socks, ignoreAPI=True) == 'pong!': # if bootstrap sever is online, tell them our service address - connectionserver.ConnectionServer(peer, address, comm_inst=comm_inst) + connectionserver.ConnectionServer( + peer, address, comm_inst=comm_inst) else: time.sleep(TRY_WAIT) else: @@ -55,7 +60,7 @@ class OnionrServices: @staticmethod def create_client(peer, comm_inst=None): # Create ephemeral onion service to bootstrap connection to server - if not comm_inst == None: + if comm_inst is not None: try: return comm_inst.direct_connection_clients[peer] except KeyError: