mirror of
https://github.com/KevinMidboe/delugeClient.git
synced 2025-10-29 12:00:13 +00:00
Imported deluge and on connect send currently downloading items.
This commit is contained in:
@@ -3,6 +3,8 @@ import datetime
|
|||||||
import random
|
import random
|
||||||
import websockets
|
import websockets
|
||||||
|
|
||||||
|
import deluge_cli
|
||||||
|
|
||||||
async def hello(websocket, path):
|
async def hello(websocket, path):
|
||||||
name = await websocket.recv()
|
name = await websocket.recv()
|
||||||
print(f"< {name}")
|
print(f"< {name}")
|
||||||
@@ -19,9 +21,14 @@ async def time(websocket, path):
|
|||||||
await asyncio.sleep(1)
|
await asyncio.sleep(1)
|
||||||
|
|
||||||
|
|
||||||
|
async def deluge(websocket, path):
|
||||||
|
downloading = deluge.main(['ls', '--downloading'])
|
||||||
|
await websocket.send()
|
||||||
|
|
||||||
serve_hello = websockets.serve(hello, '0.0.0.0', 8765)
|
serve_hello = websockets.serve(hello, '0.0.0.0', 8765)
|
||||||
serve_time = websockets.serve(time, '0.0.0.0', 5678)
|
# serve_time = websockets.serve(time, '0.0.0.0', 5678)
|
||||||
|
serve_deluge = websockets.serve(deluge, '0.0.0.0', 5678)
|
||||||
|
|
||||||
asyncio.get_event_loop().run_until_complete(serve_hello)
|
asyncio.get_event_loop().run_until_complete(serve_hello)
|
||||||
asyncio.get_event_loop().run_until_complete(serve_time)
|
asyncio.get_event_loop().run_until_complete(serve_deluge)
|
||||||
asyncio.get_event_loop().run_forever()
|
asyncio.get_event_loop().run_forever()
|
||||||
Reference in New Issue
Block a user