Fix sync in demo app

Author: simolus3

Demos/PowerSyncExample/PowerSyncExample.xcodeproj/project.xcworkspace/xcshareddata/swiftpm/Package.resolved

@@ -440,5 +440,5 @@ struct WriteCheckpointResponse: Codable {
 }
 
 private func sleepForSeconds(seconds: TimeInterval) async throws {
-    try await Task.sleep(nanoseconds: UInt64(seconds * 1_000_000_00))
+    try await Task.sleep(nanoseconds: UInt64(seconds * 1_000_000_000))
 }

Sources/PowerSync/Implementation/sync/StreamingSyncClient.swift

@@ -12,7 +12,7 @@ public protocol IndexProtocol: Sendable {
     var columns: [IndexedColumnProtocol] { get }
 }
 
-public struct Index: IndexProtocol, Encodable {
+public struct Index: IndexProtocol {
     public let name: String
     public let columns: [IndexedColumnProtocol]
 
@@ -48,24 +48,31 @@ public struct Index: IndexProtocol, Encodable {
         return ascending(name: name, columns: [column])
     }
 
-    public func encode(to encoder: any Encoder) throws {
+    internal func encode(table: borrowing Table, to: any UnkeyedEncodingContainer) throws {
         enum CodingKeys: CodingKey {
             case name
             case columns
         }
 
-        var container = encoder.container(keyedBy: CodingKeys.self)
+        var to = to
+        var container = to.nestedContainer(keyedBy: CodingKeys.self)
         try container.encode(name, forKey: .name)
         var columnsContainer = container.nestedUnkeyedContainer(forKey: .columns)
         for column in columns {
             enum IndexedColumnCodingKeys: CodingKey {
                 case name
                 case ascending
+                case type
             }
 
             var container = columnsContainer.nestedContainer(keyedBy: IndexedColumnCodingKeys.self)
             try container.encode(column.column, forKey: .name)
             try container.encode(column.ascending, forKey: .ascending)
+            guard let tableColumn = table.columns.first(where: { c in c.name == column.column }) else {
+                throw PowerSyncError.operationFailed(message: "Unserializable schema: Index \(self.name) references column \(column.column) which does not exist in \(table.name)")
+            }
+
+            try container.encode(tableColumn.type, forKey: .type)
         }
     }
 }

Sources/PowerSync/Protocol/Schema/Index.swift

@@ -190,7 +190,10 @@ public struct Table: TableProtocol, Encodable {
         try container.encode(name, forKey: .outer(.name))
         try container.encodeIfPresent(viewNameOverride, forKey: .outer(.viewName))
         try container.encode(columns, forKey: .outer(.columns))
-        try container.encode(indexes, forKey: .outer(.indexes))
+        let indexContainer = container.nestedUnkeyedContainer(forKey: .outer(.indexes))
+        for index in indexes {
+            try index.encode(table: self, to: indexContainer)
+        }
         try options.serializeTo(container)
     }
 }

Sources/PowerSync/Protocol/Schema/Table.swift

@@ -272,7 +272,8 @@ final class TableTests: XCTestCase {
       "columns" : [
         {
           "ascending" : true,
-          "name" : "name"
+          "name" : "name",
+          "type" : "text"
         }
       ],
       "name" : "test_index"