Function application_mcp_request

src/daemon/application.c:2412–2470

}

static cbm_daemon_runtime_application_status_t application_mcp_request(
    cbm_daemon_application_session_t *session, const uint8_t *request, uint32_t request_length,
    uint8_t **response_out, uint32_t *response_length_out) {
    if (!session->context_set || request_length <= 1) {
        return CBM_DAEMON_RUNTIME_APPLICATION_REJECTED;
    }
    char *message = application_text_copy(request + 1, request_length - 1);
    if (!message) {
        return CBM_DAEMON_RUNTIME_APPLICATION_REJECTED;
    }
    cbm_jsonrpc_request_t parsed = {0};
    bool parsed_ok = cbm_jsonrpc_parse(message, &parsed) == 0;
    bool initialize_request =
        parsed_ok && parsed.has_id && parsed.method && strcmp(parsed.method, "initialize") == 0;
    bool tool_request =
        parsed_ok && parsed.has_id && parsed.method && strcmp(parsed.method, "tools/call") == 0;
    char *response = cbm_mcp_server_handle(session->mcp, message);
    free(message);
    if (initialize_request && application_jsonrpc_success(response)) {
        cbm_mutex_lock(&session->application->mutex);
        session->pending_background_initialize = true;
        cbm_mutex_unlock(&session->application->mutex);
    } else if (tool_request && response) {
        application_update_notice_inject(session, &response);
    }
    if (response) {
        size_t response_length = strlen(response);
        if (response_length > UINT32_MAX) {
            if (parsed_ok) {
                cbm_jsonrpc_request_free(&parsed);
            }
            free(response);
            return CBM_DAEMON_RUNTIME_APPLICATION_HANDLER_ERROR;
        }
        /* A reply larger than one frame has to become a JSON-RPC error HERE,
         * while the request id is still in hand. Handing it to the transport
         * instead is indistinguishable from a dead socket at the frontend
         * worker, which responds by _Exit()ing the process — right for a broken
         * transport, a fatal over-reaction to a large answer. Under an MCP host
         * that does not respawn the server, that took every tool on it out for
         * the rest of the session, leaving exit=1 and an empty stderr to debug
         * from (#1375). */
        response = application_framable_response(response, parsed_ok ? &parsed : NULL);
        if (!response) {
            if (parsed_ok) {
                cbm_jsonrpc_request_free(&parsed);
            }
            return CBM_DAEMON_RUNTIME_APPLICATION_HANDLER_ERROR;
        }
        response_length = strlen(response);
        *response_out = (uint8_t *)response;
        *response_length_out = (uint32_t)response_length;
    }
    if (parsed_ok) {
        cbm_jsonrpc_request_free(&parsed);
    }
    application_refresh_watch(session);
    return CBM_DAEMON_RUNTIME_APPLICATION_OK;