Compare commits

..

8 Commits

Author SHA1 Message Date
23a11ec102 [P] Remove uncessecary empty line
All checks were successful
Component testing / Hub testing (push) Successful in 25s
Component testing / Store testing (push) Successful in 26s
Component testing / Integration smoke testing (push) Successful in 3m35s
2026-03-27 18:40:11 +02:00
ad3c336ecf [P] Send only visible records from store on websocket connection
All checks were successful
Component testing / Hub testing (push) Successful in 21s
Component testing / Store testing (push) Successful in 26s
Component testing / Integration smoke testing (push) Successful in 2m36s
2026-03-27 18:38:22 +02:00
5c3010dcfe [P] Remove user_id from store <-> mapview interaction, fix update_db_record 2026-03-27 18:24:53 +02:00
712691f3d2 [P] Sync the async function 2026-03-27 18:15:56 +02:00
f5486f0469 [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
2026-03-27 16:41:39 +01:00
51fca8436a [P] Code cleanup. 2026-03-27 16:41:39 +01:00
c5f6fbf7af [L4] Fix relative module imports 2026-03-27 16:41:39 +01:00
SimonSanich
7b02884b10 Add test for new records in DB 2026-03-27 16:41:38 +01:00
9 changed files with 3 additions and 135 deletions

View File

@@ -7,13 +7,10 @@ jobs:
name: Reset docker state
steps:
- name: Stop all containers
if: ${{always()}}
run: docker stop $(docker ps -a | cut -d " " -f 1 | tail -n +2)
- name: Remove all containers
if: ${{always()}}
run: docker rm $(docker ps -a | cut -d " " -f 1 | tail -n +2)
- name: Remove extra volumes
if: ${{always()}}
run: docker volume rm road_vision_postgres_data road_vision_pgadmin-data

View File

@@ -28,27 +28,18 @@ jobs:
- name: Clone repository
run: git clone --revision ${{ gitea.sha }} --depth 1 ${{ gitea.server_url }}/${{ gitea.repository }}
- name: Start postgres_db container for testing
working-directory: IoT-Systems
run: docker-compose up -d postgres_db
- name: Build Store testing container
working-directory: IoT-Systems
run: docker build -t local/store/${{gitea.sha}} -f store/Dockerfile-test .
- name: Run Store tests
working-directory: IoT-Systems
run: docker run --network host --rm -it local/store/${{gitea.sha}}
run: docker run --rm -it local/store/${{gitea.sha}}
- name: Clean up containers
if: ${{always()}}
run: docker image rm local/store/${{gitea.sha}}
- name: Clean up docker-compose
if: ${{always()}}
working-directory: IoT-Systems
run: docker-compose down -v --remove-orphans
integration-smoke-test:
name: Integration smoke testing
runs-on: host-arch-x86_64

View File

@@ -1,81 +0,0 @@
@startuml
interface MQTT as mqtt1
interface MQTT as mqtt2
interface HTTP as http1
interface HTTP as http2
interface WebSocket
node Agent {
component Accelerometer
component GPS
component CarParkingSlots
component "Data Aggregator" as agent_agg
}
node Edge {
component AgentMQTTAdapter
component AgentDataProcessor
component HubMQTTAdapter
component HubHTTPAdapter
}
node Hub {
component EdgeHTTPAdapter
component EdgeMQTTAdapter
component Aggregator
component StoreHTTPAdapter
component Redis
}
node Store {
component "HTTP Rest API" as store_http
component "SQL Adapter" as store_sql
component "Websocket API" as store_ws
}
node MapView {
component "Store Processor" as mv_sp
component "Input Handler" as mv_ih
component "Map"
}
component PostgreSQL
agent_agg --> Accelerometer
agent_agg --> GPS
agent_agg --> CarParkingSlots
agent_agg -> mqtt1
mqtt1 <- AgentMQTTAdapter
AgentMQTTAdapter -> AgentDataProcessor
AgentDataProcessor --> HubMQTTAdapter
AgentDataProcessor --> HubHTTPAdapter
HubMQTTAdapter --> mqtt2
HubHTTPAdapter --> http1
mqtt2 <-- EdgeMQTTAdapter
http1 <-- EdgeHTTPAdapter
EdgeMQTTAdapter --> Aggregator
EdgeHTTPAdapter --> Aggregator
Aggregator <--> Redis
StoreHTTPAdapter <-- Aggregator
http2 <-- StoreHTTPAdapter
store_http --> http2
store_http -> store_sql
store_sql <- store_ws
store_ws --> WebSocket
store_sql <--> PostgreSQL
WebSocket <-- mv_sp
mv_sp <-- mv_ih
mv_sp --> Map
actor Spectator as user
Map --> user
mv_ih <-- user
@enduml

View File

@@ -1,22 +0,0 @@
@startuml
actor Worker as worker
participant Agent as agent
participant "Edge" as edge
participant "Hub" as hub
participant "Store" as store
participant "MapView" as mapview
actor Spectator as spectator
worker -> agent : Start agent
agent -> edge : Send sensor data
edge -> edge : Classify road state
edge -> hub : Send processed data
hub -> hub : Save processed data
hub -> store : Send processed data batch
store -> store : Save processed data batch
store -> mapview : Send new rows
mapview -> spectator : Show updated paths and markers
spectator -> mapview : Click on markers
mapview -> spectator : Hide clicked markers
mapview -> store : Save display preference
@enduml

View File

@@ -1,15 +0,0 @@
@startuml
|Користувач|
start
:Натискає на іконку ями;
|Система|
:Запитує підтвердження видалення ями;
|Користувач|
:Підтверджує видалення ями;
|Система|
:Модифікує запис про яму;
note right #ff9999: Можлива виключна ситуація 1
:Видаляє яму;
|Користувач|
stop
@enduml

View File

@@ -6,7 +6,6 @@ WORKDIR /app
COPY store/requirements.txt .
RUN pip install --no-cache-dir -r requirements.txt
RUN pip install --root-user-action ignore --no-cache-dir pytest httpx
# Copy the entire application into the container
COPY store/. .
# Run the main.py script inside the container when it starts

View File

@@ -1,4 +1,3 @@
#!/bin/sh
PYTHONPATH=$PWD python3 test/main_test.py
PYTHONPATH=$PWD python3 -m pytest test_db.py

View File

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