[P] Add database update after marker deletion.
All checks were successful
Component testing / Hub testing (push) Successful in 23s
Component testing / Store testing (push) Successful in 34s
Component testing / Integration smoke testing (push) Successful in 2m54s

This commit is contained in:
2026-03-27 16:28:03 +01:00
parent 51fca8436a
commit f5486f0469
2 changed files with 11 additions and 0 deletions

View File

@@ -4,6 +4,8 @@ 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
@@ -33,6 +35,7 @@ class ProcessedAgentData(BaseModel):
class Datasource:
def __init__(self, user_id: int):
self.websocket: Connection | None = None
self.index = 0
self.user_id = user_id
self.connection_status = None
@@ -52,6 +55,7 @@ class Datasource:
Logger.debug("CONNECT TO SERVER")
async with websockets.connect(uri) as websocket:
self.connection_status = "Connected"
self.websocket = websocket
try:
while True:
data = await websocket.recv()
@@ -61,6 +65,11 @@ class Datasource:
self.connection_status = "Disconnected"
Logger.debug("SERVER DISCONNECT")
async def update_db_records(self):
if self.websocket:
data = json.dumps({"id": self.user_id})
await self.websocket.send(data, True)
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
self._active_markers)