[1/4] Add ppl protos and setup dependencies

Author: wu-hui

.gitignore

@@ -4,6 +4,7 @@ dist
 .awcache
 .cache
 /config/project.json
+/config/prod.project.json
 scripts/docgen-compat/html
 
 # OS Specific Files

packages/firestore/externs.json

@@ -5,12 +5,15 @@
     "node_modules/typescript/lib/lib.dom.d.ts",
     "node_modules/typescript/lib/lib.es2015.promise.d.ts",
     "node_modules/typescript/lib/lib.es2015.symbol.d.ts",
+    "node_modules/typescript/lib/lib.es2020.bigint.d.ts",
     "node_modules/typescript/lib/lib.es2015.iterable.d.ts",
     "node_modules/typescript/lib/lib.es2015.collection.d.ts",
     "node_modules/typescript/lib/lib.es2015.symbol.wellknown.d.ts",
     "node_modules/typescript/lib/lib.es2015.core.d.ts",
     "node_modules/typescript/lib/lib.es2017.object.d.ts",
     "node_modules/typescript/lib/lib.es2017.string.d.ts",
+    "node_modules/typescript/lib/lib.es2019.array.d.ts",
+    "node_modules/re2js/build/index.esm.d.ts",
     "packages/app-types/index.d.ts",
     "packages/app-types/private.d.ts",
     "packages/app/dist/app.d.ts",

packages/firestore/package.json

@@ -119,7 +119,8 @@
   "license": "Apache-2.0",
   "files": [
     "dist",
-    "lite/package.json"
+    "lite",
+    "pipelines"
   ],
   "dependencies": {
     "@firebase/component": "0.6.13",
@@ -128,7 +129,9 @@
     "@firebase/webchannel-wrapper": "1.0.3",
     "@grpc/grpc-js": "~1.9.0",
     "@grpc/proto-loader": "^0.7.8",
-    "tslib": "^2.1.0"
+    "re2js": "^0.4.2",
+    "tslib": "^2.1.0",
+    "undici": "6.19.7"
   },
   "peerDependencies": {
     "@firebase/app": "0.x"
@@ -146,6 +149,7 @@
     "rollup": "2.79.2",
     "rollup-plugin-copy": "3.5.0",
     "rollup-plugin-copy-assets": "2.0.3",
+    "rollup-plugin-dts": "5.3.1",
     "rollup-plugin-replace": "2.2.0",
     "rollup-plugin-sourcemaps": "0.6.3",
     "@rollup/plugin-terser": "0.4.4",
@@ -162,7 +166,7 @@
   "bugs": {
     "url": "https://github.com/firebase/firebase-js-sdk/issues"
   },
-  "types": "dist/index.d.ts",
+  "types": "dist/firestore/src/index.d.ts",
   "nyc": {
     "extension": [
       ".ts"

packages/firestore/src/protos/firestore_proto_api.ts

@@ -356,6 +356,9 @@ export declare namespace firestoreV1ApiClientInterfaces {
     parent?: string;
     structuredQuery?: StructuredQuery;
   }
+  interface PipelineQueryTarget {
+    structuredPipeline?: StructuredPipeline;
+  }
   interface ReadOnly {
     readTime?: string;
   }
@@ -424,6 +427,7 @@ export declare namespace firestoreV1ApiClientInterfaces {
   interface Target {
     query?: QueryTarget;
     documents?: DocumentsTarget;
+    pipelineQuery?: PipelineQueryTarget;
     resumeToken?: string | Uint8Array;
     readTime?: Timestamp;
     targetId?: number;
@@ -555,6 +559,8 @@ export declare type Pipeline = firestoreV1ApiClientInterfaces.Pipeline;
 export declare type Precondition = firestoreV1ApiClientInterfaces.Precondition;
 export declare type Projection = firestoreV1ApiClientInterfaces.Projection;
 export declare type QueryTarget = firestoreV1ApiClientInterfaces.QueryTarget;
+export declare type PipelineQueryTarget =
+  firestoreV1ApiClientInterfaces.PipelineQueryTarget;
 export declare type ReadOnly = firestoreV1ApiClientInterfaces.ReadOnly;
 export declare type ReadWrite = firestoreV1ApiClientInterfaces.ReadWrite;
 export declare type RollbackRequest =

packages/firestore/src/protos/google/firestore/v1/firestore.proto

@@ -913,13 +913,25 @@ message Target {
     }
   }
 
+  // A target specified by a pipeline query.
+  message PipelineQueryTarget {
+    // The pipeline to run.
+    oneof pipeline_type {
+      // A pipelined operation in structured format.
+      StructuredPipeline structured_pipeline = 1;
+    }
+  }
+
   // The type of target to listen to.
   oneof target_type {
     // A target specified by a query.
     QueryTarget query = 2;
 
     // A target specified by a set of document names.
     DocumentsTarget documents = 3;
+
+    // A target specified by a pipeline query.
+    PipelineQueryTarget pipeline_query = 13;
   }
 
   // When to start listening.

packages/firestore/src/protos/google/firestore/v1/write.proto

@@ -198,6 +198,12 @@ message WriteResult {
 //
 // Multiple [DocumentChange][google.firestore.v1.DocumentChange] messages may be returned for the same logical
 // change, if multiple targets are affected.
+//
+// For PipelineQueryTargets, `document` will be in the new pipeline format,
+// (-- TODO(b/330735468): Insert link to spec. --)
+// For a Listen stream with both QueryTargets and PipelineQueryTargets present,
+// if a document matches both types of queries, then a separate DocumentChange
+// messages will be sent out one for each set.
 message DocumentChange {
   // The new state of the [Document][google.firestore.v1.Document].
   //

packages/firestore/src/protos/protos.json

@@ -2343,7 +2343,8 @@
                     "targetType": {
                       "oneof": [
                         "query",
-                        "documents"
+                        "documents",
+                        "pipeline_query"
                       ]
                     },
                     "resumeType": {
@@ -2362,6 +2363,10 @@
                       "type": "DocumentsTarget",
                       "id": 3
                     },
+                    "pipelineQuery": {
+                      "type": "PipelineQueryTarget",
+                      "id": 13
+                    },
                     "resumeToken": {
                       "type": "bytes",
                       "id": 4
@@ -2411,6 +2416,21 @@
                           "id": 2
                         }
                       }
+                    },
+                    "PipelineQueryTarget": {
+                      "oneofs": {
+                        "pipelineType": {
+                          "oneof": [
+                            "structuredPipeline"
+                          ]
+                        }
+                      },
+                      "fields": {
+                        "structuredPipeline": {
+                          "type": "StructuredPipeline",
+                          "id": 1
+                        }
+                      }
                     }
                   }
                 },
@@ -3266,4 +3286,4 @@
       }
     }
   }
-}
+}