#include #include #include #include #include #include #include "obs-websocket.h" #include "Config.h" #include "WebSocketServer.h" #include "eventhandler/EventHandler.h" #include "forms/SettingsDialog.h" OBS_DECLARE_MODULE() OBS_MODULE_USE_DEFAULT_LOCALE("obs-websocket", "en-US") ConfigPtr _config; WebSocketServerPtr _webSocketServer; EventHandlerPtr _eventHandler; SettingsDialog *_settingsDialog = nullptr; os_cpu_usage_info_t* _cpuUsageInfo; void ___source_dummy_addref(obs_source_t*) {} void ___sceneitem_dummy_addref(obs_sceneitem_t*) {}; void ___data_dummy_addref(obs_data_t*) {}; void ___data_array_dummy_addref(obs_data_array_t*) {}; void ___output_dummy_addref(obs_output_t*) {}; void ___data_item_dummy_addref(obs_data_item_t*) {}; void ___data_item_release(obs_data_item_t* dataItem){ obs_data_item_release(&dataItem); }; void ___properties_dummy_addref(obs_properties_t*) {}; bool obs_module_load(void) { blog(LOG_INFO, "[obs_module_load] you can haz websockets (Version: %s | RPC Version: %d)", OBS_WEBSOCKET_VERSION, OBS_WEBSOCKET_RPC_VERSION); blog(LOG_INFO, "[obs_module_load] Qt version (compile-time): %s | Qt version (run-time): %s", QT_VERSION_STR, qVersion()); // Create the config object then load the parameters from storage _config = ConfigPtr(new Config()); _config->Load(); // Initialize event handler before server, as the server configures the event handler. _eventHandler = EventHandlerPtr(new EventHandler()); _webSocketServer = WebSocketServerPtr(new WebSocketServer()); obs_frontend_push_ui_translation(obs_module_get_string); QMainWindow* mainWindow = reinterpret_cast(obs_frontend_get_main_window()); _settingsDialog = new SettingsDialog(mainWindow); obs_frontend_pop_ui_translation(); const char* menuActionText = obs_module_text("OBSWebSocket.Settings.DialogTitle"); QAction* menuAction = (QAction*)obs_frontend_add_tools_menu_qaction(menuActionText); QObject::connect(menuAction, &QAction::triggered, [] { _settingsDialog->ToggleShowHide(); }); _cpuUsageInfo = os_cpu_usage_info_start(); if (_config->ServerEnabled) _webSocketServer->Start(); // Loading finished blog(LOG_INFO, "[obs_module_load] Module loaded."); return true; } void obs_module_unload() { blog(LOG_INFO, "[obs_module_unload] Shutting down..."); if (_webSocketServer->IsListening()) { blog(LOG_INFO, "[obs_module_unload] WebSocket server is running. Stopping..."); _webSocketServer->Stop(); } _webSocketServer.reset(); _eventHandler.reset(); _config->Save(); _config.reset(); os_cpu_usage_info_destroy(_cpuUsageInfo); blog(LOG_INFO, "[obs_module_unload] Finished shutting down."); } ConfigPtr GetConfig() { return _config; } WebSocketServerPtr GetWebSocketServer() { return _webSocketServer; } EventHandlerPtr GetEventHandler() { return _eventHandler; } os_cpu_usage_info_t* GetCpuUsageInfo() { return _cpuUsageInfo; }