Function expand_pattern_rels

src/cypher/cypher.c:2994–3046

}

static void expand_pattern_rels(cbm_store_t *store, cbm_pattern_t *pat, binding_t **bindings,
                                int *bind_count, const int *bind_cap, const char **var_name,
                                bool is_optional) {
    for (int ri = 0; ri < pat->rel_count; ri++) {
        cbm_rel_pattern_t *rel = &pat->rels[ri];
        cbm_node_pattern_t *target_node = &pat->nodes[ri + SKIP_ONE];
        const char *to_var = target_node->variable ? target_node->variable : "_n_t";

        bool is_variable_length = (rel->min_hops != SKIP_ONE || rel->max_hops != SKIP_ONE);

        size_t alloc_n = (size_t)*bind_cap * (size_t)CYP_GROWTH_10 + SKIP_ONE;
        binding_t *new_bindings = malloc(alloc_n * sizeof(binding_t));
        if (!new_bindings) {
            return; /* OOM: leave existing bindings untouched rather than corrupt */
        }
        int new_count = 0;

        for (int bi = 0; bi < *bind_count; bi++) {
            binding_t *b = &(*bindings)[bi];
            cbm_node_t *src = binding_get(b, *var_name);
            if (!src) {
                continue;
            }

            int match_count = 0;

            int max_new = *bind_cap * CYP_GROWTH_10;
            if (is_variable_length) {
                expand_var_length(store, rel, target_node, b, src, to_var, new_bindings, &new_count,
                                  max_new, &match_count);
            } else {
                expand_fixed_length(store, rel, target_node, b, src, to_var, new_bindings,
                                    &new_count, max_new, &match_count);
            }

            /* OPTIONAL MATCH: keep binding with empty target if no matches */
            if (is_optional && match_count == 0) {
                binding_t nb = {0};
                binding_copy(&nb, b);
                /* Don't set to_var — it remains unbound; projection returns "" */
                new_bindings[new_count++] = nb;
            }
        }

        for (int bi = 0; bi < *bind_count; bi++) {
            binding_free(&(*bindings)[bi]);
        }
        free(*bindings);
        *bindings = new_bindings;
        *bind_count = new_count;
        *var_name = to_var;
    }
}

/* ── Result postprocessing helpers ─────────────────────────────── */