/******************************************************************************

 * $Id$

 *

 * Project:  MapServer

 * Purpose:  Implementation of msSetError(), msDebug() and related functions.

 * Author:   Steve Lime and the MapServer team.

 *

 ******************************************************************************

 * Copyright (c) 1996-2005 Regents of the University of Minnesota.

 *

 * Permission is hereby granted, free of charge, to any person obtaining a

 * copy of this software and associated documentation files (the "Software"),

 * to deal in the Software without restriction, including without limitation

 * the rights to use, copy, modify, merge, publish, distribute, sublicense,

 * and/or sell copies of the Software, and to permit persons to whom the

 * Software is furnished to do so, subject to the following conditions:

 *

 * The above copyright notice and this permission notice shall be included in

 * all copies of this Software or works derived from this Software.

 *

 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS

 * OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,

 * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL

 * THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER

 * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING

 * FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER

 * DEALINGS IN THE SOFTWARE.

 ****************************************************************************/

#include "mapserver.h"

#include "maperror.h"

#include "mapthread.h"

#include "maptime.h"

#include <time.h>

#ifndef _WIN32

#include <sys/time.h>

#include <unistd.h>

#endif

#include <stdarg.h>

#include "cpl_conv.h"

#include "cpl_string.h"

static char *const ms_errorCodes[MS_NUMERRORCODES] = {

    "",

    "Unable to access file.",

    "Memory allocation error.",

    "Incorrect data type.",

    "Symbol definition error.",

    "Regular expression error.",

    "TrueType Font error.",

    "DBASE file error.",

    "GD library error.",

    "Unknown identifier.",

    "Premature End-of-File.",

    "Projection library error.",

    "General error message.",

    "CGI error.",

    "Web application error.",

    "Image handling error.",

    "Hash table error.",

    "Join error.",

    "Search returned no results.",

    "Shapefile error.",

    "Expression parser error.",

    "SDE error.",

    "OGR error.",

    "Query error.",

    "WMS server error.",

    "WMS connection error.",

    "OracleSpatial error.",

    "WFS server error.",

    "WFS connection error.",

    "WMS Map Context error.",

    "HTTP request error.",

    "Child array error.",

    "WCS server error.",

    "GEOS library error.",

    "Invalid rectangle.",

    "Date/time error.",

    "GML encoding error.",

    "SOS server error.",

    "NULL parent pointer error.",

    "AGG library error.",

    "OWS error.",

    "OpenGL renderer error.",

    "Renderer error.",

    "V8 engine error.",

    "OCG API error.",

    "Flatgeobuf error."};

#ifndef USE_THREAD

// Get the MapServer error object

errorObj *msGetErrorObj() {

  static errorObj ms_error = {MS_NOERR, "", "", "", MS_FALSE, 0, NULL, 0};

  return &ms_error;

}

#endif

#ifdef USE_THREAD

typedef struct te_info {

  struct te_info *next;

  void *thread_id;

  errorObj ms_error;

} te_info_t;

static te_info_t *error_list = NULL;

errorObj *msGetErrorObj() {

  te_info_t *link;

  void *thread_id;

  errorObj *ret_obj;

  msAcquireLock(TLOCK_ERROROBJ);

  thread_id = msGetThreadId();

  /* find link for this thread */

  for (link = error_list;

       link != NULL && link->thread_id != thread_id && link->next != NULL &&

       link->next->thread_id != thread_id;

       link = link->next) {

  }

  /* If the target thread link is already at the head of the list were ok */

  if (error_list != NULL && error_list->thread_id == thread_id) {

  }

  /* We don't have one ... initialize one. */

  else if (link == NULL || link->next == NULL) {

    te_info_t *new_link;

    errorObj error_obj = {MS_NOERR, "", "", "", 0, 0, NULL, 0};

    new_link = (te_info_t *)malloc(sizeof(te_info_t));

    new_link->next = error_list;

    new_link->thread_id = thread_id;

    new_link->ms_error = error_obj;

    error_list = new_link;

  }

  /* If the link is not already at the head of the list, promote it */

  else {

    te_info_t *target = link->next;

    link->next = link->next->next;

    target->next = error_list;

    error_list = target;

  }

  ret_obj = &(error_list->ms_error);

  msReleaseLock(TLOCK_ERROROBJ);

  return ret_obj;

}

