Compare commits

..

7 Commits

Author SHA1 Message Date
57a370ad69 [P] Remove trailing spaces
Some checks failed
Component testing / Hub testing (push) Successful in 22s
Component testing / Store testing (push) Successful in 24s
Component testing / Integration smoke testing (push) Has been cancelled
2026-03-27 19:51:27 +02:00
b2b8906478 [P] Remove uncessecary empty line 2026-03-27 19:49:18 +02:00
8a59f601c4 [P] Send only visible records from store on websocket connection 2026-03-27 19:49:18 +02:00
dc3e9b3e7a [P] Remove user_id from store <-> mapview interaction, fix update_db_record 2026-03-27 19:49:18 +02:00
0182d20348 [P] Sync the async function 2026-03-27 19:49:18 +02:00
adae93aba4 [P] Add database update after marker deletion. 2026-03-27 19:49:18 +02:00
2c4526d0ec [P] Code cleanup. 2026-03-27 19:49:18 +02:00
4 changed files with 16 additions and 15 deletions

View File

@@ -4,13 +4,12 @@ from datetime import datetime
import websockets
from kivy import Logger
from pydantic import BaseModel, field_validator
from websockets.asyncio.connection import Connection
from config import STORE_HOST, STORE_PORT
# Pydantic models
class ProcessedAgentData(BaseModel):
id: int
road_state: str
user_id: int
x: float
@@ -34,10 +33,9 @@ class ProcessedAgentData(BaseModel):
class Datasource:
def __init__(self, user_id: int):
def __init__(self):
self.websocket: Connection | None = None
self.index = 0
self.user_id = user_id
self.connection_status = None
self._new_points = []
self._active_markers = []
@@ -50,12 +48,12 @@ class Datasource:
return points
async def connect_to_server(self):
uri = f"ws://{STORE_HOST}:{STORE_PORT}/ws/{self.user_id}"
uri = f"ws://{STORE_HOST}:{STORE_PORT}/ws"
while True:
Logger.debug("CONNECT TO SERVER")
async with websockets.connect(uri) as websocket:
self.connection_status = "Connected"
self.websocket = websocket
self.websocket = websocket
try:
while True:
data = await websocket.recv()
@@ -65,10 +63,10 @@ class Datasource:
self.connection_status = "Disconnected"
Logger.debug("SERVER DISCONNECT")
async def update_db_records(self):
def update_db_record_visibility(self, record_id):
if self.websocket:
data = json.dumps({"id": self.user_id})
await self.websocket.send(data, True)
data = json.dumps({"id": record_id})
asyncio.ensure_future(self.websocket.send(data))
def map_lat_lon_to_processed_agent_data(self, lat: float, lon: float) -> ProcessedAgentData | None:
distances = tuple((abs(lon - marker.latitude) ** 2 + abs(lat - marker.longitude) ** 2) ** 0.5 for marker in

View File

@@ -33,7 +33,7 @@ class MapViewApp(App):
super().__init__(**kwargs)
self.mapview: MapView | None = None
self.datasource = Datasource(user_id=1)
self.datasource = Datasource()
self.line_layers = dict()
self.car_markers = dict()
@@ -162,7 +162,7 @@ class MapViewApp(App):
elif clicked_marker in self.bump_markers:
self.bump_markers.pop(self.bump_markers.index(clicked_marker))
self.datasource.update_db_records()
self.datasource.update_db_record_visibility(clicked_marker_data.id)
def on_touch_down(self, widget, touch):
if touch.button == "right":

View File

@@ -39,15 +39,18 @@ subscriptions: Set[WebSocket] = set()
# FastAPI WebSocket endpoint
@app.websocket("/ws/{user_id}")
async def websocket_endpoint(websocket: WebSocket, user_id: int):
@app.websocket("/ws")
async def websocket_endpoint(websocket: WebSocket):
await websocket.accept()
subscriptions.add(websocket)
try:
# send already available data
r = processed_agent_data.select().order_by(processed_agent_data.c.timestamp)
r = processed_agent_data.select() \
.where(processed_agent_data.c.visible == True) \
.order_by(processed_agent_data.c.timestamp)
session = SessionLocal()
stored_data = session.execute(r).fetchall()
session.close()

View File

@@ -15,7 +15,7 @@ def test_create_processed_agent_data():
"user_id": 123,
"data": [
{
"road_state": "good",
"road_state": "normal",
"agent_data": {
"user_id": 999,
"accelerometer": {