From cabcc65954edfbf9536529d61d5a2f510a5029e3 Mon Sep 17 00:00:00 2001
From: Valmo <valmojltrindade@gmail.com>
Date: Mon, 29 Jun 2026 23:54:34 -0300
Subject: [PATCH] Added RTSP parser

---
 Cargo.toml                    |  2 +-
 docker-compose.redis-rtsp.yml | 53 +++++++++++++++++++++++++++++++++++
 2 files changed, 54 insertions(+), 1 deletion(-)
 create mode 100644 docker-compose.redis-rtsp.yml

diff --git a/Cargo.toml b/Cargo.toml
index ed29378..6ddad19 100644
--- a/Cargo.toml
+++ b/Cargo.toml
@@ -6,5 +6,5 @@ edition = "2021"
 [dependencies]
 anyhow = "1"
 dotenvy = "0.15"
-tokio = { version = "1", features = ["io-util", "macros", "net", "rt-multi-thread", "signal", "time"] }
+tokio = { version = "1", features = ["io-util", "macros", "net", "process", "rt-multi-thread", "signal", "time"] }
 tokio-postgres = "0.7"
diff --git a/docker-compose.redis-rtsp.yml b/docker-compose.redis-rtsp.yml
new file mode 100644
index 0000000..6c2eb02
--- /dev/null
+++ b/docker-compose.redis-rtsp.yml
@@ -0,0 +1,53 @@
+services:
+  redis:
+    image: redis:7-alpine
+    command: ["redis-server", "--appendonly", "yes"]
+    volumes:
+      - camfinder-redis:/data
+
+  coordinator:
+    build: .
+    command: ["redis-coordinator"]
+    environment:
+      REDIS_URL: redis://redis:6379/0
+      RTSP_QUEUE_NAME: camfinder:rtsp:queue
+      RTSP_INPUT_CSV: /app/camfinder-open-rtsp.csv
+      RTSP_WORKER_COUNT: 2
+    depends_on:
+      - redis
+    volumes:
+      - ./camfinder-open-rtsp.csv:/app/camfinder-open-rtsp.csv:ro
+      - ./dump:/app/dump
+
+  worker-1:
+    build: .
+    command: ["redis-worker"]
+    environment:
+      REDIS_URL: redis://redis:6379/0
+      RTSP_QUEUE_NAME: camfinder:rtsp:queue
+      RTSP_SNAPSHOT_DIR: /app/dump/feeds
+      RTSP_SQLITE_PATH: /app/dump/rtsp-results.sqlite
+      RTSP_CAPTURE_TIMEOUT_MS: 15000
+    depends_on:
+      - redis
+      - coordinator
+    volumes:
+      - ./dump:/app/dump
+
+  worker-2:
+    build: .
+    command: ["redis-worker"]
+    environment:
+      REDIS_URL: redis://redis:6379/0
+      RTSP_QUEUE_NAME: camfinder:rtsp:queue
+      RTSP_SNAPSHOT_DIR: /app/dump/feeds
+      RTSP_SQLITE_PATH: /app/dump/rtsp-results.sqlite
+      RTSP_CAPTURE_TIMEOUT_MS: 15000
+    depends_on:
+      - redis
+      - coordinator
+    volumes:
+      - ./dump:/app/dump
+
+volumes:
+  camfinder-redis: