Function runtime_hello_response_decode

src/daemon/runtime.c:954–1007

}

static bool runtime_hello_response_decode(
    const uint8_t payload[CBM_DAEMON_RENDEZVOUS_RESPONSE_SIZE],
    cbm_daemon_runtime_connect_result_t *result) {
    if (!payload || !result) {
        return false;
    }
    memset(result, 0, sizeof(*result));
    result->status = (cbm_daemon_runtime_connect_status_t)runtime_get_u32(
        payload + RENDEZVOUS_RESPONSE_CONNECT_STATUS_OFFSET);
    result->hello_status = (cbm_daemon_hello_status_t)runtime_get_u32(
        payload + RENDEZVOUS_RESPONSE_HELLO_STATUS_OFFSET);
    result->client_id = runtime_get_u64(payload + RENDEZVOUS_RESPONSE_CLIENT_ID_OFFSET);
    result->authenticated_process_id =
        runtime_get_u64(payload + RENDEZVOUS_RESPONSE_PROCESS_ID_OFFSET);
    result->conflict.status = (cbm_daemon_hello_status_t)runtime_get_u32(
        payload + RENDEZVOUS_RESPONSE_CONFLICT_STATUS_OFFSET);
    if (!runtime_wire_string_decode(payload + RENDEZVOUS_RESPONSE_ACTIVE_VERSION_OFFSET,
                                    CBM_DAEMON_RENDEZVOUS_VERSION_TEXT_CAP,
                                    result->conflict.active_version, true) ||
        !runtime_wire_string_decode(payload + RENDEZVOUS_RESPONSE_ACTIVE_BUILD_OFFSET,
                                    CBM_DAEMON_RENDEZVOUS_BUILD_FINGERPRINT_CAP,
                                    result->conflict.active_build_fingerprint, true) ||
        !runtime_wire_string_decode(payload + RENDEZVOUS_RESPONSE_REQUESTED_VERSION_OFFSET,
                                    CBM_DAEMON_RENDEZVOUS_VERSION_TEXT_CAP,
                                    result->conflict.requested_version, true) ||
        !runtime_wire_string_decode(payload + RENDEZVOUS_RESPONSE_REQUESTED_BUILD_OFFSET,
                                    CBM_DAEMON_RENDEZVOUS_BUILD_FINGERPRINT_CAP,
                                    result->conflict.requested_build_fingerprint, true) ||
        !runtime_wire_string_decode(payload + RENDEZVOUS_RESPONSE_MESSAGE_OFFSET,
                                    CBM_DAEMON_RENDEZVOUS_MESSAGE_CAP, result->message, true)) {
        return false;
    }
    if (result->status == CBM_DAEMON_RUNTIME_CONNECT_ACCEPTED) {
        return result->hello_status == CBM_DAEMON_HELLO_COMPATIBLE &&
               result->conflict.status == CBM_DAEMON_HELLO_COMPATIBLE &&
               result->client_id != CBM_DAEMON_CLIENT_ID_INVALID &&
               result->authenticated_process_id != 0;
    }
    if (result->status == CBM_DAEMON_RUNTIME_CONNECT_CONFLICT) {
        char expected[CBM_DAEMON_RENDEZVOUS_MESSAGE_CAP];
        return result->hello_status >= CBM_DAEMON_HELLO_VERSION_CONFLICT &&
               result->hello_status <= CBM_DAEMON_HELLO_FEATURE_ABI_CONFLICT &&
               result->conflict.status == result->hello_status &&
               result->client_id == CBM_DAEMON_CLIENT_ID_INVALID &&
               result->authenticated_process_id == 0 &&
               cbm_daemon_conflict_format(&result->conflict, expected, sizeof(expected)) &&
               strcmp(result->message, expected) == 0;
    }
    return result->status == CBM_DAEMON_RUNTIME_CONNECT_REJECTED &&
           result->hello_status == CBM_DAEMON_HELLO_INVALID &&
           result->conflict.status == CBM_DAEMON_HELLO_INVALID &&
           result->client_id == CBM_DAEMON_CLIENT_ID_INVALID &&
           result->authenticated_process_id == 0;
}

static bool runtime_send_hello_response(cbm_daemon_ipc_connection_t *connection,
                                        const cbm_daemon_runtime_connect_result_t *result) {