IOControl/include/IO/RS485/Controller.h

Go to the documentation of this file.

#pragma once

#include "../Controller.h"
#include "../Serial.h"
#include <SimpleTimer.h>

namespace IO
{
namespace RS485
{
DECLARE_FSTR(CONTROLLER_CLASSNAME)

class Controller : public IO::Controller
{
public:
    Controller(Serial& serial, uint8_t instance) : IO::Controller(instance), serial(serial)
    {
    }

    const FlashString& classname() const override
    {
        return CONTROLLER_CLASSNAME;
    }

    void start() override;
    void stop() override;

    using SetDirectionCallback = void (*)(uint8_t segment, Direction direction);

    void onSetDirection(SetDirectionCallback callback)
    {
        setDirectionCallback = callback;
    }

    void IRAM_ATTR setDirection(IO::Direction direction)
    {
        if(setDirectionCallback != nullptr) {
            setDirectionCallback(segment, direction);
        }
    }

    Serial& getSerial()
    {
        return serial;
    }

    void handleEvent(Request* request, Event event) override;

    using OnRequestDelegate = Delegate<void(Controller& controller)>;

    void onRequest(OnRequestDelegate callback)
    {
        requestCallback = callback;
    }

    void setSegment(uint8_t segment)
    {
        this->segment = segment;
    }

    void send(const void* data, size_t size);

protected:
    virtual void handleIncomingRequest()
    {
        if(requestCallback) {
            requestCallback(*this);
        }
    }

private:
    static void IRAM_ATTR uartCallbackStatic(smg_uart_t* uart, uint32_t status);
    void IRAM_ATTR uartCallback(uint32_t status);
    void receiveComplete();

private:
    Serial& serial;
    SetDirectionCallback setDirectionCallback{nullptr};
    Request* request{nullptr};                 
    Request* transmitCompleteRequest{nullptr}; 
    uint8_t segment{0};                        
    OnRequestDelegate requestCallback;
    SimpleTimer timer; 
    Serial::Config savedConfig{};
};

} // namespace RS485
} // namespace IO