native_http_access_log.c

Go to the documentation of this file.

/**
 * @file
 * @brief Implements native access log and error log helpers.
 */
 
#include "native_http_access_log.h"
 
#include "native_artifact_emit.h"
#include "native_fs.h"
#include "native_http_log.h"
#include "native_support.h"
 
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <time.h>
 
#ifdef _WIN32
#include <sys/time.h>
#define native_http_access_log_strdup _strdup
#else
#include <sys/time.h>
#define native_http_access_log_strdup strdup
#endif
 
static int close_logged_file_native(FILE *file) {
  if (file == NULL) {
    return 0;
  }
  if (ferror(file)) {
    fclose(file);
    return -1;
  }
  return fclose(file) == 0 ? 0 : -1;
}
 
static char *access_timestamp_native(void) {
  struct timeval tv;
  struct tm tm_utc;
  char buffer[32];
  gettimeofday(&tv, NULL);
#ifdef _WIN32
  gmtime_s(&tm_utc, (const time_t *)&tv.tv_sec);
#else
  gmtime_r(&tv.tv_sec, &tm_utc);
#endif
  strftime(buffer, sizeof(buffer), "%Y%m%d.%H%M%S.", &tm_utc);
  snprintf(buffer + strlen(buffer), sizeof(buffer) - strlen(buffer), "%03ld", (long)(tv.tv_usec / 1000));
  return native_http_access_log_strdup(buffer);
}
 
static char *resolved_error_report_path_native(const char *app_id, const char *error_report_path) {
  if (error_report_path != NULL && error_report_path[0] != '\0') {
    return native_http_access_log_strdup(error_report_path);
  }
  {
    size_t needed = strlen("/var/log/pharos/.error.jsonl") + strlen(app_id != NULL && app_id[0] != '\0' ? app_id : "app") + 1;
    char *resolved = (char *)malloc(needed);
    if (resolved != NULL) {
      snprintf(resolved, needed, "/var/log/pharos/%s.error.jsonl", app_id != NULL && app_id[0] != '\0' ? app_id : "app");
    }
    return resolved;
  }
}
 
static void write_error_report_native(const char *app_id, const char *error_report_path, const HttpRequest *request, const char *request_path, const char *status_text, const char *reason, const char *resource_path, const char *detail_text) {
  char *resolved_path = NULL;
  char *timestamp = NULL;
  char *real_ip = NULL;
  char *app_id_json = NULL;
  char *timestamp_json = NULL;
  char *status_json = NULL;
  char *reason_json = NULL;
  char *method_json = NULL;
  char *path_json = NULL;
  char *client_ip_json = NULL;
  char *resource_path_json = NULL;
  char *detail_json = NULL;
  FILE *file = NULL;
  char *dir = NULL;
  if (request == NULL) {
    return;
  }
  resolved_path = resolved_error_report_path_native(app_id, error_report_path);
  if (resolved_path == NULL) {
    return;
  }
  dir = path_dirname(resolved_path);
  if (dir == NULL || ensure_directory(dir) != 0) {
    free(dir);
    free(resolved_path);
    {
      const char *fallback_app = app_id != NULL && app_id[0] != '\0' ? app_id : "app";
      size_t needed = strlen("/tmp/pharos/.error.jsonl") + strlen(fallback_app) + 1;
      resolved_path = (char *)malloc(needed);
      if (resolved_path == NULL) {
        return;
      }
      snprintf(resolved_path, needed, "/tmp/pharos/%s.error.jsonl", fallback_app);
      dir = path_dirname(resolved_path);
      if (dir != NULL) {
        ensure_directory(dir);
      }
    }
  }
  free(dir);
  file = fopen(resolved_path, "ab");
  free(resolved_path);
  if (file == NULL) {
    return;
  }
  timestamp = access_timestamp_native();
  real_ip = request_real_ip_native(request->headers);
  app_id_json = json_string_dup_native(app_id != NULL && app_id[0] != '\0' ? app_id : "app");
  timestamp_json = json_string_dup_native(timestamp != NULL ? timestamp : "");
  status_json = json_string_dup_native(status_text != NULL ? status_text : "500 Internal Server Error");
  reason_json = json_string_dup_native(reason != NULL ? reason : "http_response");
  method_json = json_string_dup_native(request->method != NULL ? request->method : "");
  path_json = json_string_dup_native(request_path != NULL ? request_path : "");
  client_ip_json = json_string_dup_native(real_ip != NULL ? real_ip : "unknown");
  resource_path_json = (resource_path != NULL && resource_path[0] != '\0') ? json_string_dup_native(resource_path) : native_http_access_log_strdup("null");
  detail_json = (detail_text != NULL && detail_text[0] != '\0') ? json_string_dup_native(detail_text) : native_http_access_log_strdup("null");
  if (app_id_json != NULL && timestamp_json != NULL && status_json != NULL && reason_json != NULL && method_json != NULL && path_json != NULL && client_ip_json != NULL && resource_path_json != NULL && detail_json != NULL) {
    if (fprintf(file, "{\"timestamp\":%s,\"app_id\":%s,\"status\":%s,\"reason\":%s,\"method\":%s,\"path\":%s,\"client_ip\":%s,\"resource_path\":%s,\"detail\":%s}\n", timestamp_json, app_id_json, status_json, reason_json, method_json, path_json, client_ip_json, resource_path_json, detail_json) < 0) {
      clearerr(file);
    }
  }
  free(timestamp);
  free(real_ip);
  free(app_id_json);
  free(timestamp_json);
  free(status_json);
  free(reason_json);
  free(method_json);
  free(path_json);
  free(client_ip_json);
  free(resource_path_json);
  free(detail_json);
  close_logged_file_native(file);
}
 
