cs_MeshTopology.h

Go to the documentation of this file.

/*
 * Author: Crownstone Team
 * Copyright: Crownstone (https://crownstone.rocks)
 * Date: Apr 30, 2021
 * License: LGPLv3+, Apache License 2.0, and/or MIT (triple-licensed)
 */
 
#pragma once
 
#include <events/cs_EventListener.h>
#include <protocol/cs_MeshTopologyPackets.h>
 
#include <cstdint>
 
#if BUILD_MESH_TOPOLOGY_RESEARCH == 1
#include <localisation/cs_MeshTopologyResearch.h>
#endif
 
class MeshTopology : EventListener {
public:
    static constexpr uint8_t MAX_NEIGHBOURS                            = 50;
 
    static constexpr uint8_t TIMEOUT_SECONDS                           = 3 * 60;
 
    static constexpr uint16_t SEND_INTERVAL_SECONDS_PER_NEIGHBOUR      = 5 * 60;
    static constexpr uint16_t SEND_INTERVAL_SECONDS_PER_NEIGHBOUR_FAST = 10;
 
    static constexpr uint16_t SEND_NOOP_INTERVAL_SECONDS               = 1 * 60;
    static constexpr uint16_t SEND_NOOP_INTERVAL_SECONDS_FAST          = 10;
 
    static constexpr uint16_t FAST_INTERVAL_TIMEOUT_SECONDS            = 5 * 60;
 
    cs_ret_code_t init();
 
    cs_ret_code_t getMacAddress(stone_id_t stoneId);
 
private:
    static constexpr uint8_t INDEX_NOT_FOUND = 0xFF;
 
    static constexpr int8_t RSSI_INIT        = 0;  // Should be in protocol
 
    struct __attribute__((__packed__)) neighbour_node_t {
        stone_id_t id;
        int8_t rssiChannel37;
        int8_t rssiChannel38;
        int8_t rssiChannel39;
        uint8_t lastSeenSecondsAgo;
    };
 
    stone_id_t _myId              = 0;
 
    neighbour_node_t* _neighbours = nullptr;
 
    uint8_t _neighbourCount       = 0;
 
    uint8_t _nextSendIndex        = 0;
 
    uint16_t _sendCountdown;
 
    uint16_t _sendNoopCountdown;
 
    uint16_t _fastIntervalCountdown;
 
    uint8_t _msgCount = 0;
 
    void reset();
 
    void add(stone_id_t id, int8_t rssi, uint8_t channel);
 
    void updateNeighbour(neighbour_node_t& node, stone_id_t id, int8_t rssi, uint8_t channel);
 
    uint8_t find(stone_id_t id);
 
    void getRssi(stone_id_t stoneId, cs_result_t& result);
 
    void sendNoop();
 
    void sendNext();
 
    void sendRssiToUart(stone_id_t reveiverId, cs_mesh_model_msg_neighbour_rssi_t& packet);
 
    // Event handlers
    void onNeighbourRssi(stone_id_t id, cs_mesh_model_msg_neighbour_rssi_t& packet);
    cs_ret_code_t onStoneMacMsg(MeshMsgEvent& meshMsg);
    void onMeshMsg(MeshMsgEvent& packet, cs_result_t& result);
    void onTickSecond();
 
    void print();
 
public:
    void handleEvent(event_t& evt);
 
#if BUILD_MESH_TOPOLOGY_RESEARCH == 1
private:
    MeshTopologyResearch _research;
#endif
};