#endif

/* msInsertErrorObj()

**

** We maintain a chained list of errorObj in which the first errorObj is

** the most recent (i.e. a stack).  msErrorReset() should be used to clear

** the list.

**

** Note that since some code in MapServer will fetch the head of the list and

** keep a handle on it for a while, the head of the chained list is static

** and never changes.

** A new errorObj is always inserted after the head, and only if the

** head of the list already contains some information.  i.e. If the static

** errorObj at the head of the list is empty then it is returned directly,

** otherwise a new object is inserted after the head and the data that was in

** the head is moved to the new errorObj, freeing the head errorObj to receive

** the new error information.

*/

static errorObj *msInsertErrorObj(void) {

  errorObj *ms_error;

  ms_error = msGetErrorObj();

  if (ms_error->code != MS_NOERR && ms_error->totalerrorcount < 100) {

    /* Head of the list already in use, insert a new errorObj after the head

     * and move head contents to this new errorObj, freeing the errorObj

     * for reuse.

     */

    errorObj *new_error;

    new_error = (errorObj *)malloc(sizeof(errorObj));

    /* Note: if malloc() failed then we simply do nothing and the head will

     * be overwritten by the caller... we cannot produce an error here

     * since we are already inside a msSetError() call.

     */

    if (new_error) {

      new_error->next = ms_error->next;

      new_error->code = ms_error->code;

      new_error->isreported = ms_error->isreported;

      strlcpy(new_error->routine, ms_error->routine,

              sizeof(new_error->routine));

      strlcpy(new_error->message, ms_error->message,

              sizeof(new_error->message));

      new_error->errorcount = ms_error->errorcount;

      ms_error->next = new_error;

      ms_error->code = MS_NOERR;

      ms_error->isreported = MS_FALSE;

      ms_error->routine[0] = '\0';

      ms_error->message[0] = '\0';

      ms_error->errorcount = 0;

    }

    ms_error->totalerrorcount++;

  }

  return ms_error;

}

/* msResetErrorList()

**

** Clear the list of error objects.

*/

void msResetErrorList() {

  errorObj *ms_error, *this_error;

  ms_error = msGetErrorObj();

  this_error = ms_error->next;

  while (this_error != NULL) {

    errorObj *next_error;

    next_error = this_error->next;

    msFree(this_error);

    this_error = next_error;

  }

  ms_error->next = NULL;

  ms_error->code = MS_NOERR;

  ms_error->isreported = MS_FALSE;

  ms_error->routine[0] = '\0';

  ms_error->message[0] = '\0';

  ms_error->errorcount = 0;

  ms_error->totalerrorcount = 0;

  /* -------------------------------------------------------------------- */

  /*      Cleanup our entry in the thread list.  This is mainly           */

  /*      imprortant when msCleanup() calls msResetErrorList().           */

  /* -------------------------------------------------------------------- */

#ifdef USE_THREAD

  {

    void *thread_id = msGetThreadId();

    te_info_t *link;

    msAcquireLock(TLOCK_ERROROBJ);

    /* find link for this thread */

    for (link = error_list;

         link != NULL && link->thread_id != thread_id && link->next != NULL &&

         link->next->thread_id != thread_id;

         link = link->next) {

    }

    if (link->thread_id == thread_id) {

      /* presumably link is at head of list.  */

      if (error_list == link)

        error_list = link->next;

      free(link);

    } else if (link->next != NULL && link->next->thread_id == thread_id) {

      te_info_t *next_link = link->next;

      link->next = link->next->next;

      free(next_link);

    }

    msReleaseLock(TLOCK_ERROROBJ);

  }

#endif

}

char *msGetErrorCodeString(int code) {

  if (code < 0 || code > MS_NUMERRORCODES - 1)

    return ("Invalid error code.");

  return (ms_errorCodes[code]);

}

/* -------------------------------------------------------------------- */

/*      Adding the displayable error string to a given string           */

