websocket.c

Go to the documentation of this file.

 
#include <ascii-chat/log/websocket.h>
#include <ascii-chat/log/log.h>
#include <libwebsockets.h>
#include <string.h>

static void websocket_server_lws_log_callback(int level, const char *line) {
  if (!line) {
    return;
  }
 
  // Strip leading timestamp (format: "[timestamp] message")
  const char *msg = line;
  if (line[0] == '[') {
    // Find the closing bracket
    const char *bracket = strchr(line, ']');
    if (bracket && bracket[1] == ' ') {
      msg = bracket + 2; // Skip "] "
    }
  }
 
  // Strip trailing newlines
  size_t len = strlen(msg);
  while (len > 0 && (msg[len - 1] == '\n' || msg[len - 1] == '\r')) {
    len--;
  }
 
  if (level & LLL_ERR) {
    log_error("[LWS:server] %.*s", (int)len, msg);
  } else if (level & LLL_WARN) {
    log_warn("[LWS:server] %.*s", (int)len, msg);
  } else if (level & LLL_NOTICE) {
    log_info("[LWS:server] %.*s", (int)len, msg);
  } else if (level & LLL_INFO) {
    log_dev("[LWS:server] %.*s", (int)len, msg);
  } else if (level & LLL_DEBUG) {
    log_debug("[LWS:server] %.*s", (int)len, msg);
  }
}

static void websocket_client_lws_log_callback(int level, const char *line) {
  if (!line) {
    return;
  }
 
  // Strip leading timestamp (format: "[timestamp] message")
  const char *msg = line;
  if (line[0] == '[') {
    // Find the closing bracket
    const char *bracket = strchr(line, ']');
    if (bracket && bracket[1] == ' ') {
      msg = bracket + 2; // Skip "] "
    }
  }
 
  // Strip trailing newlines
  size_t len = strlen(msg);
  while (len > 0 && (msg[len - 1] == '\n' || msg[len - 1] == '\r')) {
    len--;
  }
 
  if (level & LLL_ERR) {
    log_error("[LWS:client] %.*s", (int)len, msg);
  } else if (level & LLL_WARN) {
    log_warn("[LWS:client] %.*s", (int)len, msg);
  } else if (level & LLL_NOTICE) {
    log_info("[LWS:client] %.*s", (int)len, msg);
  } else if (level & LLL_INFO) {
    log_dev("[LWS:client] %.*s", (int)len, msg);
  } else if (level & LLL_DEBUG) {
    log_debug("[LWS:client] %.*s", (int)len, msg);
  }
}
 
void lws_log_init_server(void) {
  // Enable libwebsockets logging with our custom callback
  // Keep libwebsockets protocol chatter out of normal logs. NOTICE still
  // reports lifecycle events; detailed traces remain available in dev builds.
#ifdef CMAKE_BUILD_TYPE_DEBUG
  int log_level = LLL_ERR | LLL_WARN | LLL_NOTICE | LLL_DEBUG;
#else
  int log_level = LLL_ERR | LLL_WARN | LLL_NOTICE;
#endif
  lws_set_log_level(log_level, websocket_server_lws_log_callback);
}
 
void lws_log_init_client(void) {
  // Enable libwebsockets logging with our custom callback
  // Keep libwebsockets protocol chatter out of normal logs. NOTICE still
  // reports lifecycle events; detailed traces remain available in dev builds.
#ifdef CMAKE_BUILD_TYPE_DEBUG
  int log_level = LLL_ERR | LLL_WARN | LLL_NOTICE | LLL_DEBUG;
#else
  int log_level = LLL_ERR | LLL_WARN | LLL_NOTICE;
#endif
  lws_set_log_level(log_level, websocket_client_lws_log_callback);
}