Function syncRelation

packages/cli/src/actions/pull/index.ts:388–565

({
    model,
    relation,
    services,
    options,
    selfRelation,
    similarRelations,
}: {
    model: Model;
    relation: Relation;
    services: ZModelServices;
    options: PullOptions;
    //self included
    similarRelations: number;
    selfRelation: boolean;
})

}

export function syncRelation({
    model,
    relation,
    services,
    options,
    selfRelation,
    similarRelations,
}: {
    model: Model;
    relation: Relation;
    services: ZModelServices;
    options: PullOptions;
    //self included
    similarRelations: number;
    selfRelation: boolean;
}) {
    const idAttribute = getAttributeRef('@id', services);
    const uniqueAttribute = getAttributeRef('@unique', services);
    const relationAttribute = getAttributeRef('@relation', services);
    const fieldMapAttribute = getAttributeRef('@map', services);
    const tableMapAttribute = getAttributeRef('@@map', services);

    const includeRelationName = selfRelation || similarRelations > 0;

    if (!idAttribute || !uniqueAttribute || !relationAttribute || !fieldMapAttribute || !tableMapAttribute) {
        throw new CliError('Cannot find required attributes in the model.');
    }

    const sourceModel = model.declarations.find((d) => d.$type === 'DataModel' && getDbName(d) === relation.table) as
        | DataModel
        | undefined;
    if (!sourceModel) return;

    // Resolve all source and target fields for the relation (supports composite FKs)
    const sourceFields: { field: DataField; index: number }[] = [];
    for (const colName of relation.columns) {
        const idx = sourceModel.fields.findIndex((f) => getDbName(f) === colName);
        const field = sourceModel.fields[idx] as DataField | undefined;
        if (!field) return;
        sourceFields.push({ field, index: idx });
    }

    const targetModel = model.declarations.find(
        (d) => d.$type === 'DataModel' && getDbName(d) === relation.references.table,
    ) as DataModel | undefined;
    if (!targetModel) return;

    const targetFields: DataField[] = [];
    for (const colName of relation.references.columns) {
        const field = targetModel.fields.find((f) => getDbName(f) === colName);
        if (!field) return;
        targetFields.push(field);
    }

    // Use the first source field for naming heuristics
    const firstSourceField = sourceFields[0]!.field;
    const firstSourceFieldId = sourceFields[0]!.index;
    const firstColumn = relation.columns[0]!;