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, {explains: true});

        /**
         * 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);
    }
}