espnow_hal.h

Go to the documentation of this file.

 
#ifndef _ESPNOW_HAL_h
#define _ESPNOW_HAL_h
 
#if defined(ARDUINO) && ARDUINO >= 100
#include "Arduino.h"
#else
#include "WProgram.h"
#endif
 
#if defined(ESP8266)
#include <ESP8266WiFi.h>
#elif defined(ESP32)
#include <WiFi.h>
#include <esp_now.h>
#endif
#include "Comms_hal.h"
#include "helperFunctions.h"
#include "EnigmaIOTRingBuffer.h"
 
class Espnow_halClass : public Comms_halClass {
public:
    static const size_t COMMS_HAL_MAX_MESSAGE_LENGTH = 250; 
    static const uint8_t COMMS_HAL_ADDR_LEN = 6; 
 
protected:
 
    EnigmaIOTRingBuffer<comms_queue_item_t> out_queue;
    bool readyToSend = true;
#ifdef ESP32
    TaskHandle_t espnowLoopTask;
#else // ESP8266
    ETSTimer espnowLoopTask;
#endif
 
    void initComms (peerType_t peerType) override;
 
    bool addPeer (const uint8_t* da);
 
    static void ICACHE_FLASH_ATTR rx_cb (uint8_t* mac_addr, uint8_t* data, uint8_t len);
 
    static void ICACHE_FLASH_ATTR tx_cb (uint8_t* mac_addr, uint8_t status);
 
    int32_t sendEspNowMessage (comms_queue_item_t* message);
    comms_queue_item_t* getCommsQueue ();
    void popCommsQueue ();
 
public:
    Espnow_halClass () :
        out_queue (COMMS_QUEUE_SIZE) {}
 
    
    void begin (uint8_t* gateway, uint8_t channel = 0, peerType_t peerType = COMM_NODE) override;
 
    void stop () override;
 
    int32_t send (uint8_t* da, uint8_t* data, int len) override;
 
    void onDataRcvd (comms_hal_rcvd_data dataRcvd) override;
 
    void onDataSent (comms_hal_sent_data dataRcvd) override;
 
    uint8_t getAddressLength () override {
        return COMMS_HAL_ADDR_LEN;
    }
 
    size_t getMaxMessageLength () {
        return COMMS_HAL_MAX_MESSAGE_LENGTH;
    }
 
    void enableTransmit (bool enable) override {
        DEBUG_DBG ("Send esp-now task %s", enable ? "enabled" : "disabled");
        if (enable) {
#ifdef ESP8266
            os_timer_arm (&espnowLoopTask, 20, true);
            //timer1_enable (TIM_DIV16, TIM_EDGE, TIM_LOOP);
#else
            if (espnowLoopTask) {
                vTaskResume (espnowLoopTask);
            }
#endif
        } else {
#ifdef ESP8266
            os_timer_disarm (&espnowLoopTask);
            //timer1_disable ();
#else
            if (espnowLoopTask) {
                vTaskSuspend (espnowLoopTask);
            }
#endif
        }
    } 
 
    void handle () override;
 
    static void runHandle (void* param);
 
};
 
extern Espnow_halClass Espnow_hal; 
 
#endif