@@ -18,13 +18,14 @@ import Foundation
1818#else
1919 import firebase_core_shared
2020#endif
21- import FirebaseDatabase
2221
2322// Channel name constant to match macOS implementation
2423let FLTFirebaseDatabaseChannelName = " plugins.flutter.io/firebase_database "
2524
2625@objc ( FLTFirebaseDatabasePlugin)
27- public class FLTFirebaseDatabasePlugin : NSObject , FlutterPlugin , FLTFirebasePluginProtocol , FirebaseDatabaseHostApi {
26+ public class FLTFirebaseDatabasePlugin : NSObject , FlutterPlugin , FLTFirebasePluginProtocol ,
27+ FirebaseDatabaseHostApi
28+ {
2829 private var binaryMessenger : FlutterBinaryMessenger
2930 private static var cachedDatabaseInstances : [ String : Database ] = [ : ]
3031 private var streamHandlers : [ String : FLTFirebaseDatabaseObserveStreamHandler ] = [ : ]
@@ -98,20 +99,25 @@ public class FLTFirebaseDatabasePlugin: NSObject, FlutterPlugin, FLTFirebasePlug
9899
99100 // MARK: - Database Management
100101
101- func goOnline( app: DatabasePigeonFirebaseApp , completion: @escaping ( Result < Void , Error > ) -> Void ) {
102+ func goOnline( app: DatabasePigeonFirebaseApp , completion: @escaping ( Result < Void , Error > ) -> Void )
103+ {
102104 let database = getDatabaseFromPigeonApp ( app)
103105 database. goOnline ( )
104106 completion ( . success( ( ) ) )
105107 }
106108
107- func goOffline( app: DatabasePigeonFirebaseApp , completion: @escaping ( Result < Void , Error > ) -> Void ) {
109+ func goOffline(
110+ app: DatabasePigeonFirebaseApp , completion: @escaping ( Result < Void , Error > ) -> Void
111+ ) {
108112 let database = getDatabaseFromPigeonApp ( app)
109113 database. goOffline ( )
110114 completion ( . success( ( ) ) )
111115 }
112116
113- func setPersistenceEnabled( app: DatabasePigeonFirebaseApp , enabled: Bool ,
114- completion: @escaping ( Result < Void , Error > ) -> Void ) {
117+ func setPersistenceEnabled(
118+ app: DatabasePigeonFirebaseApp , enabled: Bool ,
119+ completion: @escaping ( Result < Void , Error > ) -> Void
120+ ) {
115121 let instanceKey = app. appName + ( app. databaseURL ?? " " )
116122 if Self . cachedDatabaseInstances [ instanceKey] != nil {
117123 completion ( . success( ( ) ) )
@@ -123,8 +129,10 @@ public class FLTFirebaseDatabasePlugin: NSObject, FlutterPlugin, FLTFirebasePlug
123129 completion ( . success( ( ) ) )
124130 }
125131
126- func setPersistenceCacheSizeBytes( app: DatabasePigeonFirebaseApp , cacheSize: Int64 ,
127- completion: @escaping ( Result < Void , Error > ) -> Void ) {
132+ func setPersistenceCacheSizeBytes(
133+ app: DatabasePigeonFirebaseApp , cacheSize: Int64 ,
134+ completion: @escaping ( Result < Void , Error > ) -> Void
135+ ) {
128136 let instanceKey = app. appName + ( app. databaseURL ?? " " )
129137 if Self . cachedDatabaseInstances [ instanceKey] != nil {
130138 completion ( . success( ( ) ) )
@@ -140,46 +148,58 @@ public class FLTFirebaseDatabasePlugin: NSObject, FlutterPlugin, FLTFirebasePlug
140148 completion ( . success( ( ) ) )
141149 }
142150
143- func setLoggingEnabled( app: DatabasePigeonFirebaseApp , enabled: Bool ,
144- completion: @escaping ( Result < Void , Error > ) -> Void ) {
151+ func setLoggingEnabled(
152+ app: DatabasePigeonFirebaseApp , enabled: Bool ,
153+ completion: @escaping ( Result < Void , Error > ) -> Void
154+ ) {
145155 Database . setLoggingEnabled ( enabled)
146156 completion ( . success( ( ) ) )
147157 }
148158
149- func useDatabaseEmulator( app: DatabasePigeonFirebaseApp , host: String , port: Int64 ,
150- completion: @escaping ( Result < Void , Error > ) -> Void ) {
159+ func useDatabaseEmulator(
160+ app: DatabasePigeonFirebaseApp , host: String , port: Int64 ,
161+ completion: @escaping ( Result < Void , Error > ) -> Void
162+ ) {
151163 let database = getDatabaseFromPigeonApp ( app)
152164 database. useEmulator ( withHost: host, port: Int ( port) )
153165 completion ( . success( ( ) ) )
154166 }
155167
156- func ref( app: DatabasePigeonFirebaseApp , path: String ? ,
157- completion: @escaping ( Result < DatabaseReferencePlatform , Error > ) -> Void ) {
168+ func ref(
169+ app: DatabasePigeonFirebaseApp , path: String ? ,
170+ completion: @escaping ( Result < DatabaseReferencePlatform , Error > ) -> Void
171+ ) {
158172 let database = getDatabaseFromPigeonApp ( app)
159173 let reference = database. reference ( withPath: path ?? " " )
160174 let result = DatabaseReferencePlatform ( path: reference. url)
161175 completion ( . success( result) )
162176 }
163177
164- func refFromURL( app: DatabasePigeonFirebaseApp , url: String ,
165- completion: @escaping ( Result < DatabaseReferencePlatform , Error > ) -> Void ) {
178+ func refFromURL(
179+ app: DatabasePigeonFirebaseApp , url: String ,
180+ completion: @escaping ( Result < DatabaseReferencePlatform , Error > ) -> Void
181+ ) {
166182 let database = getDatabaseFromPigeonApp ( app)
167183 let reference = database. reference ( fromURL: url)
168184 let result = DatabaseReferencePlatform ( path: reference. url)
169185 completion ( . success( result) )
170186 }
171187
172- func purgeOutstandingWrites( app: DatabasePigeonFirebaseApp ,
173- completion: @escaping ( Result < Void , Error > ) -> Void ) {
188+ func purgeOutstandingWrites(
189+ app: DatabasePigeonFirebaseApp ,
190+ completion: @escaping ( Result < Void , Error > ) -> Void
191+ ) {
174192 let database = getDatabaseFromPigeonApp ( app)
175193 database. purgeOutstandingWrites ( )
176194 completion ( . success( ( ) ) )
177195 }
178196
179197 // MARK: - Database Reference Operations
180198
181- func databaseReferenceSet( app: DatabasePigeonFirebaseApp , request: DatabaseReferenceRequest ,
182- completion: @escaping ( Result < Void , Error > ) -> Void ) {
199+ func databaseReferenceSet(
200+ app: DatabasePigeonFirebaseApp , request: DatabaseReferenceRequest ,
201+ completion: @escaping ( Result < Void , Error > ) -> Void
202+ ) {
183203 let database = getDatabaseFromPigeonApp ( app)
184204 let reference = database. reference ( withPath: request. path)
185205
@@ -192,9 +212,11 @@ public class FLTFirebaseDatabasePlugin: NSObject, FlutterPlugin, FLTFirebasePlug
192212 }
193213 }
194214
195- func databaseReferenceSetWithPriority( app: DatabasePigeonFirebaseApp ,
196- request: DatabaseReferenceRequest ,
197- completion: @escaping ( Result < Void , Error > ) -> Void ) {
215+ func databaseReferenceSetWithPriority(
216+ app: DatabasePigeonFirebaseApp ,
217+ request: DatabaseReferenceRequest ,
218+ completion: @escaping ( Result < Void , Error > ) -> Void
219+ ) {
198220 let database = getDatabaseFromPigeonApp ( app)
199221 let reference = database. reference ( withPath: request. path)
200222
@@ -207,8 +229,10 @@ public class FLTFirebaseDatabasePlugin: NSObject, FlutterPlugin, FLTFirebasePlug
207229 }
208230 }
209231
210- func databaseReferenceUpdate( app: DatabasePigeonFirebaseApp , request: UpdateRequest ,
211- completion: @escaping ( Result < Void , Error > ) -> Void ) {
232+ func databaseReferenceUpdate(
233+ app: DatabasePigeonFirebaseApp , request: UpdateRequest ,
234+ completion: @escaping ( Result < Void , Error > ) -> Void
235+ ) {
212236 let database = getDatabaseFromPigeonApp ( app)
213237 let reference = database. reference ( withPath: request. path)
214238
@@ -223,9 +247,11 @@ public class FLTFirebaseDatabasePlugin: NSObject, FlutterPlugin, FLTFirebasePlug
223247 }
224248 }
225249
226- func databaseReferenceSetPriority( app: DatabasePigeonFirebaseApp ,
227- request: DatabaseReferenceRequest ,
228- completion: @escaping ( Result < Void , Error > ) -> Void ) {
250+ func databaseReferenceSetPriority(
251+ app: DatabasePigeonFirebaseApp ,
252+ request: DatabaseReferenceRequest ,
253+ completion: @escaping ( Result < Void , Error > ) -> Void
254+ ) {
229255 let database = getDatabaseFromPigeonApp ( app)
230256 let reference = database. reference ( withPath: request. path)
231257
@@ -238,8 +264,10 @@ public class FLTFirebaseDatabasePlugin: NSObject, FlutterPlugin, FLTFirebasePlug
238264 }
239265 }
240266
241- func databaseReferenceRunTransaction( app: DatabasePigeonFirebaseApp , request: TransactionRequest ,
242- completion: @escaping ( Result < Void , Error > ) -> Void ) {
267+ func databaseReferenceRunTransaction(
268+ app: DatabasePigeonFirebaseApp , request: TransactionRequest ,
269+ completion: @escaping ( Result < Void , Error > ) -> Void
270+ ) {
243271 let database = getDatabaseFromPigeonApp ( app)
244272 let reference = database. reference ( withPath: request. path)
245273
@@ -297,21 +325,27 @@ public class FLTFirebaseDatabasePlugin: NSObject, FlutterPlugin, FLTFirebasePlug
297325 }
298326 }
299327
300- func databaseReferenceGetTransactionResult( app: DatabasePigeonFirebaseApp , transactionKey: Int64 , completion: @escaping ( Result < [ String : Any ? ] , Error > ) -> Void ) {
328+ func databaseReferenceGetTransactionResult(
329+ app: DatabasePigeonFirebaseApp , transactionKey: Int64 ,
330+ completion: @escaping ( Result < [ String : Any ? ] , Error > ) -> Void
331+ ) {
301332 if let result = transactionResults. removeValue ( forKey: transactionKey) {
302333 completion ( . success( result) )
303334 } else {
304- completion ( . success( [
305- " committed " : false ,
306- " snapshot " : [ " value " : NSNull ( ) ] ,
307- ] ) )
335+ completion (
336+ . success( [
337+ " committed " : false ,
338+ " snapshot " : [ " value " : NSNull ( ) ] ,
339+ ] ) )
308340 }
309341 }
310342
311343 // MARK: - OnDisconnect Operations
312344
313- func onDisconnectSet( app: DatabasePigeonFirebaseApp , request: DatabaseReferenceRequest ,
314- completion: @escaping ( Result < Void , Error > ) -> Void ) {
345+ func onDisconnectSet(
346+ app: DatabasePigeonFirebaseApp , request: DatabaseReferenceRequest ,
347+ completion: @escaping ( Result < Void , Error > ) -> Void
348+ ) {
315349 let database = getDatabaseFromPigeonApp ( app)
316350 let reference = database. reference ( withPath: request. path)
317351
@@ -324,9 +358,11 @@ public class FLTFirebaseDatabasePlugin: NSObject, FlutterPlugin, FLTFirebasePlug
324358 }
325359 }
326360
327- func onDisconnectSetWithPriority( app: DatabasePigeonFirebaseApp ,
328- request: DatabaseReferenceRequest ,
329- completion: @escaping ( Result < Void , Error > ) -> Void ) {
361+ func onDisconnectSetWithPriority(
362+ app: DatabasePigeonFirebaseApp ,
363+ request: DatabaseReferenceRequest ,
364+ completion: @escaping ( Result < Void , Error > ) -> Void
365+ ) {
330366 let database = getDatabaseFromPigeonApp ( app)
331367 let reference = database. reference ( withPath: request. path)
332368
@@ -339,8 +375,10 @@ public class FLTFirebaseDatabasePlugin: NSObject, FlutterPlugin, FLTFirebasePlug
339375 }
340376 }
341377
342- func onDisconnectUpdate( app: DatabasePigeonFirebaseApp , request: UpdateRequest ,
343- completion: @escaping ( Result < Void , Error > ) -> Void ) {
378+ func onDisconnectUpdate(
379+ app: DatabasePigeonFirebaseApp , request: UpdateRequest ,
380+ completion: @escaping ( Result < Void , Error > ) -> Void
381+ ) {
344382 let database = getDatabaseFromPigeonApp ( app)
345383 let reference = database. reference ( withPath: request. path)
346384
@@ -355,8 +393,10 @@ public class FLTFirebaseDatabasePlugin: NSObject, FlutterPlugin, FLTFirebasePlug
355393 }
356394 }
357395
358- func onDisconnectCancel( app: DatabasePigeonFirebaseApp , path: String ,
359- completion: @escaping ( Result < Void , Error > ) -> Void ) {
396+ func onDisconnectCancel(
397+ app: DatabasePigeonFirebaseApp , path: String ,
398+ completion: @escaping ( Result < Void , Error > ) -> Void
399+ ) {
360400 let database = getDatabaseFromPigeonApp ( app)
361401 let reference = database. reference ( withPath: path)
362402
@@ -371,8 +411,10 @@ public class FLTFirebaseDatabasePlugin: NSObject, FlutterPlugin, FLTFirebasePlug
371411
372412 // MARK: - Query Operations
373413
374- func queryObserve( app: DatabasePigeonFirebaseApp , request: QueryRequest ,
375- completion: @escaping ( Result < String , Error > ) -> Void ) {
414+ func queryObserve(
415+ app: DatabasePigeonFirebaseApp , request: QueryRequest ,
416+ completion: @escaping ( Result < String , Error > ) -> Void
417+ ) {
376418 let database = getDatabaseFromPigeonApp ( app)
377419 let reference = database. reference ( withPath: request. path)
378420
@@ -444,7 +486,8 @@ public class FLTFirebaseDatabasePlugin: NSObject, FlutterPlugin, FLTFirebasePlug
444486
445487 case " limit " :
446488 if let name = modifier [ " name " ] as? String ,
447- let limit = modifier [ " limit " ] as? NSNumber {
489+ let limit = modifier [ " limit " ] as? NSNumber
490+ {
448491 switch name {
449492 case " limitToFirst " :
450493 query = query. queryLimited ( toFirst: limit. uintValue)
@@ -482,8 +525,10 @@ public class FLTFirebaseDatabasePlugin: NSObject, FlutterPlugin, FLTFirebasePlug
482525 completion ( . success( channelName) )
483526 }
484527
485- func queryKeepSynced( app: DatabasePigeonFirebaseApp , request: QueryRequest ,
486- completion: @escaping ( Result < Void , Error > ) -> Void ) {
528+ func queryKeepSynced(
529+ app: DatabasePigeonFirebaseApp , request: QueryRequest ,
530+ completion: @escaping ( Result < Void , Error > ) -> Void
531+ ) {
487532 let database = getDatabaseFromPigeonApp ( app)
488533 let reference = database. reference ( withPath: request. path)
489534
@@ -546,7 +591,8 @@ public class FLTFirebaseDatabasePlugin: NSObject, FlutterPlugin, FLTFirebasePlug
546591
547592 case " limit " :
548593 if let name = modifier [ " name " ] as? String ,
549- let limit = modifier [ " limit " ] as? NSNumber {
594+ let limit = modifier [ " limit " ] as? NSNumber
595+ {
550596 switch name {
551597 case " limitToFirst " :
552598 query = query. queryLimited ( toFirst: limit. uintValue)
@@ -569,8 +615,10 @@ public class FLTFirebaseDatabasePlugin: NSObject, FlutterPlugin, FLTFirebasePlug
569615 completion ( . success( ( ) ) )
570616 }
571617
572- func queryGet( app: DatabasePigeonFirebaseApp , request: QueryRequest ,
573- completion: @escaping ( Result < [ String : Any ? ] , Error > ) -> Void ) {
618+ func queryGet(
619+ app: DatabasePigeonFirebaseApp , request: QueryRequest ,
620+ completion: @escaping ( Result < [ String : Any ? ] , Error > ) -> Void
621+ ) {
574622 let database = getDatabaseFromPigeonApp ( app)
575623 let reference = database. reference ( withPath: request. path)
576624
@@ -644,7 +692,8 @@ public class FLTFirebaseDatabasePlugin: NSObject, FlutterPlugin, FLTFirebasePlug
644692
645693 case " limit " :
646694 if let name = modifier [ " name " ] as? String ,
647- let limit = modifier [ " limit " ] as? NSNumber {
695+ let limit = modifier [ " limit " ] as? NSNumber
696+ {
648697 switch name {
649698 case " limitToFirst " :
650699 query = query. queryLimited ( toFirst: limit. uintValue)
@@ -707,7 +756,8 @@ public class FLTFirebaseDatabasePlugin: NSObject, FlutterPlugin, FLTFirebasePlug
707756 }
708757
709758 if let emulatorHost = app. settings. emulatorHost,
710- let emulatorPort = app. settings. emulatorPort {
759+ let emulatorPort = app. settings. emulatorPort
760+ {
711761 database. useEmulator ( withHost: emulatorHost, port: Int ( emulatorPort) )
712762 }
713763
0 commit comments