OscPatch.h

Go to the documentation of this file.

#pragma once

#include "LumiverseCoreConfig.h"

#ifdef USE_OSC

#include "Patch.h"
#include "lib/oscpack/osc/OscOutboundPacketStream.h"
#include "lib/oscpack/osc/OscPacketListener.h"
#include "lib/oscpack/osc/OscReceivedElements.h"
#include "lib/oscpack/ip/UdpSocket.h"

namespace Lumiverse {

enum OscFormat {
  PREFIXED_ADDR = 0,
  PER_DEVICE_ADDR = 1,
  ETC_EOS = 2
};

class OscPatch : public Patch, public osc::OscPacketListener {

public:
  OscPatch(string address, int port, OscFormat mode = PREFIXED_ADDR, string pattern = "lumiverse");
  OscPatch(JSONNode data);
  ~OscPatch();

  virtual void init() override;

  virtual void update(set<Device *> devices) override;

  virtual void close() override;

  virtual JSONNode toJSON() override;

  virtual void deleteDevice(string id) override;

  virtual string getType() { return "osc"; }

  void changeAddress(string address, int port);
  void changeInPort(int port);
  string getAddress();
  int getPort();
  int getInPort();
  bool isRunning();

  bool sync(const set<Device *> devices);

  set<int> getEosSelection();

  OscFormat _mode;

  string _pattern;

protected:
  virtual void ProcessMessage(const osc::ReceivedMessage& m, const IpEndpointName& remote);

private:
  string _address;
  int _port;
  int _inPort;
  bool _running;

  UdpTransmitSocket* _t;

  void deviceToOsc(osc::OutboundPacketStream& p, Device* d);

  void deviceToEos(Device* d);

  void newEosCmd();

  void loadJSON(JSONNode data);

  void processSelection(string chans);

  Device* _syncDevice;
  bool _syncReady;
  set<string> _syncParams;
  set<int> _syncChan;
};

}

#endif