obs-websocket/src/WebSocketApi.h

#pragma once

#include <functional>
#include <string>
#include <map>
#include <mutex>
#include <shared_mutex>
#include <obs.h>

#include "../lib/obs-websocket-api.h"

class WebSocketApi {
public:
	enum RequestReturnCode {
		Normal,
		NoVendor,
		NoVendorRequest,
	};

	typedef std::function<void(std::string, std::string, obs_data_t *)> EventCallback;

	struct Vendor {
		std::shared_mutex _mutex;
		std::string _name;
		std::map<std::string, obs_websocket_request_callback> _requests;
	};

	WebSocketApi();
	~WebSocketApi();

	void SetEventCallback(EventCallback cb);

	enum RequestReturnCode PerformVendorRequest(std::string vendorName, std::string requestName, obs_data_t *requestData,
						    obs_data_t *responseData);

	static void get_ph_cb(void *priv_data, calldata_t *cd);
	static void get_api_version(void *, calldata_t *cd);
	static void call_request(void *, calldata_t *cd);
	static void vendor_register_cb(void *priv_data, calldata_t *cd);
	static void vendor_request_register_cb(void *priv_data, calldata_t *cd);
	static void vendor_request_unregister_cb(void *priv_data, calldata_t *cd);
	static void vendor_event_emit_cb(void *priv_data, calldata_t *cd);

private:
	std::shared_mutex _mutex;
	EventCallback _eventCallback;
	proc_handler_t *_procHandler;
	std::map<std::string, Vendor *> _vendors;
};