kopia lustrzana https://github.com/Yakifo/amqtt
Merge pull request #47 from FlorianLudwig/ssl_argument_parsing
accept boolean as config argument for "ssl"pull/8/head
commit
f1df2701b6
|
@ -237,7 +237,13 @@ class Broker:
|
||||||
|
|
||||||
# SSL Context
|
# SSL Context
|
||||||
sc = None
|
sc = None
|
||||||
if 'ssl' in listener and listener['ssl'].upper() == 'ON':
|
|
||||||
|
# accept string "on" / "off" or boolean
|
||||||
|
ssl_active = listener.get('ssl', False)
|
||||||
|
if isinstance(ssl_active, str):
|
||||||
|
ssl_active = ssl_active.upper() == 'ON'
|
||||||
|
|
||||||
|
if ssl_active:
|
||||||
try:
|
try:
|
||||||
sc = ssl.create_default_context(ssl.Purpose.CLIENT_AUTH)
|
sc = ssl.create_default_context(ssl.Purpose.CLIENT_AUTH)
|
||||||
sc.load_cert_chain(listener['certfile'], listener['keyfile'])
|
sc.load_cert_chain(listener['certfile'], listener['keyfile'])
|
||||||
|
@ -745,4 +751,4 @@ class Broker:
|
||||||
return self._sessions[client_id][1]
|
return self._sessions[client_id][1]
|
||||||
except KeyError:
|
except KeyError:
|
||||||
pass
|
pass
|
||||||
return None
|
return None
|
||||||
|
|
Ładowanie…
Reference in New Issue