fix(windows): import remote clipboard history

Author: jqlovezkk

clipSync-windows/ClipSync.WPF.Tests/ProtocolTests.cs

@@ -74,6 +74,18 @@ public void CreateDeviceListMessage()
             Assert.Equal("device_list", obj["type"]?.Value<string>());
         }
 
+        [Fact]
+        public void CreateDeviceUnregisterMessage_IncludesDeviceId()
+        {
+            // Act
+            string message = Protocol.CreateDeviceUnregisterMessage("dev-123");
+
+            // Assert
+            var obj = JObject.Parse(message);
+            Assert.Equal("device_unregister", obj["type"]?.Value<string>());
+            Assert.Equal("dev-123", obj["payload"]?["device_id"]?.Value<string>());
+        }
+
         [Fact]
         public void Deserialize_ValidMessage()
         {

clipSync-windows/ClipSync.WPF/Core/SyncEngine.cs

@@ -20,6 +20,7 @@ public class SyncEngine : IDisposable
 
         public event Action<string>? ConnectionStateChanged;
         public event Action<Network.ClipboardItem>? ClipboardItemReceived;
+        public event Action? ClipboardHistoryUpdated;
         public event Action<string>? ErrorOccurred;
         public event Action<List<Network.Device>>? DeviceListUpdated;
 
@@ -156,7 +157,7 @@ private async void OnWebSocketMessage(string message)
                         _heartbeatTimer?.OnHeartbeatAck();
                         break;
                     case "clipboard_history":
-                        HandleClipboardHistory(wsMessage);
+                        await HandleClipboardHistoryAsync(wsMessage);
                         break;
                     case "device_list_response":
                         HandleDeviceListResponse(wsMessage);
@@ -278,13 +279,54 @@ private async Task HandleClipboardSync(WebSocketMessage message)
 
             if (_database != null)
             {
-                await _database.InsertClipboardItemAsync(item);
+                _ = await _database.InsertClipboardItemAsync(item);
             }
         }
 
-        private void HandleClipboardHistory(WebSocketMessage message)
+        private async Task HandleClipboardHistoryAsync(WebSocketMessage message)
         {
-            // Handle clipboard history response if needed
+            var itemsArray = message.Payload?.Property("items")?.Value;
+            if (itemsArray == null)
+            {
+                AppLogger.Warn("SyncEngine", "收到 clipboard_history，但缺少 items 字段");
+                return;
+            }
+
+            var importedCount = 0;
+            foreach (var itemToken in itemsArray)
+            {
+                var item = new Network.ClipboardItem
+                {
+                    Id = GetLong(itemToken, "id"),
+                    ContentType = GetString(itemToken, "content_type", "text"),
+                    Content = GetString(itemToken, "content"),
+                    Format = GetString(itemToken, "format"),
+                    Size = GetLong(itemToken, "size"),
+                    Checksum = GetString(itemToken, "checksum"),
+                    SourceDeviceId = GetString(itemToken, "source_device_id"),
+                    SourceDeviceName = GetString(itemToken, "source_device_name", "Unknown device"),
+                    CreatedAt = GetLong(itemToken, "created_at")
+                };
+
+                if (string.IsNullOrEmpty(item.Content) || string.IsNullOrEmpty(item.Checksum))
+                {
+                    continue;
+                }
+
+                if (_database != null && await _database.InsertClipboardItemAsync(item))
+                {
+                    importedCount++;
+                }
+            }
+
+            var total = GetLong(message.Payload, "total");
+            var hasMore = GetBool(message.Payload, "has_more");
+            AppLogger.Info("SyncEngine", $"收到剪贴板历史: imported={importedCount}, total={total}, has_more={hasMore}");
+
+            if (importedCount > 0)
+            {
+                ClipboardHistoryUpdated?.Invoke();
+            }
         }
 
         private void HandleDeviceListResponse(WebSocketMessage message)
@@ -479,7 +521,7 @@ private async Task SaveClipboardItemAsync(ClipboardChangedEventArgs args, string
                 CreatedAt = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds()
             };
 
