blob: 69ec6bf0ba51b3550d9bfaf42d3b2354724e384e (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
|
/*
* Copyright 2017 Google
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
#import <Foundation/Foundation.h>
#import "FRepoInfo.h"
#import "FPersistentConnection.h"
#import "FIRDataEventType.h"
#import "FTupleUserCallback.h"
@class FQuerySpec;
@class FPersistence;
@class FAuthenticationManager;
@class FIRDatabaseConfig;
@protocol FEventRegistration;
@class FCompoundWrite;
@protocol FClock;
@class FIRDatabase;
@interface FRepo : NSObject <FPersistentConnectionDelegate>
@property (nonatomic, strong) FIRDatabaseConfig *config;
- (id)initWithRepoInfo:(FRepoInfo *)info config:(FIRDatabaseConfig *)config database:(FIRDatabase *)database;
- (void) set:(FPath *)path withNode:(id)node withCallback:(fbt_void_nserror_ref)onComplete;
- (void) update:(FPath *)path withNodes:(FCompoundWrite *)compoundWrite withCallback:(fbt_void_nserror_ref)callback;
- (void) purgeOutstandingWrites;
- (void) addEventRegistration:(id<FEventRegistration>)eventRegistration forQuery:(FQuerySpec *)query;
- (void) removeEventRegistration:(id<FEventRegistration>)eventRegistration forQuery:(FQuerySpec *)query;
- (void) keepQuery:(FQuerySpec *)query synced:(BOOL)synced;
- (NSString*)name;
- (NSTimeInterval)serverTime;
- (void) onDataUpdate:(FPersistentConnection *)fpconnection forPath:(NSString *)pathString message:(id)message isMerge:(BOOL)isMerge tagId:(NSNumber *)tagId;
- (void) onConnect:(FPersistentConnection *)fpconnection;
- (void) onDisconnect:(FPersistentConnection *)fpconnection;
// Disconnect methods
- (void) onDisconnectCancel:(FPath *)path withCallback:(fbt_void_nserror_ref)callback;
- (void) onDisconnectSet:(FPath *)path withNode:(id<FNode>)node withCallback:(fbt_void_nserror_ref)callback;
- (void) onDisconnectUpdate:(FPath *)path withNodes:(FCompoundWrite *)compoundWrite withCallback:(fbt_void_nserror_ref)callback;
// Connection Management.
- (void) interrupt;
- (void) resume;
// Transactions
- (void) startTransactionOnPath:(FPath *)path
update:(fbt_transactionresult_mutabledata)update
onComplete:(fbt_void_nserror_bool_datasnapshot)onComplete
withLocalEvents:(BOOL)applyLocally;
// Testing methods
- (NSDictionary *) dumpListens;
- (void) dispose;
- (void) setHijackHash:(BOOL)hijack;
@property (nonatomic, strong, readonly) FAuthenticationManager *auth;
@property (nonatomic, strong, readonly) FIRDatabase *database;
@end
|
