Function cbm_progress_sink_fn

src/cli/progress_sink.c:341–361

enum { HANDLER_COUNT = sizeof(handlers) / sizeof(handlers[0]) };

void cbm_progress_sink_fn(const char *line) {
    progress_sink_mutex_ensure();
    cbm_mutex_lock(&s_sink_mutex);
    if (!line || !s_out) {
        cbm_mutex_unlock(&s_sink_mutex);
        return;
    }
    char msg[CBM_SZ_64] = {0};
    if (!extract_kv(line, "msg", msg, (int)sizeof(msg))) {
        cbm_mutex_unlock(&s_sink_mutex);
        return;
    }
    for (int i = 0; i < HANDLER_COUNT; i++) {
        if (strcmp(msg, handlers[i].msg) == 0) {
            handlers[i].handler(line);
            cbm_mutex_unlock(&s_sink_mutex);
            return;
        }
    }
    cbm_mutex_unlock(&s_sink_mutex);
}