Changeset - 61dc5bc8ce2e
[Not reviewed]
default
0 1 0
drewp@bigasterisk.com - 8 months ago 2024-05-20 08:27:09
drewp@bigasterisk.com
logging
1 file changed with 3 insertions and 1 deletions:
0 comments (0 inline, 0 general)
src/light9/collector/service.py
Show inline comments
 
@@ -64,12 +64,14 @@ class Updates(WebSocketEndpoint, UiListe
 
async def PutAttrs(collector: Collector, request):
 
    try:
 
        body = await request.body()
 
    except ClientDisconnect:
 
        log.warning("PUT /attrs request disconnected- ignoring")
 
        return Response('', status_code=400)
 
    #log.info(f'http recv {body=}')
 
    
 
    client, clientSession, settings, sendTime = parseJsonMessage(collector.graph, body)
 
    collector.setAttrs(client, clientSession, settings, sendTime)
 
    return Response('', status_code=202)
 

	
 

	
 
async def zmqListener(collector):
 
@@ -79,13 +81,13 @@ async def zmqListener(collector):
 
        sock.bind('tcp://127.0.0.1:9203')
 
        sock.subscribe(b'setAttr')
 
        while True:
 
            [topic, msg] = await sock.recv_multipart()
 
            if topic != b'setAttr':
 
                raise ValueError(topic)
 
            # log.info(f'zmq recv {len(msg)}')
 
            # log.info(f'zmq recv {msg=}')
 
            client, clientSession, settings, sendTime = parseJsonMessage(collector.graph, msg)
 
            collector.setAttrs(client, clientSession, settings, sendTime)
 
    except:
 
        traceback.print_exc()
 
        raise
 

	
0 comments (0 inline, 0 general)