void native_write_error_log(const char *log_path, const char *error_report_path, const char *app_id, const HttpRequest *request, const char *request_path, const char *status_text, const char *reason, const char *resource_path, const char *detail_text) {
  FILE *file;
  char *timestamp = NULL;
  char *real_ip = NULL;
  char *headers_with_ip = NULL;
  char *headers_compact = NULL;
  char *dir = NULL;
  if (log_path == NULL || log_path[0] == '\0' || request == NULL) {
    return;
  }
  dir = path_dirname(log_path);
  if (dir != NULL) {
    ensure_directory(dir);
  }
  free(dir);
  file = fopen(log_path, "ab");
  if (file == NULL) {
    return;
  }
  timestamp = access_timestamp_native();
  real_ip = request_real_ip_native(request->headers);
  headers_with_ip = request_headers_with_client_ip_native(request->headers, real_ip);
  headers_compact = compact_log_text_native(headers_with_ip != NULL ? headers_with_ip : request->headers);
  if (timestamp != NULL && real_ip != NULL && headers_compact != NULL) {
    fprintf(
      file,
      "%s error app=%s status: \"%s\" method: \"%s\" path: \"%s\" headers: \"%s\" reason: \"%s\"",
      timestamp,
      app_id != NULL && app_id[0] != '\0' ? app_id : "app",
      status_text != NULL ? status_text : "500 Internal Server Error",
      request->method != NULL ? request->method : "",
      request_path != NULL ? request_path : "",
      headers_compact,
      reason != NULL ? reason : "http_response"
    );
    if (resource_path != NULL && resource_path[0] != '\0') {
      fprintf(file, " resource: \"%s\"", resource_path);
    }
    if (detail_text != NULL && detail_text[0] != '\0') {
      char *detail_compact = compact_log_text_native(detail_text);
      if (detail_compact != NULL) {
        fprintf(file, " detail: \"%s\"", detail_compact);
      }
      free(detail_compact);
    }
    fputc('\n', file);
  }
  free(timestamp);
  free(real_ip);
  free(headers_with_ip);
  free(headers_compact);
  close_logged_file_native(file);
  write_error_report_native(app_id, error_report_path, request, request_path, status_text, reason, resource_path, detail_text);
}
 
void native_write_access_log(const char *log_path, const HttpRequest *request, const char *request_path, int status_code) {
  FILE *file;
  char *timestamp = NULL;
  char *real_ip = NULL;
  char *headers_with_ip = NULL;
  char *headers_compact = NULL;
  char *dir = NULL;
  if (log_path == NULL || log_path[0] == '\0' || request == NULL) {
    return;
  }
  dir = path_dirname(log_path);
  if (dir != NULL) {
    ensure_directory(dir);
  }
  free(dir);
  file = fopen(log_path, "ab");
  if (file == NULL) {
    return;
  }
  timestamp = access_timestamp_native();
  real_ip = request_real_ip_native(request->headers);
  headers_with_ip = request_headers_with_client_ip_native(request->headers, real_ip);
  headers_compact = compact_log_text_native(headers_with_ip != NULL ? headers_with_ip : request->headers);
  if (timestamp != NULL && real_ip != NULL && headers_compact != NULL) {
    fprintf(
      file,
      "%s access status: \"%s\" method: \"%s\" path: \"%s\" headers: \"%s\"\n",
      timestamp,
      http_status_text_native(status_code),
      request->method != NULL ? request->method : "",
      request_path != NULL ? request_path : "",
      headers_compact
    );
  }
  free(timestamp);
  free(real_ip);
  free(headers_with_ip);
  free(headers_compact);
  close_logged_file_native(file);
}