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
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
|
/*
* 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 "FSTDocumentKeySet.h"
#import "FSTDocumentVersionDictionary.h"
#import "FSTTypes.h"
@class FSTMutation;
@class FSTTimestamp;
@class FSTMutationResult;
@class FSTMutationBatchResult;
@class FSTSnapshotVersion;
NS_ASSUME_NONNULL_BEGIN
/**
* A BatchID that was searched for and not found or a batch ID value known to be before all known
* batches.
*
* FSTBatchID values from the local store are non-negative so this value is before all batches.
*/
extern const FSTBatchID kFSTBatchIDUnknown;
/**
* A batch of mutations that will be sent as one unit to the backend. Batches can be marked as a
* tombstone if the mutation queue does not remove them immediately. When a batch is a tombstone
* it has no mutations.
*/
@interface FSTMutationBatch : NSObject
/** Initializes a mutation batch with the given batchID, localWriteTime, and mutations. */
- (instancetype)initWithBatchID:(FSTBatchID)batchID
localWriteTime:(FSTTimestamp *)localWriteTime
mutations:(NSArray<FSTMutation *> *)mutations NS_DESIGNATED_INITIALIZER;
- (id)init NS_UNAVAILABLE;
/**
* Applies all the mutations in this FSTMutationBatch to the specified document.
*
* @param maybeDoc The document to apply mutations to.
* @param documentKey The key of the document to apply mutations to.
* @param mutationBatchResult The result of applying the MutationBatch to the backend. If omitted
* it's assumed that this is a local (latency-compensated) application and documents will have
* their hasLocalMutations flag set.
*/
- (FSTMaybeDocument *_Nullable)applyTo:(FSTMaybeDocument *_Nullable)maybeDoc
documentKey:(FSTDocumentKey *)documentKey
mutationBatchResult:(FSTMutationBatchResult *_Nullable)mutationBatchResult;
/**
* A helper version of applyTo for applying mutations locally (without a mutation batch result from
* the backend).
*/
- (FSTMaybeDocument *_Nullable)applyTo:(FSTMaybeDocument *_Nullable)maybeDoc
documentKey:(FSTDocumentKey *)documentKey;
/**
* Returns YES if this mutation batch has already been removed from the mutation queue.
*
* Note that not all implementations of the FSTMutationQueue necessarily use tombstones as a part
* of their implementation and generally speaking no code outside the mutation queues should really
* care about this.
*/
- (BOOL)isTombstone;
/** Converts this batch to a tombstone. */
- (FSTMutationBatch *)toTombstone;
/** Returns the set of unique keys referenced by all mutations in the batch. */
- (FSTDocumentKeySet *)keys;
@property(nonatomic, assign, readonly) FSTBatchID batchID;
@property(nonatomic, strong, readonly) FSTTimestamp *localWriteTime;
@property(nonatomic, strong, readonly) NSArray<FSTMutation *> *mutations;
@end
#pragma mark - FSTMutationBatchResult
/** The result of applying a mutation batch to the backend. */
@interface FSTMutationBatchResult : NSObject
- (instancetype)init NS_UNAVAILABLE;
/**
* Creates a new FSTMutationBatchResult for the given batch and results. There must be one result
* for each mutation in the batch. This static factory caches a document=>version mapping
* (as docVersions).
*/
+ (instancetype)resultWithBatch:(FSTMutationBatch *)batch
commitVersion:(FSTSnapshotVersion *)commitVersion
mutationResults:(NSArray<FSTMutationResult *> *)mutationResults
streamToken:(nullable NSData *)streamToken;
@property(nonatomic, strong, readonly) FSTMutationBatch *batch;
@property(nonatomic, strong, readonly) FSTSnapshotVersion *commitVersion;
@property(nonatomic, strong, readonly) NSArray<FSTMutationResult *> *mutationResults;
@property(nonatomic, strong, readonly, nullable) NSData *streamToken;
@property(nonatomic, strong, readonly) FSTDocumentVersionDictionary *docVersions;
@end
NS_ASSUME_NONNULL_END
|