aljaz/python-nostr
1
0
Fork 0
mirror of https://github.com/aljazceru/python-nostr.git synced 2025-12-19 07:14:23 +01:00
Code Issues Packages Projects Releases Wiki Activity

Merge branch 'track-connection-state'

Browse Source
This commit is contained in:
callebtc
2023-02-02 16:40:52 +01:00
parent fb3bbca372 88d436799e
commit b1b4e711b2
1 changed files with 7 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
nostr/relay.py
View File

@@ -35,6 +35,7 @@ class Relay:
self.error_counter: int = 0 self.error_counter: int = 0
self.error_threshold: int = 0 self.error_threshold: int = 0
self.ssl_options: dict = {} self.ssl_options: dict = {}
self.proxy: dict = {}
self.lock = Lock() self.lock = Lock()
self.ws = WebSocketApp( self.ws = WebSocketApp(
url, url,
@@ -44,13 +45,14 @@ class Relay:
on_close=self._on_close, on_close=self._on_close,
) )
def connect(self, ssl_options: dict=None, proxy: dict=None): def connect(self, ssl_options: dict = None, proxy: dict = None):
self.ssl_options = ssl_options self.ssl_options = ssl_options
self.proxy = proxy
self.ws.run_forever( self.ws.run_forever(
sslopt=ssl_options, sslopt=ssl_options,
http_proxy_host=None if proxy is None else proxy.get('host'), http_proxy_host=None if proxy is None else proxy.get("host"),
http_proxy_port=None if proxy is None else proxy.get('port'), http_proxy_port=None if proxy is None else proxy.get("port"),
proxy_type=None if proxy is None else proxy.get('type') proxy_type=None if proxy is None else proxy.get("type"),
) )
def close(self): def close(self):
@@ -64,7 +66,7 @@ class Relay:
self.connected = False self.connected = False
if self.reconnect: if self.reconnect:
time.sleep(1) time.sleep(1)
self.connect(self.ssl_options) self.connect(self.ssl_options, self.proxy)
def publish(self, message: str): def publish(self, message: str):
if self.connected: if self.connected: