/**
 * F003: a $lookup with a pipeline over a view whose definition contains $unionWith on
 * another view does not apply the inner view's pipeline, so documents the inner view
 * filters out are returned.
 *
 * @tags: [
 *   requires_fcv_90,
 * ]
 */

const conn = MongoRunner.runMongod({setParameter: {internalQueryDisablePlanCache: true}});
const db = conn.getDB(jsTestName());

assert.commandWorked(db.local.insert({_id: 1, k: 1}));
assert.commandWorked(db.foreign.insertMany([{_id: 1, x: 1, k: 1}, {_id: 2, x: 2, k: 1}]));
assert.commandWorked(db.other.insertMany([{_id: 10, x: 1, k: 1}, {_id: 11, x: 2, k: 1}]));
// innerV keeps only x: 1, so _id 11 must never appear through it.
assert.commandWorked(db.createView("innerV", "other", [{$match: {x: 1}}]));
assert.commandWorked(db.createView("outerV", "foreign", [{$unionWith: {coll: "innerV", pipeline: [{$set: {tag: "in"}}]}}]));

const expectedIds = [1, 2, 10];
function ids(docs) {
    return docs.map((d) => d._id).sort((a, b) => a - b);
}
function run(label, fn) {
    const got = fn();
    jsTest.log.info("F003 run", {label, ids: got});
    return got;
}

const direct = run("aggregate on outerV", () => ids(db.outerV.aggregate([]).toArray()));
run("top-level $unionWith outerV", () =>
    ids(db.local.aggregate([{$match: {_id: -1}}, {$unionWith: {coll: "outerV", pipeline: []}}]).toArray()));
run("$lookup localField/foreignField on outerV", () =>
    ids(db.local.aggregate([{$lookup: {from: "outerV", localField: "k", foreignField: "k", as: "j"}}]).toArray()[0].j));
const lookupPipeline = run("$lookup pipeline on outerV", () =>
    ids(db.local.aggregate([{$lookup: {from: "outerV", pipeline: [{$sort: {_id: 1}}], as: "j"}}]).toArray()[0].j));

// Control: reading the view directly applies both view pipelines.
assert.eq(direct, expectedIds, "aggregate on outerV");
// Fails at ba06f31d06c: returns [1, 2, 10, 11]; innerV's $match is not applied.
assert.eq(lookupPipeline, expectedIds, "$lookup pipeline on outerV");

MongoRunner.stopMongod(conn);