cs_AssetForwarder.h

Go to the documentation of this file.

/*
 * Author: Crownstone Team
 * Copyright: Crownstone (https://crownstone.rocks)
 * Date: May 12, 2021
 * License: LGPLv3+, Apache License 2.0, and/or MIT (triple-licensed)
 */
 
#pragma once
 
#include <common/cs_Component.h>
#include <events/cs_EventListener.h>
#include <localisation/cs_AssetHandler.h>
#include <localisation/cs_AssetRecord.h>
#include <protocol/mesh/cs_MeshModelPackets.h>
 
class AssetForwarder : public EventListener, public Component {
public:
    static constexpr uint16_t MIN_THROTTLED_ADVERTISEMENT_PERIOD_MS = 1000;
 
    cs_ret_code_t init();
 
    void flush();
 
    void clearOutbox();
 
    bool sendAssetMacToMesh(asset_record_t* record, const scanned_device_t& asset);
 
    bool sendAssetIdToMesh(
            asset_record_t* record, const scanned_device_t& asset, const asset_id_t& assetId, uint8_t filterBitmask);
 
    void setThrottleCountdownBumpTicks(uint8_t ticks);
 
private:
    stone_id_t _myStoneId;
 
    uint8_t _throttleCountdownBumpTicks = 0;
 
    struct outbox_msg_t {
        asset_record_t* record;
        cs_mesh_model_msg_type_t msgType;
        union {
            cs_mesh_model_msg_asset_report_id_t idMsg;
            cs_mesh_model_msg_asset_report_mac_t macMsg;
            uint8_t rawMsg[MAX_MESH_MSG_PAYLOAD_SIZE];
        };
 
        // util funcs
        outbox_msg_t();
 
        bool isValid();
 
        bool isSimilar(const outbox_msg_t& other);
    };
 
    outbox_msg_t _outbox[8] = {};
 
    bool dispatchOutboxMessage(outbox_msg_t& outMsg);
 
    outbox_msg_t* getEmptyOutboxSlot();
 
    outbox_msg_t* findSimilar(outbox_msg_t& outMsg);
 
    bool addToOutbox(outbox_msg_t& outMsg);
 
    void forwardAssetToUart(const cs_mesh_model_msg_asset_report_mac_t& assetMsg, stone_id_t seenByStoneId);
    void forwardAssetToUart(const cs_mesh_model_msg_asset_report_id_t& assetMsg, stone_id_t seenByStoneId);
 
public:
    virtual void handleEvent(event_t& event);
};