Utils: style nitpick

docs: Add @since

.github/ISSUE_TEMPLATE.md

@@ -1,18 +1,16 @@
-#### Issue type
-- [ ] Bug
-- [ ] Feature request
-- [ ] Other
+##### Issue type
+Bug report? Feature request? Other?
 
-#### Description
+##### Description
 *Replace this with a description of the bug encountered or feature requested.*
 
-#### Steps to reproduce
-*If it's a bug, please describe the steps to reproduce it. Otherwise, remove this section.*
+##### Steps to reproduce and other useful info
+*If it's a bug, please describe the steps to reproduce it and PLEASE include an OBS log file. Otherwise, remove this section.*
 
-#### Technical information
+##### Technical information
 - **Operating System** :
 - **OBS Studio version** :
 
-#### Development Environment
+##### Development Environment
 *If you're trying to compile obs-websocket, please describe your compiler type and version (e.g: GCC 4.7, VC2013, ...), and the CMake settings used.  
 Remove this section if it doesn't apply to your case.*

.gitignore

@@ -5,3 +5,5 @@
 /build64/
 /release/
 /installer/Output/
+
+.vscode

.travis.yml

@@ -1,4 +1,5 @@
 language: cpp
+
 env:
   global:
   # AWS key ID
@@ -6,9 +7,18 @@ env:
   # AWS key secret
   - secure: bGwljoP3E1OVBXLXox0O6p8kwQXLcNQ8YDKVa4H8u9Y+Ic7uqE4iV3rYS3ynNWSBMVRWY3ZbyClnhrCNwRhBAlcd8qWSJdpjVzs6HdQyzhuKa1P3V4FJPb7upGP/5R/DECGwex8Mun9dmXpYDak75LxfKIJUidPis5VDCYqul7k/xVVCou6Ctjpj7vQhWXDj2G/py+mdB8DERhymnQCtyK1Ziu8c4QlFKByZmnD72GFm/h3JPI1Pq1V2mz3x6x6GaYjb9Rdbd0UNwqjGQX4q2M/c3GEJa6B2JBCoTncawNZBNnPUF9qtv+zh0TNaNHMRWX13AJ/qYB+nVDub0C9b/6Mc48mt0Tv4ze15MproVrylZdV6qHYEG8yGPBqpTVbRP6gv6Y2TXIHWoTzqA+F/Gv2IDChyHXsld/MQQS2MSo5iaYktIrZKtX8Z0qAmTzPwIVBromaSI3vrE7UH0fRSQ6fAM8+Tn+MRthOBdqu23kS1dnG+X2CPbUhBfsJp0OSwVQD5jQtA51/sREVeGFiJvzQIkvwQDjb5MYilsRnwmoBXemkLmqaviXVY4rz1o5AIvz2pgZS2YggK1xHZCuI5tSjcNEkb77VwZTfsqrdDo9EJh6VgfdnGlHQhR2/A5hUJ4ANpJ/LgZlgfVp71Xg2GWQW6M4Znc5uj6A6xLBkO6FA=
 
+cache:
+  directories:
+  - node_modules
+
 matrix:
   include:
   - os: linux
+    env: _generate_docs
+    script: "./CI/generate-docs.sh"
+
+  - os: linux
+    env: _linux_build
     dist: trusty
     sudo: required
     services:
@@ -23,10 +33,12 @@ matrix:
     - docker exec -it xenial /root/obs-websocket/CI/package-xenial.sh
 
   - os: osx
+    env: _macos_build
     osx_image: xcode8.3
     before_install: "./CI/install-dependencies-osx.sh"
     script: "./CI/build-osx.sh"
-    after_success: "./CI/package-osx.sh"
+    after_success: 
+    - ./CI/package-osx.sh
 
 deploy:
 - provider: s3
@@ -39,7 +51,9 @@ deploy:
   acl: public_read
   on:
     repo: Palakis/obs-websocket
-    condition: "$TRAVIS_OS_NAME = linux"
+    condition: 
+    - "$TRAVIS_OS_NAME = linux"
+    - "-d /home/travis/package"
     all_branches: true
 - provider: s3
   region: eu-central-1

CI/build-osx.sh

@@ -1,10 +1,11 @@
 #!/bin/sh
 set -ex
 
-mkdir build && cd build
+#export QT_PREFIX="$(find /usr/local/Cellar/qt5 -d 1 | tail -n 1)"
 
+mkdir build && cd build
 cmake .. \
-  -DQTDIR=/usr/local/opt/qt5 \
+  -DQTDIR=/usr/local/opt/qt \
   -DLIBOBS_INCLUDE_DIR=../../obs-studio/libobs \
   -DOBS_FRONTEND_LIB="$(pwd)/../../obs-studio/build/UI/obs-frontend-api/libobs-frontend-api.dylib" \
   -DCMAKE_INSTALL_PREFIX=/usr \

CI/generate-docs.sh

