SyncFPP.h

#pragma once

/***************************************************************
 * This source files comes from the xLights project
 * https://www.xlights.org
 * https://github.com/smeighan/xLights
 * See the github commit history for a record of contributing
 * developers.
 * Copyright claimed based on commit dates recorded in Github
 * License: https://github.com/smeighan/xLights/blob/master/License.txt
 **************************************************************/

#include "SyncManager.h"
#include "ScheduleOptions.h"
#include <wx/socket.h>

class ListenerManager;

class SyncFPP : public SyncBase
{
    virtual void SendFPPSync(const std::string& item, uint32_t stepMS, uint32_t frameMS) const = 0;

public:

    static void Ping(bool remote, const std::string& localIP);

    SyncFPP(SYNCMODE sm, REMOTEMODE rm, const ScheduleOptions& options) : SyncBase(sm, rm, options) {}
    virtual void SendSync(uint32_t frameMS, uint32_t stepLengthMS, uint32_t stepMS, uint32_t playlistMS, const std::string& fseq, const std::string& media, const std::string& step, const std::string& timeItem, uint32_t stepno) const override;
    virtual void SendStop() const override;
};

class SyncBroadcastFPP : public SyncFPP
{
    wxDatagramSocket* _fppBroadcastSocket = nullptr;
    wxIPV4address _remoteAddr;

    virtual void SendFPPSync(const std::string& item, uint32_t stepMS, uint32_t frameMS) const override;

    public:

        SyncBroadcastFPP(SYNCMODE sm, REMOTEMODE rm, const ScheduleOptions& options, ListenerManager* listenerManager, const std::string& localIP);
        SyncBroadcastFPP(SyncBroadcastFPP&& from) noexcept;
        virtual ~SyncBroadcastFPP();
        virtual std::string GetType() const override { return "FPPBROADCAST"; }
};

class SyncUnicastFPP : public SyncFPP
{
    wxDatagramSocket* _fppUnicastSocket = nullptr;
    std::list<std::string> _remotes;

    void SendUnicastSync(const std::string& ip, const std::string& item, size_t msec, size_t frameMS, int action) const;
    virtual void SendFPPSync(const std::string& item, uint32_t stepMS, uint32_t frameMS) const override;

    public:

        SyncUnicastFPP(SYNCMODE sm, REMOTEMODE rm, const ScheduleOptions& options, ListenerManager* listenerManager, const std::string& localIP);
        SyncUnicastFPP(SyncUnicastFPP&& from) noexcept;
        virtual ~SyncUnicastFPP();
        virtual std::string GetType() const override { return "FPPUNICAST"; }
};

class SyncUnicastCSVFPP : public SyncFPP
{
    wxDatagramSocket* _fppUnicastSocket = nullptr;
    std::list<std::string> _remotes;

    void SendUnicastSync(const std::string& ip, const std::string& item, size_t msec, size_t frameMS, int action) const;
    virtual void SendFPPSync(const std::string& item, uint32_t stepMS, uint32_t frameMS) const override;

public:

    SyncUnicastCSVFPP(SYNCMODE sm, REMOTEMODE rm, const ScheduleOptions& options, ListenerManager* listenerManager, const std::string& localIP);
    SyncUnicastCSVFPP(SyncUnicastCSVFPP&& from) noexcept;
    virtual ~SyncUnicastCSVFPP();
    virtual std::string GetType() const override { return "FPPCSV"; }
};

class SyncMulticastFPP : public SyncFPP
{
    wxDatagramSocket* _fppMulticastSocket = nullptr;
    wxIPV4address _remoteAddr;

    virtual void SendFPPSync(const std::string& item, uint32_t stepMS, uint32_t frameMS) const override;

public:

    SyncMulticastFPP(SYNCMODE sm, REMOTEMODE rm, const ScheduleOptions& options, ListenerManager* listenerManager, const std::string& localIP);
    SyncMulticastFPP(SyncMulticastFPP&& from) noexcept;
    virtual ~SyncMulticastFPP();
    virtual std::string GetType() const override { return "FPPMULTICAST"; }
};