Add support for stateful Tor sessions

This commit is contained in:
codeking 2026-01-18 05:20:44 +01:00
parent 6057fd2329
commit 050468a6b7

View file

@ -49,6 +49,9 @@ if __name__ == '__main__':
client_observer.subscribe('updated', lambda event: print('\n')) client_observer.subscribe('updated', lambda event: print('\n'))
connection_observer.subscribe('connecting', lambda event: print(f'[{event.subject.get("attempt_count")}/{event.subject.get("maximum_number_of_attempts")}] Performing connection attempt...\n')) connection_observer.subscribe('connecting', lambda event: print(f'[{event.subject.get("attempt_count")}/{event.subject.get("maximum_number_of_attempts")}] Performing connection attempt...\n'))
connection_observer.subscribe('tor_bootstrapping', lambda event: print('Bootstrapping Tor...'))
connection_observer.subscribe('tor_bootstrap_progressing', lambda event: print(f'Current progress: {event.meta.get('progress'):.2f}%', flush=True, end='\r'))
connection_observer.subscribe('tor_bootstrapped', lambda event: print('\n'))
invoice_observer.subscribe('retrieved', lambda event: print(f'\n{pprint.pp(event.subject)}\n')) invoice_observer.subscribe('retrieved', lambda event: print(f'\n{pprint.pp(event.subject)}\n'))
invoice_observer.subscribe('processing', lambda event: print('A payment has been detected and is being verified...\n')) invoice_observer.subscribe('processing', lambda event: print('A payment has been detected and is being verified...\n'))