Add image preview to demo

Author: stevensJourney

Demo/PowerSyncExample/Components/TodoListRow.swift

@@ -3,10 +3,30 @@ import SwiftUI
 struct TodoListRow: View {
   let todo: Todo
   let completeTapped: () -> Void
+    @State private var image: UIImage? = nil
 
   var body: some View {
     HStack {
       Text(todo.description)
+        Group {
+            if (todo.photoUri == nil) {
+                // Nothing to display when photoURI is nil
+                EmptyView()
+            } else if let image = image {
+                        Image(uiImage: image)
+                            .resizable()
+                            .scaledToFit()
+            } else if todo.photoUri != nil {
+                // Only show loading indicator if we have a URL string
+                ProgressView()
+                    .onAppear {
+                        loadImage()
+                    }}
+            else {
+                                EmptyView()
+                            }
+                  
+                }
       Spacer()
       Button {
         completeTapped()
@@ -16,6 +36,18 @@ struct TodoListRow: View {
       .buttonStyle(.plain)
     }
   }
+    
+    private func loadImage() {
+        guard let urlString = todo.photoUri else {
+            return
+        }
+        let url = URL(fileURLWithPath: urlString)
+        
+        if let imageData = try? Data(contentsOf: url),
+           let loadedImage = UIImage(data: imageData) {
+            self.image = loadedImage
+        }
+    }
 }
 
 

Demo/PowerSyncExample/PowerSync/Schema.swift

@@ -10,7 +10,7 @@ let lists = Table(
         // ID column is automatically included
         .text("name"),
         .text("created_at"),
-        .text("owner_id")
+        .text("owner_id"),
     ]
 )
 
@@ -26,14 +26,14 @@ let todos = Table(
         Column.text("created_at"),
         Column.text("completed_at"),
         Column.text("created_by"),
-        Column.text("completed_by")
+        Column.text("completed_by"),
     ],
     indexes: [
         Index(
             name: "list_id",
             columns: [IndexedColumn.ascending("list_id")]
-        )
+        ),
     ]
 )
 
-let AppSchema = Schema(lists, todos)
+let AppSchema = Schema(lists, todos, createAttachmentsTable(name: "attachments"))

Demo/PowerSyncExample/PowerSync/SupabaseConnector.swift

@@ -1,10 +1,10 @@
+import AnyCodable
 import Auth
-import SwiftUI
-import Supabase
 import PowerSync
-import AnyCodable
+import Supabase
+import SwiftUI
 