/*      and reallocates the memory enough to hold the characters.       */

/*      If source is null returns a newly allocated string              */

/* -------------------------------------------------------------------- */

char *msAddErrorDisplayString(char *source, errorObj *error) {

  if ((source = msStringConcatenate(source, error->routine)) == NULL)

    return (NULL);

  if ((source = msStringConcatenate(source, ": ")) == NULL)

    return (NULL);

  if ((source = msStringConcatenate(source, ms_errorCodes[error->code])) ==

      NULL)

    return (NULL);

  if ((source = msStringConcatenate(source, " ")) == NULL)

    return (NULL);

  if ((source = msStringConcatenate(source, error->message)) == NULL)

    return (NULL);

  if (error->errorcount > 0) {

    char *pszTmp;

    if ((source = msStringConcatenate(source, " (message repeated ")) == NULL)

      return (NULL);

    pszTmp = msIntToString(error->errorcount);

    if ((source = msStringConcatenate(source, pszTmp)) == NULL) {

      msFree(pszTmp);

      return (NULL);

    }

    msFree(pszTmp);

    if ((source = msStringConcatenate(source, " times)")) == NULL)

      return (NULL);

  }

  return source;

}

char *msGetErrorString(const char *delimiter) {

  char *errstr = NULL;

  errorObj *error = msGetErrorObj();

  if (!delimiter || !error)

    return (NULL);

  while (error && error->code != MS_NOERR) {

    if ((errstr = msAddErrorDisplayString(errstr, error)) == NULL)

      return (NULL);

    if (error->next &&

        error->next->code !=

            MS_NOERR) { /* (peek ahead) more errors, use delimiter */

      if ((errstr = msStringConcatenate(errstr, delimiter)) == NULL)

        return (NULL);

    }

    error = error->next;

  }

  return (errstr);

}

static void msRedactString(char *str, const char *keyword) {

  char *password = strstr(str, keyword);

  if (password != NULL) {

    const char chOptionDelimiter = password - str > 0 ? password[-1] : 0;

    char *ptr = password + strlen(keyword);

    char chStringSep = *ptr;

    if (chStringSep == '\'' || chStringSep == '"') {

      ++ptr;

    } else if (chOptionDelimiter == ';' && chStringSep == '{' &&

               strcmp(keyword, "pwd=") == 0) {

      // Handle cases like "\\SQL2019;DATABASE=msautotest;Driver={ODBC Driver 17

      // for SQL Server};pwd={Password;12!};uid=sa;"

      ++ptr;

      chStringSep = '}';

    } else {

      chStringSep = '\0';

    }

    /* Replace all characters from after equal sign to end of line, end of

     * string, or end of quoted string.

     */

    char *ptr_first_redacted_char = NULL;

    while (*ptr != '\0' && *ptr != '\r' && *ptr != '\n') {

      if (chStringSep == '\0') {

        if (*ptr == chOptionDelimiter)

          break;

      } else {

        if (*ptr == chStringSep) {

          break;

        }

        if (*ptr == '\\' && ptr[1] == chStringSep) {

          ptr++;

        }

      }

      if (!ptr_first_redacted_char) {

        ptr_first_redacted_char = ptr;

        *ptr = '*';

      }

      ptr++;

    }

    if (ptr_first_redacted_char) {

      memmove(ptr_first_redacted_char + 1, ptr, strlen(ptr) + 1);

    }

  }

}

void msRedactCredentials(char *str) {

  // postgres or mssql formats

  msRedactString(str, "password=");

  // ODBC connections can use pwd rather than password

  msRedactString(str, "pwd=");

}

