/**
 * @file
 * @brief Implementation of global websocket functions.
 * @author Kirill Neznamov <kirill.neznamov@dsr-corporation.com>
 * @date May 2022
 * @copyright SPDX-License-Identifier: GPL-2.0-or-later WITH GCC-exception-2.0
 */
#include <libwebsockets.h>
#include <string.h>
#include <stdio.h>
#include <stdlib.h>
#include <windows.h>
#include "websocket-global.h"

static HANDLE websocket_mutex = NULL;
static HANDLE websocket_dispatch_mutex = NULL;

static void bsc_init_mutex(volatile HANDLE *m)
{
    HANDLE p;
    if (*m == NULL) {
        p = CreateMutex(NULL, FALSE, NULL);
        if (InterlockedCompareExchangePointer((PVOID *)m, (PVOID)p, NULL) !=
            NULL) {
            CloseHandle(p);
        }
    }
}

void bsc_mutex_lock(volatile HANDLE *m)
{
    bsc_init_mutex(m);
    WaitForSingleObject(*m, INFINITE);
}

void bsc_mutex_unlock(volatile HANDLE *m)
{
    ReleaseMutex(*m);
}

void bsc_websocket_global_lock(void)
{
    bsc_mutex_lock(&websocket_mutex);
}

void bsc_websocket_global_unlock(void)
{
    bsc_mutex_unlock(&websocket_mutex);
}

void bws_dispatch_lock(void)
{
    bsc_mutex_lock(&websocket_dispatch_mutex);
}

void bws_dispatch_unlock(void)
{
    bsc_mutex_unlock(&websocket_dispatch_mutex);
}

static BOOL bsc_websocket_log_initialized = FALSE;

void bsc_websocket_init_log(void)
{
    bsc_websocket_global_lock();
    if (!bsc_websocket_log_initialized) {
        bsc_websocket_log_initialized = TRUE;
#if DEBUG_LIBWEBSOCKETS_ENABLED == 1
        printf("LWS_MAX_SMP = %d", LWS_MAX_SMP);
        lws_set_log_level(
            LLL_ERR | LLL_WARN | LLL_NOTICE | LLL_INFO | LLL_DEBUG |
                LLL_PARSER | LLL_HEADER | LLL_EXT | LLL_CLIENT | LLL_LATENCY |
                LLL_USER | LLL_THREAD,
            NULL);
#else
        lws_set_log_level(0, NULL);
#endif
    }
    bsc_websocket_global_unlock();
}