Mirrored_Repos/obs-websocket
1
0
Fork 0
mirror of https://github.com/Palakis/obs-websocket.git synced 2024-08-30 18:12:16 +00:00
Code Issues Packages Projects Releases Wiki Activity

EventHandler: More stuff

Browse Source
This commit is contained in:
tt2468 2021-05-10 22:46:53 -07:00
parent 8b30d2e77e
commit 921bc81a7b
2 changed files with 55 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

52
src/eventhandler/EventHandler.cpp
View File

@ -1,18 +1,52 @@
#include "EventHandler.h" #include "EventHandler.h"
#include "../plugin-macros.generated.h"
EventHandler::EventHandler(WebSocketServerPtr webSocketServer) : EventHandler::EventHandler(WebSocketServerPtr webSocketServer) :
_webSocketServer(webSocketServer) _webSocketServer(webSocketServer)
{ {
blog(LOG_INFO, "[EventHandler::EventHandler] Setting up event handlers...");
_cpuUsageInfo = os_cpu_usage_info_start(); _cpuUsageInfo = os_cpu_usage_info_start();
obs_frontend_add_event_callback(EventHandler::OnFrontendEvent, this); obs_frontend_add_event_callback(EventHandler::OnFrontendEvent, this);
signal_handler_t* coreSignalHandler = obs_get_signal_handler();
if (coreSignalHandler) {
//signal_handler_connect(coreSignalHandler, "source_create", OnSourceCreate, this);
//signal_handler_connect(coreSignalHandler, "source_destroy", OnSourceDestroy, this);
}
obs_enum_sources([](void* param, obs_source_t* source) {
auto eventHandler = reinterpret_cast<EventHandler*>(param);
eventHandler->ConnectSourceSignals(source);
return true;
}, this);
blog(LOG_INFO, "[EventHandler::EventHandler] Finished.");
} }
EventHandler::~EventHandler() EventHandler::~EventHandler()
{ {
blog(LOG_INFO, "[EventHandler::~EventHandler] Removing event handlers...");
os_cpu_usage_info_destroy(_cpuUsageInfo); os_cpu_usage_info_destroy(_cpuUsageInfo);
obs_frontend_remove_event_callback(EventHandler::OnFrontendEvent, this); obs_frontend_remove_event_callback(EventHandler::OnFrontendEvent, this);
signal_handler_t* coreSignalHandler = obs_get_signal_handler();
if (coreSignalHandler) {
//signal_handler_disconnect(coreSignalHandler, "source_destroy", OnSourceDestroy, this);
//signal_handler_disconnect(coreSignalHandler, "source_create", OnSourceCreate, this);
}
obs_enum_sources([](void* param, obs_source_t* source) {
auto eventHandler = reinterpret_cast<EventHandler*>(param);
eventHandler->DisconnectSourceSignals(source);
return true;
}, this);
blog(LOG_INFO, "[EventHandler::~EventHandler] Finished.");
} }
std::string EventHandler::GetCalldataString(const calldata_t *data, const char* name) std::string EventHandler::GetCalldataString(const calldata_t *data, const char* name)
@ -22,6 +56,24 @@ std::string EventHandler::GetCalldataString(const calldata_t *data, const char*
return value; return value;
} }
void EventHandler::ConnectSourceSignals(obs_source_t *source)
{
if (!source || obs_source_removed(source))
return;
DisconnectSourceSignals(source);
signal_handler_t* sh = obs_source_get_signal_handler(source);
}
void EventHandler::DisconnectSourceSignals(obs_source_t *source)
{
if (!source)
return;
signal_handler_t* sh = obs_source_get_signal_handler(source);
}
void EventHandler::OnFrontendEvent(enum obs_frontend_event event, void *private_data) { void EventHandler::OnFrontendEvent(enum obs_frontend_event event, void *private_data) {
auto eventHandler = reinterpret_cast<EventHandler*>(private_data); auto eventHandler = reinterpret_cast<EventHandler*>(private_data);

3
src/eventhandler/EventHandler.h
View File

@ -25,5 +25,8 @@ class EventHandler
WebSocketServerPtr _webSocketServer; WebSocketServerPtr _webSocketServer;
os_cpu_usage_info_t *_cpuUsageInfo; os_cpu_usage_info_t *_cpuUsageInfo;
void ConnectSourceSignals(obs_source_t *source);
void DisconnectSourceSignals(obs_source_t *source);
static void OnFrontendEvent(enum obs_frontend_event event, void *private_data); static void OnFrontendEvent(enum obs_frontend_event event, void *private_data);
}; };