-private struct PostgresFatalCodes {
+private enum PostgresFatalCodes {
     /// Postgres Response codes that we cannot recover from by retrying.
     static let fatalResponseCodes: [String] = [
         // Class 22 — Data Exception
@@ -14,7 +14,7 @@ private struct PostgresFatalCodes {
         // Examples include NOT NULL, FOREIGN KEY and UNIQUE violations.
         "23...",
         // INSUFFICIENT PRIVILEGE - typically a row-level security violation
-        "42501"
+        "42501",
     ]
 
     static func isFatalError(_ code: String) -> Bool {
@@ -27,20 +27,20 @@ private struct PostgresFatalCodes {
         // Look for code: Optional("XXXXX") pattern
         let errorString = String(describing: error)
         if let range = errorString.range(of: "code: Optional\\(\"([^\"]+)\"\\)", options: .regularExpression),
-            let codeRange = errorString[range].range(of: "\"([^\"]+)\"", options: .regularExpression) {
-                // Extract just the code from within the quotes
-                let code = errorString[codeRange].dropFirst().dropLast()
-                return String(code)
-            }
+           let codeRange = errorString[range].range(of: "\"([^\"]+)\"", options: .regularExpression)
+        {
+            // Extract just the code from within the quotes
+            let code = errorString[codeRange].dropFirst().dropLast()
+            return String(code)
+        }
         return nil
     }
 }
 
-
 @Observable
 class SupabaseConnector: PowerSyncBackendConnector {
     let powerSyncEndpoint: String = Secrets.powerSyncEndpoint
-    let client: SupabaseClient = SupabaseClient(supabaseURL: Secrets.supabaseURL, supabaseKey: Secrets.supabaseAnonKey)
+    let client: SupabaseClient = .init(supabaseURL: Secrets.supabaseURL, supabaseKey: Secrets.supabaseAnonKey)
     var session: Session?
     private var errorCode: String?
 
@@ -68,20 +68,23 @@ class SupabaseConnector: PowerSyncBackendConnector {
         return id.uuidString.lowercased()
     }
 
+    func getStorageBucket() -> StorageFileApi {
+        return client.storage.from(Secrets.supabaseStorageBucket)
+    }
+
     override func fetchCredentials() async throws -> PowerSyncCredentials? {
         session = try await client.auth.session
 
-        if (self.session == nil) {
+        if session == nil {
             throw AuthError.sessionMissing
         }
 
         let token = session!.accessToken
 
-        return PowerSyncCredentials(endpoint: self.powerSyncEndpoint, token: token)
+        return PowerSyncCredentials(endpoint: powerSyncEndpoint, token: token)
     }
 
     override func uploadData(database: PowerSyncDatabaseProtocol) async throws {
-
         guard let transaction = try await database.getNextCrudTransaction() else { return }
 
         var lastEntry: CrudEntry?
@@ -96,39 +99,36 @@ class SupabaseConnector: PowerSyncBackendConnector {
                 case .put:
                     var data: [String: AnyCodable] = entry.opData?.mapValues { AnyCodable($0) } ?? [:]
                     data["id"] = AnyCodable(entry.id)
-                    try await table.upsert(data).execute();
+                    try await table.upsert(data).execute()
                 case .patch:
                     guard let opData = entry.opData else { continue }
                     let encodableData = opData.mapValues { AnyCodable($0) }
                     try await table.update(encodableData).eq("id", value: entry.id).execute()
                 case .delete:
-                    try await table.delete().eq( "id", value: entry.id).execute()
+                    try await table.delete().eq("id", value: entry.id).execute()
                 }
             }
 
             _ = try await transaction.complete.invoke(p1: nil)
 
         } catch {
             if let errorCode = PostgresFatalCodes.extractErrorCode(from: error),
-                PostgresFatalCodes.isFatalError(errorCode) {
-                    /// Instead of blocking the queue with these errors,
-                    /// discard the (rest of the) transaction.
-                    ///
-                    /// Note that these errors typically indicate a bug in the application.
-                    /// If protecting against data loss is important, save the failing records
-                    /// elsewhere instead of discarding, and/or notify the user.
-                    print("Data upload error: \(error)")
-                    print("Discarding entry: \(lastEntry!)")
-                    _ = try await transaction.complete.invoke(p1: nil)
-                    return
-                }
+               PostgresFatalCodes.isFatalError(errorCode)
+            {
+                /// Instead of blocking the queue with these errors,
+                /// discard the (rest of the) transaction.
+                ///
+                /// Note that these errors typically indicate a bug in the application.
+                /// If protecting against data loss is important, save the failing records
+                /// elsewhere instead of discarding, and/or notify the user.
+                print("Data upload error: \(error)")
+                print("Discarding entry: \(lastEntry!)")
+                _ = try await transaction.complete.invoke(p1: nil)
+                return
+            }
 
             print("Data upload error - retrying last entry: \(lastEntry!), \(error)")
             throw error
         }
     }
-
-    deinit {
-        observeAuthStateChangesTask?.cancel()
-    }
 }

Demo/PowerSyncExample/PowerSync/SupabaseRemoteStorage.swift

@@ -0,0 +1,23 @@
+import Foundation
+import PowerSync
+import Supabase
+
+class SupabaseRemoteStorage: RemoteStorageAdapter {
+    let storage: Supabase.StorageFileApi
+
+    init(storage: Supabase.StorageFileApi) {
+        self.storage = storage
+    }
+
+    func uploadFile(fileData: Data, attachment: PowerSync.Attachment) async throws {
+        try await storage.upload(attachment.filename, data: fileData)
+    }
+
+    func downloadFile(attachment: PowerSync.Attachment) async throws -> Data {
+        try await storage.download(path: attachment.filename)
+    }
+
+    func deleteFile(attachment: PowerSync.Attachment) async throws {
+        _ = try await storage.remove(paths: [attachment.filename])
+    }
+}