Function flattenCompoundUniqueFilters

packages/orm/src/client/query-utils.ts:396–438

(schema: SchemaDef, model: string, filter: unknown)

 * Convert filter like `{ id1_id2: { id1: 1, id2: 1 } }` to `{ id1: 1, id2: 1 }`
 */
export function flattenCompoundUniqueFilters(schema: SchemaDef, model: string, filter: unknown) {
    if (typeof filter !== 'object' || !filter) {
        return filter;
    }

    const uniqueFields = getUniqueFields(schema, model);
    const compoundUniques = uniqueFields.filter((u) => 'defs' in u);
    if (compoundUniques.length === 0) {
        return filter;
    }

    const flattenedResult: any = {};
    const restFilter: any = {};

    for (const [key, value] of Object.entries(filter)) {
        if (compoundUniques.some(({ name }) => name === key)) {
            // flatten the compound field
            Object.assign(flattenedResult, value);
        } else {
            restFilter[key] = value;
        }
    }

    if (Object.keys(flattenedResult).length === 0) {
        // nothing flattened
        return filter;
    } else if (Object.keys(restFilter).length === 0) {
        // all flattened
        return flattenedResult;
    } else {
        const flattenedKeys = Object.keys(flattenedResult);
        const restKeys = Object.keys(restFilter);
        if (flattenedKeys.some((k) => restKeys.includes(k))) {
            // keys overlap, cannot merge directly, build an AND clause
            return {
                AND: [flattenedResult, restFilter],
            };
        } else {
            // safe to merge directly
            return { ...flattenedResult, ...restFilter };
        }
    }
}

export function ensureArray<T>(value: T | T[]): T[] {
    if (Array.isArray(value)) {