cs_AssetStore.h

Go to the documentation of this file.

/*
 * Author: Crownstone Team
 * Copyright: Crownstone (https://crownstone.rocks)
 * Date: Aug 17, 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_AssetRecord.h>
#include <util/cs_Coroutine.h>
#include <util/cs_Store.h>
 
class AssetStore : public EventListener, public Component {
public:
    // ===================== public settings =====================
 
    static constexpr uint8_t LAST_RECEIVED_TIMEOUT_THRESHOLD_S = 250;
 
    static constexpr auto LAST_RECEIVED_COUNTER_PERIOD_MS      = 1000;
 
    static constexpr auto THROTTLE_COUNTER_PERIOD_MS           = 100;
 
    // ===================== public methods =====================
 
    AssetStore();
    cs_ret_code_t init() override;
 
    void handleEvent(event_t& evt) override;
 
    asset_record_t* handleAcceptedAsset(const scanned_device_t& asset, const asset_id_t& assetId);
 
    asset_record_t* getRecord(const asset_id_t& id);
 
    void addThrottlingBump(asset_record_t& record, uint16_t timeToNextThrottleOpenMs);
 
    uint16_t throttlingBumpMsToTicks(uint16_t timeToNextThrottleOpenMs);
 
private:
    // =================== private settings ===================
    static constexpr auto MAX_RECORDS = 50u;
 
    // =================== private variables ===================
 
    Store<asset_record_t, MAX_RECORDS> _store;
 
    Coroutine updateLastReceivedCounterRoutine;
    Coroutine updateLastSentCounterRoutine;
 
    // =================== private methods ===================
 
    asset_record_t* getOrCreateRecord(const asset_id_t& id);
 
    void incrementLastReceivedCounters();
 
    void decrementThrottlingCounters();
};