static void msSetErrorInternal(int ms_errcode, const char *http_status,

                               const char *message, const char *routine) {

  errorObj *ms_error = msGetErrorObj();

  /* Insert the error to the list if it is not the same as the previous error*/

  if (ms_error->code != ms_errcode || !EQUAL(message, ms_error->message) ||

      !EQUAL(routine, ms_error->routine)) {

    ms_error = msInsertErrorObj();

    if (!routine)

      strcpy(ms_error->routine, "");

    else {

      strlcpy(ms_error->routine, routine, sizeof(ms_error->routine));

    }

    if (!http_status)

      strcpy(ms_error->http_status, "");

    else {

      strlcpy(ms_error->http_status, http_status,

              sizeof(ms_error->http_status));

    }

    strlcpy(ms_error->message, message, sizeof(ms_error->message));

    ms_error->code = ms_errcode;

    ms_error->errorcount = 0;

  } else

    ++ms_error->errorcount;

  msRedactCredentials(ms_error->message);

  /* Log a copy of errors to MS_ERRORFILE if set (handled automatically inside

   * msDebug()) */

  msDebug("%s: %s %s\n", ms_error->routine, ms_errorCodes[ms_error->code],

          ms_error->message);

}

void msSetError(int code, const char *message_fmt, const char *routine, ...) {

  va_list args;

  char message[MESSAGELENGTH];

  if (!message_fmt)

    strcpy(message, "");

  else {

    va_start(args, routine);

    vsnprintf(message, MESSAGELENGTH, message_fmt, args);

    va_end(args);

  }

  msSetErrorInternal(code, NULL, message, routine);

}

#ifdef _MSC_VER

__declspec(thread) int gIsWMS = MS_FALSE;

#else

static _Thread_local int gIsWMS = MS_FALSE;

#endif

void msSetErrorSetIsWMS(int is_wms) { gIsWMS = is_wms; }

void msSetErrorWithStatus(int ms_errcode, const char *http_status,

                          const char *message_fmt, const char *routine, ...) {

  va_list args;

  char message[MESSAGELENGTH];

  if (!message_fmt)

    strcpy(message, "");

  else {

    va_start(args, routine);

    vsnprintf(message, MESSAGELENGTH, message_fmt, args);

    va_end(args);

  }

  if (http_status) {

    if (gIsWMS) {

      if (!CPLTestBoolean(

              CPLGetConfigOption("MS_WMS_ERROR_STATUS_CODE", "OFF")))

        http_status = NULL;

    } else {

      http_status = NULL;

    }

  }

  msSetErrorInternal(ms_errcode, http_status, message, routine);

}

void msWriteError(FILE *stream) {

  errorObj *ms_error = msGetErrorObj();

  while (ms_error && ms_error->code != MS_NOERR) {

    msIO_fprintf(stream, "%s: %s %s <br>\n", ms_error->routine,

                 ms_errorCodes[ms_error->code], ms_error->message);

    ms_error->isreported = MS_TRUE;

    ms_error = ms_error->next;

  }

}

void msWriteErrorXML(FILE *stream) {

  char *message;

  errorObj *ms_error = msGetErrorObj();

  while (ms_error && ms_error->code != MS_NOERR) {

    message = msEncodeHTMLEntities(ms_error->message);

    msIO_fprintf(stream, "%s: %s %s\n", ms_error->routine,

                 ms_errorCodes[ms_error->code], message);

    ms_error->isreported = MS_TRUE;

    ms_error = ms_error->next;

    msFree(message);

  }

}

