[P] Remove user_id from store <-> mapview interaction, fix update_db_record

This commit is contained in:
2026-03-27 18:24:53 +02:00
parent 712691f3d2
commit 5c3010dcfe
3 changed files with 9 additions and 9 deletions

View File

@@ -10,6 +10,7 @@ from config import STORE_HOST, STORE_PORT
# Pydantic models
class ProcessedAgentData(BaseModel):
id: int
road_state: str
user_id: int
x: float
@@ -33,10 +34,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 = []
@@ -49,7 +49,7 @@ 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:
@@ -64,9 +64,9 @@ class Datasource:
self.connection_status = "Disconnected"
Logger.debug("SERVER DISCONNECT")
def update_db_records(self):
def update_db_record_visibility(self, record_id):
if self.websocket:
data = json.dumps({"id": self.user_id})
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: