OscReceiver.h

#pragma once

#include <functional>
#include <memory>
#include <vector>
#include <oscpkt.hh>

class UdpServer;
namespace std {
        class thread;
};
class OscReceiver{
public:
        OscReceiver();
        OscReceiver(int port, std::function<void(oscpkt::Message* msg, const char* addr, void* arg)> on_receive, void* callbackArg = nullptr);
        ~OscReceiver();

        void setup(int port, std::function<void(oscpkt::Message* msg, const char* addr, void* arg)> on_receive, void* callbackArg = nullptr);

private:
        bool lShouldStop = false;

        volatile bool waitingForMessage = false;
        int waitForMessage(int timeout_ms);

        std::unique_ptr<UdpServer> socket;
        std::unique_ptr<std::thread> receive_task;

        void receive_task_func();

        std::unique_ptr<oscpkt::PacketReader> pr;
        std::vector<char> inBuffer;

        std::function<void(oscpkt::Message* msg, const char* addr, void* arg)> on_receive;
        void* onReceiveArg = nullptr;
};