fixed enrichment edge

tlm-solutions · Dec 7, 2022 · 9d78f53 · 9d78f53
1 parent a1d5bc4
commit 9d78f53
Show file tree

Hide file tree

Showing 3 changed files with 10 additions and 10 deletions.
diff --git a/flake.lock b/flake.lock
diff --git a/src/broadcast_server.cpp b/src/broadcast_server.cpp
@@ -232,9 +232,7 @@ void BroadcastServer::queue_telegram(const dvbdump::R09GrpcTelegram* telegram) n
         enriched_telegram.set_train_length(telegram->train_length());
         enriched_telegram.set_vehicle_number(telegram->vehicle_number());
         enriched_telegram.set_operator_(telegram->operator_());
-
-        auto list_of_values = enriched_telegram.add_enriched();
-        list_of_values->set_historical_time(extracted.historical_time());
+        enriched_telegram.set_allocated_enriched(&extracted);
         google::protobuf::util::MessageToJsonString(enriched_telegram, &enriched_serialized, options);
     }
 

diff --git a/test.py b/test.py
@@ -16,7 +16,9 @@ async def hello(uri):
     async with connect(uri) as websocket:
         await websocket.send(raw_config)
         while True:
-            print(await websocket.recv())
+            data = json.loads(await websocket.recv())
+            if "enriched" in data.keys():
+                print(data["enriched"])
 
 asyncio.run(hello("wss://socket.staging.dvb.solutions"))
 #asyncio.run(hello("ws://127.0.0.1:9001"))