From 399ea0f2d03a256ccf80f888bb39a10f371e3681 Mon Sep 17 00:00:00 2001
From: leo <260626284+cameledev@users.noreply.github.com>
Date: Tue, 24 Mar 2026 16:04:59 +0100
Subject: [PATCH] update Dockerfile and compose

---
 Makefile                         |  5 +++++
 compose.yml                      | 17 +++++++++++++++++
 src/agents/metadata_collector.py |  5 ++++-
 3 files changed, 26 insertions(+), 1 deletion(-)

diff --git a/Makefile b/Makefile
index 5c9504d5..af2baf9d 100644
--- a/Makefile
+++ b/Makefile
@@ -125,10 +125,15 @@ run-summary: ## start only the summary application and all needed services
 	@$(COMPOSE) up --force-recreate -d celery-summary-summarize
 .PHONY: run-summary
 
+run-agents: ## start the LiveKit agents (metadata collector)
+	@$(COMPOSE) up --force-recreate -d metadata-collector
+.PHONY: run-agents
+
 run:
 run: ## start the wsgi (production) and development server
 	@$(MAKE) run-backend
 	@$(MAKE) run-summary
+	@$(MAKE) run-agents
 	@$(COMPOSE) up --force-recreate -d frontend
 .PHONY: run
 
diff --git a/compose.yml b/compose.yml
index 44106a0c..bf8feeef 100644
--- a/compose.yml
+++ b/compose.yml
@@ -246,6 +246,23 @@ services:
       depends_on:
         - redis
 
+  metadata-collector:
+    build:
+      context: ./src/agents
+    command: ["python", "metadata_collector.py", "dev"]
+    environment:
+      - LIVEKIT_URL=ws://livekit:7880
+      - LIVEKIT_API_KEY=devkey
+      - LIVEKIT_API_SECRET=secret
+      - AWS_S3_ENDPOINT_URL=minio:9000
+      - AWS_S3_ACCESS_KEY_ID=meet
+      - AWS_S3_SECRET_ACCESS_KEY=password
+      - AWS_STORAGE_BUCKET_NAME=meet-media-storage
+      - AWS_S3_SECURE_ACCESS=False
+    depends_on:
+      - livekit
+      - minio
+
   redis-summary:
     image: redis
     ports:
diff --git a/src/agents/metadata_collector.py b/src/agents/metadata_collector.py
index fd5a1561..c64d912e 100644
--- a/src/agents/metadata_collector.py
+++ b/src/agents/metadata_collector.py
@@ -178,7 +178,10 @@ class MetadataCollector:
 
     def save(self):
         """Serialize collected events and upload as JSON to S3."""
-        logger.info("Persisting processed metadata output to disk…")
+        scheme = "https" if os.getenv("AWS_S3_SECURE_ACCESS", "False").lower() == "true" else "http"
+        endpoint = os.getenv("AWS_S3_ENDPOINT_URL", "")
+        url = f"{scheme}://{endpoint}/{self.bucket_name}/{self.output_filename}"
+        logger.info("Persisting metadata to %s", url)
 
         participants = []
         for k, v in self.participants.items():