Function genericComputeFunction

api/src/compute/generic.ts:258–688

(
    options: GenericComputeOptions
)

        // restrict aggregation to current and past editions, to avoid including results from the future
        // when regenerating older surveys
        const pastEditions = getPastNEditions({ survey, edition, editionCount })
        match.editionId = { $in: pastEditions.map(e => e.id) }
    }
    return match
}

export async function genericComputeFunction(
    options: GenericComputeOptions
): Promise<ResponseEditionData[]> {
    const startAt = new Date()
    const stageLog: StageLogItem[] = []

    const runStage = async (f: (...args: any[]) => Promise<any>, args: any) => {
        const startAt = new Date()
        const result = await f.apply(null, args)
        const bucketCount = result?.[0]?.buckets?.length
        const endAt = new Date()
        const duration = Math.abs(endAt.getTime() - startAt.getTime())
        const logItem = { name: f.name, startAt, endAt, duration, bucketCount }
        stageLog.push(logItem)
        return result
    }

    const { context, survey, edition, question, questionObjects, computeArguments } = options

    let axis1: ComputeAxisParameters,
        axis2: ComputeAxisParameters | null = null
    const { db, isDebug } = context

    // TODO "responsesType" is now called "subField" elsewhere, change it here as well at some point
    const {
        responsesType,
        filters,
        parameters = {},
        bucketsFilter,
        facet,
        selectedEditionId,
        editionCount,
        executionContext = ExecutionContext.REGULAR
    } = computeArguments
    const {
        cutoff = DEFAULT_CUTOFF,
        cutoffPercent,
        sort,
        limit = DEFAULT_LIMIT,
        facetSort,
        facetLimit = DEFAULT_LIMIT,
        facetCutoff = DEFAULT_CUTOFF,
        facetCutoffPercent,
        showNoAnswer,
        mergeOtherBuckets = true,
        enableBucketGroups = true,
        enableBucketNesting = true,
        enableAddOverallBucket = true,
        enableAddMissingBuckets
    } = parameters

    const logPath = `last_query/${executionContext}`