🐛(summary) fix feature flag on summary job

Sadly, we used user db id as the posthog distinct id
of identified user, and not the sub.

Before this commit, we were only passing sub to the
summary microservice.

Add the owner's id. Please note we introduce a different
naming behavir, by prefixing the id with "owner". We didn't
for the sub and the email.

We cannot align sub and email with this new naming approach,
because external contributors have already started building
their own microservice.

Makefile

@@ -45,6 +45,7 @@ COMPOSE_RUN         = $(COMPOSE) run --rm
 COMPOSE_RUN_APP     = $(COMPOSE_RUN) app-dev
 COMPOSE_RUN_CROWDIN = $(COMPOSE_RUN) crowdin crowdin
 WAIT_DB             = @$(COMPOSE_RUN) dockerize -wait tcp://$(DB_HOST):$(DB_PORT) -timeout 60s
+WAIT_MINIO          = @$(COMPOSE_RUN) dockerize -wait tcp://minio:9000 -timeout 60s
 
 # -- Backend
 MANAGE              = $(COMPOSE_RUN_APP) python manage.py
@@ -53,6 +54,21 @@ MAIL_NPM            = $(COMPOSE_RUN) -w /app/src/mail node npm
 # -- Frontend
 PATH_FRONT          = ./src/frontend
 
+# -- MinIO / Webhook
+MINIO_ALIAS         ?= meet
+MINIO_ENDPOINT      ?= http://127.0.0.1:9000
+MINIO_ACCESS_KEY    ?= meet
+MINIO_SECRET_KEY    ?= password
+MINIO_BUCKET        ?= meet-media-storage
+MINIO_WEBHOOK_NAME  ?= recording
+
+MINIO_WEBHOOK_ENDPOINT ?= http://app-dev:8000/api/v1.0/recordings/storage-hook/
+
+MINIO_QUEUE_DIR     ?= /data/minio/events
+MINIO_QUEUE_LIMIT   ?= 100000
+
+STORAGE_EVENT_TOKEN ?= password
+
 # ==============================================================================
 # RULES
 
@@ -137,6 +153,55 @@ stop: ## stop the development server using Docker
 	@$(COMPOSE) stop
 .PHONY: stop
 
+# -- MinIO webhook (configuration & events)
+minio-wait: ## wait for minio to be ready
+	@echo "$(BOLD)Waiting for MinIO$(RESET)"
+	$(WAIT_MINIO)
+.PHONY: minio-wait
+
+minio-queue-dir: minio-wait ## ensure queue dir exists in MinIO container
+	@echo "$(BOLD)Ensuring MinIO queue dir$(RESET)"
+	@$(COMPOSE) exec minio sh -lc 'mkdir -p $(MINIO_QUEUE_DIR) && chmod -R 777 $(dir $(MINIO_QUEUE_DIR)) || true'
+.PHONY: minio-queue-dir
+
+minio-alias: minio-wait ## set mc alias to MinIO
+	@echo "$(BOLD)Setting mc alias $(MINIO_ALIAS) -> $(MINIO_ENDPOINT)$(RESET)"
+	@mc alias set $(MINIO_ALIAS) $(MINIO_ENDPOINT) $(MINIO_ACCESS_KEY) $(MINIO_SECRET_KEY) >/dev/null
+.PHONY: minio-alias
+
+minio-webhook-config: minio-alias minio-queue-dir ## configure webhook on MinIO
+	@echo "$(BOLD)Configuring MinIO webhook $(MINIO_WEBHOOK_NAME)$(RESET)"
+	@mc admin config set $(MINIO_ALIAS) notify_webhook:$(MINIO_WEBHOOK_NAME) \
+	  endpoint="$(MINIO_WEBHOOK_ENDPOINT)" \
+	  auth_token="Bearer $(STORAGE_EVENT_TOKEN)" \
+	  queue_dir="$(MINIO_QUEUE_DIR)" \
+	  queue_limit="$(MINIO_QUEUE_LIMIT)"
+.PHONY: minio-webhook-config
+
+minio-restart: minio-alias ## restart MinIO after config change
+	@echo "$(BOLD)Restarting MinIO service$(RESET)"
+	@mc admin service restart $(MINIO_ALIAS)
+.PHONY: minio-restart
+
+minio-events-reset: minio-alias ## remove all bucket notifications
+	@echo "$(BOLD)Removing existing bucket events on $(MINIO_BUCKET)$(RESET)"
+	@mc event remove --force $(MINIO_ALIAS)/$(MINIO_BUCKET) >/dev/null || true
+.PHONY: minio-events-reset
+
+minio-event-add: minio-alias ## add put event -> webhook
+	@echo "$(BOLD)Adding put event -> webhook $(MINIO_WEBHOOK_NAME)$(RESET)"
+	@mc event add $(MINIO_ALIAS)/$(MINIO_BUCKET) arn:minio:sqs::$(MINIO_WEBHOOK_NAME):webhook --event put
+	@mc event list $(MINIO_ALIAS)/$(MINIO_BUCKET)
+.PHONY: minio-event-add
+
+minio-webhook-setup: ## full setup: alias, config, restart, reset events, add event
+minio-webhook-setup: \
+	minio-webhook-config \
+	minio-restart \
+	minio-events-reset \
+	minio-event-add
+.PHONY: minio-webhook-setup
+
 # -- Front
 
 frontend-development-install: ## install the frontend locally

