FSTMutation.h 12 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286
  1. /*
  2. * Copyright 2017 Google
  3. *
  4. * Licensed under the Apache License, Version 2.0 (the "License");
  5. * you may not use this file except in compliance with the License.
  6. * You may obtain a copy of the License at
  7. *
  8. * http://www.apache.org/licenses/LICENSE-2.0
  9. *
  10. * Unless required by applicable law or agreed to in writing, software
  11. * distributed under the License is distributed on an "AS IS" BASIS,
  12. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  13. * See the License for the specific language governing permissions and
  14. * limitations under the License.
  15. */
  16. #import <Foundation/Foundation.h>
  17. #include <memory>
  18. #include <vector>
  19. #include "Firestore/core/src/firebase/firestore/model/document_key.h"
  20. #include "Firestore/core/src/firebase/firestore/model/field_mask.h"
  21. #include "Firestore/core/src/firebase/firestore/model/field_path.h"
  22. #include "Firestore/core/src/firebase/firestore/model/field_transform.h"
  23. #include "Firestore/core/src/firebase/firestore/model/field_value.h"
  24. #include "Firestore/core/src/firebase/firestore/model/precondition.h"
  25. #include "Firestore/core/src/firebase/firestore/model/snapshot_version.h"
  26. #include "Firestore/core/src/firebase/firestore/model/transform_operations.h"
  27. #include "absl/types/optional.h"
  28. @class FSTDocument;
  29. @class FSTMaybeDocument;
  30. @class FIRTimestamp;
  31. namespace model = firebase::firestore::model;
  32. NS_ASSUME_NONNULL_BEGIN
  33. #pragma mark - FSTMutationResult
  34. @interface FSTMutationResult : NSObject
  35. - (instancetype)init NS_UNAVAILABLE;
  36. - (instancetype)initWithVersion:(model::SnapshotVersion)version
  37. transformResults:(absl::optional<std::vector<model::FieldValue>>)transformResults
  38. NS_DESIGNATED_INITIALIZER;
  39. /**
  40. * The version at which the mutation was committed.
  41. *
  42. * - For most operations, this is the updateTime in the WriteResult.
  43. * - For deletes, it is the commitTime of the WriteResponse (because deletes are not stored
  44. * and have no updateTime).
  45. *
  46. * Note that these versions can be different: No-op writes will not change the updateTime even
  47. * though the commitTime advances.
  48. */
  49. - (const model::SnapshotVersion &)version;
  50. /**
  51. * The resulting fields returned from the backend after a FSTTransformMutation has been committed.
  52. * Contains one FieldValue for each FieldTransform that was in the mutation.
  53. *
  54. * Will be nullopt if the mutation was not a FSTTransformMutation.
  55. */
  56. // TODO(wilhuff): This seems like I could be a empty vector without harm.
  57. @property(nonatomic, assign, readonly)
  58. const absl::optional<std::vector<model::FieldValue>> &transformResults;
  59. @end
  60. #pragma mark - FSTMutation
  61. /**
  62. * Represents a Mutation of a document. Different subclasses of Mutation will perform different
  63. * kinds of changes to a base document. For example, an FSTSetMutation replaces the value of a
  64. * document and an FSTDeleteMutation deletes a document.
  65. *
  66. * Subclasses of FSTMutation need to implement `applyToRemoteDocument:mutationResult:` and
  67. * `applyToLocalDocument:baseDocument:localWriteTime:` to implement the actual the behavior of
  68. * mutations as applied to some source document.
  69. *
  70. * In addition to the value of the document mutations also operate on the version. For local
  71. * mutations (mutations that haven't been committed yet), we preserve the existing version for Set,
  72. * Patch, and Transform mutations. For local deletes, we reset the version to 0.
  73. *
  74. * Here's the expected transition table.
  75. *
  76. * MUTATION APPLIED TO RESULTS IN
  77. *
  78. * SetMutation Document(v3) Document(v3)
  79. * SetMutation DeletedDocument(v3) Document(v0)
  80. * SetMutation nil Document(v0)
  81. * PatchMutation Document(v3) Document(v3)
  82. * PatchMutation DeletedDocument(v3) DeletedDocument(v3)
  83. * PatchMutation nil nil
  84. * TransformMutation Document(v3) Document(v3)
  85. * TransformMutation DeletedDocument(v3) DeletedDocument(v3)
  86. * TransformMutation nil nil
  87. * DeleteMutation Document(v3) DeletedDocument(v0)
  88. * DeleteMutation DeletedDocument(v3) DeletedDocument(v0)
  89. * DeleteMutation nil DeletedDocument(v0)
  90. *
  91. * For acknowledged mutations, we use the updateTime of the WriteResponse as the resulting version
  92. * for Set, Patch, and Transform mutations. As deletes have no explicit update time, we use the
  93. * commitTime of the WriteResponse for acknowledged deletes.
  94. *
  95. * If a mutation is acknowledged by the backend but fails the precondition check locally, we
  96. * return an `FSTUnknownDocument` and rely on Watch to send us the updated version.
  97. *
  98. * Note that FSTTransformMutations don't create Documents (in the case of being applied to an
  99. * FSTDeletedDocument), even though they would on the backend. This is because the client always
  100. * combines the FSTTransformMutations with a FSTSetMutation or FSTPatchMutation and we only want to
  101. * apply the transform if the prior mutation resulted in an FSTDocument (always true for an
  102. * FSTSetMutation, but not necessarily for an FSTPatchMutation).
  103. */
  104. @interface FSTMutation : NSObject
  105. - (id)init NS_UNAVAILABLE;
  106. - (instancetype)initWithKey:(model::DocumentKey)key
  107. precondition:(model::Precondition)precondition NS_DESIGNATED_INITIALIZER;
  108. /**
  109. * Applies this mutation to the given FSTMaybeDocument for the purposes of computing a new remote
  110. * document. If the input document doesn't match the expected state (e.g. it is nil or outdated),
  111. * an `FSTUnknownDocument` can be returned.
  112. *
  113. * @param maybeDoc The document to mutate. The input document can be nil if the client has no
  114. * knowledge of the pre-mutation state of the document.
  115. * @param mutationResult The result of applying the mutation from the backend.
  116. * @return The mutated document. The returned document may be an FSTUnknownDocument if the mutation
  117. * could not be applied to the locally cached base document.
  118. */
  119. - (FSTMaybeDocument *)applyToRemoteDocument:(nullable FSTMaybeDocument *)maybeDoc
  120. mutationResult:(FSTMutationResult *)mutationResult;
  121. /**
  122. * Applies this mutation to the given FSTMaybeDocument for the purposes of computing the new local
  123. * view of a document. Both the input and returned documents can be nil.
  124. *
  125. * @param maybeDoc The document to mutate. The input document can be nil if the client has no
  126. * knowledge of the pre-mutation state of the document.
  127. * @param baseDoc The state of the document prior to this mutation batch. The input document can
  128. * be nil if the client has no knowledge of the pre-mutation state of the document.
  129. * @param localWriteTime A timestamp indicating the local write time of the batch this mutation is
  130. * a part of.
  131. * @return The mutated document. The returned document may be nil, but only if maybeDoc was nil
  132. * and the mutation would not create a new document.
  133. */
  134. - (nullable FSTMaybeDocument *)applyToLocalDocument:(nullable FSTMaybeDocument *)maybeDoc
  135. baseDocument:(nullable FSTMaybeDocument *)baseDoc
  136. localWriteTime:(const firebase::Timestamp &)localWriteTime;
  137. /**
  138. * If this mutation is not idempotent, returns the base value to persist with this mutation.
  139. * If a base value is returned, the mutation is always applied to this base value, even if
  140. * document has already been updated.
  141. *
  142. * The base value is a sparse object that consists of only the document fields for which this
  143. * mutation contains a non-idempotent transformation (e.g. a numeric increment). The provided
  144. * value guarantees consistent behavior for non-idempotent transforms and allow us to return the
  145. * same latency-compensated value even if the backend has already applied the mutation. The base
  146. * value is empty for idempotent mutations, as they can be re-played even if the backend has
  147. * already applied them.
  148. *
  149. * @return a base value to store along with the mutation, or empty for idempotent mutations.
  150. */
  151. - (absl::optional<model::ObjectValue>)extractBaseValue:(nullable FSTMaybeDocument *)maybeDoc;
  152. - (const model::DocumentKey &)key;
  153. - (const model::Precondition &)precondition;
  154. @end
  155. #pragma mark - FSTSetMutation
  156. /**
  157. * A mutation that creates or replaces the document at the given key with the object value
  158. * contents.
  159. */
  160. @interface FSTSetMutation : FSTMutation
  161. - (instancetype)initWithKey:(model::DocumentKey)key
  162. precondition:(model::Precondition)precondition NS_UNAVAILABLE;
  163. /**
  164. * Initializes the set mutation.
  165. *
  166. * @param key Identifies the location of the document to mutate.
  167. * @param value An object value that describes the contents to store at the location named by the
  168. * key.
  169. * @param precondition The precondition for this mutation.
  170. */
  171. - (instancetype)initWithKey:(model::DocumentKey)key
  172. value:(model::ObjectValue)value
  173. precondition:(model::Precondition)precondition NS_DESIGNATED_INITIALIZER;
  174. /** The object value to use when setting the document. */
  175. @property(nonatomic, assign, readonly) model::ObjectValue value;
  176. @end
  177. #pragma mark - FSTPatchMutation
  178. /**
  179. * A mutation that modifies fields of the document at the given key with the given values. The
  180. * values are applied through a field mask:
  181. *
  182. * * When a field is in both the mask and the values, the corresponding field is updated.
  183. * * When a field is in neither the mask nor the values, the corresponding field is unmodified.
  184. * * When a field is in the mask but not in the values, the corresponding field is deleted.
  185. * * When a field is not in the mask but is in the values, the values map is ignored.
  186. */
  187. @interface FSTPatchMutation : FSTMutation
  188. /** Returns the precondition for the given Precondition. */
  189. - (instancetype)initWithKey:(model::DocumentKey)key
  190. precondition:(model::Precondition)precondition NS_UNAVAILABLE;
  191. /**
  192. * Initializes a new patch mutation with an explicit FieldMask and ObjectValue representing the
  193. * updates to perform.
  194. *
  195. * @param key Identifies the location of the document to mutate.
  196. * @param fieldMask The field mask specifying at what locations the data in value should be
  197. * applied.
  198. * @param value An ObjectValue containing the data to be written (using the paths in fieldMask to
  199. * determine the locations at which it should be applied).
  200. * @param precondition The precondition for this mutation.
  201. */
  202. - (instancetype)initWithKey:(model::DocumentKey)key
  203. fieldMask:(model::FieldMask)fieldMask
  204. value:(model::ObjectValue)value
  205. precondition:(model::Precondition)precondition NS_DESIGNATED_INITIALIZER;
  206. /**
  207. * A mask to apply to |value|, where only fields that are in both the fieldMask and the value
  208. * will be updated.
  209. */
  210. - (const model::FieldMask *)fieldMask;
  211. /** The fields and associated values to use when patching the document. */
  212. @property(nonatomic, assign, readonly) model::ObjectValue value;
  213. @end
  214. #pragma mark - FSTTransformMutation
  215. /**
  216. * A mutation that modifies specific fields of the document with transform operations. Currently
  217. * the only supported transform is a server timestamp, but IP Address, increment(n), etc. could
  218. * be supported in the future.
  219. *
  220. * It is somewhat similar to an FSTPatchMutation in that it patches specific fields and has no
  221. * effect when applied to nil or an FSTDeletedDocument (see comment on [FSTMutation applyTo] for
  222. * rationale).
  223. */
  224. @interface FSTTransformMutation : FSTMutation
  225. - (instancetype)initWithKey:(model::DocumentKey)key
  226. precondition:(model::Precondition)precondition NS_UNAVAILABLE;
  227. /**
  228. * Initializes a new transform mutation with the specified field transforms.
  229. *
  230. * @param key Identifies the location of the document to mutate.
  231. * @param fieldTransforms A list of FieldTransform objects to perform to the document.
  232. */
  233. - (instancetype)initWithKey:(model::DocumentKey)key
  234. fieldTransforms:(std::vector<model::FieldTransform>)fieldTransforms
  235. NS_DESIGNATED_INITIALIZER;
  236. /** The field transforms to use when transforming the document. */
  237. - (const std::vector<model::FieldTransform> &)fieldTransforms;
  238. @end
  239. #pragma mark - FSTDeleteMutation
  240. @interface FSTDeleteMutation : FSTMutation
  241. @end
  242. NS_ASSUME_NONNULL_END