void msWriteErrorImage(mapObj *map, char *filename, int blank) {

  imageObj *img;

  int width = 400, height = 300;

  const int nMargin = 5;

  char **papszLines = NULL;

  pointObj pnt = {0};

  outputFormatObj *format = NULL;

  char *errormsg = msGetErrorString("; ");

  errorObj *error = msGetErrorObj();

  char *imagepath = NULL, *imageurl = NULL;

  colorObj imagecolor, *imagecolorptr = NULL;

  textSymbolObj ts;

  labelObj label;

  int charWidth = 5,

      charHeight = 8; /* hardcoded, should be looked up from ft face */

  if (!errormsg) {

    errormsg = msStrdup("No error found sorry. This is likely a bug");

  }

  if (map) {

    /* Error paths that run before the requested image size has been validated

       (e.g. a WMS GetMap exception raised while the request is still being

       parsed) leave map->width/map->height holding raw client input, so only

       use them when they are within the MAXSIZE limit of the map. The width

       must also leave room for at least one character between the margins,

       otherwise the line splitting below has no usable width to divide by. */

    if (map->width >= (nMargin * 2) + charWidth && map->width <= map->maxsize &&

        map->height > 0 && map->height <= map->maxsize) {

      width = map->width;

      height = map->height;

    }

    format = map->outputformat;

    imagepath = map->web.imagepath;

    imageurl = map->web.imageurl;

  }

  /* Default to GIF if no suitable GD output format set */

  if (format == NULL || !MS_RENDERER_PLUGIN(format))

    format = msCreateDefaultOutputFormat(NULL, "AGG/PNG8", "png", NULL);

  if (!format->transparent) {

    if (map && MS_VALID_COLOR(map->imagecolor)) {

      imagecolorptr = &map->imagecolor;

    } else {

      MS_INIT_COLOR(imagecolor, 255, 255, 255, 255);

      imagecolorptr = &imagecolor;

    }

  }

  img = msImageCreate(width, height, format, imagepath, imageurl,

                      MS_DEFAULT_RESOLUTION, MS_DEFAULT_RESOLUTION,

                      imagecolorptr);

  if (img == NULL) {

    /* Nothing to draw the message on. Return with the errors still unreported

       and no headers sent, so that msCGIWriteError() emits its own error page

       instead; marking them reported here would make it skip that and leave

       the client with an empty response. */

    if (format->refcount == 0)

      msFreeOutputFormat(format);

    msFree(errormsg);

    return;

  }

  const int nTextLength = strlen(errormsg);

  const int nWidthTxt = nTextLength * charWidth;

  const int nUsableWidth = width - (nMargin * 2);

  /* Check to see if it all fits on one line. If not, split the text on several

   * lines. */

  if (!blank) {

    int nLines;

    if (nWidthTxt > nUsableWidth) {

      const int nMaxCharsPerLine = nUsableWidth / charWidth;

      nLines = (int)ceil((double)nTextLength / (double)nMaxCharsPerLine);

      if (nLines > 0) {

        papszLines = (char **)malloc(nLines * sizeof(char *));

        for (int i = 0; i < nLines; i++) {

          papszLines[i] = (char *)malloc((nMaxCharsPerLine + 1) * sizeof(char));

          papszLines[i][0] = '\0';

        }

      }

      for (int i = 0; i < nLines; i++) {

        const int nStart = i * nMaxCharsPerLine;

        int nEnd = nStart + nMaxCharsPerLine;

        if (nStart < nTextLength) {

          if (nEnd > nTextLength)

            nEnd = nTextLength;

          const int nLength = nEnd - nStart;

          strncpy(papszLines[i], errormsg + nStart, nLength);

          papszLines[i][nLength] = '\0';

        }

      }

    } else {

      nLines = 1;

      papszLines = (char **)malloc(nLines * sizeof(char *));

      papszLines[0] = msStrdup(errormsg);

    }

    initLabel(&label);

    MS_INIT_COLOR(label.color, 0, 0, 0, 255);

    MS_INIT_COLOR(label.outlinecolor, 255, 255, 255, 255);

    label.outlinewidth = 1;

    label.size = MS_SMALL;

    MS_REFCNT_INCR((&label));

    for (int i = 0; i < nLines; i++) {

      pnt.y = charHeight * ((i * 2) + 1);

      pnt.x = charWidth;

      initTextSymbol(&ts);

      msPopulateTextSymbolForLabelAndString(&ts, &label, papszLines[i], 1, 1,

                                            0);

      if (MS_LIKELY(MS_SUCCESS == msComputeTextPath(map, &ts))) {

        if (MS_SUCCESS != msDrawTextSymbol(NULL, img, pnt, &ts)) {

          /* an error occurred, but there's nothing much we can do about it here

           * as we are already handling an error condition */

        }

        freeTextSymbol(&ts);

      }

    }

    if (papszLines) {

      free(papszLines);

    }

  }

  /* actually write the image */

  if (!filename) {

    msIO_setHeader("Content-Type", "%s", MS_IMAGE_MIME_TYPE(format));

    msIO_sendHeaders();

  }

  msSaveImage(NULL, img, filename);

  msFreeImage(img);

  /* the errors are reported */

  while (error && error->code != MS_NOERR) {

    error->isreported = MS_TRUE;

    error = error->next;

  }

  if (format->refcount == 0)

    msFreeOutputFormat(format);

  msFree(errormsg);

}

