src/claim/cloud-status.c

Rama master · réplica de lectura del repositorio original.

// SPDX-License-Identifier: GPL-3.0-or-later

#include "claim.h"

ENUM_STR_MAP_DEFINE(CLOUD_STATUS) = {
    { CLOUD_STATUS_ONLINE, "online"},
    { CLOUD_STATUS_INDIRECT, "indirect"},
    { CLOUD_STATUS_AVAILABLE, "available"},
    { CLOUD_STATUS_BANNED, "banned"},
    { CLOUD_STATUS_OFFLINE, "offline"},

    // terminator
    { 0, NULL },
};
ENUM_STR_DEFINE_FUNCTIONS(CLOUD_STATUS, CLOUD_STATUS_AVAILABLE, "available");

CLOUD_STATUS cloud_status(void) {
    if(unlikely(__atomic_load_n(&aclk_disable_runtime, __ATOMIC_RELAXED)))
        return CLOUD_STATUS_BANNED;

    if(likely(aclk_online()))
        return CLOUD_STATUS_ONLINE;

    if(localhost &&
        localhost->sender &&
        rrdhost_flag_check(localhost, RRDHOST_FLAG_STREAM_SENDER_READY_4_METRICS) &&
        stream_sender_has_capabilities(localhost, STREAM_CAP_NODE_ID) &&
        !UUIDiszero(localhost->node_id) &&
        !UUIDiszero(rrdhost_claim_id_of_parent_get(localhost)))
        return CLOUD_STATUS_INDIRECT;

    if(is_agent_claimed())
        return CLOUD_STATUS_OFFLINE;

    return CLOUD_STATUS_AVAILABLE;
}

time_t cloud_last_change(void) {
    time_t last_conn = __atomic_load_n(&last_conn_time_mqtt, __ATOMIC_RELAXED);
    time_t last_disconnect = __atomic_load_n(&last_disconnect_time, __ATOMIC_RELAXED);
    time_t ret = MAX(last_conn, last_disconnect);
    if(!ret) ret = netdata_start_time;
    return ret;
}

time_t cloud_next_connection_attempt(void) {
    return __atomic_load_n(&next_connection_attempt, __ATOMIC_RELAXED);
}

size_t cloud_connection_id(void) {
    return (size_t)__atomic_load_n(&aclk_connection_counter, __ATOMIC_RELAXED);
}

const char *cloud_status_aclk_offline_reason() {
    if(__atomic_load_n(&aclk_disable_runtime, __ATOMIC_RELAXED))
        return "banned";

    return aclk_status_to_string();
}

const char *cloud_status_aclk_base_url() {
    return aclk_cloud_base_url;
}

CLOUD_STATUS buffer_json_cloud_status(BUFFER *wb, time_t now_s) {
    CLOUD_STATUS status = cloud_status();

    buffer_json_member_add_object(wb, "cloud");
    {
        size_t id = cloud_connection_id();
        time_t last_change = cloud_last_change();
        time_t next_connect = cloud_next_connection_attempt();
        buffer_json_member_add_uint64(wb, "id", id);
        buffer_json_member_add_string(wb, "status", CLOUD_STATUS_2str(status));
        buffer_json_member_add_time_t(wb, "since", last_change);
        buffer_json_member_add_time_t(wb, "age", now_s - last_change);

        switch(status) {
            default:
            case CLOUD_STATUS_AVAILABLE:
                // the agent is not claimed
                buffer_json_member_add_string(wb, "url", cloud_config_url_get());
                buffer_json_member_add_string(wb, "reason", claim_agent_failure_reason_get());
                break;

            case CLOUD_STATUS_BANNED: {
                // the agent is claimed, but has been banned from NC
                CLAIM_ID claim_id = claim_id_get();
                buffer_json_member_add_string(wb, "claim_id", claim_id.str);
                buffer_json_member_add_string(wb, "url", cloud_status_aclk_base_url());
                buffer_json_member_add_string(wb, "reason", "Agent is banned from Netdata Cloud");
                buffer_json_member_add_string(wb, "url", cloud_config_url_get());
                break;
            }

            case CLOUD_STATUS_OFFLINE: {
                // the agent is claimed, but cannot get online
                CLAIM_ID claim_id = rrdhost_claim_id_get(localhost);
                buffer_json_member_add_string(wb, "claim_id", claim_id.str);
                buffer_json_member_add_string(wb, "url", cloud_status_aclk_base_url());
                buffer_json_member_add_string(wb, "reason", cloud_status_aclk_offline_reason());
                if (next_connect > now_s) {
                    buffer_json_member_add_time_t(wb, "next_check", next_connect);
                    buffer_json_member_add_time_t(wb, "next_in", next_connect - now_s);
                }
                break;
            }

            case CLOUD_STATUS_ONLINE: {
                // the agent is claimed and online
                CLAIM_ID claim_id = claim_id_get();
                buffer_json_member_add_string(wb, "claim_id", claim_id.str);
                buffer_json_member_add_string(wb, "url", cloud_status_aclk_base_url());
                buffer_json_member_add_string(wb, "reason", "");
                break;
            }

            case CLOUD_STATUS_INDIRECT: {
                CLAIM_ID claim_id = rrdhost_claim_id_get(localhost);
                buffer_json_member_add_string(wb, "claim_id", claim_id.str);
                buffer_json_member_add_string(wb, "url", cloud_config_url_get());
                buffer_json_member_add_string(wb, "reason", cloud_status_aclk_offline_reason());
                break;
            }
        }
    }
    buffer_json_object_close(wb); // cloud

    return status;
}