expose ssl options for ws connection

This commit is contained in:
jeffthibault
2022-08-03 14:28:28 -04:00
parent 71d4679caf
commit c4c4482775
2 changed files with 5 additions and 4 deletions

View File

@@ -1,5 +1,4 @@
import json
import ssl
from websocket import WebSocketApp
from .event import Event
from .filter import Filters
@@ -36,8 +35,8 @@ class Relay:
on_error=self._on_error,
on_close=self._on_close)
def connect(self):
self.ws.run_forever(sslopt={"cert_reqs": ssl.CERT_NONE})
def connect(self, ssl_options: dict=None):
self.ws.run_forever(sslopt=ssl_options)
def close(self):
self.ws.close()

View File

@@ -30,16 +30,18 @@ class RelayManager:
for relay in self.relays.values():
relay.close_subscription(id)
def open_connection(self, relay: Relay=None):
def open_connection(self, relay: Relay=None, ssl_options: dict=None):
if relay != None:
threading.Thread(
target=relay.connect,
args=(ssl_options,),
name=f"{relay.url}-thread"
).start()
else:
for relay in self.relays.values():
threading.Thread(
target=relay.connect,
args=(ssl_options,),
name=f"{relay.url}-thread"
).start()