fix(firestore): read user data in internal pipeline proto serialization (#9752)

dlarocque · web-flow · commit 4e99d4ba66a9 · 2026-03-25T14:17:06.000-04:00
diff --git a/.changeset/sour-peaches-attend.md b/.changeset/sour-peaches-attend.md
@@ -0,0 +1,5 @@
+---
+'@firebase/firestore': patch
+---
+
+Read user data when using internal pipeline proto serialization.
diff --git a/packages/firestore/src/remote/internal_serializer.ts b/packages/firestore/src/remote/internal_serializer.ts
@@ -26,6 +26,10 @@ import { AggregateSpec } from '../lite-api/aggregate_types';
 import { getDatastore } from '../lite-api/components';
 import { Pipeline } from '../lite-api/pipeline';
 import { Query } from '../lite-api/reference';
+import {
+  newUserDataReader,
+  UserDataSource
+} from '../lite-api/user_data_reader';
 import { ExecutePipelineRequest as ProtoExecutePipelineRequest } from '../protos/firestore_proto_api';
 import { cast } from '../util/input_validation';
 import { mapToArray } from '../util/obj';
@@ -116,6 +120,15 @@ export function _internalPipelineToExecutePipelineRequestProto(
   // eslint-disable-next-line @typescript-eslint/no-explicit-any
 ): any {
   const firestore = cast(pipeline._db, Firestore);
+
+  const userDataReader = newUserDataReader(firestore);
+  const context = userDataReader.createContext(
+    UserDataSource.Argument,
+    '_internalPipelineToExecutePipelineRequestProto'
+  );
+
+  pipeline._readUserData(context);
+
   const datastore = getDatastore(firestore);
   const serializer = datastore.serializer;
   if (serializer === undefined) {

-Original file line number
+Diff line change
@@ @@ -0,0 +1,5 @@ @@
 +---
 +'@firebase/firestore': patch
 +---
++
 +Read user data when using internal pipeline proto serialization.