Migrating To GRDBQuery 0.9

Gem/App.swift

@@ -20,6 +20,7 @@ struct GemApp: App {
             WalletCoordinator(
                 db: db
             )
+            .databaseContext(.readWrite { db.dbQueue })
             .navigationBarTitleDisplayMode(.inline)
             .tint(Colors.blue)
         }

Gem/Connections/Scenes/ConnectionsScene.swift

@@ -15,7 +15,7 @@ struct ConnectionsScene: View {
     @State private var isPresentingScanner: Bool = false
     @State private var isPresentingErrorMessage: String?
 
-    @Query<ConnectionsRequest>
+    @Query(ConnectionsRequest())
     var connections: [WalletConnection]
 
     var groupedByWallet: [Wallet: [Primitives.WalletConnection]] {
@@ -32,7 +32,6 @@ struct ConnectionsScene: View {
         model: ConnectionsViewModel
     ) {
         self.model = model
-        _connections = Query(ConnectionsRequest(), in: \.db.dbQueue)
     }
 
     var body: some View {

Gem/Wallet/Types/Environment.swift

@@ -7,6 +7,7 @@ import Store
 import Keystore
 import GemstonePrimitives
 
+// TODO: - remove ref. https://swiftpackageindex.com/groue/grdbquery/0.9.0/documentation/grdbquery/migratingtogrdbquery09-unrestricted-writes
 struct DatabaseQueueKey: EnvironmentKey {
     static var defaultValue: DB { DB.main }
 }
@@ -80,6 +81,7 @@ struct IsWalletPresentedServiceKey: EnvironmentKey {
 }
 
 extension EnvironmentValues {
+    // TODO: - remove ref. https://swiftpackageindex.com/groue/grdbquery/0.9.0/documentation/grdbquery/migratingtogrdbquery09-unrestricted-writes
     var db: DB {
         get { self[DatabaseQueueKey.self] }
         set { self[DatabaseQueueKey.self] = newValue }

Packages/Store/Sources/Requests/ConnectionsRequest.swift

@@ -6,21 +6,13 @@ import GRDBQuery
 import Combine
 import Primitives
 
-public struct ConnectionsRequest: Queryable {
+public struct ConnectionsRequest: ValueObservationQueryable {
     public static var defaultValue: [WalletConnection] { [] }
 
     public init() {
     }
-
-    public func publisher(in dbQueue: DatabaseQueue) -> AnyPublisher<[WalletConnection], Error> {
-        ValueObservation
-            .tracking { db in try fetch(db) }
-            .publisher(in: dbQueue, scheduling: .immediate)
-            .map { $0.map{ $0 } }
-            .eraseToAnyPublisher()
-    }
-
-    private func fetch(_ db: Database) throws -> [WalletConnection] {
+
+    public func fetch(_ db: Database) throws -> [WalletConnection] {
         return try WalletRecord
             .including(required: WalletRecord.connection)
             .asRequest(of: WalletConnectionInfo.self)