firmware/src/NodeStatus.h

#pragma once
#include "Status.h"
#include "configuration.h"
#include <Arduino.h>

namespace meshtastic
{

/// Describes the state of the NodeDB system.
class NodeStatus : public Status
{

  private:
    CallbackObserver<NodeStatus, const NodeStatus *> statusObserver =
        CallbackObserver<NodeStatus, const NodeStatus *>(this, &NodeStatus::updateStatus);

    uint8_t numOnline = 0;
    uint8_t numTotal = 0;

    uint8_t lastNumTotal = 0;

  public:
    bool forceUpdate = false;

    NodeStatus() { statusType = STATUS_TYPE_NODE; }
    NodeStatus(uint8_t numOnline, uint8_t numTotal, bool forceUpdate = false) : Status()
    {
        this->forceUpdate = forceUpdate;
        this->numOnline = numOnline;
        this->numTotal = numTotal;
    }
    NodeStatus(const NodeStatus &);
    NodeStatus &operator=(const NodeStatus &);

    void observe(Observable<const NodeStatus *> *source) { statusObserver.observe(source); }

    uint8_t getNumOnline() const { return numOnline; }

    uint8_t getNumTotal() const { return numTotal; }

    uint8_t getLastNumTotal() const { return lastNumTotal; }

    bool matches(const NodeStatus *newStatus) const
    {
        return (newStatus->getNumOnline() != numOnline || newStatus->getNumTotal() != numTotal);
    }
    int updateStatus(const NodeStatus *newStatus)
    {
        // Only update the status if values have actually changed
        lastNumTotal = numTotal;
        bool isDirty;
        {
            isDirty = matches(newStatus);
            initialized = true;
            numOnline = newStatus->getNumOnline();
            numTotal = newStatus->getNumTotal();
        }
        if (isDirty || newStatus->forceUpdate) {
            LOG_DEBUG("Node status update: %d online, %d total\n", numOnline, numTotal);
            onNewStatus.notifyObservers(this);
        }
        return 0;
    }
};

} // namespace meshtastic

extern meshtastic::NodeStatus *nodeStatus;