[feat] ppl

.idx/.gitignore

@@ -0,0 +1,2 @@
+
+gc/

.idx/dev.nix

@@ -0,0 +1,17 @@
+{ pkgs, ... }: {
+
+  # Which nixpkgs channel to use.
+  channel = "stable-23.11"; # or "unstable"
+
+  # Use https://search.nixos.org/packages to find packages
+  packages = [
+    pkgs.jdk11 # Or jdk8, jdk17, etc. - match your project's requirements
+    pkgs.maven
+    pkgs.kotlin
+  ];
+
+  # Sets environment variables in the workspace
+  env = {
+    SOME_ENV_VAR = "hello";
+  };
+}

.vscode/settings.json

@@ -0,0 +1,3 @@
+{
+    "java.compile.nullAnalysis.mode": "automatic"
+}

README.md

@@ -50,20 +50,20 @@ If you are using Maven without the BOM, add this to your dependencies:
 If you are using Gradle 5.x or later, add this to your dependencies:
 
 ```Groovy
-implementation platform('com.google.cloud:libraries-bom:26.39.0')
+implementation platform('com.google.cloud:libraries-bom:26.43.0')
 
 implementation 'com.google.cloud:google-cloud-firestore'
 ```
 If you are using Gradle without BOM, add this to your dependencies:
 
 ```Groovy
-implementation 'com.google.cloud:google-cloud-firestore:3.21.1'
+implementation 'com.google.cloud:google-cloud-firestore:3.24.2'
 ```
 
 If you are using SBT, add this to your dependencies:
 
 ```Scala
-libraryDependencies += "com.google.cloud" % "google-cloud-firestore" % "3.21.1"
+libraryDependencies += "com.google.cloud" % "google-cloud-firestore" % "3.24.2"
 ```
 <!-- {x-version-update-end} -->
 
@@ -222,7 +222,7 @@ Java is a registered trademark of Oracle and/or its affiliates.
 [kokoro-badge-link-5]: http://storage.googleapis.com/cloud-devrel-public/java/badges/java-firestore/java11.html
 [stability-image]: https://img.shields.io/badge/stability-stable-green
 [maven-version-image]: https://img.shields.io/maven-central/v/com.google.cloud/google-cloud-firestore.svg
-[maven-version-link]: https://central.sonatype.com/artifact/com.google.cloud/google-cloud-firestore/3.21.1
+[maven-version-link]: https://central.sonatype.com/artifact/com.google.cloud/google-cloud-firestore/3.24.2
 [authentication]: https://github.com/googleapis/google-cloud-java#authentication
 [auth-scopes]: https://developers.google.com/identity/protocols/oauth2/scopes
 [predefined-iam-roles]: https://cloud.google.com/iam/docs/understanding-roles#predefined_roles

google-cloud-firestore-admin/src/main/java/com/google/cloud/firestore/v1/stub/FirestoreAdminStubSettings.java

@@ -486,6 +486,15 @@ public FirestoreAdminStub createStub() throws IOException {
             "Transport not supported: %s", getTransportChannelProvider().getTransportName()));
   }
 
+  /** Returns the endpoint set by the user or the the service's default endpoint. */
+  @Override
+  public String getEndpoint() {
+    if (super.getEndpoint() != null) {
+      return super.getEndpoint();
+    }
+    return getDefaultEndpoint();
+  }
+
   /** Returns the default service name. */
   @Override
   public String getServiceName() {
@@ -1377,6 +1386,15 @@ public UnaryCallSettings.Builder<RestoreDatabaseRequest, Operation> restoreDatab
       return deleteBackupScheduleSettings;
     }
 
