test(firestore): cover pipeline exit frame and receiver expression lowering on Android

Author: mikehardy

okf-bundle/packages/firestore/pipeline-coverage-work-queue.md

@@ -8,7 +8,7 @@ timestamp: 2026-06-25T12:00:00Z
 
 # Pipeline coverage and parity — work queue
 
-> **IN PROGRESS:** **M** — `commit`. **L** landing now.
+> **IN PROGRESS:** **N** queued — iOS stage coercion (~293 missed).
 > **Goal/order:** platform parity first; then TS/native coverage toward intractable limits. Links: [parity](pipeline-platform-parity.md), [SDK audit](pipeline-sdk-support-audit.md), [coverage](../../testing/coverage-design.md), [e2e](../../testing/running-e2e.md), [architecture](pipelines.md).
 
 ---
@@ -76,12 +76,12 @@ Gate prerequisites before any `:test-cover` ([host rule](../../testing/change-au
 
 ## Current snapshot
 
-**Label:** `lm-commit-pending`; **harness:** full test app (committed)
+**Label:** `n-queued`; **harness:** full test app (committed)
 
 **Next item:** **N** — iOS stage coercion (~293 missed).
 
 | **L** parsed-aggregate tail | `test(firestore): cover pipeline aggregate expression argument lowering on Android` | **closed** | **closed** | **closed** | — | — | — | `arrayAgg`/`arrayAggDistinct` expr args |
-| **M** exit/receiver/vector | `test(firestore): cover pipeline exit frame and receiver expression lowering on Android` | **closed** | **closed** | open | `commit` | — | — | review 141/141/136; NodeBuilder 75.03%; exit 73→44 missed |
+| **M** exit/receiver/vector | `test(firestore): cover pipeline exit frame and receiver expression lowering on Android` | **closed** | **closed** | **closed** | — | — | — | 3 e2e; NodeBuilder 75.03%; exit 73→44 missed |
 
 | **J2** P-005 `integerLiteral` | `fix(firestore, android): align pipeline integerLiteral constant lowering with iOS` | **closed** | **closed** | **closed** | — | — | — | P-005 → Resolved; CFBoolean deferral accepted |
 | **J3** P-010 stage option expressions | `fix(firestore, android): align pipeline stage option expression fields with iOS` | **closed** | **closed** | **closed** | — | — | — | P-010 → Resolved |
@@ -306,7 +306,7 @@ Per [SDK audit §6](pipeline-sdk-support-audit.md): one function/commit; remove
 
 **Gate for Phase K+:** J0 complete + **J0b** committed + J1–J6 bridge commits + parity **Resolved** updated.
 
-**Current gates:** **M** commit pending. **L** complete.
+**Current gates:** **N** queued. **L** and **M** complete.
 
 ---
 

packages/firestore/e2e/Pipeline.e2e.js

@@ -3188,6 +3188,115 @@ describe('FirestorePipeline', function () {
       });
     });
 
