From 7c0680df4b19a21a7cbe5e43caf21f7b5d04e871 Mon Sep 17 00:00:00 2001
From: Steven Ontong <steven@journeyapps.com>
Date: Tue, 27 Aug 2024 15:08:54 +0200
Subject: [PATCH] added client_id log to sync/stream endpoint

---
 .changeset/stale-llamas-shave.md                           | 5 +++++
 packages/service-core/src/routes/endpoints/socket-route.ts | 1 +
 2 files changed, 6 insertions(+)
 create mode 100644 .changeset/stale-llamas-shave.md

diff --git a/.changeset/stale-llamas-shave.md b/.changeset/stale-llamas-shave.md
new file mode 100644
index 000000000..c8a22760f
--- /dev/null
+++ b/.changeset/stale-llamas-shave.md
@@ -0,0 +1,5 @@
+---
+'@powersync/service-core': patch
+---
+
+Added `client_id` log to WebSocket `sync/stream` endpoint.
diff --git a/packages/service-core/src/routes/endpoints/socket-route.ts b/packages/service-core/src/routes/endpoints/socket-route.ts
index 8759ef355..9a46c2147 100644
--- a/packages/service-core/src/routes/endpoints/socket-route.ts
+++ b/packages/service-core/src/routes/endpoints/socket-route.ts
@@ -124,6 +124,7 @@ export const syncStreamReactive: SocketRouteGenerator = (router) =>
         disposer();
         logger.info(`Sync stream complete`, {
           user_id: syncParams.user_id,
+          client_id: params.client_id,
           user_agent: context.user_agent,
           operations_synced: tracker.operationsSynced,
           data_synced_bytes: tracker.dataSyncedBytes