@@ -0,0 +1,32 @@
+#!/bin/bash
+echo "-- Generating documentation."
+echo "-- Node version: $(node -v)"
+echo "-- NPM version: $(npm -v)"
+
+cd docs
+npm install
+npm run build
+
+echo "-- Documentation successfully generated."
+
+if git diff --quiet; then
+    echo "-- No documentation changes to commit."
+    exit 0
+fi
+
+if [ "$TRAVIS_PULL_REQUEST" != "false" -o "$TRAVIS_BRANCH" != "master" ]; then
+    echo "-- Skipping documentation deployment because this is either a pull request or a non-master branch."
+    exit 0
+fi
+
+REMOTE_URL="$(git config remote.origin.url)"
+TARGET_REPO=${REMOTE_URL/https:\/\/github.com\//github.com/}
+GITHUB_REPO=https://${GH_TOKEN:-git}@${TARGET_REPO}
+
+git config user.name "Travis CI"
+git config user.email "$COMMIT_AUTHOR_EMAIL"
+
+git add ./generated
+git pull
+git commit -m "docs(travis): Update protocol.md - $(git rev-parse --short HEAD) [skip ci]"
+git push -q $GITHUB_REPO HEAD:$TRAVIS_BRANCH

CI/install-dependencies-osx.sh

@@ -7,16 +7,17 @@ brew install ffmpeg
 brew install libav
 
 # qtwebsockets deps
-brew install https://raw.githubusercontent.com/Homebrew/homebrew-core/fdb7c6e960e830b3bf630850c0002c5df9f68ed8/Formula/qt5.rb
+brew install qt5
+#echo "Qt path: $(find /usr/local/Cellar/qt5 -d 1 | tail -n 1)"
 
 # Build obs-studio
 cd ..
 git clone --recursive https://github.com/jp9000/obs-studio
 cd obs-studio
-git checkout 19.0.2
+git checkout 19.0.3
 mkdir build && cd build
 cmake .. \
-  -DCMAKE_PREFIX_PATH=/usr/local/opt/qt5/lib/cmake \
+  -DCMAKE_PREFIX_PATH=/usr/local/opt/qt/lib/cmake \
 && make -j4
 
 sudo make install

CI/install-dependencies-xenial.sh

@@ -48,7 +48,7 @@ apt-get install -y libqt5websockets5-dev
 cd /root
 git clone https://github.com/jp9000/obs-studio ./obs-studio
 cd obs-studio
-git checkout 19.0.2
+git checkout 19.0.3
 mkdir build && cd build
 cmake -DUNIX_STRUCTURE=1 -DCMAKE_INSTALL_PREFIX=/usr ..
 make -j4

CI/package-osx.sh

@@ -3,10 +3,10 @@
 set -e
 
 echo "-- Preparing package build"
-export QT_PREFIX="/usr/local/opt/qt5"
+export QT_CELLAR_PREFIX="$(find /usr/local/Cellar/qt -d 1 | tail -n 1)"
 
-export WS_LIB="$QT_PREFIX/lib/QtWebSockets.framework/QtWebSockets"
-export NET_LIB="$QT_PREFIX/lib/QtNetwork.framework/QtNetwork"
+export WS_LIB="/usr/local/opt/qt/lib/QtWebSockets.framework/QtWebSockets"
+export NET_LIB="/usr/local/opt/qt/lib/QtNetwork.framework/QtNetwork"
 
 export GIT_HASH=$(git rev-parse --short HEAD)
 
@@ -27,28 +27,35 @@ cp $NET_LIB ./build
 chmod +rw ./build/QtWebSockets ./build/QtNetwork
 
 echo "-- Modifying QtNetwork"
-# TODO : put a loop in there
 install_name_tool \
 	-change /usr/local/opt/qt/lib/QtNetwork.framework/Versions/5/QtNetwork @rpath/QtNetwork \
-	-change /usr/local/opt/qt/lib/QtCore.framework/Versions/5/QtCore @rpath/QtCore \
+	-change $QT_CELLAR_PREFIX/lib/QtCore.framework/Versions/5/QtCore @rpath/QtCore \
 	./build/QtNetwork
 
 echo "-- Modifying QtWebSockets"
 install_name_tool \
 	-change /usr/local/opt/qt/lib/QtWebSockets.framework/Versions/5/QtWebSockets @rpath/QtWebSockets \
-	-change /usr/local/opt/qt/lib/QtNetwork.framework/Versions/5/QtNetwork @rpath/QtNetwork \
-	-change /usr/local/opt/qt/lib/QtCore.framework/Versions/5/QtCore @rpath/QtCore \
+	-change $QT_CELLAR_PREFIX/lib/QtNetwork.framework/Versions/5/QtNetwork @rpath/QtNetwork \
+	-change $QT_CELLAR_PREFIX/lib/QtCore.framework/Versions/5/QtCore @rpath/QtCore \
 	./build/QtWebSockets
 
 echo "-- Modifying obs-websocket.so"
 install_name_tool \
-	-change "$QT_PREFIX/lib/QtWebSockets.framework/Versions/5/QtWebSockets" @rpath/QtWebSockets \
-	-change "$QT_PREFIX/lib/QtWidgets.framework/Versions/5/QtWidgets" @rpath/QtWidgets \
-	-change "$QT_PREFIX/lib/QtNetwork.framework/Versions/5/QtNetwork" @rpath/QtNetwork \
-	-change "$QT_PREFIX/lib/QtGui.framework/Versions/5/QtGui" @rpath/QtGui \
-	-change "$QT_PREFIX/lib/QtCore.framework/Versions/5/QtCore" @rpath/QtCore \
+	-change /usr/local/opt/qt/lib/QtWebSockets.framework/Versions/5/QtWebSockets @rpath/QtWebSockets \
+	-change /usr/local/opt/qt/lib/QtWidgets.framework/Versions/5/QtWidgets @rpath/QtWidgets \
+	-change /usr/local/opt/qt/lib/QtNetwork.framework/Versions/5/QtNetwork @rpath/QtNetwork \
+	-change /usr/local/opt/qt/lib/QtGui.framework/Versions/5/QtGui @rpath/QtGui \
+	-change /usr/local/opt/qt/lib/QtCore.framework/Versions/5/QtCore @rpath/QtCore \
 	./build/obs-websocket.so
 
+# Check if replacement worked
+echo "-- Dependencies for QtNetwork"
+otool -L ./build/QtNetwork
+echo "-- Dependencies for QtWebSockets"
+otool -L ./build/QtWebSockets
+echo "-- Dependencies for obs-websocket"
+otool -L ./build/obs-websocket.so
+
 chmod -w ./build/QtWebSockets ./build/QtNetwork
 
 echo "-- Actual package build"

CMakeLists.txt

@@ -65,6 +65,18 @@ if(WIN32)
 		message(FATAL_ERROR "Could not find OBS Frontend API\'s library !")
 	endif()
 
+	if(CMAKE_SIZEOF_VOID_P EQUAL 8)
+		set(ARCH_NAME "64bit")
+		set(OBS_BUILDDIR_ARCH "build64")
+	else()
+		set(ARCH_NAME "32bit")
+		set(OBS_BUILDDIR_ARCH "build32")
+	endif()
+
+	include_directories(
+		"${LIBOBS_INCLUDE_DIR}/../${OBS_BUILDDIR_ARCH}/UI"
+	)
+
 	target_link_libraries(obs-websocket
 		"${OBS_FRONTEND_LIB}")
 
@@ -84,12 +96,6 @@ if(WIN32)
 	# The "release" folder has a structure similar OBS' one on Windows
 	set(RELEASE_DIR "${PROJECT_SOURCE_DIR}/release")
 
-	if(CMAKE_SIZEOF_VOID_P EQUAL 8)
-		set(ARCH_NAME "64bit")
-	else()
-		set(ARCH_NAME "32bit")
-	endif()
-
 	add_custom_command(TARGET obs-websocket POST_BUILD
 		COMMAND if $<CONFIG:Release>==1 (
 			"${CMAKE_COMMAND}" -E make_directory
@@ -105,6 +111,23 @@ if(WIN32)
 			"${QTDIR}/bin/Qt5WebSockets.dll" 
 			"${QTDIR}/bin/Qt5Network.dll" 
 			"${RELEASE_DIR}/obs-plugins/${ARCH_NAME}")
+
+		# Copy to obs-studio dev environment for immediate testing
+		COMMAND if $<CONFIG:Debug>==1 (
+			"${CMAKE_COMMAND}" -E copy
+				"$<TARGET_FILE:obs-websocket>"
+				"${QTDIR}/bin/Qt5WebSocketsd.dll"
+				"${QTDIR}/bin/Qt5Networkd.dll"
+				"${LIBOBS_INCLUDE_DIR}/../${OBS_BUILDDIR_ARCH}/rundir/$<CONFIG>/obs-plugins/${ARCH_NAME}")
+
+		COMMAND if $<CONFIG:Debug>==1 (
+			"${CMAKE_COMMAND}" -E make_directory
+				"${LIBOBS_INCLUDE_DIR}/../${OBS_BUILDDIR_ARCH}/rundir/$<CONFIG>/data/obs-plugins/obs-websocket")
+
+		COMMAND if $<CONFIG:Debug>==1 (
+			"${CMAKE_COMMAND}" -E copy_directory
+				"${PROJECT_SOURCE_DIR}/data"
+				"${LIBOBS_INCLUDE_DIR}/../${OBS_BUILDDIR_ARCH}/rundir/$<CONFIG>/data/obs-plugins/obs-websocket")
 	)
 	# --- End of sub-section ---
 

Config.cpp

@@ -22,8 +22,6 @@ with this program. If not, see <https://www.gnu.org/licenses/>
 #include <util/config-file.h>
 #include <string>
 
-#include "Config.h"
-
 #define SECTION_NAME "WebsocketAPI"
 #define PARAM_ENABLE "ServerEnabled"
 #define PARAM_PORT "ServerPort"
@@ -32,168 +30,155 @@ with this program. If not, see <https://www.gnu.org/licenses/>
 #define PARAM_SECRET "AuthSecret"
 #define PARAM_SALT "AuthSalt"
 
-Config *Config::_instance = new Config();
+#include "Config.h"
 
-Config::Config()
-{
-	// Default settings
-	ServerEnabled = true;
-	ServerPort = 4444;
-	
-	DebugEnabled = false;
+Config* Config::_instance = new Config();
 
-	AuthRequired = false;
-	Secret = "";
-	Salt = "";
-	SettingsLoaded = false;
+Config::Config() :
+    ServerEnabled(true),
+    ServerPort(4444),
+    DebugEnabled(false),
+    AuthRequired(false),
+    Secret(""),
+    Salt(""),
+    SettingsLoaded(false) {
+    // OBS Config defaults
+    config_t* obs_config = obs_frontend_get_global_config();
+    if (obs_config) {
+        config_set_default_bool(obs_config, 
+            SECTION_NAME, PARAM_ENABLE, ServerEnabled);
+        config_set_default_uint(obs_config, 
+            SECTION_NAME, PARAM_PORT, ServerPort);
+            
+        config_set_default_bool(obs_config,
+            SECTION_NAME, PARAM_DEBUG, DebugEnabled);
 
-	// OBS Config defaults
-	config_t* obs_config = obs_frontend_get_global_config();
-	if (obs_config)
-	{
-		config_set_default_bool(obs_config, 
-			SECTION_NAME, PARAM_ENABLE, ServerEnabled);
-		config_set_default_uint(obs_config, 
-			SECTION_NAME, PARAM_PORT, ServerPort);
-			
-		config_set_default_bool(obs_config,
-			SECTION_NAME, PARAM_DEBUG, DebugEnabled);
+        config_set_default_bool(obs_config, 
+            SECTION_NAME, PARAM_AUTHREQUIRED, AuthRequired);
+        config_set_default_string(obs_config, 
+            SECTION_NAME, PARAM_SECRET, Secret);
+        config_set_default_string(obs_config, 
+            SECTION_NAME, PARAM_SALT, Salt);
+    }
 
-		config_set_default_bool(obs_config, 
-			SECTION_NAME, PARAM_AUTHREQUIRED, AuthRequired);
-		config_set_default_string(obs_config, 
-			SECTION_NAME, PARAM_SECRET, Secret);
-		config_set_default_string(obs_config, 
-			SECTION_NAME, PARAM_SALT, Salt);
-	}
+    mbedtls_entropy_init(&entropy);
+    mbedtls_ctr_drbg_init(&rng);
+    mbedtls_ctr_drbg_seed(&rng, mbedtls_entropy_func, &entropy, nullptr, 0);
 
-	mbedtls_entropy_init(&entropy);
-	mbedtls_ctr_drbg_init(&rng);
-	mbedtls_ctr_drbg_seed(&rng, mbedtls_entropy_func, &entropy, nullptr, 0);
-	//mbedtls_ctr_drbg_set_prediction_resistance(&rng, MBEDTLS_CTR_DRBG_PR_ON);
-
-	SessionChallenge = GenerateSalt();
+    SessionChallenge = GenerateSalt();
 }
 
-Config::~Config()
-{
-	mbedtls_ctr_drbg_free(&rng);
-	mbedtls_entropy_free(&entropy);
+Config::~Config() {
+    mbedtls_ctr_drbg_free(&rng);
+    mbedtls_entropy_free(&entropy);
 }
 
-void Config::Load()
-{
-	config_t* obs_config = obs_frontend_get_global_config();
+void Config::Load() {
+    config_t* obs_config = obs_frontend_get_global_config();
 
-	ServerEnabled = config_get_bool(obs_config, SECTION_NAME, PARAM_ENABLE);
-	ServerPort = config_get_uint(obs_config, SECTION_NAME, PARAM_PORT);
-	
-	DebugEnabled = config_get_bool(obs_config, SECTION_NAME, PARAM_DEBUG);
+    ServerEnabled = config_get_bool(obs_config, SECTION_NAME, PARAM_ENABLE);
+    ServerPort = config_get_uint(obs_config, SECTION_NAME, PARAM_PORT);
+    
+    DebugEnabled = config_get_bool(obs_config, SECTION_NAME, PARAM_DEBUG);
 
-	AuthRequired = config_get_bool(obs_config, SECTION_NAME, PARAM_AUTHREQUIRED);
-	Secret = config_get_string(obs_config, SECTION_NAME, PARAM_SECRET);
-	Salt = config_get_string(obs_config, SECTION_NAME, PARAM_SALT);
+    AuthRequired = config_get_bool(obs_config, SECTION_NAME, PARAM_AUTHREQUIRED);
+    Secret = config_get_string(obs_config, SECTION_NAME, PARAM_SECRET);
+    Salt = config_get_string(obs_config, SECTION_NAME, PARAM_SALT);
 }
 
-void Config::Save()
-{
-	config_t* obs_config = obs_frontend_get_global_config();
+void Config::Save() {
+    config_t* obs_config = obs_frontend_get_global_config();
 
-	config_set_bool(obs_config, SECTION_NAME, PARAM_ENABLE, ServerEnabled);
-	config_set_uint(obs_config, SECTION_NAME, PARAM_PORT, ServerPort);
-	
-	config_set_bool(obs_config, SECTION_NAME, PARAM_DEBUG, DebugEnabled);
+    config_set_bool(obs_config, SECTION_NAME, PARAM_ENABLE, ServerEnabled);
+    config_set_uint(obs_config, SECTION_NAME, PARAM_PORT, ServerPort);
+    
+    config_set_bool(obs_config, SECTION_NAME, PARAM_DEBUG, DebugEnabled);
 
-	config_set_bool(obs_config, SECTION_NAME, PARAM_AUTHREQUIRED, AuthRequired);
-	config_set_string(obs_config, SECTION_NAME, PARAM_SECRET, Secret);
-	config_set_string(obs_config, SECTION_NAME, PARAM_SALT, Salt);
+    config_set_bool(obs_config, SECTION_NAME, PARAM_AUTHREQUIRED, AuthRequired);
+    config_set_string(obs_config, SECTION_NAME, PARAM_SECRET, Secret);
+    config_set_string(obs_config, SECTION_NAME, PARAM_SALT, Salt);
 
-	config_save(obs_config);
+    config_save(obs_config);
 }
 
-const char* Config::GenerateSalt()
-{
-	// Generate 32 random chars
-	unsigned char* random_chars = (unsigned char*)bzalloc(32);
-	mbedtls_ctr_drbg_random(&rng, random_chars, 32);
+const char* Config::GenerateSalt() {
+    // Generate 32 random chars
+    unsigned char* random_chars = (unsigned char*)bzalloc(32);
+    mbedtls_ctr_drbg_random(&rng, random_chars, 32);
 
-	// Convert the 32 random chars to a base64 string
-	char* salt = (char*)bzalloc(64);
-	size_t salt_bytes;
-	mbedtls_base64_encode(
-		(unsigned char*)salt, 64, &salt_bytes,
-		random_chars, 32);
+    // Convert the 32 random chars to a base64 string
+    char* salt = (char*)bzalloc(64);
+    size_t salt_bytes;
+    mbedtls_base64_encode(
+        (unsigned char*)salt, 64, &salt_bytes,
+        random_chars, 32);
 
-	bfree(random_chars);
-	return salt;
+    bfree(random_chars);
+    return salt;
 }
 
-const char* Config::GenerateSecret(const char *password, const char *salt)
-{
-	// Concatenate the password and the salt
-	std::string passAndSalt = "";
-	passAndSalt += password;
-	passAndSalt += salt;
+const char* Config::GenerateSecret(const char* password, const char* salt) {
+    // Concatenate the password and the salt
+    std::string passAndSalt = "";
+    passAndSalt += password;
+    passAndSalt += salt;
 
-	// Generate a SHA256 hash of the password
-	unsigned char* challengeHash = (unsigned char*)bzalloc(32);
-	mbedtls_sha256(
-		(unsigned char*)passAndSalt.c_str(), passAndSalt.length(),
-		challengeHash, 0);
-	
-	// Encode SHA256 hash to Base64
-	char* challenge = (char*)bzalloc(64);
-	size_t challenge_bytes = 0;
-	mbedtls_base64_encode(
-		(unsigned char*)challenge, 64, &challenge_bytes,
-		challengeHash, 32);
+    // Generate a SHA256 hash of the password
+    unsigned char* challengeHash = (unsigned char*)bzalloc(32);
+    mbedtls_sha256(
+        (unsigned char*)passAndSalt.c_str(), passAndSalt.length(),
+        challengeHash, 0);
+    
+    // Encode SHA256 hash to Base64
+    char* challenge = (char*)bzalloc(64);
+    size_t challenge_bytes = 0;
+    mbedtls_base64_encode(
+        (unsigned char*)challenge, 64, &challenge_bytes,
+        challengeHash, 32);
 
-	bfree(challengeHash);
-	return challenge;
+    bfree(challengeHash);
+    return challenge;
 }
 
-void Config::SetPassword(const char *password)
-{
-	const char *new_salt = GenerateSalt();
-	const char *new_challenge = GenerateSecret(password, new_salt);
+void Config::SetPassword(const char* password) {
+    const char* new_salt = GenerateSalt();
+    const char* new_challenge = GenerateSecret(password, new_salt);
 
-	this->Salt = new_salt;
-	this->Secret = new_challenge;
+    this->Salt = new_salt;
+    this->Secret = new_challenge;
 }
 
-bool Config::CheckAuth(const char *response)
-{
-	// Concatenate auth secret with the challenge sent to the user
-	std::string challengeAndResponse = "";
-	challengeAndResponse += this->Secret;
-	challengeAndResponse += this->SessionChallenge;
+bool Config::CheckAuth(const char* response) {
+    // Concatenate auth secret with the challenge sent to the user
+    std::string challengeAndResponse = "";
+    challengeAndResponse += this->Secret;
+    challengeAndResponse += this->SessionChallenge;
 
-	// Generate a SHA256 hash of challengeAndResponse
-	unsigned char* hash = (unsigned char*)bzalloc(32);
-	mbedtls_sha256(
-		(unsigned char*)challengeAndResponse.c_str(),
-		challengeAndResponse.length(),
-		hash, 0);
+    // Generate a SHA256 hash of challengeAndResponse
+    unsigned char* hash = (unsigned char*)bzalloc(32);
+    mbedtls_sha256(
+        (unsigned char*)challengeAndResponse.c_str(),
+        challengeAndResponse.length(),
+        hash, 0);
 
-	// Encode the SHA256 hash to Base64
-	char* expected_response = (char*)bzalloc(64);
-	size_t base64_size = 0;
-	mbedtls_base64_encode(
-		(unsigned char*)expected_response, 64, &base64_size,
-		hash, 32);
+    // Encode the SHA256 hash to Base64
+    char* expected_response = (char*)bzalloc(64);
+    size_t base64_size = 0;
+    mbedtls_base64_encode(
+        (unsigned char*)expected_response, 64, &base64_size,
+        hash, 32);
 
-	bool authSuccess = false;
-	if (strcmp(expected_response, response) == 0) {
-		SessionChallenge = GenerateSalt();
-		authSuccess = true;
-	}
+    bool authSuccess = false;
+    if (strcmp(expected_response, response) == 0) {
+        SessionChallenge = GenerateSalt();
+        authSuccess = true;
+    }
 
-	bfree(hash);
-	bfree(expected_response);
-	return authSuccess;
+    bfree(hash);
+    bfree(expected_response);
+    return authSuccess;
 }
 
-Config* Config::Current()
-{
-	return _instance;
+Config* Config::Current() {
+    return _instance;
 }

Config.h

@@ -22,37 +22,36 @@ with this program. If not, see <https://www.gnu.org/licenses/>
 #include <mbedtls/entropy.h>
 #include <mbedtls/ctr_drbg.h>
 
-class Config
-{
-	public:
-		Config();
-		~Config();
-		void Load();
-		void Save();
+class Config {
+  public:
+    Config();
+    ~Config();
+    void Load();
+    void Save();
 
-		void SetPassword(const char *password);
-		bool CheckAuth(const char *userChallenge);
-		const char* GenerateSalt();
-		static const char* GenerateSecret(
-			const char *password, const char *salt);
+    void SetPassword(const char* password);
+    bool CheckAuth(const char* userChallenge);
+    const char* GenerateSalt();
+    static const char* GenerateSecret(
+        const char* password, const char* salt);
 
-		bool ServerEnabled;
-		uint64_t ServerPort;
-		
-		bool DebugEnabled;
+    bool ServerEnabled;
+    uint64_t ServerPort;
+        
+    bool DebugEnabled;
 
-		bool AuthRequired;
-		const char *Secret;
-		const char *Salt;
-		const char *SessionChallenge;
-		bool SettingsLoaded;
-		
-		static Config* Current();
+    bool AuthRequired;
+    const char* Secret;
+    const char* Salt;
+    const char* SessionChallenge;
+    bool SettingsLoaded;
+        
+    static Config* Current();
 
-	private:
-		static Config *_instance;
-		mbedtls_entropy_context entropy;
-		mbedtls_ctr_drbg_context rng;
+  private:
+    static Config* _instance;
+    mbedtls_entropy_context entropy;
+    mbedtls_ctr_drbg_context rng;
 };
 
 #endif // CONFIG_H

PROTOCOL.md

@@ -1,967 +0,0 @@
-obs-websocket 4.1 protocol reference
-================================
-**This is the reference for the latest 4.1 developement build. [See here for obs-websocket 4.0.0!](https://github.com/Palakis/obs-websocket/blob/4.0.0/PROTOCOL.md)**
-
-## General Introduction
-Messages exchanged between the client and the server are JSON objects.  
-The protocol in general is based on the OBS Remote protocol created by Bill Hamilton, with new commands specific to OBS Studio.
-
-### Table of contents
-* [Authentication](#authentication)
-* [Events](#events)
-  - [Description](#description)
-  - [Event Types](#event-types)
-    - **Scenes**
-      - ["SwitchScenes"](#switchscenes)
-      - ["ScenesChanged"](#sceneschanged)
-    - **Scene Items**
-      - ["SourceOrderChanged"](#sourceorderchanged)
-      - ["SceneItemAdded"](#sceneitemadded)
-      - ["SceneItemRemoved"](#sceneitemremoved)
-      - ["SceneItemVisibilityChanged"](#sceneitemvisibilitychanged)
-    - **Scene Collections**
-      - ["SceneCollectionChanged"](#scenecollectionchanged)
-      - ["SceneCollectionListChanged"](#scenecollectionlistchanged)
-    - **Transitions**
-      - ["SwitchTransition"](#switchtransition)
-      - ["TransitionDurationChanged"](#transitiondurationchanged)
-      - ["TransitionListChanged"](#transitionlistchanged)
-      - ["TransitionBegin"](#transitionbegin)
-    - **Studio Mode**
-      - ["PreviewSceneChanged"](#previewscenechanged)
-      - ["StudioModeSwitched"](#studiomodeswitched)
-    - **Profiles**
-      - ["ProfileChanged"](#profilechanged)
-      - ["ProfileListChanged"](#profilelistchanged)
-    - **Streaming**
-      - ["StreamStarting"](#streamstarting)
-      - ["StreamStarted"](#streamstarted)
-      - ["StreamStopping"](#streamstopping)
-      - ["StreamStopped"](#streamstopped)
-      - ["StreamStatus"](#streamstatus)
-    - **Recording**
-      - ["RecordingStarting"](#recordingstarting)
-      - ["RecordingStarted"](#recordingstarted)
-      - ["RecordingStopping"](#recordingstopping)
-      - ["RecordingStopped"](#recordingstopped)
-    - **Other**
-      - ["Exiting"](#exiting)
-* [Requests](#requests)
-  - [Description](#description-1)
-  - [Request Types](#request-types)
-    - **General**
-      - ["GetVersion"](#getversion)
-      - ["GetAuthRequired"](#getauthrequired)
-      - ["Authenticate"](#authenticate)
-    - **Scenes**
-      - ["GetCurrentScene"](#getcurrentscene)
-      - ["SetCurrentScene"](#setcurrentscene)
-      - ["GetSceneList"](#getscenelist)
-    - **Studio Mode**
-      - ["GetStudioModeStatus"](#getstudiomodestatus)
-      - ["SetPreviewScene"](#setpreviewscene)
-      - ["TransitionToProgram"](#transitiontoprogram)
-      - ["EnableStudioMode"](#enablestudiomode)
-      - ["DisableStudioMode"](#disablestudiomode)
-      - ["ToggleStudioMode"](#togglestudiomode)
-    - **Streaming**
-      - ["StartStopStreaming"](#startstopstreaming)
-      - ["StartStreaming"](#startstreaming)
-      - ["StopStreaming"](#stopstreaming)
-      - ["GetStreamingStatus"](#getstreamingstatus)
-    - **Recording**
-      - ["StartStopRecording"](#startstoprecording)
-      - ["StartRecording"](#startrecording)
-      - ["StopRecording"](#stoprecording)
-      - ["GetStreamingStatus"](#getstreamingstatus)
-      - ["SetRecordingFolder"](#setrecordingfolder)
-      - ["GetRecordingFolder"](#getrecordingfolder)
-    - **Transitions**
-      - ["GetTransitionList"](#gettransitionlist)
-      - ["GetCurrentTransition"](#getcurrenttransition)
-      - ["SetCurrentTransition"](#setcurrenttransition)
-      - ["GetTransitionDuration"](#gettransitionduration)
-      - ["SetTransitionDuration"](#settransitionduration)
-    - **Sources**
-      - ["GetCurrentScene"](#getcurrentscene)
-      - ["GetSceneList"](#getscenelist)
-      - ["GetSpecialSources"](#getspecialsources)
-      - ["GetTextGDIPlusProperties"](#gettextgdiplusproperties)
-      - ["SetTextGDIPlusProperties"](#settextgdiplusproperties)
-      - ["GetBrowserSourceProperties"](#getbrowsersourceproperties)
-      - ["SetBrowserSourceProperties"](#setbrowsersourceproperties)
-      - ["SetVolume"](#setvolume)
-      - ["GetVolume"](#getvolume)
-      - ["SetMute"](#setmute)
-      - ["GetMute"](#getmute)
-      - ["ToggleMute"](#togglemute)
-    - **Scene Items**
-      - ["SetSceneItemRender"](#setsourcerender) (a.k.a `SetSourceRender`)
-      - ["SetSceneItemPosition"](#setsceneitemposition)
-      - ["SetSceneItemTransform"](#setsceneitemtransform)
-      - ["SetSceneItemCrop"](#setsceneitemcrop)
-    - **Scene Collections**
-      - ["ListSceneCollections"](#listscenecollections)
-      - ["SetCurrentSceneCollection"](#setcurrentscenecollection)
-      - ["GetCurrentSceneCollection"](#getcurrentscenecollection)
-    - **Streaming Server Settings**
-      - ["GetStreamSettings"](#getstreamsettings)
-      - ["SetStreamSettings"](#setstreamsettings)
-      - ["SaveStreamSettings"](#savestreamsettings)
-    - **Profiles**
-      - ["ListProfiles"](#listprofiles)
-      - ["SetCurrentProfile"](#setcurrentprofile)
-      - ["GetCurrentProfile"](#getcurrentprofile)
-
-## Authentication
-A call to [`GetAuthRequired`](#getauthrequired) gives the client two elements :
-- A challenge : a random string that will be used to generate the auth response
-- A salt : applied to the password when generating the auth response
-
-The client knows a password and must it to authenticate itself to the server.  
-However, it must keep this password secret, and it is the purpose of the authentication mecanism used by obs-websocket.
-
-After a call to [`GetAuthRequired`](#getauthrequired), the client knows a password (kept secret), a challenge and a salt (sent by the server).
-To generate the answer to the auth challenge, follow this procedure :
-- Concatenate the password with the salt sent by the server (in this order : password + server salt), then generate a binary SHA256 hash of the result and encode the resulting SHA256 binary hash to base64.
-- Concatenate the base64 secret with the challenge sent by the server (in this order : base64 secret + server challenge), then generate a binary SHA256 hash of the result and encode it to base64.
-- Voilà, this last base64 string is the auth response. You may now use it to authenticate to the server with the `Authenticate` request.
-
-Here's how it looks in pseudocode :
-```
-password = "supersecretpassword"
-challenge = "ztTBnnuqrqaKDzRM3xcVdbYm"
-salt = "PZVbYpvAnZut2SS6JNJytDm9"
-
-secret_string = password + salt
-secret_hash = binary_sha256(secret_string)
-secret = base64_encode(secret_hash)
-
-auth_response_string = secret + challenge
-auth_response_hash = binary_sha256(auth_response_string)
-auth_response = base64_encode(auth_response_hash)
-```
-
-A client can then authenticate to the server by calling [`Authenticate`](#authenticate) with the computed challenge response.
-
-## Events
-### Description
-Events are sent exclusively by the server and broadcast to each connected client.  
-An event message will contain at least one field :
-- **update-type** (string) : the type of event
-- **stream-timecode** (string, optional) : time elapsed between now and stream start (only present if OBS Studio is streaming)
-- **rec-timecode** (string, optional) : time elapsed between now and recording start (only present if OBS Studio is recording)
-
-Timecodes are in the following format : HH:MM:SS.mmm
-
-Additional fields will be present in the event message depending on the event type.
-
-### Event Types
-#### "SwitchScenes"
-OBS is switching to another scene (called at the end of the transition).  
-- **scene-name** (string) : The name of the scene being switched to.
-- **sources** (array of objects) : List of sources composing the scene. Same specification as [`GetCurrentScene`](#getcurrentscene).
-
----
-
-#### "ScenesChanged"
-The scene list has been modified (Scenes have been added, removed, or renamed).
-
----
-
-#### "SourceOrderChanged"
-Scene items have been reordered.
-- **"scene-name"** (string) : name of the scene where items have been reordered
-
----
-
-#### "SceneItemAdded"
-An item has been added to the current scene.
-- **"scene-name"** (string) :  name of the scene
-- **"item-name"** (string) : name of the item added to **scene-name**
-
----
-
-#### "SceneItemRemoved"
-An item has been removed from the current scene.
-- **"scene-name"** (string) :  name of the scene
-- **"item-name"** (string) : name of the item removed from **scene-name**
-
----
-
-#### "SceneItemVisibilityChanged"
-An item's visibility has been toggled.
-- **"scene-name"** (string) :  name of the scene
-- **"item-name"** (string) : name of the item in **scene-name**
-- **"item-visible"** (bool) : new visibility of item **item-name**
-
----
-
-#### "SceneCollectionChanged"
-Triggered when switching to another scene collection or when renaming the current scene collection.
-
----
-
-#### "SceneCollectionListChanged"
-Triggered when a scene collection is created, added, renamed or removed.
-
----
-
-#### "SwitchTransition"
-The active transition has been changed.  
-- **transition-name** (string) : The name of the active transition.
-
----
-
-#### "TransitionDurationChanged"
-Triggered when the transition duration has changed.
-- **"new-duration"** (integer) : new transition duration
-
----
-
-#### "TransitionListChanged"
-The list of available transitions has been modified (Transitions have been added, removed, or renamed).
-
----
-
-#### "TransitionBegin"
-A transition other than "Cut" has begun.
-
----
-
-#### "PreviewSceneChanged"
-The selected Preview scene changed (only in Studio Mode).
-- **scene-name** (string) : Name of the scene being previewed.
-- **sources** (array of objects) : List of sources composing the scene. Same specification as [`GetCurrentScene`](#getcurrentscene).
-
----
-
-#### "StudioModeSwitched"
-Studio Mode has been switched on or off.
-- **"new-state"** (bool) : new state of Studio Mode: true if enabled, false if disabled.
-
----
-
-#### "ProfileChanged"
-Triggered when switching to another profile or when renaming the current profile.
-
----
-
-#### "ProfileListChanged"
-Triggered when a profile is created, added, renamed or removed.
-
----
-
-#### "StreamStarting"
-A request to start streaming has been issued.  
-- **preview-only** (bool) : Always false.
-
----
-
-#### "StreamStarted"  
-Streaming started successfully.  
-
----
-
-#### "StreamStopping"
-A request to stop streaming has been issued.  
-- **preview-only** (bool) : Always false.
-
----
-
-#### "StreamStopped"  
-Streaming stopped successfully.  
-
----
-
-#### "RecordingStarting"  
-A request to start recording has been issued.  
-
----
-
-#### "RecordingStarted"  
-Recording started successfully.  
-
----
-
-#### "RecordingStopping"
-A request to stop streaming has been issued.  
-
----
-
-#### "RecordingStopped"  
-Recording stopped successfully.  
-
----
-
-#### "StreamStatus"
-Sent every 2 seconds with the following information :  
-- **streaming** (bool) : Current Streaming state.
-- **recording** (bool) : Current Recording state.
-- **preview-only** (bool) : Always false.
-- **bytes-per-sec** (integer) : Amount of data per second (in bytes) transmitted by the stream encoder.
-- **kbits-per-sec** (integer) : "bytes-per-sec" converted to kilobits per second
-- **strain** (double) : Percentage of dropped frames
-- **total-stream-time** (integer) : Total time (in seconds) since the stream started.
-- **num-total-frames** (integer) : Total number of frames transmitted since the stream started.
-- **num-dropped-frames** (integer) : Number of frames dropped by the encoder since the stream started.
-- **fps** (double) : Current framerate.
-
----
-
-#### "Exiting"
-OBS is exiting.  
-
----
-
-## Requests
-
-### Description
-Requests are sent by the client and must have at least the following two fields :  
-- **"request-type"** (string) : One of the request types listed in the sub-section "[Requests Types](#request-types)".
-- **"message-id"** (string) : An identifier defined by the client which will be embedded in the server response.  
-
-Depending on the request type additional fields may be required (see the "[Request Types](#request-types)" section below for more information).
-
-Once a request is sent, the server will return a JSON response with the following fields :  
-- **"message-id"** (string) : The identifier specified in the request.
-- **"status"** (string) : Response status, will be one of the following : "ok", "error"
-- **"error"** (string) : The error message associated with an "error" status.  
-
-Depending on the request type additional fields may be present (see the "[Request Types](#request-types)" section below for more information).
-
-### Request Types
-#### "GetVersion"
-Returns the latest version of the plugin and the API.
-
-__Request fields__ : none  
-__Response__ : always OK, with these additional fields :  
-- **"version"** (double) : OBSRemote API version. Fixed to 1.1 for retrocompatibility.
-- **"obs-websocket-version"** (string) : obs-websocket version string
-- **"obs-studio-version"** (string) : OBS Studio version string
-
----
-
-#### "GetAuthRequired"
-Tells the client if authentication is required. If it is, authentication parameters "challenge" and "salt" are passed in the response fields (see "Authentication").
-
-__Request fields__ : none  
-__Response__ : always OK, with these additional fields :  
-- **"authRequired"** (bool)
-- **"challenge"** (string)
-- **"salt"** (string)
-
----
-
-#### "Authenticate"
-Try to authenticate the client on the server.
-
-__Request fields__ :  
-- **"auth"** (string) : response to the auth challenge (see "Authentication").
-
-__Response__ : OK if auth succeeded, error if invalid credentials. No additional fields.
-
----
-
-#### "GetCurrentScene"
-Get the current scene's name and items.
-
-__Request fields__ : none  
-__Response__ : always OK, with these additional fields :  
-- **"name"** (string) : name of the current scene
-- **"sources"** (array of objects) : ordered list of the current scene's items descriptions
-
-Objects in the "sources" array have the following fields :
-- **"name"** (string) : name of the source associated with the scene item
-- **"type"** (string) : internal source type name
-- **"volume"** (double) : audio volume of the source, ranging from 0.0 to 1.0
-- **"x"** (double) : X coordinate of the top-left corner of the item in the scene
-- **"y"** (double) : Y coordinate of the top-left corner of the item in the scene
-- **"source_cx"** (integer) : width of the item (without scale applied)
-- **"source_cy"** (integer) : height of the item (without scale applied)
-- **"cx"** (double) : width of the item (with scale applied)
-- **"cy"** (double) : height of the item (with scale applied)
-- **"render"** (bool) : visibility of the source in the scene
-
----
-
-#### "SetCurrentScene"
-Switch to the scene specified in "scene-name".
-
-__Request fields__ :  
-- **"scene-name"** (string) : name of the scene to switch to.
-
-__Response__ : always OK if scene exists, error if it doesn't. No additional fields
-
----
-
-#### "GetSceneList"
-List OBS' scenes.
-
-__Request fields__ : none  
-__Response__ : always OK, with these additional fields :  
-- **"current-scene"** (string) : name of the currently active scene
-- **"scenes"** (array of objects) : ordered list of scene descriptions (see `GetCurrentScene` for reference)
-
----
-
-#### "SetSourceRender"
-Show or hide a specific source in the current scene.
-
-__Request fields__ :  
-- **"source"** (string) : name of the source in the currently active scene.
-- **"render"** (bool) : desired visibility
-- **"scene-name"** (string; optional) : name of the scene the source belongs to.  defaults to current scene.
-
-__Response__ : OK if source exists in the current scene, error otherwise.
-
----
-
-#### "GetStudioModeStatus"
-Tells if Studio Mode is currently enabled or disabled.
-
-__Request fields__ : none  
-__Response__ : always OK, with these additional fields :  
-- **"studio-mode"** (bool) : true if OBS is in Studio Mode, false otherwise.
-
----
-
-#### "GetPreviewScene"
-Studio Mode only. Gets the name of the currently Previewed scene, along with a list of its sources.
-
-__Request fields__ : none  
-__Response__ : OK if Studio Mode is enabled, with the same fields as [`GetCurrentScene`](#getcurrentscene), error otherwise.
-
----
-
-#### "SetPreviewScene"
-Studio Mode only. Sets the specified scene as the Previewed scene in Studio Mode.
-
-__Request fields__ :  
-- **"scene-name"** (string) : name of the scene to selected as the preview of Studio Mode
-
-__Response__ : OK if Studio Mode is enabled and specified scene exists, error otherwise.
-
----
-
-#### "TransitionToProgram"
-Studio Mode only. Transitions the currently previewed scene to Program (main output).
-
-__Request fields__ :  
-- **"with-transition"** (object, optional) : if specified, use this transition when switching from preview to program. This will change the current transition in the frontend to this one.
-
-__Response__ : OK if studio mode is enabled and optional transition exists, error otherwise.
-
-An object passed as `"with-transition"` in a request must have the following fields :  
-- **"name"** (string, optional) : transition name
-- **"duration"** (integer, optional) : transition duration in milliseconds
-
----
-
-#### "EnableStudioMode"
-Enables Studio Mode.
-
-__Request fields__ : none  
-__Response__ : always OK. No additional fields.
-
----
-
-#### "DisableStudioMode"
-Disables Studio Mode.
-
-__Request fields__ : none  
-__Response__ : always OK. No additional fields.
-
----
-
-#### "ToggleStudioMode"
-Toggles Studio Mode on or off.
-
-__Request fields__ : none  
-__Response__ : always OK. No additional fields.
-
----
-
-#### "StartStopStreaming"
-Toggles streaming on or off.
-
-__Request fields__ : none  
-__Response__ : always OK. No additional fields.
-
----
-
-#### "StartStopRecording"
-Toggles recording on or off.
-
-__Request fields__ : 
-- **"stream"** (object; optional) : See 'stream' parameter in 'StartStreaming'.  Ignored if stream is already started.
-
-__Response__ : always OK. No additional fields.  
-
----
-
-#### "StartStreaming"
-Start streaming.
-
-__Request fields__ : 
-- **"stream"** (object; optional) : If specified allows for special configuration of the stream
- 
-The 'stream' object has the following fields:
-- **"settings"** (object; optional) : The settings for the stream
-- **"type"** (string; optional) : If specified ensures the type of the stream matches the given type (usually 'rtmp\_custom' or 'rtmp\_common').  If the currently configured stream type does not match the given stream type, all settings must be specified in the 'settings' object or an error will occur starting the stream.
-- **"metadata"** (object; optional) : Adds the given object parameters as encoded query string parameters to the 'key' of the RTMP stream.  Used to pass data to the RTMP service about the stream.
-
-The 'settings' object has the following fields:
-- **"server"** (string; optional) : The publish URL
-- **"key"** (string; optional) : The publish key of the stream
-- **"use-auth"** (bool; optional) : should authentication be used when connecting to the streaming server
-- **"username"** (string; optional) : if authentication is enabled, the username for access to the streaming server. Ignored if 'use-auth' is not specified as 'true'.
-- **"password"** (string; optional) : if authentication is enabled, the password for access to the streaming server. Ignored if 'use-auth' is not specified as 'true'.
-
-The 'metadata' object supports passing any string, numeric or boolean field.
-  
-__Response__ : Error if streaming is already active, OK otherwise. No additional fields.  
-
----
-
-#### "StopStreaming"
-Stop streaming.
-
-__Request fields__ : none  
-__Response__ : Error if streaming is already inactive, OK otherwise. No additional fields.  
-
----
-
-#### "StartRecording"
-Start recording.
-
-__Request fields__ : none  
-__Response__ : Error if recording is already active, OK otherwise. No additional fields.  
-
----
-
-#### "StopRecording"
-Stop recording.
-
-__Request fields__ : none  
-__Response__ : Error if recording is already inactive, OK otherwise. No additional fields.  
-
----
-
-#### "SetRecordingFolder"
-Change the current recording folder.
-
-__Request fields__ :
-- **"rec-folder"** (string) : path of the desired recording folder
-
-__Response__ : OK if path is valid, error otherwise.
-
----
-
-#### "GetRecordingFolder"
-Get the path of the current recording folder.
-
-__Request fields__ : none
-
-__Response__ : OK with these additional fields :
-- **"rec-folder"** (string) : path of the current recording folder
-
----
-
-#### "GetStreamingStatus"
-Get current streaming and recording status.
-
-__Request fields__ : none  
-__Response__ : always OK, with these additional fields :
-- **"streaming"** (bool) : streaming status (active or not)
-- **"recording"** (bool) : recording status (active or not)
-- **stream-timecode** (string, optional) : time elapsed between now and stream start (only present if OBS Studio is streaming)
-- **rec-timecode** (string, optional) : time elapsed between now and recording start (only present if OBS Studio is recording)
-- **"preview-only"** (bool) : always false. Retrocompat with OBSRemote.
-
----
-
-#### "GetTransitionList"
-List all transitions available in the frontend's dropdown menu.
-
-__Request fields__ : none  
-__Response__ : always OK, with these additional fields :
-- **"current-transition"** (string) : name of the current transition
-- **"transitions"** (array of objects) : list of transition descriptions
-
-Objects in the "transitions" array have only one field :
-- **"name"** (string) : name of the transition
-
----
-
-#### "GetCurrentTransition"
-Get the name of the currently selected transition in the frontend's dropdown menu.
-
-__Request fields__ : none  
-__Response__ : always OK, with these additional fields :
-- **"name"** (string) : name of the selected transition
-- **"duration"** (integer, only if transition supports this) : transition duration
-
----
-
-#### "SetCurrentTransition"
-__Request fields__ :
-- **"transition-name"** (string) : The name of the transition.
-
-__Response__ : OK if specified transition exists, error otherwise. 
-
----
-
-#### "SetTransitionDuration"
-Set the duration of the currently selected transition.
-
-__Request fields__ :
-- **"duration"** (integer) : desired transition duration in milliseconds
-
-__Response__ : always OK.
-
----
-
-#### "GetTransitionDuration"
-Set the duration of the currently selected transition.
-
-__Request fields__ : none  
-__Response__ : always OK, with these additional fields :
-- **"transition-duration"** (integer) : current transition duration, in milliseconds
-
----
-
-#### "SetVolume"
-Set the volume of a specific source.
-
-__Request fields__ :
-- **"source"** (string) : the name of the source
-- **"volume"** (double) : the desired volume
-
-__Response__ : OK if specified source exists, error otherwise.
-
----
-
-#### "GetVolume"
-Get the volume of a specific source.
-
-__Request fields__ :
-- **"source"** (string) : name of the source
-
-__Response__ : OK if source exists, with these additional fields :
-- **"name"** (string) : source name
-- **"volume"** (double) : source volume, on a linear scale (0.0 to 1.0)
-- **"muted"** (bool) : source mute status
-
----
-
-#### "SetMute"
-Mutes or unmutes a specific source.
-
-__Request fields__ :
-- **"source"** (string) : the name of the source
-- **"mute"** (bool) : the desired mute status
-
-__Response__ : OK if specified source exists, error otherwise.
-
----
-
-#### "GetMute"
-Get mute status of a specific source.
-
-__Request fields__ :
-- **"source"** (string) : the name of the source
-
-__Response__ : OK if source exists, with these additional fields :
-- **"name"** (string) : source name
-- **"muted"** (bool) : source mute status
-
----
-
-#### "ToggleMute"
-Inverts the mute status of a specific source.
-
-__Request fields__ :
-- **"source"** (string) : the name of the source
-
-__Response__ : OK if specified source exists, error otherwise.
-
----
-
-#### "GetSpecialSources"
-Get configured special sources like Desktop Audio and Mic/Aux sources.
-
-__Request fields__ : none
-
-__Response__ : always OK, with these additional fields :  
-- **"desktop-1"** (string, optional) : Name of the first Desktop Audio capture source
-- **"desktop-1"** (string, optional) : Name of the second Desktop Audio capture source
-- **"mic-1"** (string, optional) : Name of the first Mic/Aux input source
-- **"mic-2"** (string, optional) : Name of the second Mic/Aux input source
-- **"mic-3"** (string, optional) : Name of the third Mic/Aux input source
-
----
-
-#### "SetSceneItemPosition"
-__Request fields__ :
-- **"item"** (string) : The name of the scene item.
-- **"x"** (float) : x coordinate
-- **"y"** (float) : y coordinate
-- **"scene-name"** (string) : scene the item belongs to.  defaults to current scene.
-
-__Response__ : OK if specified item exists, error otherwise.
-
----
-
-#### "SetSceneItemTransform"
-__Request fields__ :
-- **"item"** (string) : The name of the scene item.
-- **"x-scale"** (float) : width scale factor
-- **"y-scale"** (float) : height scale factor
-- **"rotation"** (float) : item rotation (in degrees)
-- **"scene-name"** (string) : scene the item belongs to.  defaults to current scene.
-
-__Response__ : OK if specified item exists, error otherwise.
-
----
-
-#### "SetSceneItemCrop"
-__Request fields__ :
-- **"item"** (string) : Name of the scene item
-- **"scene-name"** (string, optional) : Scene the item belongs to. Default : current scene.
-- **"top"** (integer)
-- **"bottom"** (integer)
-- **"left"** (integer)
-- **"right"** (integer)
-
-__Response__ : OK if specified item exists, error otherwise.
-
----
-
-#### "SetCurrentSceneCollection"
-Change the current scene collection.
-
-__Request fields__ :
-- **"sc-name"** (string) : name of the desired scene collection
-
-__Response__ : OK if scene collection exists, error otherwise.
-
----
-
-#### "GetCurrentSceneCollection"
-Get the name of the current scene collection.
-
-__Request fields__ : none
-
-__Response__ : OK with these additional fields :
-- **"sc-name"** (string) : name of the current scene collection
-
----
-
-#### "ListSceneCollections"
-Get a list of available scene collections.
-
-__Request fields__ : none
-
-__Response__ : OK with these additional fields :
-- **"scene-collections"** (array of objects) : names of available scene collections
-
----
-
-#### "GetStreamSettings"
-Gets the current streaming server settings
-
-__Request fields__ : none
-
-__Response__ : OK with these additional fields :
-- **"type"** (string) : The type of streaming service configuration usually 'rtmp\_custom' or 'rtmp\_common'
-- **"settings"** (object) : The actual settings of the stream (i.e. server, key, use-auth, username, password)
-
-The 'settings' object has the following fields however they may vary by 'type':
-- **"server"** (string) : The publish URL
-- **"key"** (string) : The publish key of the stream
-- **"use-auth"** (bool) : should authentication be used when connecting to the streaming server
-- **"username"** (string) : if authentication is enabled, the username for access to the streaming server
-- **"password"** (string) : if authentication is enabled, the password for access to the streaming server
-
---
-
-#### "SetStreamSettings"
-Sets one or more attributes of the current streaming server settings. Any options not passed will remain unchanged. Returns the updated settings in response. 
-If 'type' is different than the current streaming service type, all settings are required.
-Returns the full settings of the stream (i.e. the same as GetStreamSettings)
-
-__Request fields__ :
-- **"type"** (string) : The type of streaming service configuration usually 'rtmp\_custom' or 'rtmp\_common'
-- **"settings"** (object) : The actual settings of the stream (i.e. server, key, use-auth, username, password)
-- **"save"** (bool) : If specified as true, saves the settings to disk
-
-The 'settings' object has the following fields however they may vary by 'type':
-- **"server"** (string; optional) : The publish URL
-- **"key"** (string; optional) : The publish key of the stream
-- **"use-auth"** (bool; optional) : should authentication be used when connecting to the streaming server
-- **"username"** (string; optional) : if authentication is enabled, the username for access to the streaming server
-- **"password"** (string; optional) : if authentication is enabled, the password for access to the streaming server
-
-__Response__ : OK with the same fields as the request (except 'save')
-
----
-
-#### "SaveStreamSettings"
-Saves the current streaming server settings to disk
-
-__Request fields__ : none
-
-__Response__ : OK
-
-
-#### "SetCurrentProfile"
-Change the current profile.
-
-__Request fields__ :
-- **"profile-name"** (string) : name of the desired profile
-
-__Response__ : OK if profile exists, error otherwise.
-
----
-
-#### "GetCurrentProfile"
-Get the name of the current profile.
-
-__Request fields__ : none
-
-__Response__ : OK with these additional fields :
-- **"profile-name"** (string) : name of the current profile
-
----
-
-#### "ListProfiles"
-Get a list of available profiles.
-
-__Request fields__ : none
-
-__Response__ : OK with the additional fields :
-- **"profiles"** (array of objects) : names of available profiles
-
----
-
-#### "GetTextGDIPlusProperties"
-Gets current properties for Text GDI Plus source.
-
-__Request fields__ :  
-- **"source"** (string) : name of the source in the currently active scene.
-- **"scene-name"** (string; optional) : name of the scene the source belongs to.  defaults to current scene.
-
-__Response__ : OK if source exists in the current scene with these additional fields when fields are set, error otherwise.
-- **"align"** (string) : "left","center","right" : text alignment
-- **"bk_color"** (integer) : background color
-- **"bk_opacity"** (integer) : background opacity range 0 to 100
-- **"chatlog"** (bool) : chat log 
-- **"chatlog_lines"** (integer) : chat log lines
-- **"color"** (integer) : text color
-- **"extents"** (bool) : extents 
-- **"extents_wrap"** (bool) : extents wrap 
-- **"extents_cx"** (integer) : extents cx
-- **"extents_cy"** (integer) : extents cy
-- **"file"** (string) : file path name
-- **"read_from_file"** (bool) : read text from file specified
-- **"font"** (object) : holds font data for face, flags, size and style
--- Example: "font": {"face": "Arial","flags": 0,"size": 150,"style": ""}
-- **"face"** (string) : font face i.e. Arial
-- **"flags"** (integer) : font text style flag i.e. Bold 1, Italic 2, Bold Italic 3, Underline 5, Strikeout 8
-- **"size"** (integer) : font text size
-- **"style"** (string) : font style (unknown function)
-- **"gradient"** (bool) : gradient 
-- **"gradient_color"** (integer) : gradient color
-- **"gradient_dir"** (float) : gradient direction
-- **"gradient_opacity"** (integer) : gradient opacity range 0 to 100
-- **"outline"** (bool) : outline 
-- **"outline_color"** (integer) : outline color
-- **"outline_size"** (integer) : outline size
-- **"outline_opacity"** (integer) : outline opacity range 0 to 100
-- **"text"** (string) : text to be displayed
-- **"valign"** (string) : "top","center","bottom" : text vertical alignment
-- **"vertical"** (bool) : vertical text 
-- **"render"** (bool) : visibility of the scene item
-
----
-
-#### "SetTextGDIPlusProperties"
-Sets current properties for Text GDI Plus source.
-
-__Request fields__ :  
-- **"source"** (string) : name of the source in the currently active scene.
-- **"scene-name"** (string; optional) : name of the scene the source belongs to.  defaults to current scene.
-- **"align"** (string; optional) : "left","center","right" : text alignment
-- **"bk_color"** (integer; optional) : background color
-- **"bk_opacity"** (integer; optional) : background opacity range 0 to 100
-- **"chatlog"** (bool; optional) : chat log 
-- **"chatlog_lines"** (integer; optional) : chat log lines
-- **"color"** (integer; optional) : text color
-- **"extents"** (bool; optional) : extents 
-- **"extents_wrap"** (bool; optional) : extents wrap 
-- **"extents_cx"** (integer; optional) : extents cx
-- **"extents_cy"** (integer; optional) : extents cy
-- **"file"** (string; optional) : file path name
-- **"read_from_file"** (bool; optional) : read text from file specified
-- **"font"** (object; optional) : holds font data for face, flags, size and style
--- Example: "font":{"face": "Arial","flags": 0,"size": 150,"style": ""}
-- **"face"** (string; optional) : font face i.e. Arial
--- Example: "font":{"face": "Arial"}
-- **"flags"** (integer; optional) : font text style flag i.e. Bold 1, Italic 2, Bold Italic 3, Underline 5, Strikeout 8
-- **"size"** (integer; optional) : font text size 
--- Example: "font": {"size":125}
-- **"style"** (string; optional) : font style (unknown function)
-- **"gradient"** (bool; optional) : gradient 
-- **"gradient_color"** (integer; optional) : gradient color
-- **"gradient_dir"** (float; optional) : gradient direction
-- **"gradient_opacity"** (integer; optional) : gradient opacity range 0 to 100
-- **"outline"** (bool; optional) : outline 
-- **"outline_color"** (integer; optional) : outline color
-- **"outline_size"** (integer; optional) : outline size
-- **"outline_opacity"** (integer; optional) : outline opacity range 0 to 100
-- **"text"** (string; optional) : text to be displayed
-- **"valign"** (string; optional) : "top","center","bottom" : text vertical alignment
-- **"vertical"** (bool; optional) : vertical text 
-- **"render"** (bool; optional) : visibility of the scene item
-
-__Response__ : OK if source exists in the current scene, error otherwise.
-
----
-
-#### "GetBrowserSourceProperties"
-Gets current properties for Browser Source.
-
-__Request fields__ :  
-- **"source"** (string) : name of the source in the currently active scene.
-- **"scene-name"** (string; optional) : name of the scene the source belongs to.  defaults to current scene.
-
-__Response__ : OK if source exists in the current scene with these additional fields when fields are set, error otherwise.
-
-- **"is_local_file"** (bool) : use local file
-- **"url"** (string) : url or file path
-- **"css"** (string) : cascading style sheet code
-- **"width"** (integer) : width
-- **"height"** (integer) : height
-- **"fps"** (integer) : frames per second 
-- **"shutdown"** (bool) : shutdown when sorce is not visible
-- **"render"** (bool; optional) : visibility of the scene item
-
----
-
-#### "SetBrowserSourceProperties"
-Sets current properties for Browser Source.
-
-__Request fields__ :  
-- **"source"** (string) : name of the source in the currently active scene.
-- **"scene-name"** (string; optional) : name of the scene the source belongs to.  defaults to current scene.
-- **"is_local_file"** (bool; optional) : use local file
-- **"url"** (string; optional) : url or file path
-- **"css"** (string; optional) : cascading style sheet code
-- **"width"** (integer; optional) : width
-- **"height"** (integer; optional) : height
-- **"fps"** (integer; optional) : frames per second 
-- **"shutdown"** (bool; optional) : shutdown when sorce is not visible
-- **"render"** (bool; optional) : visibility of the scene item
-
----

README.md

@@ -21,12 +21,13 @@ It is **highly recommended** to protect obs-websocket with a password against un
 
 ### For developers
 The server is a typical Websockets server running by default on port 4444 (the port number can be changed in the Settings dialog). 
-The protocol understood by the server is documented in [PROTOCOL.md](PROTOCOL.md).  
+The protocol understood by the server is documented in [PROTOCOL.md](docs/generated/protocol.md).  
 
 Here's a list of available language APIs for obs-websocket :
-- Javascript (browser & nodejs) : [obs-websocket-js](https://github.com/haganbmj/obs-websocket-js) by Brendan Hagan
-- C#/VB.NET : [obs-websocket-dotnet](https://github.com/Palakis/obs-websocket-dotnet)
-- Python : [obs-websocket-py](https://github.com/Elektordi/obs-websocket-py) by Guillaume Genty a.k.a Elektordi
+- Javascript (browser & nodejs): [obs-websocket-js](https://github.com/haganbmj/obs-websocket-js) by Brendan Hagan
+- C#/VB.NET: [obs-websocket-dotnet](https://github.com/Palakis/obs-websocket-dotnet)
+- Python 2 and 3: [obs-websocket-py](https://github.com/Elektordi/obs-websocket-py) by Guillaume Genty a.k.a Elektordi
+- Python 3.5+ with asyncio: [obs-ws-rc](https://github.com/KirillMysnik/obs-ws-rc) by Kirill Mysnik
 
 I'd like to know what you're building with or for obs-websocket. If you do something in this fashion, feel free to drop me an email at `contact at slepin dot fr` !
 
@@ -38,7 +39,7 @@ See the [build instructions](BUILDING.md).
 
 ## Special thanks
 In order of appearance:
-- [Brendan H.](https://github.com/haganbmj) : Code contributions and better English in the Protocol specification
+- [Brendan H.](https://github.com/haganbmj) : Code contributions and gooder English in the Protocol specification
 - [Mikhail Swift](https://github.com/mikhailswift) : Code contributions
 - [Tobias Frahmer](https://github.com/Frahmer) : German translation
 - [Genture](https://github.com/Genteure) : Simplified Chinese and Traditional Chinese translations
@@ -46,6 +47,10 @@ In order of appearance:
 - [Andy Asquelt](https://github.com/asquelt) : Polish translation
 - [Marcel Haazen](https://github.com/inpothet) : Dutch translation
 - [Peter Antonvich](https://github.com/pantonvich) : Code contributions
+- [yinzara](https://github.com/yinzara) : Code contributions
+- [Chris Angelico](https://github.com/Rosuav) : Code contributions
+- [Guillaume "Elektordi" Genty](https://github.com/Elektordi) : Code contributions
+- [Marwin M](https://github.com/dragonbane0) : Code contributions
 
 And also: special thanks to supporters of the project!
 
@@ -56,10 +61,10 @@ They have contributed financially to the project and made possible the addition
 
 [Support Class](http://supportclass.net) designs and develops professional livestreams, with services ranging from broadcast graphics design and integration to event organization, along many other skills.  
 
-[![Support Class](doc/supportclass_logo_blacktext.png)](http://supportclass.net)
+[![Support Class](.github/images/supportclass_logo_blacktext.png)](http://supportclass.net)
 
 ---
 
 [MediaUnit](http://www.mediaunit.no) is a Norwegian media company developing products and services for the media industry, primarly focused on web and events.  
 
-[![MediaUnit](doc/mediaunit_logo_black.png)](http://www.mediaunit.no/)
+[![MediaUnit](.github/images/mediaunit_logo_black.png)](http://www.mediaunit.no/)

Utils.cpp

@@ -16,507 +16,516 @@ You should have received a copy of the GNU General Public License along
 with this program. If not, see <https://www.gnu.org/licenses/>
 */
 
-#include <obs-frontend-api.h>
-#include <obs.hpp>
 #include <QMainWindow>
 #include <QDir>
 #include <QUrl>
-#include "Utils.h"
+#include <obs-frontend-api.h>
+#include <obs.hpp>
 #include "obs-websocket.h"
 
+#include "Utils.h"
+
 Q_DECLARE_METATYPE(OBSScene);
 
-obs_data_array_t* string_list_to_array(char** strings, char* key)
-{
-	if (!strings)
-		return obs_data_array_create();
+obs_data_array_t* string_list_to_array(char** strings, char* key) {
+    if (!strings)
+        return obs_data_array_create();
 
-	obs_data_array_t* list = obs_data_array_create();
+    obs_data_array_t* list = obs_data_array_create();
 
-	char* value = "";
-	for (int i = 0; value != nullptr; i++)
-	{
-		value = strings[i];
+    char* value = "";
+    for (int i = 0; value != nullptr; i++) {
+        value = strings[i];
 
-		obs_data_t* item = obs_data_create();
-		obs_data_set_string(item, key, value);
+        obs_data_t* item = obs_data_create();
+        obs_data_set_string(item, key, value);
 
-		if (value)
-			obs_data_array_push_back(list, item);
+        if (value)
+            obs_data_array_push_back(list, item);
 
-		obs_data_release(item);
-	}
+        obs_data_release(item);
+    }
 
-	return list;
+    return list;
 }
 
-obs_data_array_t* Utils::GetSceneItems(obs_source_t* source)
-{
-	obs_data_array_t* items = obs_data_array_create();
-	obs_scene_t* scene = obs_scene_from_source(source);
+obs_data_array_t* Utils::GetSceneItems(obs_source_t* source) {
+    obs_data_array_t* items = obs_data_array_create();
+    obs_scene_t* scene = obs_scene_from_source(source);
 
-	if (!scene)
-		return nullptr;
+    if (!scene)
+        return nullptr;
 
-	obs_scene_enum_items(scene, [](obs_scene_t* scene, obs_sceneitem_t* currentItem, void* param)
-	{
-		obs_data_array_t* data = static_cast<obs_data_array_t* >(param);
+    obs_scene_enum_items(scene, [](
+            obs_scene_t* scene,
+            obs_sceneitem_t* currentItem,
+            void* param)
+    {
+        obs_data_array_t* data = static_cast<obs_data_array_t*>(param);
 
-		obs_data_t* item_data = GetSceneItemData(currentItem);
-		obs_data_array_insert(data, 0, item_data);
+        obs_data_t* item_data = GetSceneItemData(currentItem);
+        obs_data_array_insert(data, 0, item_data);
 
-		obs_data_release(item_data);
-		return true;
-	}, items);
+        obs_data_release(item_data);
+        return true;
+    }, items);
 
-	return items;
+    return items;
 }
 
-obs_data_t* Utils::GetSceneItemData(obs_sceneitem_t* item)
-{
-	if (!item)
-		return nullptr;
+obs_data_t* Utils::GetSceneItemData(obs_sceneitem_t* item) {
+    if (!item)
+        return nullptr;
 
-	vec2 pos;
-	obs_sceneitem_get_pos(item, &pos);
+    vec2 pos;
+    obs_sceneitem_get_pos(item, &pos);
 
-	vec2 scale;
-	obs_sceneitem_get_scale(item, &scale);
+    vec2 scale;
+    obs_sceneitem_get_scale(item, &scale);
 
-	obs_source_t* item_source = obs_sceneitem_get_source(item);
-	float item_width = float(obs_source_get_width(item_source));
-	float item_height = float(obs_source_get_height(item_source));
+    obs_source_t* item_source = obs_sceneitem_get_source(item);
+    float item_width = float(obs_source_get_width(item_source));
+    float item_height = float(obs_source_get_height(item_source));
 
-	obs_data_t* data = obs_data_create();
-	obs_data_set_string(data, "name",
-		obs_source_get_name(obs_sceneitem_get_source(item)));
-	obs_data_set_string(data, "type",
-		obs_source_get_id(obs_sceneitem_get_source(item)));
-	obs_data_set_double(data, "volume",
-		obs_source_get_volume(obs_sceneitem_get_source(item)));
-	obs_data_set_double(data, "x", pos.x);
-	obs_data_set_double(data, "y", pos.y);
-	obs_data_set_int(data, "source_cx", (int)item_width);
-	obs_data_set_int(data, "source_cy", (int)item_height);
-	obs_data_set_double(data, "cx", item_width*  scale.x);
-	obs_data_set_double(data, "cy", item_height*  scale.y);
-	obs_data_set_bool(data, "render", obs_sceneitem_visible(item));
+    obs_data_t* data = obs_data_create();
+    obs_data_set_string(data, "name",
+        obs_source_get_name(obs_sceneitem_get_source(item)));
+    obs_data_set_string(data, "type",
+        obs_source_get_id(obs_sceneitem_get_source(item)));
+    obs_data_set_double(data, "volume",
+        obs_source_get_volume(obs_sceneitem_get_source(item)));
+    obs_data_set_double(data, "x", pos.x);
+    obs_data_set_double(data, "y", pos.y);
+    obs_data_set_int(data, "source_cx", (int)item_width);
+    obs_data_set_int(data, "source_cy", (int)item_height);
+    obs_data_set_double(data, "cx", item_width*  scale.x);
+    obs_data_set_double(data, "cy", item_height*  scale.y);
+    obs_data_set_bool(data, "render", obs_sceneitem_visible(item));
 
-	return data;
+    return data;
 }
 
-obs_sceneitem_t* Utils::GetSceneItemFromName(obs_source_t* source, const char* name)
-{
-	struct current_search {
-		const char* query;
-		obs_sceneitem_t* result;
-	};
+obs_sceneitem_t* Utils::GetSceneItemFromName(obs_source_t* source, const char* name) {
+    struct current_search {
+        const char* query;
+        obs_sceneitem_t* result;
+    };
 
-	current_search search;
-	search.query = name;
-	search.result = nullptr;
+    current_search search;
+    search.query = name;
+    search.result = nullptr;
 
-	obs_scene_t* scene = obs_scene_from_source(source);
-	if (scene == nullptr)
-		return nullptr;
+    obs_scene_t* scene = obs_scene_from_source(source);
+    if (scene == nullptr)
+        return nullptr;
 
-	obs_scene_enum_items(scene, [](obs_scene_t* scene, obs_sceneitem_t* currentItem, void* param)
-	{
-		current_search* search = static_cast<current_search* >(param);
+    obs_scene_enum_items(scene, [](
+            obs_scene_t* scene,
+            obs_sceneitem_t* currentItem,
+            void* param)
+    {
+        current_search* search = static_cast<current_search*>(param);
 
-		const char* currentItemName =
-			obs_source_get_name(obs_sceneitem_get_source(currentItem));
+        const char* currentItemName =
+            obs_source_get_name(obs_sceneitem_get_source(currentItem));
 
-		if (strcmp(currentItemName, search->query) == 0)
-		{
-			search->result = currentItem;
-			obs_sceneitem_addref(search->result);
-			return false;
-		}
+        if (strcmp(currentItemName, search->query) == 0) {
+            search->result = currentItem;
+            obs_sceneitem_addref(search->result);
+            return false;
+        }
 
-		return true;
-	}, &search);
+        return true;
+    }, &search);
 
-	return search.result;
+    return search.result;
 }
 
-obs_source_t* Utils::GetTransitionFromName(const char* search_name)
-{
-	obs_source_t* found_transition = NULL;
+obs_source_t* Utils::GetTransitionFromName(const char* search_name) {
+    obs_source_t* found_transition = NULL;
 
-	obs_frontend_source_list transition_list = {};
-	obs_frontend_get_transitions(&transition_list);
+    obs_frontend_source_list transition_list = {};
+    obs_frontend_get_transitions(&transition_list);
 
-	for (size_t i = 0; i < transition_list.sources.num; i++)
-	{
-		obs_source_t* transition = transition_list.sources.array[i];
+    for (size_t i = 0; i < transition_list.sources.num; i++) {
+        obs_source_t* transition = transition_list.sources.array[i];
 
-		const char* transition_name = obs_source_get_name(transition);
-		if (strcmp(transition_name, search_name) == 0)
-		{
-			found_transition = transition;
-			obs_source_addref(found_transition);
-			break;
-		}
-	}
+        const char* transition_name = obs_source_get_name(transition);
+        if (strcmp(transition_name, search_name) == 0)
+        {
+            found_transition = transition;
+            obs_source_addref(found_transition);
+            break;
+        }
+    }
 
-	obs_frontend_source_list_free(&transition_list);
+    obs_frontend_source_list_free(&transition_list);
 
-	return found_transition;
+    return found_transition;
 }
 
-obs_source_t* Utils::GetSceneFromNameOrCurrent(const char* scene_name)
-{
-	obs_source_t* scene = nullptr;
+obs_source_t* Utils::GetSceneFromNameOrCurrent(const char* scene_name) {
+    obs_source_t* scene = nullptr;
 
-	if (!scene_name || !strlen(scene_name))
-		scene = obs_frontend_get_current_scene();
-	else
-		scene = obs_get_source_by_name(scene_name);
+    if (!scene_name || !strlen(scene_name))
+        scene = obs_frontend_get_current_scene();
+    else
+        scene = obs_get_source_by_name(scene_name);
 
-	return scene;
+    return scene;
 }
 
-obs_data_array_t* Utils::GetScenes()
-{
-	obs_frontend_source_list sceneList = {};
-	obs_frontend_get_scenes(&sceneList);
+obs_data_array_t* Utils::GetScenes() {
+    obs_frontend_source_list sceneList = {};
+    obs_frontend_get_scenes(&sceneList);
 
-	obs_data_array_t* scenes = obs_data_array_create();
-	for (size_t i = 0; i < sceneList.sources.num; i++)
-	{
-		obs_source_t* scene = sceneList.sources.array[i];
+    obs_data_array_t* scenes = obs_data_array_create();
+    for (size_t i = 0; i < sceneList.sources.num; i++) {
+        obs_source_t* scene = sceneList.sources.array[i];
 
-		obs_data_t* scene_data = GetSceneData(scene);
-		obs_data_array_push_back(scenes, scene_data);
+        obs_data_t* scene_data = GetSceneData(scene);
+        obs_data_array_push_back(scenes, scene_data);
 
-		obs_data_release(scene_data);
-	}
+        obs_data_release(scene_data);
+    }
 
-	obs_frontend_source_list_free(&sceneList);
+    obs_frontend_source_list_free(&sceneList);
 
-	return scenes;
+    return scenes;
 }
 
-obs_data_t* Utils::GetSceneData(obs_source* source)
-{
-	obs_data_array_t* scene_items = GetSceneItems(source);
+obs_data_t* Utils::GetSceneData(obs_source* source) {
+    obs_data_array_t* scene_items = GetSceneItems(source);
 
-	obs_data_t* sceneData = obs_data_create();
-	obs_data_set_string(sceneData, "name", obs_source_get_name(source));
-	obs_data_set_array(sceneData, "sources", scene_items);
+    obs_data_t* sceneData = obs_data_create();
+    obs_data_set_string(sceneData, "name", obs_source_get_name(source));
+    obs_data_set_array(sceneData, "sources", scene_items);
 
-	obs_data_array_release(scene_items);
-	return sceneData;
+    obs_data_array_release(scene_items);
+    return sceneData;
 }
 
-obs_data_array_t* Utils::GetSceneCollections()
-{
-	char** scene_collections = obs_frontend_get_scene_collections();
-	obs_data_array_t* list = string_list_to_array(scene_collections, "sc-name");
+obs_data_array_t* Utils::GetSceneCollections() {
+    char** scene_collections = obs_frontend_get_scene_collections();
+    obs_data_array_t* list = string_list_to_array(scene_collections, "sc-name");
 
-	bfree(scene_collections);
-	return list;
+    bfree(scene_collections);
+    return list;
 }
 
-obs_data_array_t* Utils::GetProfiles()
-{
-	char** profiles = obs_frontend_get_profiles();
-	obs_data_array_t* list = string_list_to_array(profiles, "profile-name");
+obs_data_array_t* Utils::GetProfiles() {
+    char** profiles = obs_frontend_get_profiles();
+    obs_data_array_t* list = string_list_to_array(profiles, "profile-name");
 
-	bfree(profiles);
-	return list;
+    bfree(profiles);
+    return list;
 }
 
-QSpinBox* Utils::GetTransitionDurationControl()
-{
-	QMainWindow* window = (QMainWindow*)obs_frontend_get_main_window();
-	return window->findChild<QSpinBox*>("transitionDuration");
+QSpinBox* Utils::GetTransitionDurationControl() {
+    QMainWindow* window = (QMainWindow*)obs_frontend_get_main_window();
+    return window->findChild<QSpinBox*>("transitionDuration");
 }
 
-int Utils::GetTransitionDuration()
-{
-	QSpinBox* control = GetTransitionDurationControl();
-	if (control)
-		return control->value();
-	else
-		return -1;
+int Utils::GetTransitionDuration() {
+    QSpinBox* control = GetTransitionDurationControl();
+    if (control)
+        return control->value();
+    else
+        return -1;
 }
 
-void Utils::SetTransitionDuration(int ms)
-{
-	QSpinBox* control = GetTransitionDurationControl();
-
-	if (control && ms >= 0)
-		control->setValue(ms);
+void Utils::SetTransitionDuration(int ms) {
+    QSpinBox* control = GetTransitionDurationControl();
+    if (control && ms >= 0)
+        control->setValue(ms);
 }
 
-bool Utils::SetTransitionByName(const char* transition_name)
-{
-	obs_source_t* transition = GetTransitionFromName(transition_name);
+bool Utils::SetTransitionByName(const char* transition_name) {
+    obs_source_t* transition = GetTransitionFromName(transition_name);
 
-	if (transition)
-	{
-		obs_frontend_set_current_transition(transition);
-		obs_source_release(transition);
-
-		return true;
-	}
-	else
-	{
-		return false;
-	}
+    if (transition) {
+        obs_frontend_set_current_transition(transition);
+        obs_source_release(transition);
+        return true;
+    } else {
+        return false;
+    }
 }
 
-QPushButton* Utils::GetPreviewModeButtonControl()
-{
-	QMainWindow* main = (QMainWindow*)obs_frontend_get_main_window();
-	return main->findChild<QPushButton*>("modeSwitch");
+QPushButton* Utils::GetPreviewModeButtonControl() {
+    QMainWindow* main = (QMainWindow*)obs_frontend_get_main_window();
+    return main->findChild<QPushButton*>("modeSwitch");
 }
 
-QListWidget* Utils::GetSceneListControl()
-{
-	QMainWindow* main = (QMainWindow*)obs_frontend_get_main_window();
-	return main->findChild<QListWidget*>("scenes");
+QListWidget* Utils::GetSceneListControl() {
+    QMainWindow* main = (QMainWindow*)obs_frontend_get_main_window();
+    return main->findChild<QListWidget*>("scenes");
 }
 
-obs_scene_t* Utils::SceneListItemToScene(QListWidgetItem* item)
-{
-	if (!item)
-		return nullptr;
+obs_scene_t* Utils::SceneListItemToScene(QListWidgetItem* item) {
+    if (!item)
+        return nullptr;
 
-	QVariant item_data = item->data(static_cast<int>(Qt::UserRole));
-	return item_data.value<OBSScene>();
+    QVariant item_data = item->data(static_cast<int>(Qt::UserRole));
+    return item_data.value<OBSScene>();
 }
 
-QLayout* Utils::GetPreviewLayout()
-{
-	QMainWindow* main = (QMainWindow*)obs_frontend_get_main_window();
-	return main->findChild<QLayout*>("previewLayout");
+QLayout* Utils::GetPreviewLayout() {
+    QMainWindow* main = (QMainWindow*)obs_frontend_get_main_window();
+    return main->findChild<QLayout*>("previewLayout");
 }
 
-bool Utils::IsPreviewModeActive()
-{
-	QMainWindow* main = (QMainWindow*)obs_frontend_get_main_window();
+bool Utils::IsPreviewModeActive() {
+    QMainWindow* main = (QMainWindow*)obs_frontend_get_main_window();
 
-	// Clue 1 : "Studio Mode" button is toggled on
-	bool buttonToggledOn = GetPreviewModeButtonControl()->isChecked();
+    // Clue 1 : "Studio Mode" button is toggled on
+    bool buttonToggledOn = GetPreviewModeButtonControl()->isChecked();
 
-	// Clue 2 : Preview layout has more than one item
-	int previewChildCount = GetPreviewLayout()->count();
-	blog(LOG_INFO, "preview layout children count : %d", previewChildCount);
+    // Clue 2 : Preview layout has more than one item
+    int previewChildCount = GetPreviewLayout()->count();
+    blog(LOG_INFO, "preview layout children count : %d", previewChildCount);
 
-	return buttonToggledOn || (previewChildCount >= 2);
+    return buttonToggledOn || (previewChildCount >= 2);
 }
 
-void Utils::EnablePreviewMode()
-{
-	if (!IsPreviewModeActive())
-		GetPreviewModeButtonControl()->click();
+void Utils::EnablePreviewMode() {
+    if (!IsPreviewModeActive())
+        GetPreviewModeButtonControl()->click();
 }
 
-void Utils::DisablePreviewMode()
-{
-	if (IsPreviewModeActive())
-		GetPreviewModeButtonControl()->click();
+void Utils::DisablePreviewMode() {
+    if (IsPreviewModeActive())
+        GetPreviewModeButtonControl()->click();
 }
 
-void Utils::TogglePreviewMode()
-{
-	GetPreviewModeButtonControl()->click();
+void Utils::TogglePreviewMode() {
+    GetPreviewModeButtonControl()->click();
 }
 
-obs_scene_t* Utils::GetPreviewScene()
-{
-	if (IsPreviewModeActive())
-	{
-		QListWidget* sceneList = GetSceneListControl();
+obs_scene_t* Utils::GetPreviewScene() {
+    if (IsPreviewModeActive()) {
+        QListWidget* sceneList = GetSceneListControl();
+        QList<QListWidgetItem*> selected = sceneList->selectedItems();
 
-		QList<QListWidgetItem*> selected = sceneList->selectedItems();
+        // Qt::UserRole == QtUserRole::OBSRef
+        obs_scene_t* scene = Utils::SceneListItemToScene(selected.first());
 
-		// Qt::UserRole == QtUserRole::OBSRef
-		obs_scene_t* scene = Utils::SceneListItemToScene(selected.first());
+        obs_scene_addref(scene);
+        return scene;
+    }
 
-		obs_scene_addref(scene);
-		return scene;
-	}
-
-	return nullptr;
+    return nullptr;
 }
 
-bool Utils::SetPreviewScene(const char* name)
-{
-	if (IsPreviewModeActive())
-	{
-		QListWidget* sceneList = GetSceneListControl();
-		QList<QListWidgetItem*> matchingItems =
-			sceneList->findItems(name, Qt::MatchExactly);
+bool Utils::SetPreviewScene(const char* name) {
+    if (IsPreviewModeActive()) {
+        QListWidget* sceneList = GetSceneListControl();
+        QList<QListWidgetItem*> matchingItems =
+            sceneList->findItems(name, Qt::MatchExactly);
 
-		if (matchingItems.count() > 0)
-		{
-			sceneList->setCurrentItem(matchingItems.first());
-			return true;
-		}
-		else
-		{
-			return false;
-		}
-	}
+        if (matchingItems.count() > 0) {
+            sceneList->setCurrentItem(matchingItems.first());
+            return true;
+        } else {
+            return false;
+        }
+    }
 
-	return false;
+    return false;
 }
 
-void Utils::TransitionToProgram()
-{
-	if (!IsPreviewModeActive())
-		return;
+void Utils::TransitionToProgram() {
+    if (!IsPreviewModeActive())
+        return;
 
-	// WARNING : if the layout created in OBS' CreateProgramOptions() changes
-	// then this won't work as expected
+    // WARNING : if the layout created in OBS' CreateProgramOptions() changes
+    // then this won't work as expected
 
-	QMainWindow* main = (QMainWindow*)obs_frontend_get_main_window();
+    QMainWindow* main = (QMainWindow*)obs_frontend_get_main_window();
 
-	// The program options widget is the second item in the left-to-right layout
-	QWidget* programOptions = GetPreviewLayout()->itemAt(1)->widget();
+    // The program options widget is the second item in the left-to-right layout
+    QWidget* programOptions = GetPreviewLayout()->itemAt(1)->widget();
 
-	// The "Transition" button lies in the mainButtonLayout
-	// which is the first itemin the program options' layout
-	QLayout* mainButtonLayout = programOptions->layout()->itemAt(1)->layout();
-	QWidget* transitionBtnWidget = mainButtonLayout->itemAt(0)->widget();
+    // The "Transition" button lies in the mainButtonLayout
+    // which is the first itemin the program options' layout
+    QLayout* mainButtonLayout = programOptions->layout()->itemAt(1)->layout();
+    QWidget* transitionBtnWidget = mainButtonLayout->itemAt(0)->widget();
 
-	// Try to cast that widget into a button
-	QPushButton* transitionBtn = qobject_cast<QPushButton*>(transitionBtnWidget);
+    // Try to cast that widget into a button
+    QPushButton* transitionBtn = qobject_cast<QPushButton*>(transitionBtnWidget);
 
-	// Perform a click on that button
-	transitionBtn->click();
+    // Perform a click on that button
+    transitionBtn->click();
 }
 
 const char* Utils::OBSVersionString() {
-	uint32_t version = obs_get_version();
+    uint32_t version = obs_get_version();
 
-	uint8_t major, minor, patch;
-	major = (version >> 24) & 0xFF;
-	minor = (version >> 16) & 0xFF;
-	patch = version & 0xFF;
+    uint8_t major, minor, patch;
+    major = (version >> 24) & 0xFF;
+    minor = (version >> 16) & 0xFF;
+    patch = version & 0xFF;
 
-	char* result = (char*)bmalloc(sizeof(char) * 12);
-	sprintf(result, "%d.%d.%d", major, minor, patch);
+    char* result = (char*)bmalloc(sizeof(char) * 12);
+    sprintf(result, "%d.%d.%d", major, minor, patch);
 
-	return result;
+    return result;
 }
 
-QSystemTrayIcon* Utils::GetTrayIcon()
-{
-	QMainWindow* main = (QMainWindow*)obs_frontend_get_main_window();
-	return main->findChildren<QSystemTrayIcon*>().first();
+QSystemTrayIcon* Utils::GetTrayIcon() {
+    QMainWindow* main = (QMainWindow*)obs_frontend_get_main_window();
+    return main->findChildren<QSystemTrayIcon*>().first();
 }
 
-void Utils::SysTrayNotify(QString &text, QSystemTrayIcon::MessageIcon icon, QString title)
-{
-	if (!QSystemTrayIcon::supportsMessages())
-		return;
+void Utils::SysTrayNotify(QString &text,
+    QSystemTrayIcon::MessageIcon icon, QString title) {
+    if (!QSystemTrayIcon::supportsMessages())
+        return;
 
-	QSystemTrayIcon* trayIcon = GetTrayIcon();
-	if (trayIcon)
-		trayIcon->showMessage(title, text, icon);
+    QSystemTrayIcon* trayIcon = GetTrayIcon();
+    if (trayIcon)
+        trayIcon->showMessage(title, text, icon);
 }
 
-QString Utils::FormatIPAddress(QHostAddress &addr)
-{
-	if (addr.protocol() == QAbstractSocket::IPv4Protocol)
-		QString v4addr = addr.toString().replace("::fff:", "");
-
-	return addr.toString();
+QString Utils::FormatIPAddress(QHostAddress &addr) {
+    QRegExp v4regex("(::ffff:)(((\\d).){3})", Qt::CaseInsensitive);
+    QString addrString = addr.toString();
+    if (addrString.contains(v4regex)) {
+        addrString = QHostAddress(addr.toIPv4Address()).toString();
+    }
+    return addrString;
 }
 
-const char* Utils::GetRecordingFolder()
-{
-	config_t* profile = obs_frontend_get_profile_config();
-	const char* outputMode = config_get_string(profile, "Output", "Mode");
+const char* Utils::GetRecordingFolder() {
+    config_t* profile = obs_frontend_get_profile_config();
+    const char* outputMode = config_get_string(profile, "Output", "Mode");
 
-	if (strcmp(outputMode, "Advanced") == 0)
-	{
-		// Advanced mode
-		return config_get_string(profile, "AdvOut", "RecFilePath");
-	}
-	else
-	{
-		// Simple mode
-		return config_get_string(profile, "SimpleOutput", "FilePath");
-	}
+    if (strcmp(outputMode, "Advanced") == 0) {
+        // Advanced mode
+        return config_get_string(profile, "AdvOut", "RecFilePath");
+    } else {
+        // Simple mode
+        return config_get_string(profile, "SimpleOutput", "FilePath");
+    }
 }
 
-bool Utils::SetRecordingFolder(const char* path)
-{
-	if (!QDir(path).exists())
-		return false;
+bool Utils::SetRecordingFolder(const char* path) {
+    if (!QDir(path).exists())
+        return false;
 
-	config_t* profile = obs_frontend_get_profile_config();
-	const char* outputMode = config_get_string(profile, "Output", "Mode");
+    config_t* profile = obs_frontend_get_profile_config();
+    const char* outputMode = config_get_string(profile, "Output", "Mode");
 
-	if (strcmp(outputMode, "Advanced") == 0)
-	{
-		config_set_string(profile, "AdvOut", "RecFilePath", path);
-	}
-	else
-	{
-		config_set_string(profile, "SimpleOutput", "FilePath", path);
-	}
+    if (strcmp(outputMode, "Advanced") == 0) {
+        config_set_string(profile, "AdvOut", "RecFilePath", path);
+    } else {
+        config_set_string(profile, "SimpleOutput", "FilePath", path);
+    }
 
-	config_save(profile);
-	return true;
+    config_save(profile);
+    return true;
 }
 
-QString* Utils::ParseDataToQueryString(obs_data_t * data)
-{
-	QString* query = nullptr;
-	if (data)
-	{
-		obs_data_item_t* item = obs_data_first(data);
-		if (item)
-		{
-			query = new QString();
-			bool isFirst = true;
-			do
-			{
-				if (!obs_data_item_has_user_value(item))
-					continue;
-				
-				if (!isFirst)
-					query->append('&');
-				else
-					isFirst = false;
-				
-				const char* attrName = obs_data_item_get_name(item);
-				query->append(attrName).append("=");
-				switch (obs_data_item_gettype(item))
-				{
-					case OBS_DATA_BOOLEAN:
-						query->append(obs_data_item_get_bool(item)?"true":"false");
-						break;
-					case OBS_DATA_NUMBER:
-						switch (obs_data_item_numtype(item))
-						{
-							case OBS_DATA_NUM_DOUBLE:
-								query->append(QString::number(obs_data_item_get_double(item)));
-								break;
-							case OBS_DATA_NUM_INT:
-								query->append(QString::number(obs_data_item_get_int(item)));
-								break;
-							case OBS_DATA_NUM_INVALID:
-								break;
-						}
-						break;
-					case OBS_DATA_STRING:
-						query->append(QUrl::toPercentEncoding(QString(obs_data_item_get_string(item))));
-						break;
-					default:
-						//other types are not supported
-						break;
-				}
-			} while ( obs_data_item_next( &item ) );
-		}
-	}
-	
-	return query;
+QString* Utils::ParseDataToQueryString(obs_data_t* data) {
+    QString* query = nullptr;
+    if (data) {
+        obs_data_item_t* item = obs_data_first(data);
+        if (item) {
+            query = new QString();
+            bool isFirst = true;
+            do {
+                if (!obs_data_item_has_user_value(item))
+                    continue;
+
+                if (!isFirst)
+                    query->append('&');
+                else
+                    isFirst = false;
+
+                const char* attrName = obs_data_item_get_name(item);
+                query->append(attrName).append("=");
+
+                switch (obs_data_item_gettype(item)) {
+                    case OBS_DATA_BOOLEAN:
+                        query->append(obs_data_item_get_bool(item)?"true":"false");
+                        break;
+                    case OBS_DATA_NUMBER:
+                        switch (obs_data_item_numtype(item))
+                        {
+                            case OBS_DATA_NUM_DOUBLE:
+                                query->append(
+                                    QString::number(obs_data_item_get_double(item)));
+                                break;
+                            case OBS_DATA_NUM_INT:
+                                query->append(
+                                    QString::number(obs_data_item_get_int(item)));
+                                break;
+                            case OBS_DATA_NUM_INVALID:
+                                break;
+                        }
+                        break;
+                    case OBS_DATA_STRING:
+                        query->append(QUrl::toPercentEncoding(
+                            QString(obs_data_item_get_string(item))));
+                        break;
+                    default:
+                        //other types are not supported
+                        break;
+                }
+            } while (obs_data_item_next(&item));
+        }
+    }
+    return query;
+}
+
+obs_hotkey_t* Utils::FindHotkeyByName(const char* name) {
+    struct current_search {
+        const char* query;
+        obs_hotkey_t* result;
+    };
+
+    current_search search;
+    search.query = name;
+    search.result = nullptr;
+
+    obs_enum_hotkeys([](void* data, obs_hotkey_id id, obs_hotkey_t* hotkey) {
+        current_search* search = static_cast<current_search*>(data);
+
+        const char* hk_name = obs_hotkey_get_name(hotkey);
+        if (strcmp(hk_name, search->query) == 0) {
+            search->result = hotkey;
+            blog(LOG_INFO, "Utils::FindHotkeyByName: found %s", hk_name);
+            return false;
+        }
+        return true;
+    }, &search);
+
+    return search.result;
+}
+
+bool Utils::ReplayBufferEnabled() {
+    config_t* profile = obs_frontend_get_profile_config();
+    const char* outputMode = config_get_string(profile, "Output", "Mode");
+
+    if (strcmp(outputMode, "Simple") == 0) {
+        return config_get_bool(profile, "SimpleOutput", "RecRB");
+    }
+
+    return false;
+}
+
+bool Utils::RPHotkeySet() {
+    obs_output_t* rp_output = obs_frontend_get_replay_buffer_output();
+    
+    obs_data_t *hotkeys = obs_hotkeys_save_output(rp_output);
+    obs_data_array_t *bindings = obs_data_get_array(hotkeys,
+        "ReplayBuffer.Save");
+
+    size_t count = obs_data_array_count(bindings);
+    
+    obs_data_array_release(bindings);
+    obs_data_release(hotkeys);
+    obs_output_release(rp_output);
+
+    return (count > 0);
 }

Utils.h

@@ -25,59 +25,62 @@ with this program. If not, see <https://www.gnu.org/licenses/>
 #include <QListWidget>
 #include <QSystemTrayIcon>
 #include <QHostAddress>
+
 #include <stdio.h>
 #include <obs-module.h>
 #include <util/config-file.h>
 
-class Utils
-{
-	public:
-		static obs_data_array_t* GetSceneItems(obs_source_t* source);
-		static obs_data_t* GetSceneItemData(obs_scene_item* item);
-		static obs_sceneitem_t* GetSceneItemFromName(
-			obs_source_t* source, const char* name);
-		static obs_source_t* GetTransitionFromName(const char* search_name);
-		static obs_source_t* GetSceneFromNameOrCurrent(const char* scene_name);
+class Utils {
+  public:
+    static obs_data_array_t* GetSceneItems(obs_source_t* source);
+    static obs_data_t* GetSceneItemData(obs_scene_item* item);
+    static obs_sceneitem_t* GetSceneItemFromName(
+        obs_source_t* source, const char* name);
+    static obs_source_t* GetTransitionFromName(const char* search_name);
+    static obs_source_t* GetSceneFromNameOrCurrent(const char* scene_name);
 
-		static obs_data_array_t* GetScenes();
-		static obs_data_t* GetSceneData(obs_source* source);
+    static obs_data_array_t* GetScenes();
+    static obs_data_t* GetSceneData(obs_source* source);
 
-		static obs_data_array_t* GetSceneCollections();
-		static obs_data_array_t* GetProfiles();
+    static obs_data_array_t* GetSceneCollections();
+    static obs_data_array_t* GetProfiles();
+    
+    static QSpinBox* GetTransitionDurationControl();
+    static int GetTransitionDuration();
+    static void SetTransitionDuration(int ms);
 
-		static QSpinBox* GetTransitionDurationControl();
-		static int GetTransitionDuration();
-		static void SetTransitionDuration(int ms);
+    static bool SetTransitionByName(const char* transition_name);
 
-		static bool SetTransitionByName(const char* transition_name);
+    static QPushButton* GetPreviewModeButtonControl();
+    static QLayout* GetPreviewLayout();
+    static QListWidget* GetSceneListControl();
+    static obs_scene_t* SceneListItemToScene(QListWidgetItem* item);
 
-		static QPushButton* GetPreviewModeButtonControl();
-		static QLayout* GetPreviewLayout();
-		static QListWidget* GetSceneListControl();
-		static obs_scene_t* SceneListItemToScene(QListWidgetItem* item);
+    static bool IsPreviewModeActive();
+    static void EnablePreviewMode();
+    static void DisablePreviewMode();
+    static void TogglePreviewMode();
 
-		static bool IsPreviewModeActive();
-		static void EnablePreviewMode();
-		static void DisablePreviewMode();
-		static void TogglePreviewMode();
+    static obs_scene_t* GetPreviewScene();
+    static bool SetPreviewScene(const char* name);
+    static void TransitionToProgram();
 
-		static obs_scene_t* GetPreviewScene();
-		static bool SetPreviewScene(const char* name);
-		static void TransitionToProgram();
+    static const char* OBSVersionString();
 
-		static const char* OBSVersionString();
+    static QSystemTrayIcon* GetTrayIcon();
+    static void SysTrayNotify(
+        QString &text,
+        QSystemTrayIcon::MessageIcon n,
+        QString title = QString("obs-websocket"));
 
-		static QSystemTrayIcon* GetTrayIcon();
-		static void SysTrayNotify(
-			QString &text,
-			QSystemTrayIcon::MessageIcon n,
-			QString title = QString("obs-websocket"));
+    static QString FormatIPAddress(QHostAddress &addr);
+    static const char* GetRecordingFolder();
+    static bool SetRecordingFolder(const char* path);
 
-		static QString FormatIPAddress(QHostAddress &addr);
-		static const char* GetRecordingFolder();
-		static bool SetRecordingFolder(const char* path);
-	
-		static QString* ParseDataToQueryString(obs_data_t * data);
+    static QString* ParseDataToQueryString(obs_data_t * data);
+    static obs_hotkey_t* FindHotkeyByName(const char* name);
+    static bool ReplayBufferEnabled();
+    static bool RPHotkeySet();
 };
 
 #endif // UTILS_H

WSEvents.h

@@ -22,80 +22,84 @@ with this program. If not, see <https://www.gnu.org/licenses/>
 
 #include <obs-frontend-api.h>
 #include <QListWidgetItem>
+
 #include "WSServer.h"
 
-class WSEvents : public QObject
-{
-	Q_OBJECT
+class WSEvents : public QObject {
+  Q_OBJECT
+  public:
+    explicit WSEvents(WSServer* srv);
+    ~WSEvents();
+    static void FrontendEventHandler(
+        enum obs_frontend_event event, void* private_data);
+    void connectTransitionSignals(obs_source_t* transition);
+    void connectSceneSignals(obs_source_t* scene);
+    static WSEvents* Instance;
 
-	public:
-		explicit WSEvents(WSServer* srv);
-		~WSEvents();
-		static void FrontendEventHandler(
-			enum obs_frontend_event event, void* private_data);
-		void connectTransitionSignals(obs_source_t* transition);
-		void connectSceneSignals(obs_source_t* scene);
-		static WSEvents* Instance;
+    uint64_t GetStreamingTime();
+    const char* GetStreamingTimecode();
+    uint64_t GetRecordingTime();
+    const char* GetRecordingTimecode();
 
-		uint64_t GetStreamingTime();
-		const char* GetStreamingTimecode();
-		uint64_t GetRecordingTime();
-		const char* GetRecordingTimecode();
+  private slots:
+    void deferredInitOperations();
+    void StreamStatus();
+    void TransitionDurationChanged(int ms);
+    void SelectedSceneChanged(
+        QListWidgetItem* current, QListWidgetItem* prev);
+    void ModeSwitchClicked(bool checked);
 
-	private Q_SLOTS:
-		void deferredInitOperations();
-		void StreamStatus();
-		void TransitionDurationChanged(int ms);
-		void SelectedSceneChanged(
-			QListWidgetItem* current, QListWidgetItem* prev);
-		void ModeSwitchClicked(bool checked);
+  private:
+    WSServer* _srv;
+    signal_handler_t* transition_handler;
+    signal_handler_t* scene_handler;
 
-	private:
-		WSServer* _srv;
-		signal_handler_t* transition_handler;
-		signal_handler_t* scene_handler;
+    bool _streaming_active;
+    bool _recording_active;
 
-		bool _streaming_active;
-		bool _recording_active;
+    uint64_t _stream_starttime;
+    uint64_t _rec_starttime;
 
-		uint64_t _stream_starttime;
-		uint64_t _rec_starttime;
+    uint64_t _lastBytesSent;
+    uint64_t _lastBytesSentTime;
 
-		uint64_t _lastBytesSent;
-		uint64_t _lastBytesSentTime;
+    void broadcastUpdate(const char* updateType,
+        obs_data_t* additionalFields);
 
-		void broadcastUpdate(const char* updateType,
-			obs_data_t* additionalFields);
+    void OnSceneChange();
+    void OnSceneListChange();
+    void OnSceneCollectionChange();
+    void OnSceneCollectionListChange();
 
-		void OnSceneChange();
-		void OnSceneListChange();
-		void OnSceneCollectionChange();
-		void OnSceneCollectionListChange();
+    void OnTransitionChange();
+    void OnTransitionListChange();
 
-		void OnTransitionChange();
-		void OnTransitionListChange();
+    void OnProfileChange();
+    void OnProfileListChange();
 
-		void OnProfileChange();
-		void OnProfileListChange();
+    void OnStreamStarting();
+    void OnStreamStarted();
+    void OnStreamStopping();
+    void OnStreamStopped();
 
-		void OnStreamStarting();
-		void OnStreamStarted();
-		void OnStreamStopping();
-		void OnStreamStopped();
+    void OnRecordingStarting();
+    void OnRecordingStarted();
+    void OnRecordingStopping();
+    void OnRecordingStopped();
 
-		void OnRecordingStarting();
-		void OnRecordingStarted();
-		void OnRecordingStopping();
-		void OnRecordingStopped();
+    void OnReplayStarting();
+    void OnReplayStarted();
+    void OnReplayStopping();
+    void OnReplayStopped();
 
-		void OnExit();
+    void OnExit();
 
-		static void OnTransitionBegin(void* param, calldata_t* data);
+    static void OnTransitionBegin(void* param, calldata_t* data);
 
-		static void OnSceneReordered(void* param, calldata_t* data);
-		static void OnSceneItemAdd(void* param, calldata_t* data);
-		static void OnSceneItemDelete(void* param, calldata_t* data);
-		static void OnSceneItemVisibilityChanged(void* param, calldata_t* data);
+    static void OnSceneReordered(void* param, calldata_t* data);
+    static void OnSceneItemAdd(void* param, calldata_t* data);
+    static void OnSceneItemDelete(void* param, calldata_t* data);
+    static void OnSceneItemVisibilityChanged(void* param, calldata_t* data);
 };
 
 #endif // WSEVENTS_H

WSRequestHandler.h

@@ -20,97 +20,105 @@ with this program. If not, see <https://www.gnu.org/licenses/>
 #ifndef WSREQUESTHANDLER_H
 #define WSREQUESTHANDLER_H
 
+#include <QMap>
+#include <QWebSocket>
+#include <QWebSocketServer>
+
 #include <obs-frontend-api.h>
 
-#include <QtWebSockets/QWebSocket>
-#include <QtWebSockets/QWebSocketServer>
+class WSRequestHandler : public QObject {
+  Q_OBJECT
 
-class WSRequestHandler : public QObject
-{
-	Q_OBJECT
+  public:
+    explicit WSRequestHandler(QWebSocket* client);
+    ~WSRequestHandler();
+    void processIncomingMessage(QString textMessage);
+    bool hasField(const char* name);
 
-	public:
-		explicit WSRequestHandler(QWebSocket* client);
-		~WSRequestHandler();
-		void processIncomingMessage(QString textMessage);
-		bool hasField(const char* name);
+  private:
+    static obs_service_t* _service;
+    QWebSocket* _client;
+    const char* _messageId;
+    const char* _requestType;
+    obs_data_t* data;
 
-	private:
-		static obs_service_t* _service;
-		QWebSocket* _client;
-		const char* _messageId;
-		const char* _requestType;
-		obs_data_t* data;
+    QMap<QString, void(*)(WSRequestHandler*)> messageMap;
+    QSet<QString> authNotRequired;
 
-		QMap<QString, void(*)(WSRequestHandler*)> messageMap;
-		QSet<QString> authNotRequired;
+    void SendOKResponse(obs_data_t* additionalFields = NULL);
+    void SendErrorResponse(const char* errorMessage);
+    void SendResponse(obs_data_t* response);
 
-		void SendOKResponse(obs_data_t* additionalFields = NULL);
-		void SendErrorResponse(const char* errorMessage);
-		void SendResponse(obs_data_t* response);
+    static void HandleGetVersion(WSRequestHandler* req);
+    static void HandleGetAuthRequired(WSRequestHandler* req);
+    static void HandleAuthenticate(WSRequestHandler* req);
 
-		static void HandleGetVersion(WSRequestHandler* req);
-		static void HandleGetAuthRequired(WSRequestHandler* req);
-		static void HandleAuthenticate(WSRequestHandler* req);
+    static void HandleSetCurrentScene(WSRequestHandler* req);
+    static void HandleGetCurrentScene(WSRequestHandler* req);
+    static void HandleGetSceneList(WSRequestHandler* req);
 
-		static void HandleSetCurrentScene(WSRequestHandler* req);
-		static void HandleGetCurrentScene(WSRequestHandler* req);
-		static void HandleGetSceneList(WSRequestHandler* req);
+    static void HandleSetSceneItemRender(WSRequestHandler* req);
+    static void HandleSetSceneItemPosition(WSRequestHandler* req);
+    static void HandleSetSceneItemTransform(WSRequestHandler* req);
+    static void HandleSetSceneItemCrop(WSRequestHandler* req);
+    static void HandleResetSceneItem(WSRequestHandler* req);
 
-		static void HandleSetSceneItemRender(WSRequestHandler* req);
-		static void HandleSetSceneItemPosition(WSRequestHandler* req);
-		static void HandleSetSceneItemTransform(WSRequestHandler* req);
-		static void HandleSetSceneItemCrop(WSRequestHandler* req);
+    static void HandleGetStreamingStatus(WSRequestHandler* req);
+    static void HandleStartStopStreaming(WSRequestHandler* req);
+    static void HandleStartStopRecording(WSRequestHandler* req);
+    static void HandleStartStreaming(WSRequestHandler* req);
+    static void HandleStopStreaming(WSRequestHandler* req);
+    static void HandleStartRecording(WSRequestHandler* req);
+    static void HandleStopRecording(WSRequestHandler* req);
 
-		static void HandleGetStreamingStatus(WSRequestHandler* req);
-		static void HandleStartStopStreaming(WSRequestHandler* req);
-		static void HandleStartStopRecording(WSRequestHandler* req);
-		static void HandleStartStreaming(WSRequestHandler* req);
-		static void HandleStopStreaming(WSRequestHandler* req);
-		static void HandleStartRecording(WSRequestHandler* req);
-		static void HandleStopRecording(WSRequestHandler* req);
+    static void HandleStartStopReplayBuffer(WSRequestHandler* req);
+    static void HandleStartReplayBuffer(WSRequestHandler* req);
+    static void HandleStopReplayBuffer(WSRequestHandler* req);
+    static void HandleSaveReplayBuffer(WSRequestHandler* req);
 
-		static void HandleSetRecordingFolder(WSRequestHandler* req);
-		static void HandleGetRecordingFolder(WSRequestHandler* req);
+    static void HandleSetRecordingFolder(WSRequestHandler* req);
+    static void HandleGetRecordingFolder(WSRequestHandler* req);
 
-		static void HandleGetTransitionList(WSRequestHandler* req);
-		static void HandleGetCurrentTransition(WSRequestHandler* req);
-		static void HandleSetCurrentTransition(WSRequestHandler* req);
+    static void HandleGetTransitionList(WSRequestHandler* req);
+    static void HandleGetCurrentTransition(WSRequestHandler* req);
+    static void HandleSetCurrentTransition(WSRequestHandler* req);
 
-		static void HandleSetVolume(WSRequestHandler* req);
-		static void HandleGetVolume(WSRequestHandler* req);
-		static void HandleToggleMute(WSRequestHandler* req);
-		static void HandleSetMute(WSRequestHandler* req);
-		static void HandleGetMute(WSRequestHandler* req);
-		static void HandleGetSpecialSources(WSRequestHandler* req);
+    static void HandleSetVolume(WSRequestHandler* req);
+    static void HandleGetVolume(WSRequestHandler* req);
+    static void HandleToggleMute(WSRequestHandler* req);
+    static void HandleSetMute(WSRequestHandler* req);
+    static void HandleGetMute(WSRequestHandler* req);
+    static void HandleSetSyncOffset(WSRequestHandler* req);
+    static void HandleGetSyncOffset(WSRequestHandler* req);
+    static void HandleGetSpecialSources(WSRequestHandler* req);
 
-		static void HandleSetCurrentSceneCollection(WSRequestHandler* req);
-		static void HandleGetCurrentSceneCollection(WSRequestHandler* req);
-		static void HandleListSceneCollections(WSRequestHandler* req);
+    static void HandleSetCurrentSceneCollection(WSRequestHandler* req);
+    static void HandleGetCurrentSceneCollection(WSRequestHandler* req);
+    static void HandleListSceneCollections(WSRequestHandler* req);
 
-		static void HandleSetCurrentProfile(WSRequestHandler* req);
-		static void HandleGetCurrentProfile(WSRequestHandler* req);
-		static void HandleListProfiles(WSRequestHandler* req);
+    static void HandleSetCurrentProfile(WSRequestHandler* req);
+    static void HandleGetCurrentProfile(WSRequestHandler* req);
+    static void HandleListProfiles(WSRequestHandler* req);
 
-		static void HandleSetStreamSettings(WSRequestHandler* req);
-		static void HandleGetStreamSettings(WSRequestHandler* req);
-		static void HandleSaveStreamSettings(WSRequestHandler* req);
+    static void HandleSetStreamSettings(WSRequestHandler* req);
+    static void HandleGetStreamSettings(WSRequestHandler* req);
+    static void HandleSaveStreamSettings(WSRequestHandler* req);
 
-		static void HandleSetTransitionDuration(WSRequestHandler* req);
-		static void HandleGetTransitionDuration(WSRequestHandler* req);
+    static void HandleSetTransitionDuration(WSRequestHandler* req);
+    static void HandleGetTransitionDuration(WSRequestHandler* req);
 
-		static void HandleGetStudioModeStatus(WSRequestHandler* req);
-		static void HandleGetPreviewScene(WSRequestHandler* req);
-		static void HandleSetPreviewScene(WSRequestHandler* req);
-		static void HandleTransitionToProgram(WSRequestHandler* req);
-		static void HandleEnableStudioMode(WSRequestHandler* req);
-		static void HandleDisableStudioMode(WSRequestHandler* req);
-		static void HandleToggleStudioMode(WSRequestHandler* req);
-		
-		static void HandleSetTextGDIPlusProperties(WSRequestHandler* req);
-		static void HandleGetTextGDIPlusProperties(WSRequestHandler* req);
-		static void HandleSetBrowserSourceProperties(WSRequestHandler* req);
-		static void HandleGetBrowserSourceProperties(WSRequestHandler* req);
+    static void HandleGetStudioModeStatus(WSRequestHandler* req);
+    static void HandleGetPreviewScene(WSRequestHandler* req);
+    static void HandleSetPreviewScene(WSRequestHandler* req);
+    static void HandleTransitionToProgram(WSRequestHandler* req);
+    static void HandleEnableStudioMode(WSRequestHandler* req);
+    static void HandleDisableStudioMode(WSRequestHandler* req);
+    static void HandleToggleStudioMode(WSRequestHandler* req);
+        
+    static void HandleSetTextGDIPlusProperties(WSRequestHandler* req);
+    static void HandleGetTextGDIPlusProperties(WSRequestHandler* req);
+    static void HandleSetBrowserSourceProperties(WSRequestHandler* req);
+    static void HandleGetBrowserSourceProperties(WSRequestHandler* req);
 };
 
 #endif // WSPROTOCOL_H

WSServer.cpp

@@ -30,142 +30,118 @@ QT_USE_NAMESPACE
 
 WSServer* WSServer::Instance = nullptr;
 
-WSServer::WSServer(QObject* parent) :
-	QObject(parent),
-	_wsServer(Q_NULLPTR),
-	_clients(),
-	_clMutex(QMutex::Recursive)
-{
-	_serverThread = new QThread();
-
-	_wsServer = new QWebSocketServer(
-		QStringLiteral("obs-websocket"),
-		QWebSocketServer::NonSecureMode,
-		_serverThread);
-
-	_serverThread->start();
+WSServer::WSServer(QObject* parent)
+    : QObject(parent),
+      _wsServer(Q_NULLPTR),
+      _clients(),
+      _clMutex(QMutex::Recursive) {
+    _wsServer = new QWebSocketServer(
+        QStringLiteral("obs-websocket"),
+        QWebSocketServer::NonSecureMode);
 }
 
-WSServer::~WSServer()
-{
-	Stop();
-	delete _serverThread;
+WSServer::~WSServer() {
+    Stop();
 }
 
-void WSServer::Start(quint16 port)
-{
-	if (port == _wsServer->serverPort())
-		return;
+void WSServer::Start(quint16 port) {
+    if (port == _wsServer->serverPort())
+        return;
 
-	if(_wsServer->isListening())
-		Stop();
+    if(_wsServer->isListening())
+        Stop();
 
-	bool serverStarted = _wsServer->listen(QHostAddress::Any, port);
-	if (serverStarted)
-	{
-		connect(_wsServer, &QWebSocketServer::newConnection,
-			this, &WSServer::onNewConnection);
-	}
+    bool serverStarted = _wsServer->listen(QHostAddress::Any, port);
+    if (serverStarted) {
+        connect(_wsServer, SIGNAL(newConnection()),
+            this, SLOT(onNewConnection()));
+    }
 }
 
-void WSServer::Stop()
-{
-	_clMutex.lock();
-	for(QWebSocket* pClient : _clients) {
-		pClient->close();
-	}
-	_clMutex.unlock();
+void WSServer::Stop() {
+    _clMutex.lock();
+    for(QWebSocket* pClient : _clients) {
+        pClient->close();
+    }
+    _clMutex.unlock();
 
-	_wsServer->close();
+    _wsServer->close();
 }
 
-void WSServer::broadcast(QString message)
-{
-	_clMutex.lock();
-
-	for(QWebSocket* pClient : _clients) {
-		if (Config::Current()->AuthRequired
-			&& (pClient->property(PROP_AUTHENTICATED).toBool() == false))
-		{
-			// Skip this client if unauthenticated
-			continue;
-		}
-
-		pClient->sendTextMessage(message);
-	}
-
-	_clMutex.unlock();
+void WSServer::broadcast(QString message) {
+    _clMutex.lock();
+    for(QWebSocket* pClient : _clients) {
+        if (Config::Current()->AuthRequired
+            && (pClient->property(PROP_AUTHENTICATED).toBool() == false)) {
+            // Skip this client if unauthenticated
+            continue;
+        }
+        pClient->sendTextMessage(message);
+    }
+    _clMutex.unlock();
 }
 
-void WSServer::onNewConnection()
-{
-	QWebSocket* pSocket = _wsServer->nextPendingConnection();
+void WSServer::onNewConnection() {
+    QWebSocket* pSocket = _wsServer->nextPendingConnection();
+    if (pSocket) {
+        connect(pSocket, SIGNAL(textMessageReceived(const QString&)),
+            this, SLOT(onTextMessageReceived(QString)));
+        connect(pSocket, SIGNAL(disconnected()),
+            this, SLOT(onSocketDisconnected()));
 
-	if (pSocket)
-	{
-		connect(pSocket, &QWebSocket::textMessageReceived,
-			this, &WSServer::textMessageReceived);
-		connect(pSocket, &QWebSocket::disconnected,
-			this, &WSServer::socketDisconnected);
-		pSocket->setProperty(PROP_AUTHENTICATED, false);
+        pSocket->setProperty(PROP_AUTHENTICATED, false);
 
-		_clMutex.lock();
-		_clients << pSocket;
-		_clMutex.unlock();
+        _clMutex.lock();
+        _clients << pSocket;
+        _clMutex.unlock();
 
-		QHostAddress clientAddr = pSocket->peerAddress();
-		QString clientIp = Utils::FormatIPAddress(clientAddr);
+        QHostAddress clientAddr = pSocket->peerAddress();
+        QString clientIp = Utils::FormatIPAddress(clientAddr);
 
-		blog(LOG_INFO, "new client connection from %s:%d",
-			clientIp.toUtf8().constData(), pSocket->peerPort());
+        blog(LOG_INFO, "new client connection from %s:%d",
+            clientIp.toUtf8().constData(), pSocket->peerPort());
 
-		QString msg = QString(obs_module_text("OBSWebsocket.ConnectNotify.ClientIP"))
-			+ QString(" ")
-			+ clientAddr.toString();
+        QString msg = QString(obs_module_text("OBSWebsocket.ConnectNotify.ClientIP"))
+            + QString(" ")
+            + Utils::FormatIPAddress(clientAddr);
 
-		Utils::SysTrayNotify(msg,
-			QSystemTrayIcon::Information,
-			QString(obs_module_text("OBSWebsocket.ConnectNotify.Connected")));
-	}
+        Utils::SysTrayNotify(msg,
+            QSystemTrayIcon::Information,
+            QString(obs_module_text("OBSWebsocket.ConnectNotify.Connected")));
+    }
 }
 
-void WSServer::textMessageReceived(QString message)
-{
-	QWebSocket* pSocket = qobject_cast<QWebSocket*>(sender());
-
-	if (pSocket)
-	{
-		WSRequestHandler handler(pSocket);
-		handler.processIncomingMessage(message);
-	}
+void WSServer::onTextMessageReceived(QString message) {
+    QWebSocket* pSocket = qobject_cast<QWebSocket*>(sender());
+    if (pSocket) {
+        WSRequestHandler handler(pSocket);
+        handler.processIncomingMessage(message);
+    }
 }
 
-void WSServer::socketDisconnected()
-{
-	QWebSocket* pSocket = qobject_cast<QWebSocket*>(sender());
+void WSServer::onSocketDisconnected() {
+    QWebSocket* pSocket = qobject_cast<QWebSocket*>(sender());
+    if (pSocket) {
+        pSocket->setProperty(PROP_AUTHENTICATED, false);
 
-	if (pSocket)
-	{
-		pSocket->setProperty(PROP_AUTHENTICATED, false);
+        _clMutex.lock();
+        _clients.removeAll(pSocket);
+        _clMutex.unlock();
 
-		_clMutex.lock();
-		_clients.removeAll(pSocket);
-		_clMutex.unlock();
+        pSocket->deleteLater();
 
-		pSocket->deleteLater();
+        QHostAddress clientAddr = pSocket->peerAddress();
+        QString clientIp = Utils::FormatIPAddress(clientAddr);
 
-		QHostAddress clientAddr = pSocket->peerAddress();
-		QString clientIp = Utils::FormatIPAddress(clientAddr);
+        blog(LOG_INFO, "client %s:%d disconnected",
+            clientIp.toUtf8().constData(), pSocket->peerPort());
 
-		blog(LOG_INFO, "client %s:%d disconnected",
-			clientIp.toUtf8().constData(), pSocket->peerPort());
+        QString msg = QString(obs_module_text("OBSWebsocket.ConnectNotify.ClientIP"))
+            + QString(" ")
+            + Utils::FormatIPAddress(clientAddr);
 
-		QString msg = QString(obs_module_text("OBSWebsocket.ConnectNotify.ClientIP"))
-			+ QString(" ")
-			+ clientAddr.toString();
-
-		Utils::SysTrayNotify(msg,
-			QSystemTrayIcon::Information,
-			QString(obs_module_text("OBSWebsocket.ConnectNotify.Disconnected")));
-	}
+        Utils::SysTrayNotify(msg,
+            QSystemTrayIcon::Information,
+            QString(obs_module_text("OBSWebsocket.ConnectNotify.Disconnected")));
+    }
 }

WSServer.h

@@ -19,37 +19,34 @@ with this program. If not, see <https://www.gnu.org/licenses/>
 #ifndef WSSERVER_H
 #define WSSERVER_H
 
-#include <QtCore/QObject>
-#include <QtCore/QList>
-#include <QtCore/QMutex>
+#include <QObject>
+#include <QList>
+#include <QMutex>
+
+#include "WSRequestHandler.h"
 
 QT_FORWARD_DECLARE_CLASS(QWebSocketServer)
 QT_FORWARD_DECLARE_CLASS(QWebSocket)
 
-#include "WSRequestHandler.h"
+class WSServer : public QObject {
+  Q_OBJECT
+  public:
+    explicit WSServer(QObject* parent = Q_NULLPTR);
+    virtual ~WSServer();
+    void Start(quint16 port);
+    void Stop();
+    void broadcast(QString message);
+    static WSServer* Instance;
 
-class WSServer : public QObject
-{
-	Q_OBJECT
+  private slots:
+    void onNewConnection();
+    void onTextMessageReceived(QString message);
+    void onSocketDisconnected();
 
-	public:
-		explicit WSServer(QObject* parent = Q_NULLPTR);
-		virtual ~WSServer();
-		void Start(quint16 port);
-		void Stop();
-		void broadcast(QString message);
-		static WSServer* Instance;
-
-	private Q_SLOTS:
-		void onNewConnection();
-		void textMessageReceived(QString message);
-		void socketDisconnected();
-
-	private:
-		QWebSocketServer* _wsServer;
-		QList<QWebSocket*> _clients;
-		QMutex _clMutex;
-		QThread* _serverThread;
+  private:
+    QWebSocketServer* _wsServer;
+    QList<QWebSocket*> _clients;
+    QMutex _clMutex;
 };
 
 #endif // WSSERVER_H

appveyor.yml

@@ -15,7 +15,7 @@ install:
   - set build_config=Release
   - git clone --recursive https://github.com/jp9000/obs-studio
   - cd C:\projects\obs-studio\
-  - git checkout 19.0.2
+  - git checkout 19.0.3
   - mkdir build
   - mkdir build32
   - mkdir build64

docs/.editorconfig

@@ -0,0 +1,11 @@
+[*]
+end_of_line = lf
+charset = utf-8
+indent_style = space
+indent_size = 4
+trim_trailing_whitespace = true
+insert_final_newline = true
+
+[*.md, *.mustache]
+trim_trailing_whitespace = false
+insert_final_newline = false

docs/.gitignore

@@ -0,0 +1,4 @@
+node_modules
+logs
+*.log
+npm-debug.log*

docs/.npmrc

@@ -0,0 +1 @@
+package-lock=false

docs/README.md

@@ -0,0 +1,21 @@
+## Installation
+
+Install node and update npm if necessary.
+
+```sh
+cd obs-websocket/docs
+npm install
+```
+
+## Build
+
+```sh
+# Just extract the comments.
+npm run comments
+
+# Just render the markdown.
+npm run docs
+
+# Do both comments and markdown.
+npm run build
+```

docs/comments.js

@@ -0,0 +1,52 @@
+const fs = require('fs');
+const glob = require('glob');
+const parseComments = require('parse-comments');
+
+/**
+ * Read each file and call `parse-comments` on it.
+ *
+ * @param  {String|Array} `files` List of file paths to read from.
+ * @return {Object|Array}         Array of `parse-comments` objects.
+ */
+const parseFiles = files => {
+    let response = [];
+    files.forEach(file => {
+        const f = fs.readFileSync(file, 'utf8').toString();
+        response = response.concat(parseComments(f));
+    });
+
+    return response;
+};
+
+/**
+ * Filters/sorts the results from `parse-comments`.
+ * @param  {Object|Array} `comments` Array of `parse-comments` objects.
+ * @return {Object}                  Filtered comments sorted by `@api` and `@category`.
+ */
+const processComments = comments => {
+    let sorted = {};
+
+    comments.forEach(comment => {
+        if (typeof comment.api === 'undefined') return;
+
+        // Store the object based on its api (ie. requests, events) and category (ie. general, scenes, etc).
+        comment.category = comment.category || 'miscellaneous';
+
+        // Remove some unnecessary properties to avoid result differences in travis.
+        comment.comment = undefined;
+        comment.context = undefined;
+
+        // Create an entry in sorted for the api/category if one does not exist.
+        sorted[comment.api] = sorted[comment.api] || {};
+        sorted[comment.api][comment.category] = sorted[comment.api][comment.category] || [];
+
+        // Store the comment in the appropriate api/category.
+        sorted[comment.api][comment.category].push(comment);
+    });
+
+    return sorted;
+};
+
+const files = glob.sync("./../*.@(cpp|h)");
+const comments = processComments(parseFiles(files));
+fs.writeFileSync('./generated/comments.json', JSON.stringify(comments, null, 2));

docs/docs.js

@@ -0,0 +1,31 @@
+const fs = require('fs');
+const toc = require('markdown-toc');
+const handlebars = require('handlebars');
+
+const helpers = require('handlebars-helpers')({
+  handlebars: handlebars
+});
+
+// Allows pipe characters to be used within markdown tables.
+handlebars.registerHelper('depipe', (text) => {
+    return text.replace('|', `\\|`);
+});
+
+const insertHeader = (text) => {
+    return '<!-- This file was generated based on handlebars templates. Do not edit directly! -->\n\n' + text;
+};
+
+/**
+ * Writes `protocol.md` using `protocol.mustache`.
+ *
+ * @param  {Object} `data` Data to assign to the mustache template.
+ */
+const generateProtocol = (templatePath, data) => {
+    const template = fs.readFileSync(templatePath).toString();
+    const generated = handlebars.compile(template)(data);
+    return insertHeader(toc.insert(generated));
+};
+
+const comments = fs.readFileSync('./generated/comments.json', 'utf8');
+const markdown = generateProtocol('./protocol.hbs', JSON.parse(comments));
+fs.writeFileSync('./generated/protocol.md', markdown);

docs/package.json

@@ -0,0 +1,21 @@
+{
+  "name": "obs-websocket-docs",
+  "version": "1.0.0",
+  "description": "",
+  "main": "docs.js",
+  "scripts": {
+    "test": "echo \"Error: no test specified\" && exit 1",
+    "docs": "node ./docs.js",
+    "comments": "node ./comments.js",
+    "build": "npm run comments && npm run docs"
+  },
+  "author": "",
+  "license": "ISC",
+  "dependencies": {
+    "glob": "^7.1.2",
+    "handlebars": "^4.0.10",
+    "handlebars-helpers": "^0.9.6",
+    "markdown-toc": "^1.1.0",
+    "parse-comments": "^0.4.3"
+  }
+}

docs/partials/eventsHeader.md

@@ -0,0 +1,11 @@
+# Events
+Events are broadcast by the server to each connected client when a recognized action occurs within OBS.
+
+An event message will contain at least the following base fields:
+- `update-type` _String_: the type of event.
+- `stream-timecode` _String (optional)_: time elapsed between now and stream start (only present if OBS Studio is streaming).
+- `rec-timecode` _String (optional)_: time elapsed between now and recording start (only present if OBS Studio is recording).
+
+Timecodes are sent using the format: `HH:MM:SS.mmm`
+
+Additional fields may be present in the event message depending on the event type.

docs/partials/introduction.md

@@ -0,0 +1,39 @@
+# obs-websocket 4.2.0 protocol reference
+
+**This is the reference for obs-websocket 4.2.0. See the list below for older versions.**
+- [4.1.0 protocol reference](https://github.com/Palakis/obs-websocket/blob/4.1.0/PROTOCOL.md)
+- [4.0.0 protocol reference](https://github.com/Palakis/obs-websocket/blob/4.0.0/PROTOCOL.md)
+
+# General Introduction
+Messages are exchanged between the client and the server as JSON objects.
+This protocol is based on the original OBS Remote protocol created by Bill Hamilton, with new commands specific to OBS Studio.
+
+
+# Authentication
+OBSWebSocket uses SHA256 to transmit credentials.
+
+A request for [`GetAuthRequired`](#getauthrequired) returns two elements:
+- A `challenge`: a random string that will be used to generate the auth response.
+- A `salt`: applied to the password when generating the auth response.
+
+To generate the answer to the auth challenge, follow this procedure:
+- Concatenate the user declared password with the `salt` sent by the server (in this order: `password + server salt`).
+- Generate a binary SHA256 hash of the result and encode the resulting SHA256 binary hash to base64, known as a `base64 secret`.
+- Concatenate the base64 secret with the `challenge` sent by the server (in this order: `base64 secret + server challenge`).
+- Generate a binary SHA256 hash of the result and encode it to base64.
+- Voilà, this last base64 string is the `auth response`. You may now use it to authenticate to the server with the [`Authenticate`](#authenticate) request.
+
+Pseudo Code Example:
+```
+password = "supersecretpassword"
+challenge = "ztTBnnuqrqaKDzRM3xcVdbYm"
+salt = "PZVbYpvAnZut2SS6JNJytDm9"
+
+secret_string = password + salt
+secret_hash = binary_sha256(secret_string)
+secret = base64_encode(secret_hash)
+
+auth_response_string = secret + challenge
+auth_response_hash = binary_sha256(auth_response_string)
+auth_response = base64_encode(auth_response_hash)
+```

docs/partials/requestsHeader.md

@@ -0,0 +1,11 @@
+# Requests
+Requests are sent by the client and require at least the following two fields:
+- `request-type` _String_: String name of the request type.
+- `message-id` _String_: Client defined identifier for the message, will be echoed in the response.
+
+Once a request is sent, the server will return a JSON response with at least the following fields:
+- `message-id` _String_: The client defined identifier specified in the request.
+- `status` _String_: Response status, will be one of the following: `ok`, `error`
+- `error` _String_: An error message accompanying an `error` status.
+
+Additional information may be required/returned depending on the request type. See below for more information.

docs/protocol.hbs

@@ -0,0 +1,92 @@
+{{#read "partials/introduction.md"}}{{/read}}
+
+
+
+# Table of Contents
+<!-- toc -->
+
+
+
+{{#read "partials/eventsHeader.md"}}{{/read}}
+
+{{#each events}}
+## {{capitalizeAll @key}}
+
+{{#each this}}
+### {{name}}
+
+{{#eq since "unreleased"}}
+- Unreleased
+{{else}}
+- Added in v{{since}}
+{{/eq}}
+
+{{{description}}}
+
+**Response Items:**
+
+{{#if returns.length}}
+| Name | Type  | Description |
+| ---- | :---: | ------------|
+{{#each returns}}
+| `{{name}}` | _{{depipe type}}_ | {{{description}}} |
+{{/each}}
+
+{{else}}
+_No additional response items._
+{{/if}}
+
+---
+
+{{/each}}
+{{/each}}
+
+
+
+{{#read "partials/requestsHeader.md"}}{{/read}}
+
+{{#each requests}}
+## {{capitalizeAll @key}}
+
+{{#each this}}
+### {{name}}
+
+{{#eq since "unreleased"}}
+- Unreleased
+{{else}}
+- Added in v{{since}}
+{{/eq}}
+
+{{{description}}}
+
+**Request Fields:**
+
+{{#if params.length}}
+| Name | Type  | Description |
+| ---- | :---: | ------------|
+{{#each params}}
+| `{{name}}` | _{{depipe type}}_ | {{{description}}} |
+{{/each}}
+
+{{else}}
+_No specified parameters._
+{{/if}}
+
+**Response Items:**
+
+{{#if returns.length}}
+| Name | Type  | Description |
+| ---- | :---: | ------------|
+{{#each returns}}
+| `{{name}}` | _{{depipe type}}_ | {{{description}}} |
+{{/each}}
+
+{{else}}
+_No additional response items._
+{{/if}}
+
+---
+
+{{/each}}
+{{/each}}
+

forms/settings-dialog.cpp

@@ -27,87 +27,87 @@ with this program. If not, see <https://www.gnu.org/licenses/>
 #define CHANGE_ME "changeme"
 
 SettingsDialog::SettingsDialog(QWidget* parent) :
-	QDialog(parent, Qt::Dialog),
-	ui(new Ui::SettingsDialog)
+    QDialog(parent, Qt::Dialog),
+    ui(new Ui::SettingsDialog)
 {
-	ui->setupUi(this);
+    ui->setupUi(this);
 
-	connect(ui->authRequired, &QCheckBox::stateChanged,
-		this, &SettingsDialog::AuthCheckboxChanged);
-	connect(ui->buttonBox, &QDialogButtonBox::accepted,
-		this, &SettingsDialog::FormAccepted);
+    connect(ui->authRequired, &QCheckBox::stateChanged,
+        this, &SettingsDialog::AuthCheckboxChanged);
+    connect(ui->buttonBox, &QDialogButtonBox::accepted,
+        this, &SettingsDialog::FormAccepted);
 
 
-	AuthCheckboxChanged();
+    AuthCheckboxChanged();
 }
 
 void SettingsDialog::showEvent(QShowEvent* event)
 {
-	Config* conf = Config::Current();
+    Config* conf = Config::Current();
 
-	ui->serverEnabled->setChecked(conf->ServerEnabled);
-	ui->serverPort->setValue(conf->ServerPort);
-	
-	ui->debugEnabled->setChecked(conf->DebugEnabled);
+    ui->serverEnabled->setChecked(conf->ServerEnabled);
+    ui->serverPort->setValue(conf->ServerPort);
+    
+    ui->debugEnabled->setChecked(conf->DebugEnabled);
 
-	ui->authRequired->setChecked(conf->AuthRequired);
-	ui->password->setText(CHANGE_ME);
+    ui->authRequired->setChecked(conf->AuthRequired);
+    ui->password->setText(CHANGE_ME);
 }
 
 void SettingsDialog::ToggleShowHide()
 {
-	if (!isVisible())
-		setVisible(true);
-	else
-		setVisible(false);
+    if (!isVisible())
+        setVisible(true);
+    else
+        setVisible(false);
 }
 
 void SettingsDialog::AuthCheckboxChanged()
 {
-	if (ui->authRequired->isChecked())
-		ui->password->setEnabled(true);
-	else
-		ui->password->setEnabled(false);
+    if (ui->authRequired->isChecked())
+        ui->password->setEnabled(true);
+    else
+        ui->password->setEnabled(false);
 }
 
 void SettingsDialog::FormAccepted()
 {
-	Config* conf = Config::Current();
+    Config* conf = Config::Current();
 
-	conf->ServerEnabled = ui->serverEnabled->isChecked();
-	conf->ServerPort = ui->serverPort->value();
-	
-	conf->DebugEnabled = ui->debugEnabled->isChecked();
+    conf->ServerEnabled = ui->serverEnabled->isChecked();
+    conf->ServerPort = ui->serverPort->value();
+    
+    conf->DebugEnabled = ui->debugEnabled->isChecked();
 
-	if (ui->authRequired->isChecked())
-	{
-		if (ui->password->text() != CHANGE_ME)
-		{
-			QByteArray pwd = ui->password->text().toUtf8();
-			const char *new_password = pwd;
+    if (ui->authRequired->isChecked())
+    {
+        if (ui->password->text() != CHANGE_ME)
+        {
+            QByteArray pwd = ui->password->text().toUtf8();
+            const char *new_password = pwd;
 
-			conf->SetPassword(new_password);
-		}
+            conf->SetPassword(new_password);
+        }
 
-		if (strcmp(Config::Current()->Secret, "") != 0)
-			conf->AuthRequired = true;
-		else
-			conf->AuthRequired = false;
-	}
-	else
-	{
-		conf->AuthRequired = false;
-	}
+        if (strcmp(Config::Current()->Secret, "") != 0)
+            conf->AuthRequired = true;
+        else
+            conf->AuthRequired = false;
+    }
+    else
+    {
+        conf->AuthRequired = false;
+    }
 
-	conf->Save();
+    conf->Save();
 
-	if (conf->ServerEnabled)
-		WSServer::Instance->Start(conf->ServerPort);
-	else
-		WSServer::Instance->Stop();
+    if (conf->ServerEnabled)
+        WSServer::Instance->Start(conf->ServerPort);
+    else
+        WSServer::Instance->Stop();
 }
 
 SettingsDialog::~SettingsDialog()
 {
-	delete ui;
+    delete ui;
 }

forms/settings-dialog.h

@@ -27,20 +27,20 @@ class SettingsDialog;
 
 class SettingsDialog : public QDialog
 {
-	Q_OBJECT
+    Q_OBJECT
 
 public:
-	explicit SettingsDialog(QWidget* parent = 0);
-	~SettingsDialog();
-	void showEvent(QShowEvent* event);
-	void ToggleShowHide();
+    explicit SettingsDialog(QWidget* parent = 0);
+    ~SettingsDialog();
+    void showEvent(QShowEvent* event);
+    void ToggleShowHide();
 
 private Q_SLOTS:
-	void AuthCheckboxChanged();
-	void FormAccepted();
+    void AuthCheckboxChanged();
+    void FormAccepted();
 
 private:
-	Ui::SettingsDialog* ui;
+    Ui::SettingsDialog* ui;
 };
 
 #endif // SETTINGSDIALOG_H

installer/installer.iss

@@ -2,7 +2,7 @@
 ; SEE THE DOCUMENTATION FOR DETAILS ON CREATING INNO SETUP SCRIPT FILES!
 
 #define MyAppName "obs-websocket"
-#define MyAppVersion "4.0.0"
+#define MyAppVersion "4.2.0"
 #define MyAppPublisher "St<53>phane Lepin"
 #define MyAppURL "http://github.com/Palakis/obs-websocket"
 

obs-websocket.cpp

@@ -31,44 +31,44 @@ with this program. If not, see <https://www.gnu.org/licenses/>
 OBS_DECLARE_MODULE()
 OBS_MODULE_USE_DEFAULT_LOCALE("obs-websocket", "en-US")
 
-SettingsDialog *settings_dialog;
+SettingsDialog* settings_dialog;
 
-bool obs_module_load(void) 
-{
-	blog(LOG_INFO, "you can haz websockets (version %s)", OBS_WEBSOCKET_VERSION);
+bool obs_module_load(void) {
+    blog(LOG_INFO, "you can haz websockets (version %s)", OBS_WEBSOCKET_VERSION);
+    blog(LOG_INFO, "qt version (compile-time): %s ; qt version (run-time): %s",
+        QT_VERSION_STR, qVersion());
 
-	// Core setup
-	Config* config = Config::Current();
-	config->Load();
+    // Core setup
+    Config* config = Config::Current();
+    config->Load();
 
-	WSServer::Instance = new WSServer();
-	WSEvents::Instance = new WSEvents(WSServer::Instance);
+    WSServer::Instance = new WSServer();
+    WSEvents::Instance = new WSEvents(WSServer::Instance);
 
-	if (config->ServerEnabled)
-		WSServer::Instance->Start(config->ServerPort);
+    if (config->ServerEnabled)
+        WSServer::Instance->Start(config->ServerPort);
 
-	// UI setup
-	QAction *menu_action = (QAction*)obs_frontend_add_tools_menu_qaction(
-		obs_module_text("OBSWebsocket.Menu.SettingsItem"));
+    // UI setup
+    QAction* menu_action = (QAction*)obs_frontend_add_tools_menu_qaction(
+        obs_module_text("OBSWebsocket.Menu.SettingsItem"));
 
-	obs_frontend_push_ui_translation(obs_module_get_string);
-	QMainWindow* main_window = (QMainWindow*)obs_frontend_get_main_window();
-	settings_dialog = new SettingsDialog(main_window);
-	obs_frontend_pop_ui_translation();
+    obs_frontend_push_ui_translation(obs_module_get_string);
+    QMainWindow* main_window = (QMainWindow*)obs_frontend_get_main_window();
+    settings_dialog = new SettingsDialog(main_window);
+    obs_frontend_pop_ui_translation();
 
-	auto menu_cb = [] {
-		settings_dialog->ToggleShowHide();
-	};
-	menu_action->connect(menu_action, &QAction::triggered, menu_cb);
+    auto menu_cb = [] {
+        settings_dialog->ToggleShowHide();
+    };
+    menu_action->connect(menu_action, &QAction::triggered, menu_cb);
 
-	// Loading finished
-	blog(LOG_INFO, "module loaded!");
+    // Loading finished
+    blog(LOG_INFO, "module loaded!");
 
-	return true;
+    return true;
 }
 
-void obs_module_unload()
-{
-	blog(LOG_INFO, "goodbye!");
+void obs_module_unload() {
+    blog(LOG_INFO, "goodbye!");
 }
 

obs-websocket.h

@@ -20,8 +20,7 @@ with this program. If not, see <https://www.gnu.org/licenses/>
 #define OBSWEBSOCKET_H
 
 #define PROP_AUTHENTICATED "wsclient_authenticated"
-#define OBS_WEBSOCKET_VERSION "4.1.0"
-#define API_VERSION 1.3
+#define OBS_WEBSOCKET_VERSION "4.2.0"
 
 #define blog(level, msg, ...) blog(level, "[obs-websocket] " msg, ##__VA_ARGS__)