char *msGetVersion() {

  static char version[2048];

  sprintf(version, "MapServer version %s", MS_VERSION);

  // add versions of required dependencies

  static char PROJVersion[20];

  sprintf(PROJVersion, " PROJ version %d.%d", PROJ_VERSION_MAJOR,

          PROJ_VERSION_MINOR);

  strcat(version, PROJVersion);

  static char GDALVersion[20];

  sprintf(GDALVersion, " GDAL version %d.%d", GDAL_VERSION_MAJOR,

          GDAL_VERSION_MINOR);

  strcat(version, GDALVersion);

#if (defined USE_PNG)

  strcat(version, " OUTPUT=PNG");

#endif

#if (defined USE_JPEG)

  strcat(version, " OUTPUT=JPEG");

#endif

#ifdef USE_KML

  strcat(version, " OUTPUT=KML");

#endif

  strcat(version, " SUPPORTS=PROJ");

  strcat(version, " SUPPORTS=AGG");

  strcat(version, " SUPPORTS=FREETYPE");

#ifdef USE_CAIRO

  strcat(version, " SUPPORTS=CAIRO");

#endif

#if defined(USE_SVG_CAIRO) || defined(USE_RSVG)

  strcat(version, " SUPPORTS=SVG_SYMBOLS");

#ifdef USE_SVG_CAIRO

  strcat(version, " SUPPORTS=SVGCAIRO");

#else

  strcat(version, " SUPPORTS=RSVG");

#endif

#endif

#ifdef USE_OGL

  strcat(version, " SUPPORTS=OPENGL");

#endif

#ifdef USE_ICONV

  strcat(version, " SUPPORTS=ICONV");

#endif

#ifdef USE_EXEMPI

  strcat(version, " SUPPORTS=XMP");

#endif

#ifdef USE_FRIBIDI

  strcat(version, " SUPPORTS=FRIBIDI");

#endif

#ifdef USE_WMS_SVR

  strcat(version, " SUPPORTS=WMS_SERVER");

#endif

#ifdef USE_WMS_LYR

  strcat(version, " SUPPORTS=WMS_CLIENT");

#endif

#ifdef USE_WFS_SVR

  strcat(version, " SUPPORTS=WFS_SERVER");

#endif

#ifdef USE_WFS_LYR

  strcat(version, " SUPPORTS=WFS_CLIENT");

#endif

#ifdef USE_WCS_SVR

  strcat(version, " SUPPORTS=WCS_SERVER");

#endif

#ifdef USE_SOS_SVR

  strcat(version, " SUPPORTS=SOS_SERVER");

#endif

#ifdef USE_OGCAPI_SVR

  strcat(version, " SUPPORTS=OGCAPI_SERVER");

#endif

#ifdef USE_FASTCGI

  strcat(version, " SUPPORTS=FASTCGI");

#endif

#ifdef USE_THREAD

  strcat(version, " SUPPORTS=THREADS");

#endif

#ifdef USE_GEOS

  strcat(version, " SUPPORTS=GEOS");

#endif

#ifdef USE_V8_MAPSCRIPT

  strcat(version, " SUPPORTS=V8");

#endif

#ifdef USE_PBF

  strcat(version, " SUPPORTS=PBF");

#endif

#ifdef USE_JPEG

  strcat(version, " INPUT=JPEG");

#endif

#ifdef USE_SDE

  strcat(version, " INPUT=SDE");

#endif

#ifdef USE_POSTGIS

  strcat(version, " INPUT=POSTGIS");

#endif

#ifdef USE_ORACLESPATIAL

  strcat(version, " INPUT=ORACLESPATIAL");

#endif

  strcat(version, " INPUT=OGR");

  strcat(version, " INPUT=GDAL");

  strcat(version, " INPUT=SHAPEFILE");

  strcat(version, " INPUT=FLATGEOBUF");

  return (version);

}

int msGetVersionInt() { return MS_VERSION_NUM; }