FSTQueryData.h 3.4 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192
  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 "Firestore/core/src/firebase/firestore/model/snapshot_version.h"
  18. #include "Firestore/core/src/firebase/firestore/model/types.h"
  19. @class FSTQuery;
  20. namespace model = firebase::firestore::model;
  21. NS_ASSUME_NONNULL_BEGIN
  22. /** An enumeration of the different purposes we have for queries. */
  23. typedef NS_ENUM(NSInteger, FSTQueryPurpose) {
  24. /** A regular, normal query. */
  25. FSTQueryPurposeListen,
  26. /** The query was used to refill a query after an existence filter mismatch. */
  27. FSTQueryPurposeExistenceFilterMismatch,
  28. /** The query was used to resolve a limbo document. */
  29. FSTQueryPurposeLimboResolution,
  30. };
  31. /** An immutable set of metadata that the store will need to keep track of for each query. */
  32. @interface FSTQueryData : NSObject
  33. - (instancetype)initWithQuery:(FSTQuery *)query
  34. targetID:(model::TargetId)targetID
  35. listenSequenceNumber:(model::ListenSequenceNumber)sequenceNumber
  36. purpose:(FSTQueryPurpose)purpose
  37. snapshotVersion:(model::SnapshotVersion)snapshotVersion
  38. resumeToken:(NSData *)resumeToken NS_DESIGNATED_INITIALIZER;
  39. /** Convenience initializer for use when creating an FSTQueryData for the first time. */
  40. - (instancetype)initWithQuery:(FSTQuery *)query
  41. targetID:(model::TargetId)targetID
  42. listenSequenceNumber:(model::ListenSequenceNumber)sequenceNumber
  43. purpose:(FSTQueryPurpose)purpose;
  44. - (instancetype)init NS_UNAVAILABLE;
  45. /**
  46. * Creates a new query data instance with an updated snapshot version, resume token, and sequence
  47. * number.
  48. */
  49. - (instancetype)queryDataByReplacingSnapshotVersion:(model::SnapshotVersion)snapshotVersion
  50. resumeToken:(NSData *)resumeToken
  51. sequenceNumber:(model::ListenSequenceNumber)sequenceNumber;
  52. /** The latest snapshot version seen for this target. */
  53. - (const model::SnapshotVersion &)snapshotVersion;
  54. /** The query being listened to. */
  55. @property(nonatomic, strong, readonly) FSTQuery *query;
  56. /**
  57. * The targetID to which the query corresponds, assigned by the FSTLocalStore for user queries or
  58. * the FSTSyncEngine for limbo queries.
  59. */
  60. @property(nonatomic, assign, readonly) model::TargetId targetID;
  61. @property(nonatomic, assign, readonly) model::ListenSequenceNumber sequenceNumber;
  62. /** The purpose of the query. */
  63. @property(nonatomic, assign, readonly) FSTQueryPurpose purpose;
  64. /**
  65. * An opaque, server-assigned token that allows watching a query to be resumed after disconnecting
  66. * without retransmitting all the data that matches the query. The resume token essentially
  67. * identifies a point in time from which the server should resume sending results.
  68. */
  69. @property(nonatomic, copy, readonly) NSData *resumeToken;
  70. @end
  71. NS_ASSUME_NONNULL_END