#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(EventCallback cb);
		~WebSocketApi();

		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 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;
};