+    /** Returns the endpoint set by the user or the the service's default endpoint. */
+    @Override
+    public String getEndpoint() {
+      if (super.getEndpoint() != null) {
+        return super.getEndpoint();
+      }
+      return getDefaultEndpoint();
+    }
+
     @Override
     public FirestoreAdminStubSettings build() throws IOException {
       return new FirestoreAdminStubSettings(this);

google-cloud-firestore/pom.xml

@@ -214,6 +214,42 @@
         <groupId>org.codehaus.mojo</groupId>
         <artifactId>flatten-maven-plugin</artifactId>
       </plugin>
+      <plugin>
+        <artifactId>maven-assembly-plugin</artifactId>
+        <configuration>
+          <descriptorRefs>
+            <descriptorRef>jar-with-dependencies</descriptorRef>
+          </descriptorRefs>
+        </configuration>
+      </plugin>
+      <plugin>
+        <groupId>org.apache.maven.plugins</groupId>
+        <artifactId>maven-compiler-plugin</artifactId>
+        <executions>
+          <execution>
+            <id>default-compile</id>
+            <phase>none</phase>
+          </execution>
+          <execution>
+            <id>default-testCompile</id>
+            <phase>none</phase>
+          </execution>
+          <execution>
+            <id>compile</id>
+            <phase>compile</phase>
+            <goals>
+              <goal>compile</goal>
+            </goals>
+          </execution>
+          <execution>
+            <id>testCompile</id>
+            <phase>test-compile</phase>
+            <goals>
+              <goal>testCompile</goal>
+            </goals>
+          </execution>
+        </executions>
+      </plugin>
     </plugins>
   </build>
 

google-cloud-firestore/src/main/java/com/google/cloud/firestore/AggregateQuery.java

@@ -17,13 +17,15 @@
 package com.google.cloud.firestore;
 
 import com.google.api.core.ApiFuture;
+import com.google.api.core.BetaApi;
 import com.google.api.core.InternalExtensionOnly;
 import com.google.api.core.SettableApiFuture;
 import com.google.api.gax.rpc.ResponseObserver;
 import com.google.api.gax.rpc.ServerStreamingCallable;
 import com.google.api.gax.rpc.StatusCode;
 import com.google.api.gax.rpc.StreamController;
 import com.google.cloud.Timestamp;
+import com.google.cloud.firestore.pipeline.expressions.ExprWithAlias;
 import com.google.cloud.firestore.v1.FirestoreSettings;
 import com.google.common.collect.ImmutableMap;
 import com.google.firestore.v1.RunAggregationQueryRequest;
@@ -65,6 +67,17 @@ public Query getQuery() {
     return query;
   }
 
+  @Nonnull
+  @BetaApi
+  public Pipeline pipeline() {
+    return getQuery()
+        .pipeline()
+        .aggregate(
+            this.aggregateFieldList.stream()
+                .map(PipelineUtils::toPipelineAggregatorTarget)
+                .toArray(ExprWithAlias[]::new));
+  }
+
   /**
    * Executes this query.
    *

google-cloud-firestore/src/main/java/com/google/cloud/firestore/AggregateQuerySnapshot.java

@@ -16,6 +16,7 @@
 
 package com.google.cloud.firestore;
 
+import com.google.api.core.InternalApi;
 import com.google.api.core.InternalExtensionOnly;
 import com.google.cloud.Timestamp;
 import com.google.firestore.v1.Value;
@@ -189,4 +190,9 @@ public boolean equals(Object object) {
   public int hashCode() {
     return Objects.hash(query, data);
   }
+
+  @InternalApi
+  Map<String, Value> getData() {
+    return data;
+  }
 }

google-cloud-firestore/src/main/java/com/google/cloud/firestore/FieldPath.java

@@ -16,6 +16,7 @@
 
 package com.google.cloud.firestore;
 
+import com.google.api.core.InternalApi;
 import com.google.auto.value.AutoValue;
 import com.google.common.base.Preconditions;
 import com.google.common.collect.ImmutableList;
@@ -79,7 +80,8 @@ static boolean isDocumentId(String path) {
   }
 
   /** Returns a field path from a dot separated string. Does not support escaping. */
-  static FieldPath fromDotSeparatedString(String field) {
+  @InternalApi
+  public static FieldPath fromDotSeparatedString(String field) {
     if (PROHIBITED_CHARACTERS.matcher(field).matches()) {
       throw new IllegalArgumentException("Use FieldPath.of() for field names containing '˜*/[]'.");
     }

google-cloud-firestore/src/main/java/com/google/cloud/firestore/Firestore.java

@@ -66,6 +66,8 @@ public interface Firestore extends Service<FirestoreOptions>, AutoCloseable {
    */
   CollectionGroup collectionGroup(@Nonnull String collectionId);
 
+  PipelineSource pipeline();
+
   /**
    * Executes the given updateFunction and then attempts to commit the changes applied within the
    * transaction. If any document read within the transaction has changed, the updateFunction will

google-cloud-firestore/src/main/java/com/google/cloud/firestore/FirestoreImpl.java

@@ -18,6 +18,7 @@
 
 import com.google.api.core.ApiClock;
 import com.google.api.core.ApiFuture;
+import com.google.api.core.BetaApi;
 import com.google.api.core.NanoClock;
 import com.google.api.core.SettableApiFuture;
 import com.google.api.gax.rpc.ApiStreamObserver;
@@ -29,6 +30,8 @@
 import com.google.api.gax.rpc.StreamController;
 import com.google.api.gax.rpc.UnaryCallable;
 import com.google.cloud.Timestamp;
+import com.google.cloud.firestore.Transaction.AsyncFunction;
+import com.google.cloud.firestore.Transaction.Function;
 import com.google.cloud.firestore.spi.v1.FirestoreRpc;
 import com.google.common.annotations.VisibleForTesting;
 import com.google.common.base.Preconditions;
@@ -385,30 +388,35 @@ public CollectionGroup collectionGroup(@Nonnull final String collectionId) {
 
   @Nonnull
   @Override
-  public <T> ApiFuture<T> runTransaction(@Nonnull final Transaction.Function<T> updateFunction) {
+  @BetaApi
+  public PipelineSource pipeline() {
+    return new PipelineSource(this);
+  }
+
+  @Nonnull
+  @Override
+  public <T> ApiFuture<T> runTransaction(@Nonnull final Function<T> updateFunction) {
     return runAsyncTransaction(
         new TransactionAsyncAdapter<>(updateFunction), TransactionOptions.create());
   }
 
   @Nonnull
   @Override
   public <T> ApiFuture<T> runTransaction(
-      @Nonnull final Transaction.Function<T> updateFunction,
-      @Nonnull TransactionOptions transactionOptions) {
+      @Nonnull final Function<T> updateFunction, @Nonnull TransactionOptions transactionOptions) {
     return runAsyncTransaction(new TransactionAsyncAdapter<>(updateFunction), transactionOptions);
   }
 
   @Nonnull
   @Override
-  public <T> ApiFuture<T> runAsyncTransaction(
-      @Nonnull final Transaction.AsyncFunction<T> updateFunction) {
+  public <T> ApiFuture<T> runAsyncTransaction(@Nonnull final AsyncFunction<T> updateFunction) {
     return runAsyncTransaction(updateFunction, TransactionOptions.create());
   }
 
   @Nonnull
   @Override
   public <T> ApiFuture<T> runAsyncTransaction(
-      @Nonnull final Transaction.AsyncFunction<T> updateFunction,
+      @Nonnull final AsyncFunction<T> updateFunction,
       @Nonnull TransactionOptions transactionOptions) {
 
     if (transactionOptions.getReadTime() != null) {
@@ -519,10 +527,10 @@ public void shutdownNow() {
     closed = true;
   }
 
-  private static class TransactionAsyncAdapter<T> implements Transaction.AsyncFunction<T> {
-    private final Transaction.Function<T> syncFunction;
+  private static class TransactionAsyncAdapter<T> implements AsyncFunction<T> {
+    private final Function<T> syncFunction;
 
-    public TransactionAsyncAdapter(Transaction.Function<T> syncFunction) {
+    public TransactionAsyncAdapter(Function<T> syncFunction) {
       this.syncFunction = syncFunction;
     }