compose.yml

@@ -46,21 +46,6 @@ services:
       /usr/bin/mc mb meet/meet-media-storage && \
       exit 0;"
 
-  createwebhook:
-    image: minio/mc
-    depends_on:
-      minio:
-        condition: service_healthy
-        restart: true
-    entrypoint: >
-      sh -c "
-      /usr/bin/mc alias set meet http://minio:9000 meet password &&
-      /usr/bin/mc admin config set meet notify_webhook:meet-webhook endpoint='http://app-dev:8000/api/v1.0/recordings/storage-hook/' auth_token='Bearer password' &&
-      /usr/bin/mc admin service restart meet --wait --json &&
-      sleep 15 &&
-      /usr/bin/mc event add meet/meet-media-storage arn:minio:sqs::meet-webhook:webhook --event put &&
-      exit 0;"
-
   app-dev:
     build:
       context: .
@@ -87,7 +72,6 @@ services:
         - nginx
         - livekit
         - createbuckets
-        - createwebhook
     extra_hosts:
       - "127.0.0.1.nip.io:host-gateway"
   

docker/dinum-frontend/Dockerfile

@@ -42,7 +42,7 @@ COPY ./docker/dinum-frontend/fonts/ \
 FROM nginxinc/nginx-unprivileged:alpine3.21 AS frontend-production
 
 USER root
-RUN apk update && apk upgrade libssl3 libcrypto3 libxml2>=2.12.7-r2 libxslt>=1.1.39-r2 libexpat>=2.7.2-r0
+RUN apk update && apk upgrade libssl3 libcrypto3 libxml2>=2.12.7-r2 libxslt>=1.1.39-r2
 
 USER nginx
 

src/backend/core/recording/event/notification.py

@@ -131,8 +131,8 @@ class NotificationService:
         if not owner_access:
             logger.error("No owner found for recording %s", recording.id)
             return False
-
         payload = {
+            "owner_id": str(owner_access.user.id),
             "filename": recording.key,
             "email": owner_access.user.email,
             "sub": owner_access.user.sub,

src/frontend/Dockerfile

@@ -38,7 +38,7 @@ RUN npm run build
 FROM nginxinc/nginx-unprivileged:alpine3.21 AS frontend-production
 
 USER root
-RUN apk update && apk upgrade libssl3 libcrypto3 libxml2>=2.12.7-r2 libxslt>=1.1.39-r2 libexpat>=2.7.2-r0
+RUN apk update && apk upgrade libssl3 libcrypto3 libxml2>=2.12.7-r2 libxslt>=1.1.39-r2
 
 USER nginx
 

src/summary/summary/api/route/tasks.py

@@ -18,6 +18,7 @@ settings = get_settings()
 class TaskCreation(BaseModel):
     """Task data."""
 
+    owner_id: str
     filename: str
     email: str
     sub: str
@@ -35,6 +36,7 @@ async def create_task(request: TaskCreation):
     """Create a task."""
     task = process_audio_transcribe_summarize_v2.apply_async(
         args=[
+            request.owner_id,
             request.filename,
             request.email,
             request.sub,

src/summary/summary/core/celery_worker.py

@@ -204,6 +204,7 @@ def task_failure_handler(task_id, exception=None, **kwargs):
 )
 def process_audio_transcribe_summarize_v2(
     self,
+    owner_id: str,
     filename: str,
     email: str,
     sub: str,
@@ -320,7 +321,7 @@ def process_audio_transcribe_summarize_v2(
     metadata_manager.capture(task_id, settings.posthog_event_success)
 
     if (
-        analytics.is_feature_enabled("summary-enabled", distinct_id=sub)
+        analytics.is_feature_enabled("summary-enabled", distinct_id=owner_id)
         and settings.is_summary_enabled
     ):
         logger.info("Queuing summary generation task.")