Add client_id to sync stream request.

Author: rkistner

packages/powersync/lib/src/bucket_storage.dart

@@ -40,6 +40,11 @@ class BucketStorage {
     ];
   }
 
+  Future<String> getClientId() async {
+    final rows = await select('SELECT powersync_client_id() as client_id');
+    return rows.first['client_id'] as String;
+  }
+
   Future<void> streamOp(String op) async {
     await writeTransaction((tx) async {
       await tx.execute(

packages/powersync/lib/src/streaming_sync.dart

@@ -245,6 +245,7 @@ class StreamingSyncImplementation {
       {AbortController? abortController}) async {
     adapter.startSession();
     final bucketEntries = await adapter.getBucketStates();
+    final clientId = await adapter.getClientId();
 
     Map<String, String> initialBucketStates = {};
 
@@ -262,8 +263,8 @@ class StreamingSyncImplementation {
     Checkpoint? appliedCheckpoint;
     var bucketSet = Set<String>.from(initialBucketStates.keys);
 
-    var requestStream =
-        streamingSyncRequest(StreamingSyncRequest(buckets, syncParameters));
+    var requestStream = streamingSyncRequest(
+        StreamingSyncRequest(buckets, syncParameters, clientId));
 
     var merged = addBroadcast(requestStream, _localPingController.stream);
 

packages/powersync/lib/src/sync_types.dart

@@ -112,15 +112,17 @@ Object? parseStreamingSyncLine(Map<String, dynamic> line) {
 class StreamingSyncRequest {
   List<BucketRequest> buckets;
   bool includeChecksum = true;
+  String clientId;
   Map<String, dynamic>? parameters;
 
-  StreamingSyncRequest(this.buckets, this.parameters);
+  StreamingSyncRequest(this.buckets, this.parameters, this.clientId);
 
   Map<String, dynamic> toJson() {
     final Map<String, dynamic> json = {
       'buckets': buckets,
       'include_checksum': includeChecksum,
       'raw_data': true,
+      'client_id': clientId
     };
 
     if (parameters != null) {