Function extract_kv

src/cli/progress_sink.c:157–178

Extract a field from either structured text or JSON worker logs. */

/* Extract a field from either structured text or JSON worker logs. */
static const char *extract_kv(const char *line, const char *key, char *buf, int buf_len) {
    if (!line || !key || !buf || buf_len <= 0) {
        return NULL;
    }
    size_t klen = strlen(key);
    const char *p = line;
    while (*p) {
        if ((p == line || p[-SKIP_ONE] == ' ') && strncmp(p, key, klen) == 0 && p[klen] == '=') {
            const char *val = p + klen + SKIP_ONE;
            int i = 0;
            while (val[i] && val[i] != ' ' && i < buf_len - SKIP_ONE) {
                buf[i] = val[i];
                i++;
            }
            buf[i] = '\0';
            return buf;
        }
        p++;
    }
    const char *json_key = strcmp(key, "msg") == 0 ? "event" : key;
    return extract_json_field(line, json_key, buf, buf_len);
}

void cbm_progress_sink_init(FILE *out) {
    progress_sink_mutex_ensure();