implement pipeline files in C++ side

Author: cherylEnkidu

Firestore/core/src/api/firestore.cc

@@ -227,6 +227,10 @@ void Firestore::SetClientLanguage(std::string language_token) {
   GrpcConnection::SetClientLanguage(std::move(language_token));
 }
 
+PipelineSource Firestore::pipeline() {
+  return {shared_from_this()};
+}
+
 std::unique_ptr<ListenerRegistration> Firestore::AddSnapshotsInSyncListener(
     std::unique_ptr<core::EventListener<Empty>> listener) {
   EnsureClientConfigured();

Firestore/core/src/api/firestore.h

@@ -29,6 +29,7 @@
 #include "Firestore/core/src/model/database_id.h"
 #include "Firestore/core/src/util/byte_stream.h"
 #include "Firestore/core/src/util/status_fwd.h"
+#include "Firestore/core/swift/include/pipeline_source.h"
 
 namespace firebase {
 namespace firestore {
@@ -125,6 +126,8 @@ class Firestore : public std::enable_shared_from_this<Firestore> {
    */
   static void SetClientLanguage(std::string language_token);
 
+  PipelineSource pipeline();
+
  private:
   void EnsureClientConfigured();
   core::DatabaseInfo MakeDatabaseInfo() const;

Firestore/core/swift/include/FirebaseFirestoreCpp.h

@@ -17,6 +17,11 @@
 #ifndef FIREBASE_FIREBASEFIRESTORECPP_H
 #define FIREBASE_FIREBASEFIRESTORECPP_H
 
+#import "collection_stage.h"
+#import "firestore_pipeline.h"
+#import "pipeline.h"
+#import "pipeline_source.h"
+#import "stage.h"
 #import "used_by_swift.h"
 
 #endif  // FIREBASE_FIREBASEFIRESTORECPP_H

Firestore/core/swift/include/collection_stage.h

@@ -0,0 +1,29 @@
+//
+// Created by Cheryl Lin on 2024-12-11.
+//
+
+#ifndef FIREBASE_COLLECTION_GROUP_STAGE_H
+#define FIREBASE_COLLECTION_GROUP_STAGE_H
+
+#include <string>
+#include "stage.h"
+
+namespace firebase {
+namespace firestore {
+
+namespace api {
+
+class Collection : public Stage {
+ public:
+  Collection(std::string collection_path);
+
+ private:
+  std::string collection_path_;
+};
+
+}  // namespace api
+
+}  // namespace firestore
+}  // namespace firebase
+
+#endif  // FIREBASE_COLLECTION_GROUP_STAGE_H

Firestore/core/swift/include/firestore_pipeline.h

@@ -0,0 +1,25 @@
+//
+// Created by Cheryl Lin on 2024-12-10.
+//
+
+#ifndef FIREBASE_FIRESTORE_PIPELINE_H
+#define FIREBASE_FIRESTORE_PIPELINE_H
+
+#include "pipeline_source.h"
+
+namespace firebase {
+namespace firestore {
+
+namespace api {
+class Firestore;
+
+class FirestorePipeline {
+ public:
+  PipelineSource pipeline(std::shared_ptr<Firestore> firestore);
+};
+
+}  // namespace api
+}  // namespace firestore
+}  // namespace firebase
+
+#endif  // FIREBASE_FIRESTORE_PIPELINE_H

Firestore/core/swift/include/pipeline.h

@@ -0,0 +1,32 @@
+//
+// Created by Cheryl Lin on 2024-12-11.
+//
+
+#ifndef FIREBASE_PIPELINE_H
+#define FIREBASE_PIPELINE_H
+
+#include <memory>
+#include "stage.h"
+
+namespace firebase {
+namespace firestore {
+
+namespace api {
+
+class Firestore;
+
+class Pipeline {
+ public:
+  Pipeline(std::shared_ptr<Firestore> firestore, Stage stage);
+
+ private:
+  std::shared_ptr<Firestore> firestore_;
+  Stage stage_;
+};
+
+}  // namespace api
+
+}  // namespace firestore
+}  // namespace firebase
+
+#endif  // FIREBASE_PIPELINE_H

Firestore/core/swift/include/pipeline_source.h

@@ -0,0 +1,35 @@
+//
+// Created by Cheryl Lin on 2024-12-09.
+//
+
+#ifndef FIREBASE_PIPELINE_SOURCE_H
+#define FIREBASE_PIPELINE_SOURCE_H
+
+#include <memory>
+#include <vector>
+#include "pipeline.h"
+
+namespace firebase {
+namespace firestore {
+
+namespace api {
+
+class Firestore;
+class DocumentReference;
+
+class PipelineSource {
+ public:
+  PipelineSource(std::shared_ptr<Firestore> firestore);
+
+  Pipeline GetCollection(std::string collection_path);
+
+ private:
+  std::shared_ptr<Firestore> firestore_;
+};
+
+}  // namespace api
+
+}  // namespace firestore
+}  // namespace firebase
+
+#endif  // FIREBASE_PIPELINE_SOURCE_H

Firestore/core/swift/include/stage.h

@@ -0,0 +1,23 @@
+//
+// Created by Cheryl Lin on 2024-12-11.
+//
+
+#ifndef FIREBASE_STAGE_H
+#define FIREBASE_STAGE_H
+
+namespace firebase {
+namespace firestore {
+
+namespace api {
+
+class Stage {
+ public:
+  Stage();
+};
+
+}  // namespace api
+
+}  // namespace firestore
+}  // namespace firebase
+
+#endif  // FIREBASE_STAGE_H

Firestore/core/swift/src/collection_stage.cc

@@ -0,0 +1,17 @@
+#include "Firestore/core/swift/include/collection_stage.h"
+#include <iostream>
+
+namespace firebase {
+namespace firestore {
+
+namespace api {
+
+Collection::Collection(std::string collection_path)
+    : collection_path_(collection_path) {
+  std::cout << "Calling Pipeline Collection ctor" << std::endl;
+};
+
+}  // namespace api
+
+}  // namespace firestore
+}  // namespace firebase

Firestore/core/swift/src/firestore_pipeline.cc

@@ -0,0 +1,16 @@
+#include "Firestore/core/swift/include/firestore_pipeline.h"
+#include "Firestore/core/src/api/firestore.h"
+
+namespace firebase {
+namespace firestore {
+
+namespace api {
+
+PipelineSource FirestorePipeline::pipeline(
+    std::shared_ptr<Firestore> firestore) {
+  return firestore->pipeline();
+}
+
+}  // namespace api
+}  // namespace firestore
+}  // namespace firebase