/* This work is licensed under a Creative Commons CCZero 1.0 Universal License.

 * See http://creativecommons.org/publicdomain/zero/1.0/ for more information.

 *

 *    Copyright 2016-2018 (c) Fraunhofer IOSB (Author: Julius Pfrommer)

 *    Copyright 2017 (c) Thomas Stalder, Blue Time Concept SA

 */

#include <open62541/plugin/log_stdout.h>

#include <open62541/types.h>

#include <stdio.h>

#include "mp_printf.h"

/* ANSI escape sequences for color output taken from here:

 * https://stackoverflow.com/questions/3219393/stdlib-and-colored-output-in-c*/

#ifdef UA_ARCHITECTURE_POSIX

# define ANSI_COLOR_RED     "\x1b[31m"

# define ANSI_COLOR_GREEN   "\x1b[32m"

# define ANSI_COLOR_YELLOW  "\x1b[33m"

# define ANSI_COLOR_BLUE    "\x1b[34m"

# define ANSI_COLOR_MAGENTA "\x1b[35m"

# define ANSI_COLOR_CYAN    "\x1b[36m"

# define ANSI_COLOR_RESET   "\x1b[0m"

#else

# define ANSI_COLOR_RED     ""

# define ANSI_COLOR_GREEN   ""

# define ANSI_COLOR_YELLOW  ""

# define ANSI_COLOR_BLUE    ""

# define ANSI_COLOR_MAGENTA ""

# define ANSI_COLOR_CYAN    ""

# define ANSI_COLOR_RESET   ""

#endif

static

const char *logLevelNames[6] = {"trace", "debug",

                                ANSI_COLOR_GREEN "info",

                                ANSI_COLOR_YELLOW "warn",

                                ANSI_COLOR_RED "error",

                                ANSI_COLOR_MAGENTA "fatal"};

static const char *

logCategoryNames[UA_LOGCATEGORIES] =

    {"network", "channel", "session", "server", "client",

     "userland", "security", "eventloop", "pubsub", "discovery"};

/* Protect crosstalk during logging via global lock. Use a spinlock as we cannot

 * statically initialize a global lock across all platforms. */

#if UA_MULTITHREADING >= 100

void *logSpinLock = NULL;

static UA_INLINE void spinLock(void) {

    while(UA_atomic_cmpxchg(&logSpinLock, NULL, (void*)0x1) != NULL) {}

}

static UA_INLINE void spinUnLock(void) {

    UA_atomic_xchg(&logSpinLock, NULL);

}

#endif

#ifdef __clang__

__attribute__((__format__(__printf__, 4 , 0)))

#endif

static void

UA_Log_Stdout_log(void *context, UA_LogLevel level, UA_LogCategory category,

                  const char *msg, va_list args) {

    /* MinLevel encoded in the context pointer */

    UA_LogLevel minLevel = (UA_LogLevel)(uintptr_t)context;

    if(minLevel > level)

        return;

    UA_Int64 tOffset = UA_DateTime_localTimeUtcOffset();

    UA_DateTimeStruct dts = UA_DateTime_toStruct(UA_DateTime_now() + tOffset);

    int logLevelSlot = ((int)level / 100) - 1;

    if(logLevelSlot < 0 || logLevelSlot > 5)

        logLevelSlot = 5; /* Set to fatal if the level is outside the range */

    /* Lock */

#if UA_MULTITHREADING >= 100

    spinLock();

#endif

#define STDOUT_LOGBUFSIZE 512

    char logbuf[STDOUT_LOGBUFSIZE];

    /* Log */

    printf("[%04u-%02u-%02u %02u:%02u:%02u.%03u (UTC%+05d)] %s/%s" ANSI_COLOR_RESET "\t",

           dts.year, dts.month, dts.day, dts.hour, dts.min, dts.sec, dts.milliSec,

           (int)(tOffset / UA_DATETIME_SEC / 36), logLevelNames[logLevelSlot],

           logCategoryNames[category]);

    mp_vsnprintf(logbuf, STDOUT_LOGBUFSIZE, msg, args);

    printf("%s\n", logbuf);

    fflush(stdout);

    /* Unlock */

#if UA_MULTITHREADING >= 100

    spinUnLock();

#endif

}

static void

UA_Log_Stdout_clear(UA_Logger *logger) {

    UA_free(logger);

}

const UA_Logger UA_Log_Stdout_ = {UA_Log_Stdout_log, NULL, NULL};

const UA_Logger *UA_Log_Stdout = &UA_Log_Stdout_;

UA_Logger

UA_Log_Stdout_withLevel(UA_LogLevel minlevel) {

    UA_Logger logger =

        {UA_Log_Stdout_log, (void*)(uintptr_t)minlevel, NULL};

    return logger;

}

UA_Logger *

UA_Log_Stdout_new(UA_LogLevel minlevel) {

    UA_Logger *logger = (UA_Logger*)UA_malloc(sizeof(UA_Logger));

    if(!logger)

        return NULL;

    *logger = UA_Log_Stdout_withLevel(minlevel);

    logger->clear = UA_Log_Stdout_clear;

    return logger;

}