Add Pipeline Result

Author: cherylEnkidu

Firestore/Swift/Source/SwiftAPI/Pipeline.swift

@@ -0,0 +1,35 @@
+//
+//  Pipeline.swift
+//  Firebase
+//
+//  Created by Cheryl Lin on 2024-12-18.
+//
+
+@available(iOS 13, tvOS 13, macOS 10.15, macCatalyst 13, watchOS 7, *)
+public class Pipeline {
+  var cppPtr: firebase.firestore.api.Pipeline
+
+  public init(_ cppSource: firebase.firestore.api.Pipeline) {
+    cppPtr = cppSource
+  }
+
+  @discardableResult
+  public func GetPipelineResult() async throws -> PipelineResult {
+//    return try await withCheckedThrowingContinuation { continuation in
+//
+//      let callback: (
+//        firebase.firestore.api.PipelineResult,
+//        Bool
+//      ) -> Void = { result, isSucceed in
+//        if isSucceed {
+//          continuation.resume(returning: PipelineResult(result))
+//        } else {
+//          continuation.resume(throwing: "ERROR!" as! Error)
+//        }
+//              }
+
+    // cppPtr.fetchDataWithCppCallback(callback)
+    return PipelineResult(firebase.firestore.api.PipelineResult
+      .GetTestResult(cppPtr.GetFirestore()))
+  }
+}

Firestore/Swift/Source/SwiftAPI/PipelineResult.swift

@@ -0,0 +1,14 @@
+//
+//  PipelineResult.swift
+//  Firebase
+//
+//  Created by Cheryl Lin on 2024-12-18.
+//
+
+public class PipelineResult {
+  let cppPtr: firebase.firestore.api.PipelineResult
+
+  public init(_ cppSource: firebase.firestore.api.PipelineResult) {
+    cppPtr = cppSource
+  }
+}

Firestore/Swift/Source/SwiftAPI/PipelineSource.swift

@@ -5,10 +5,15 @@
 //  Created by Cheryl Lin on 2024-12-12.
 //
 
+@available(iOS 13, tvOS 13, macOS 10.15, macCatalyst 13, watchOS 7, *)
 public class PipelineSource {
   let cppPtr: firebase.firestore.api.PipelineSource
 
   public init(_ cppSource: firebase.firestore.api.PipelineSource) {
     cppPtr = cppSource
   }
+
+  public func GetCollection(_ path: String) -> Pipeline {
+    return Pipeline(cppPtr.GetCollection(std.string(path)))
+  }
 }

Firestore/core/swift/include/FirebaseFirestoreCpp.h

@@ -20,6 +20,7 @@
 #import "collection_stage.h"
 #import "firestore_pipeline.h"
 #import "pipeline.h"
+#import "pipeline_result.h"
 #import "pipeline_source.h"
 #import "stage.h"
 #import "used_by_swift.h"

Firestore/core/swift/include/pipeline.h

@@ -5,8 +5,10 @@
 #ifndef FIREBASE_PIPELINE_H
 #define FIREBASE_PIPELINE_H
 
+#include <functional>
 #include <memory>
 #include <vector>
