Compare commits

..

6 Commits

Author SHA1 Message Date
hasslesstech 1f6b02c5f6 [P] Add a simple .gpx to .csv file converter
Component testing / Hub testing (push) Successful in 33s
Component testing / Store testing (push) Successful in 32s
Component testing / Integration smoke testing (push) Successful in 3m0s
2026-03-25 23:39:32 +02:00
hasslesstech 69523a9fd2 [P] Reduce batch size to improve viewing experience
Component testing / Hub testing (push) Successful in 25s
Component testing / Integration smoke testing (push) Has been cancelled
Component testing / Store testing (push) Has been cancelled
2026-03-25 23:35:24 +02:00
hasslesstech 094662f59e [P] Add second agent in docker-compose.yaml
Component testing / Hub testing (push) Has been cancelled
Component testing / Store testing (push) Has been cancelled
Component testing / Integration smoke testing (push) Has been cancelled
2026-03-25 23:27:59 +02:00
hasslesstech 88454f381d [P] Add GPS file selection to agent 2026-03-25 23:27:59 +02:00
hasslesstech 119547d288 [P] Add TRACK_ID selection in MapView
Component testing / Hub testing (push) Successful in 41s
Component testing / Store testing (push) Successful in 24s
Component testing / Integration smoke testing (push) Successful in 2m30s
2026-03-25 23:27:20 +02:00
hasslesstech b58167f0de [P] Fix wrong row sending order
Component testing / Hub testing (push) Successful in 35s
Component testing / Store testing (push) Successful in 26s
Component testing / Integration smoke testing (push) Successful in 2m37s
2026-03-25 23:26:39 +02:00
3 changed files with 15 additions and 2 deletions
+13
View File
@@ -0,0 +1,13 @@
print('lat,lon')
try:
while True:
i = input()
if '<trkpt' not in i:
continue
si = i.split('"')[1::2]
print(f"{si[0]},{si[1]}")
except EOFError:
pass
+1 -1
View File
@@ -148,7 +148,7 @@ services:
MQTT_BROKER_HOST: "mqtt"
MQTT_BROKER_PORT: 1883
MQTT_TOPIC: "processed_data_topic"
BATCH_SIZE: 20
BATCH_SIZE: 4
ports:
- "9000:8000"
networks:
+1 -1
View File
@@ -45,7 +45,7 @@ async def websocket_endpoint(websocket: WebSocket, user_id: int):
try:
# send already available data
r = processed_agent_data.select()
r = processed_agent_data.select().order_by(processed_agent_data.c.timestamp)
stored_data = SessionLocal().execute(r).fetchall()
jsonable_data = [{c.name: getattr(i, c.name) for c in processed_agent_data.columns} for i in stored_data]