fix
This commit is contained in:
parent
aa912e0dc2
commit
69da1a797a
8
main.py
8
main.py
@ -38,7 +38,7 @@ async def handle_client(reader, writer):
|
|||||||
except Exception:
|
except Exception:
|
||||||
break
|
break
|
||||||
|
|
||||||
data = None
|
data = 'unknown'
|
||||||
if request == 'on':
|
if request == 'on':
|
||||||
await relay_set(ON)
|
await relay_set(ON)
|
||||||
logger.info('set on')
|
logger.info('set on')
|
||||||
@ -54,9 +54,15 @@ async def handle_client(reader, writer):
|
|||||||
data = 'on' if status is True else 'off'
|
data = 'on' if status is True else 'off'
|
||||||
|
|
||||||
writer.write((data + '\r\n').encode('utf-8'))
|
writer.write((data + '\r\n').encode('utf-8'))
|
||||||
|
try:
|
||||||
await writer.drain()
|
await writer.drain()
|
||||||
|
except ConnectionError:
|
||||||
|
break
|
||||||
|
|
||||||
|
try:
|
||||||
writer.close()
|
writer.close()
|
||||||
|
except ConnectionError:
|
||||||
|
pass
|
||||||
|
|
||||||
|
|
||||||
async def run_server(host, port):
|
async def run_server(host, port):
|
||||||
|
Loading…
x
Reference in New Issue
Block a user