+#include "pipeline_result.h"
 #include "stage.h"
 
 namespace firebase {
@@ -29,7 +31,12 @@ class Pipeline {
  public:
   Pipeline(std::shared_ptr<Firestore> firestore, Stage stage);
 
-  std::shared_ptr<PipelineSnapshotListener> GetPipelineResult();
+  void GetPipelineResult(
+      std::function<void(PipelineResult, bool)> callback) const;
+
+  std::shared_ptr<Firestore> GetFirestore() const {
+    return firestore_;
+  }
 
  private:
   std::shared_ptr<Firestore> firestore_;

Firestore/core/swift/include/pipeline_result.h

@@ -6,9 +6,11 @@
 #define FIREBASE_PIPELINE_RESULT_H
 
 #include <memory>
-#include "Firestore/core/include/firebase/firestore/timestamp.h"
 
 namespace firebase {
+
+class Timestamp;
+
 namespace firestore {
 
 namespace api {
@@ -19,17 +21,17 @@ class DocumentReference;
 class PipelineResult {
  public:
   PipelineResult(std::shared_ptr<Firestore> firestore,
-                 std::shared_ptr<DocumentReference> doc_ref_ptr,
-                 Timestamp execution_time,
-                 Timestamp update_time,
-                 Timestamp create_time);
+                 std::shared_ptr<Timestamp> execution_time,
+                 std::shared_ptr<Timestamp> update_time,
+                 std::shared_ptr<Timestamp> create_time);
+
+  static PipelineResult GetTestResult(std::shared_ptr<Firestore> firestore);
 
  private:
   std::shared_ptr<Firestore> firestore_;
-  std::shared_ptr<DocumentReference> doc_ref_ptr_;
-  Timestamp execution_time_;
-  Timestamp update_time_;
-  Timestamp create_time_;
+  std::shared_ptr<Timestamp> execution_time_;
+  std::shared_ptr<Timestamp> update_time_;
+  std::shared_ptr<Timestamp> create_time_;
 };
 
 }  // namespace api

Firestore/core/swift/include/pipeline_source.h

@@ -21,7 +21,7 @@ class PipelineSource {
  public:
   PipelineSource(std::shared_ptr<Firestore> firestore);
 
-  Pipeline GetCollection(std::string collection_path);
+  Pipeline GetCollection(std::string collection_path) const;
 
  private:
   std::shared_ptr<Firestore> firestore_;

Firestore/core/swift/src/pipeline.cc

@@ -1,6 +1,8 @@
 #include "Firestore/core/swift/include/pipeline.h"
+#include "Firestore/core/include/firebase/firestore/timestamp.h"
 #include "Firestore/core/src/api/firestore.h"
 #include "Firestore/core/src/core/event_listener.h"
+#include "Firestore/core/swift/include/pipeline_result.h"
 
 namespace firebase {
 namespace firestore {
@@ -11,11 +13,15 @@ Pipeline::Pipeline(std::shared_ptr<Firestore> firestore, Stage stage)
     : firestore_(firestore), stage_(stage) {
 }
 
-std::shared_ptr<PipelineSnapshotListener> Pipeline::GetPipelineResult() {
-  return {};
+void Pipeline::GetPipelineResult(
+    std::function<void(PipelineResult, bool)> callback) const {
+  callback(PipelineResult(firestore_, std::make_shared<Timestamp>(0, 0),
+                          std::make_shared<Timestamp>(0, 0),
+                          std::make_shared<Timestamp>(0, 0)),
+           true);
 }
 
 }  // namespace api
 
 }  // namespace firestore
-}  // namespace firebase
+}  // namespace firebase

Firestore/core/swift/src/pipeline_result.cc

@@ -1,23 +1,29 @@
 
 #include "Firestore/core/swift/include/pipeline_result.h"
+#include "Firestore/core/include/firebase/firestore/timestamp.h"
 
 namespace firebase {
 namespace firestore {
 
 namespace api {
 
 PipelineResult::PipelineResult(std::shared_ptr<Firestore> firestore,
-                               std::shared_ptr<DocumentReference> doc_ref_ptr,
-                               Timestamp execution_time,
-                               Timestamp update_time,
-                               Timestamp create_time)
+                               std::shared_ptr<Timestamp> execution_time,
+                               std::shared_ptr<Timestamp> update_time,
+                               std::shared_ptr<Timestamp> create_time)
     : firestore_(firestore),
-      doc_ref_ptr_(doc_ref_ptr),
       execution_time_(execution_time),
       update_time_(update_time),
       create_time_(create_time) {
 }
 
+PipelineResult PipelineResult::GetTestResult(
+    std::shared_ptr<Firestore> firestore) {
+  return PipelineResult(firestore, std::make_shared<Timestamp>(0, 0),
+                        std::make_shared<Timestamp>(0, 0),
+                        std::make_shared<Timestamp>(0, 0));
+}
+
 }  // namespace api
 
 }  // namespace firestore

Firestore/core/swift/src/pipeline_source.cc

@@ -14,7 +14,7 @@ PipelineSource::PipelineSource(std::shared_ptr<Firestore> firestore)
   std::cout << "PipelineSource constructs" << std::endl;
 }
 
-Pipeline PipelineSource::GetCollection(std::string collection_path) {
+Pipeline PipelineSource::GetCollection(std::string collection_path) const {
   return {firestore_, Collection{collection_path}};
 }