Docker: Video recorder/uploader listen on session events (#3070)

* Docker: Video recorder/uploader listen on session events
* Handle session events for standalone

---------

Signed-off-by: Viet Nguyen Duc <viet.dnguyen@katalon.com>

Author: VietND96

Base/Dockerfile

@@ -193,7 +193,7 @@ RUN ARCH=$(if [ "$(dpkg --print-architecture)" = "amd64" ]; then echo "x86_64";
 USER ${SEL_UID}:${SEL_GID}
 
 RUN python3 -m venv $VENV_PATH \
-    && $VENV_PATH/bin/python3 -m pip install --upgrade pip psutil requests \
+    && $VENV_PATH/bin/python3 -m pip install --upgrade pip psutil requests pyzmq \
     && wget -q https://github.com/Supervisor/supervisor/archive/refs/heads/main.zip -O /tmp/supervisor.zip \
     && unzip /tmp/supervisor.zip -d /tmp \
     && cd /tmp/supervisor-main \

Makefile

@@ -1115,7 +1115,7 @@ test_node_docker: hub standalone_docker standalone_chrome standalone_firefox sta
 		echo VIDEO_TAG=$(FFMPEG_TAG_VERSION)-$(BUILD_DATE) >> .env ; \
 		echo TEST_DRAIN_AFTER_SESSION_COUNT=$(or $(TEST_DRAIN_AFTER_SESSION_COUNT), 0) >> .env ; \
 		echo TEST_PARALLEL_HARDENING=$(or $(TEST_PARALLEL_HARDENING), "false") >> .env ; \
-		echo LOG_LEVEL=$(or $(LOG_LEVEL), "INFO") >> .env ; \
+		echo LOG_LEVEL=$(or $(LOG_LEVEL), "FINE") >> .env ; \
 		echo REQUEST_TIMEOUT=$(or $(REQUEST_TIMEOUT), 300) >> .env ; \
 		echo SELENIUM_ENABLE_MANAGED_DOWNLOADS=$(or $(SELENIUM_ENABLE_MANAGED_DOWNLOADS), "false") >> .env ; \
 		echo TEST_DELAY_AFTER_TEST=$(or $(TEST_DELAY_AFTER_TEST), 2) >> .env ; \

Standalone/Dockerfile

@@ -27,6 +27,10 @@ ENV SE_SESSION_REQUEST_TIMEOUT="300" \
     SE_RELAX_CHECKS="true" \
     SE_REJECT_UNSUPPORTED_CAPS="true" \
     SE_OTEL_SERVICE_NAME="selenium-standalone" \
-    SE_NODE_ENABLE_MANAGED_DOWNLOADS="true"
+    SE_NODE_ENABLE_MANAGED_DOWNLOADS="true" \
+    SE_BIND_BUS="false" \
+    SE_EVENT_BUS_IMPLEMENTATION=""
 
 EXPOSE 4444
+EXPOSE 4443
+EXPOSE 4442

Standalone/start-selenium-standalone.sh

@@ -103,6 +103,17 @@ if [ ! -z "${SE_EVENT_BUS_HEARTBEAT_PERIOD}" ]; then
   append_se_opts "--eventbus-heartbeat-period" "${SE_EVENT_BUS_HEARTBEAT_PERIOD}"
 fi
 
+if [ ! -z "${SE_EVENT_BUS_IMPLEMENTATION}" ]; then
+  append_se_opts "--events-implementation" "${SE_EVENT_BUS_IMPLEMENTATION}"
+fi
+
+if [ "${SE_BIND_BUS}" = "true" ]; then
+  append_se_opts "--bind-bus" "${SE_BIND_BUS}"
+  if [ -z "${SE_EVENT_BUS_IMPLEMENTATION}" ]; then
+    append_se_opts "--events-implementation" "org.openqa.selenium.events.zeromq.ZeroMqEventBus"
+  fi
+fi
+
 if [ "${SE_ENABLE_TLS}" = "true" ]; then
   # Configure truststore for the server
   if [ ! -z "$SE_JAVA_SSL_TRUST_STORE" ]; then

Video/recorder.conf

@@ -1,6 +1,6 @@
 [program:video-recording]
 priority=10
-command=/opt/bin/video.sh
+command=python3 /opt/bin/video_recorder.py
 killasgroup=true
 autostart=%(ENV_SE_RECORD_VIDEO)s
 startsecs=0

Video/uploader.conf

@@ -1,6 +1,6 @@
 [program:video-upload]
 priority=5
-command=/opt/bin/upload.sh
+command=python3 /opt/bin/video_uploader.py
 killasgroup=true
 autostart=%(ENV_SE_VIDEO_UPLOAD_ENABLED)s
 startsecs=0

Video/video_recorder.py

@@ -0,0 +1,39 @@
+#!/usr/bin/env python3
+"""
+Video service entry point that switches between:
+1. Unified event-driven service (SE_EVENT_DRIVEN_SERVICES=true)
+2. Traditional shell-based polling (SE_EVENT_DRIVEN_SERVICES=false or unset)
+
+When event-driven mode is enabled, this launches a single unified service
+that handles both recording and uploading with shared state management.
+"""
+
+import os
+import subprocess
+import sys
+
+
+def main():
+    event_driven = os.environ.get("SE_EVENT_DRIVEN_SERVICES", "false").lower() == "true"
+
+    if event_driven:
+        print("Starting unified event-driven video service...")
+        print("This service handles both recording and uploading with shared state.")
+        try:
+            import asyncio
+
+            from video_service import main as service_main
+
+            asyncio.run(service_main())
+        except ImportError as e:
+            print(f"Failed to import video service: {e}")
+            print("Ensure pyzmq is installed: pip install pyzmq")
+            print("Falling back to shell-based recording...")
+            subprocess.run(["/opt/bin/video.sh"], check=True)
+    else:
+        print("Starting shell-based video recording...")
+        subprocess.run(["/opt/bin/video.sh"], check=True)
+
+
+if __name__ == "__main__":
+    main()