diff --git a/app/public/index.html b/app/public/index.html
index 47d4814..d3a5662 100644
--- a/app/public/index.html
+++ b/app/public/index.html
@@ -12,7 +12,8 @@
 <body>
   <video id="v" controls autoplay muted></video>
   <script>
-    const wsUrl = `${location.protocol === 'https:' ? 'wss' : 'ws'}://${location.host}/ws`;
+    const cameraId = new URLSearchParams(location.search).get('camera') ?? 'v1';
+    const wsUrl = `${location.protocol === 'https:' ? 'wss' : 'ws'}://${location.host}/ws/${cameraId}`;
     const player = mpegts.createPlayer(
       { type: 'mpegts', isLive: true, url: wsUrl },
       { liveBufferLatencyChasing: true, liveBufferLatencyMaxLatency: 1.5 }
diff --git a/app/src/handlers/edge5-video-v2.ts b/app/src/handlers/edge5-video-v2.ts
index 75897a1..2d95982 100644
--- a/app/src/handlers/edge5-video-v2.ts
+++ b/app/src/handlers/edge5-video-v2.ts
@@ -1,5 +1,6 @@
 import { log } from '../helpers/log.js'
 import { lastTopicSegment } from '../helpers/topic-match.js'
+import { onEdgeChunk } from '../stream/edge-chunk-relay.js'
 import type { TopicHandler } from '../types.js'
 
 const LOG_INTERVAL_MS = 10_000
@@ -9,15 +10,12 @@ const lastLogByCamera = new Map<string, number>()
 export const handleEdge5VideoV2: TopicHandler = async (topic, payload) => {
   const cameraId = lastTopicSegment(topic)
 
-  if (!cameraId) {
-    console.warn('edge5.video.v2.invalid_topic', { topic })
-    return
-  }
-
   const now = Date.now()
   const lastLog = lastLogByCamera.get(cameraId) ?? 0
   if (now - lastLog >= LOG_INTERVAL_MS) {
     log(`edge5.video.v2 [${cameraId}] ↑ ${payload.length}B`)
     lastLogByCamera.set(cameraId, now)
   }
+
+  onEdgeChunk(cameraId, payload);
 }
diff --git a/app/src/handlers/edge5-video.ts b/app/src/handlers/edge5-video.ts
index 0e587b1..e75b156 100644
--- a/app/src/handlers/edge5-video.ts
+++ b/app/src/handlers/edge5-video.ts
@@ -11,5 +11,5 @@ export const handleEdge5Video: TopicHandler = async (_topic, payload) => {
     log(`edge5.video ↑ ${payload.length}B`)
     lastLog = now
   }
-  onEdgeChunk(payload)
+  onEdgeChunk('v1', payload);
 }
\ No newline at end of file
diff --git a/app/src/stream/edge-chunk-relay.ts b/app/src/stream/edge-chunk-relay.ts
index 4cecd24..507c7f2 100644
--- a/app/src/stream/edge-chunk-relay.ts
+++ b/app/src/stream/edge-chunk-relay.ts
@@ -2,30 +2,40 @@ import type { IncomingMessage } from 'http'
 import { WebSocket, WebSocketServer } from 'ws'
 
 import { log } from '../helpers/log.js'
+import { lastTopicSegment } from '../helpers/topic-match.js'
 
 const wsPort = Number(process.env.WS_PORT)
 
 const wss = new WebSocketServer({ port: wsPort, perMessageDeflate: false })
-const clients = new Set<WebSocket>()
+
+const clientsByCamera = new Map<string, Set<WebSocket>>()
+
+function getClients(cameraId: string): Set<WebSocket> {
+  let clients = clientsByCamera.get(cameraId)
+  if (!clients) {
+    clients = new Set()
+    clientsByCamera.set(cameraId, clients)
+  }
+  return clients
+}
 
 wss.on('connection', (ws: WebSocket, req: IncomingMessage) => {
-  clients.add(ws)
-  log('ws.client_connected', {
-    clients: clients.size,
-    ip: req.socket.remoteAddress,
-  })
+  log(`ws.connection ${req.url}`);
+  const cameraId = req.url ? lastTopicSegment(req.url) : 'v1';
+
+  const clients = getClients(cameraId);
+  clients.add(ws);
 
   ws.on('close', () => {
     clients.delete(ws)
-    log('ws.client_closed', { clients: clients.size })
-  })
+    if (clients.size === 0) clientsByCamera.delete(cameraId)
+  });
+
 })
 
-wss.on('listening', () => {
-  log('ws.server_started', { port: wsPort })
-})
-
-export function onEdgeChunk(chunk: Buffer): void {
+export function onEdgeChunk(cameraId: string, chunk: Buffer): void {
+  const clients = clientsByCamera.get(cameraId)
+  if (!clients) return
   for (const client of clients) {
     if (client.readyState === WebSocket.OPEN) {
       client.send(chunk)
