/**
 * @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
 */
#define _GNU_SOURCE
#include <string.h>
#include <stdio.h>
#include <stdlib.h>
#include <pthread.h>
#include <libwebsockets.h>
#include "websocket-global.h"
#include "bacnet/basic/sys/debug.h"

#if LWS_MAX_SMP <= 1
#warning \
    "Libwebsockets must be built with LWS_MAX_SMP > 1 (otherwise it does not support thread synchronization in correct way)"
#endif

static pthread_mutex_t websocket_mutex = PTHREAD_RECURSIVE_MUTEX_INITIALIZER_NP;
static pthread_mutex_t websocket_dispatch_mutex =
    PTHREAD_RECURSIVE_MUTEX_INITIALIZER_NP;

#if (BSC_DEBUG_WEBSOCKET_MUTEX_ENABLED != 1)

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

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

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

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

#else
static volatile int websocket_mutex_cnt = 0;
static volatile int websocket_dispatch_mutex_cnt = 0;

void bsc_websocket_global_lock_dbg(char *f, int line)
{
    debug_printf(
        "bsc_websocket_global_lock_dbg() >>> %s:%d lock_cnt %d tid = %ld\n", f,
        line, websocket_mutex_cnt, pthread_self());
    websocket_mutex_cnt++;
    fflush(stdout);
    pthread_mutex_lock(&websocket_mutex);
    debug_printf(
        "bsc_websocket_global_lock_dbg() <<< lock_cnt %d tid = %ld\n",
        websocket_mutex_cnt, pthread_self());
    fflush(stdout);
}

void bsc_websocket_global_unlock_dbg(char *f, int line)
{
    debug_printf(
        "bsc_websocket_global_unlock_dbg() >>> %s:%d lock_cnt %d tid = %ld\n",
        f, line, websocket_mutex_cnt, pthread_self());
    websocket_mutex_cnt--;
    fflush(stdout);
    pthread_mutex_unlock(&websocket_mutex);
    debug_printf(
        "bsc_websocket_global_unlock_dbg() <<< lock_cnt %d tid = %ld\n",
        websocket_mutex_cnt, pthread_self());
    fflush(stdout);
}

void bws_dispatch_lock_dbg(char *f, int line)
{
    debug_printf(
        "bws_dispatch_lock_dbg() >>> %s:%d lock_cnt %d tid = %ld\n", f, line,
        websocket_dispatch_mutex_cnt, pthread_self());
    websocket_dispatch_mutex_cnt++;
    fflush(stdout);
    pthread_mutex_lock(&websocket_dispatch_mutex);
    debug_printf(
        "bws_dispatch_lock_dbg() <<< lock_cnt %d tid = %ld\n",
        websocket_dispatch_mutex_cnt, pthread_self());
    fflush(stdout);
}

void bws_dispatch_unlock_dbg(char *f, int line)
{
    debug_printf(
        "bws_dispatch_unlock_dbg() >>> %s:%d lock_cnt %d  tid = %ld\n", f, line,
        websocket_dispatch_mutex_cnt, pthread_self());
    websocket_dispatch_mutex_cnt--;
    fflush(stdout);
    pthread_mutex_unlock(&websocket_dispatch_mutex);
    debug_printf(
        "bws_dispatch_unlock_dbg() <<< lock_cnt %d tid = %ld\n",
        websocket_dispatch_mutex_cnt, pthread_self());
    fflush(stdout);
}

#endif

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
        debug_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();
}