cs_AssetFilterSyncer.h

Go to the documentation of this file.

/*
 * Author: Crownstone Team
 * Copyright: Crownstone (https://crownstone.rocks)
 * Date: May 10, 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_AssetFilterStore.h>
#include <protocol/cs_Typedefs.h>
 
class AssetFilterSyncer : public EventListener, public Component {
public:
    constexpr static uint16_t VERSION_BROADCAST_NORMAL_INTERVAL_SECONDS = 5 * 60;
    constexpr static uint16_t VERSION_BROADCAST_LOW_INTERVAL_SECONDS    = 1;
 
    constexpr static uint16_t VERSION_BROADCAST_INTERVAL_RESET_SECONDS  = 60;
 
    cs_ret_code_t init();
 
private:
    enum class SyncStep { NONE, CONNECT, GET_FILTER_SUMMARIES, REMOVE_FILTERS, UPLOAD_FILTERS, COMMIT, DISCONNECT };
 
    enum class VersionCompare { UNKOWN, OLDER, EQUAL, NEWER };
 
    AssetFilterStore* _store = nullptr;
 
    SyncStep _step           = SyncStep::NONE;
 
    uint8_t _nextFilterIndex;
 
    uint16_t _nextChunkIndex;
 
    uint8_t _filterIdsToUpload[AssetFilterStore::MAX_FILTER_IDS];
    uint8_t _filterUploadCount;
 
    uint8_t _filterIdsToRemove[AssetFilterStore::MAX_FILTER_IDS];
    uint8_t _filterRemoveCount;
 
    uint16_t _sendVersionAtLowIntervalCountdown = 0;
 
    uint16_t _sendVersionCountdown              = 0;
 
    void sendVersion(bool reliable);
 
    void sendVersionAtLowInterval();
 
    void setStep(SyncStep step);
 
    void reset();
 
    VersionCompare compareToMyVersion(asset_filter_cmd_protocol_t protocol, uint16_t masterVersion, uint32_t masterCrc);
 
    void syncFilters(stone_id_t stoneId);
 
    void connect(stone_id_t stoneId);
    void removeNextFilter();
    void uploadNextFilter();
    void commit();
    void disconnect();
 
    void done();
 
    cs_ret_code_t onVersion(stone_id_t stoneId, cs_mesh_model_msg_asset_filter_version_t& packet);
 
    void onModificationInProgress(bool inProgress);
 
    void onConnectResult(cs_ret_code_t retCode);
    void onDisconnect();
    void onWriteResult(cs_central_write_result_t& result);
    void onFilterSummaries(cs_data_t& payload);
 
    void onTick(uint32_t tickCount);
 
public:
    void handleEvent(event_t& evt);
};