grapher/lib/query/hypernova/storeHypernovaResults.js

import applyProps from '../lib/applyProps.js';
import AggregateFilters from './aggregateSearchFilters.js';
import assemble from './assembler.js';
import assembleAggregateResults from './assembleAggregateResults.js';
import buildAggregatePipeline from './buildAggregatePipeline.js';
import snapBackDottedFields from './lib/snapBackDottedFields';

export default function storeHypernovaResults(childCollectionNode, userId) {
    if (childCollectionNode.parent.results.length === 0) {
        return (childCollectionNode.results = []);
    }

    let { filters, options } = applyProps(childCollectionNode);

    const metaFilters = filters.$meta;
    const aggregateFilters = new AggregateFilters(
        childCollectionNode,
        metaFilters
    );
    delete filters.$meta;

    const linker = childCollectionNode.linker;
    const isVirtual = linker.isVirtual();
    const collection = childCollectionNode.collection;

    _.extend(filters, aggregateFilters.create());

    // if it's not virtual then we retrieve them and assemble them here.
    if (!isVirtual) {
        const filteredOptions = _.omit(options, 'limit');

        childCollectionNode.results = collection
            .find(filters, filteredOptions, userId)
            .fetch();

        assemble(childCollectionNode, {
            ...options,
            metaFilters,
        });
    } else {
        // virtuals arrive here
        let { pipeline, containsDottedFields } = buildAggregatePipeline(
            childCollectionNode,
            filters,
            options,
            userId
        );

        let aggregateResults = collection.aggregate(pipeline);

        /**
         * If in aggregation it contains '.', we replace it with a custom string '___'
         * And then after aggregation is complete we need to snap-it back to how it was.
         */
        if (containsDottedFields) {
            snapBackDottedFields(aggregateResults);
        }

        assembleAggregateResults(
            childCollectionNode,
            aggregateResults,
            metaFilters
        );
    }
}