+    describe('exit frame and receiver expression lowering coverage', function () {
+      it('lowers vector distance receiver chains with expression vector operands', async function () {
+        const { execute, field, cosineDistance, dotProduct } = firestorePipelinesModular;
+        const { getFirestore, doc, setDoc, vector } = firestoreModular;
+        const db = getFirestore(DATABASE_ID);
+        const docPath = `${COLLECTION}/${Utils.randString(12, '#aA')}`;
+
+        await setDoc(doc(db, docPath), {
+          embedding: vector([1.0, 0.0, 0.0]),
+          query: vector([0.0, 1.0, 0.0]),
+        });
+
+        const snapshot = await execute(
+          db
+            .pipeline()
+            .documents([docPath])
+            .select(
+              cosineDistance(field('embedding'), field('query')).as('globalCosDist'),
+              field('embedding').dotProduct(field('query')).as('fluentDot'),
+              field('embedding').euclideanDistance(field('query')).as('fluentEuclid'),
+              dotProduct(field('embedding'), field('query')).as('globalDot'),
+            ),
+        );
+
+        snapshot.results.should.have.length(1);
+        const data = snapshot.results[0].data();
+        should(data.globalCosDist).be.approximately(1, 0.0001);
+        should(data.fluentDot).be.approximately(0, 0.0001);
+        should(data.fluentEuclid).be.approximately(Math.sqrt(2), 0.0001);
+        should(data.globalDot).be.approximately(0, 0.0001);
+      });
+
+      it('lowers fluent receiver exit frames with expression map, array, and extrema operands', async function () {
+        const { execute, field, logicalMaximum, logicalMinimum } = firestorePipelinesModular;
+        const { getFirestore, doc, setDoc } = firestoreModular;
+        const db = getFirestore(DATABASE_ID);
+        const docPath = `${COLLECTION}/${Utils.randString(12, '#aA')}`;
+
+        await setDoc(doc(db, docPath), {
+          metadata: { theme: 'dark', locale: 'en' },
+          keyName: 'theme',
+          scores: [10, 25, 40],
+          idx: 1,
+          bidA: 100,
+          bidB: 150,
+          bidC: 120,
+          askA: 200,
+          askB: 175,
+          askC: 190,
+        });
+
+        const snapshot = await execute(
+          db
+            .pipeline()
+            .documents([docPath])
+            .select(
+              field('metadata').mapGet(field('keyName')).as('fluentMapGet'),
+              field('scores').arrayGet(field('idx')).as('fluentArrayGet'),
+              field('bidA').logicalMaximum(field('bidB'), field('bidC')).as('fluentMaxBid'),
+              field('askA').logicalMinimum(field('askB'), field('askC')).as('fluentMinAsk'),
+              logicalMaximum(field('bidA'), field('bidB'), field('bidC')).as('globalMaxBid'),
+              logicalMinimum(field('askA'), field('askB'), field('askC')).as('globalMinAsk'),
+            ),
+        );
+
+        snapshot.results.should.have.length(1);
+        const data = snapshot.results[0].data();
+        data.fluentMapGet.should.equal('dark');
+        data.fluentArrayGet.should.equal(25);
+        data.fluentMaxBid.should.equal(150);
+        data.fluentMinAsk.should.equal(175);
+        data.globalMaxBid.should.equal(150);
+        data.globalMinAsk.should.equal(175);
+      });
+
+      it('lowers boolean receiver and logical exit frames with expression operands', async function () {
+        const { execute, field, or, and } = firestorePipelinesModular;
+        const { getFirestore, collection, doc, setDoc } = firestoreModular;
+        const db = getFirestore(DATABASE_ID);
+        const coll = collection(
+          db,
+          `${COLLECTION}/${Utils.randString(12, '#aA')}/boolean-receiver-exit-frames`,
+        );
+
+        await Promise.all([
+          setDoc(doc(coll, 'match-a'), { score: 12, threshold: 10, tier: 'gold', region: 'EU' }),
+          setDoc(doc(coll, 'match-b'), { score: 12, threshold: 10, tier: 'silver', region: 'US' }),
+          setDoc(doc(coll, 'skip'), { score: 3, threshold: 10, tier: 'bronze', region: 'APAC' }),
+        ]);
+
+        const snapshot = await execute(
+          db
+            .pipeline()
+            .collection(coll)
+            .where(
+              and(
+                field('score').greaterThan(field('threshold')),
+                or(field('tier').equal('gold'), field('region').equal('US')),
+              ),
+            )
+            .select('score', 'tier', 'region'),
+        );
+
+        snapshot.results.should.have.length(2);
+        const tiers = snapshot.results.map(row => row.data().tier).sort();
+        tiers.should.eql(['gold', 'silver']);
+      });
+    });
+
     describe('operand mode rhs shape coverage', function () {
       it('coerces string, array, and boolean rhs shapes in comparisons and arithmetic', async function () {
         const { execute, field, constant, add, multiply, mod, equal, equalAny, greaterThan, and } =