-            await _database.InsertClipboardItemAsync(item);
+            _ = await _database.InsertClipboardItemAsync(item);
         }
 
         private async Task PublishClipboardChangedEventAsync(ClipboardChangedEventArgs args)

clipSync-windows/ClipSync.WPF/MainWindow.xaml.cs

@@ -63,6 +63,7 @@ public MainWindow(SettingsManager settingsManager, SyncEngine syncEngine, System
             _syncEngine.ErrorOccurred += OnErrorOccurred;
             _syncEngine.DeviceListUpdated += OnDeviceListUpdated;
             _syncEngine.ClipboardItemReceived += OnClipboardItemReceived;
+            _syncEngine.ClipboardHistoryUpdated += OnClipboardHistoryUpdated;
 
             ShowLoginContent();
         }
@@ -491,6 +492,12 @@ private async void OnClipboardItemReceived(Network.ClipboardItem item)
             await LoadHistoryAsync();
         }
 
+        private async void OnClipboardHistoryUpdated()
+        {
+            AppLogger.Info("MainWindow", "远端剪贴板历史已导入，准备刷新历史列表");
+            await LoadHistoryAsync();
+        }
+
         private void ShowMainContent()
         {
             _isLoggedIn = true;

clipSync-windows/ClipSync.WPF/Network/Protocol.cs

@@ -158,6 +158,15 @@ public static string CreateDeviceListMessage()
             return Serialize(WebSocketMessage.Create("device_list", new JObject()));
         }
 
+        public static string CreateDeviceUnregisterMessage(string deviceId)
+        {
+            var payload = new JObject
+            {
+                ["device_id"] = deviceId
+            };
+            return Serialize(WebSocketMessage.Create("device_unregister", payload));
+        }
+
         public static string CreatePongMessage()
         {
             return Serialize(WebSocketMessage.Create("pong", new JObject()));

clipSync-windows/ClipSync.WPF/Storage/LocalDatabase.cs

@@ -57,11 +57,11 @@ CREATE INDEX IF NOT EXISTS idx_clipboard_created_at
             });
         }
 
-        public async Task InsertClipboardItemAsync(Network.ClipboardItem item)
+        public async Task<bool> InsertClipboardItemAsync(Network.ClipboardItem item)
         {
             await EnsureInitializedAsync();
 
-            await Task.Run(() =>
+            return await Task.Run(() =>
             {
                 using var connection = new SqliteConnection($"Data Source={_dbPath}");
                 connection.Open();
@@ -70,8 +70,15 @@ await Task.Run(() =>
                 command.CommandText = @"
                     INSERT INTO clipboard_history
                     (content_type, content, format, size, checksum, source_device_id, source_device_name, created_at)
-                    VALUES
-                    (@contentType, @content, @format, @size, @checksum, @sourceDeviceId, @sourceDeviceName, @createdAt)";
+                    SELECT
+                    @contentType, @content, @format, @size, @checksum, @sourceDeviceId, @sourceDeviceName, @createdAt
+                    WHERE NOT EXISTS (
+                        SELECT 1
+                        FROM clipboard_history
+                        WHERE checksum = @checksum
+                          AND source_device_id = @sourceDeviceId
+                          AND created_at = @createdAt
+                    )";
                 command.Parameters.AddWithValue("@contentType", item.ContentType);
                 command.Parameters.AddWithValue("@content", item.Content);
                 command.Parameters.AddWithValue("@format", item.Format);
@@ -80,7 +87,12 @@ INSERT INTO clipboard_history
                 command.Parameters.AddWithValue("@sourceDeviceId", item.SourceDeviceId);
                 command.Parameters.AddWithValue("@sourceDeviceName", item.SourceDeviceName);
                 command.Parameters.AddWithValue("@createdAt", item.CreatedAt);
-                command.ExecuteNonQuery();
+                var inserted = command.ExecuteNonQuery() > 0;
+
+                if (!inserted)
+                {
+                    return false;
+                }
 
                 // Keep only last 50 items
                 var deleteCommand = connection.CreateCommand();
@@ -92,6 +104,8 @@ ORDER BY created_at DESC
                         LIMIT 50
                     )";
                 deleteCommand.ExecuteNonQuery();
+
+                return true;
             });
         }