Refresh session before calling into Postgrest (#33)

* Update postgres-swift and add support for `RequestAdapter`

* Implement `PostgrestClientDelegate` for refreshing and inserting access token before postgrest request

* Update dependencies

Author: Guilherme Souza

Package.resolved

@@ -19,10 +19,10 @@ let package = Package(
     )
   ],
   dependencies: [
-    .package(url: "https://github.com/supabase-community/gotrue-swift", from: "0.0.5"),
+    .package(url: "https://github.com/supabase-community/gotrue-swift", from: "0.0.7"),
     .package(url: "https://github.com/supabase-community/storage-swift.git", from: "0.0.2"),
     .package(url: "https://github.com/supabase-community/realtime-swift.git", from: "0.0.1"),
-    .package(url: "https://github.com/supabase-community/postgrest-swift", from: "0.0.4"),
+    .package(url: "https://github.com/supabase-community/postgrest-swift", from: "0.0.5"),
   ],
   targets: [
     .target(

Package.swift

@@ -40,7 +40,11 @@ public class SupabaseClient {
     var headers: [String: String] = defaultHeaders
     headers["Authorization"] = "Bearer \(auth.session?.accessToken ?? supabaseKey)"
     return PostgrestClient(
-      url: restURL.absoluteString, headers: headers, fetch: nil, schema: schema)
+      url: restURL.absoluteString,
+      headers: headers,
+      schema: schema,
+      delegate: self
+    )
   }
 
   /// Realtime client for Supabase
@@ -77,3 +81,24 @@ public class SupabaseClient {
     realtime = RealtimeClient(endPoint: realtimeURL.absoluteString, params: defaultHeaders)
   }
 }
+
+extension SupabaseClient: PostgrestClientDelegate {
+  public func client(
+    _ client: PostgrestClient,
+    willSendRequest request: URLRequest,
+    completion: @escaping (URLRequest) -> Void
+  ) {
+    Task {
+      do {
+        try await auth.refreshCurrentSessionIfNeeded()
+        var request = request
+        if let accessToken = auth.session?.accessToken {
+          request.setValue("Bearer \(accessToken)", forHTTPHeaderField: "Authorization")
+        }
+        completion(request)
+      } catch {
+        completion(request)
+      }
+    }
+  }
+}