/*-------------------------------------------------------------------------
 *
 * csvlog.c
 *	  CSV logging
 *
 * Portions Copyright (c) 2003-2025, PgPool Global Development Group
 * Portions Copyright (c) 1996-2024, PostgreSQL Global Development Group
 * Portions Copyright (c) 1994, Regents of the University of California
 *
 *
 * IDENTIFICATION
 *	  src/utils/error/csvlog.c
 *
 *-------------------------------------------------------------------------
 */


#include "pool.h"
#include "pool_config.h"
#include <string.h>
#include <time.h>
#include "main/pgpool_logger.h"
#include "utils/elog.h"
#include "utils/memutils.h"
#include "utils/ps_status.h"
#include "context/pool_session_context.h"


/*
 * append a CSV'd version of a string to a StringInfo
 * We use the PostgreSQL defaults for CSV, i.e. quote = escape = '"'
 * If it's NULL, append nothing.
 */
static inline void
appendCSVLiteral(StringInfo buf, const char *data)
{
	const char *p = data;
	char		c;

	/* avoid confusing an empty string with NULL */
	if (p == NULL)
		return;

	appendStringInfoCharMacro(buf, '"');
	while ((c = *p++) != '\0')
	{
		if (c == '"')
			appendStringInfoCharMacro(buf, '"');
		appendStringInfoCharMacro(buf, c);
	}
	appendStringInfoCharMacro(buf, '"');
}

/*
 * write_csvlog -- Generate and write CSV log entry
 *
 * Constructs the error message, depending on the Errordata it gets.
 */
void
write_csvlog(ErrorData *edata)
{
	StringInfoData buf;
	char		strbuf[129];

	/* static counter for line numbers */
	static long log_line_number = 0;

	char	   *appname;

	/* has counter been reset in current process? */
	static int	log_my_pid = 0;

	POOL_CONNECTION *frontend = NULL;
	POOL_SESSION_CONTEXT *session = pool_get_session_context(true);

	if (session)
		frontend = session->frontend;

	/*
	 * This is one of the few places where we'd rather not inherit a static
	 * variable's value from the postmaster.  But since we will, reset it when
	 * MyProcPid changes.
	 */
	if (log_my_pid != myProcPid)
	{
		log_line_number = 0;
		log_my_pid = myProcPid;
	}
	log_line_number++;

	initStringInfo(&buf);

	/* timestamp with milliseconds */
	time_t		now = time(NULL);

	strftime(strbuf, sizeof(strbuf), "%Y-%m-%d %H:%M:%S", localtime(&now));
	appendCSVLiteral(&buf, strbuf);
	appendStringInfoChar(&buf, ',');

	appname = get_application_name();
	/* application name */
	if (appname)
		appendCSVLiteral(&buf, appname);

	appendStringInfoChar(&buf, ',');

	/* Process id  */
	if (myProcPid != 0)
		appendStringInfo(&buf, "%d", myProcPid);
	appendStringInfoChar(&buf, ',');

	/* Error severity */
	appendStringInfoString(&buf, _(error_severity(edata->elevel, false)));
	appendStringInfoChar(&buf, ',');

	/* Line number */
	appendStringInfo(&buf, "%ld", log_line_number);
	appendStringInfoChar(&buf, ',');

	/* username */
	const char *username = frontend ? frontend->username : "[No Connection]";

	appendCSVLiteral(&buf, username);
	appendStringInfoChar(&buf, ',');

	/* database name */
	const char *dbname = frontend ? frontend->database : "[No Connection]";

	appendCSVLiteral(&buf, dbname);
	appendStringInfoChar(&buf, ',');

	/* errmessage */
	appendCSVLiteral(&buf, edata->message);
	appendStringInfoChar(&buf, ',');

	/* errdetail or errdetail_log */
	if (edata->detail_log)
		appendCSVLiteral(&buf, edata->detail_log);
	else
		appendCSVLiteral(&buf, edata->detail);
	appendStringInfoChar(&buf, ',');

	/* errhint */
	appendCSVLiteral(&buf, edata->hint);
	appendStringInfoChar(&buf, ',');

	/* file error location */
	if (pool_config->log_error_verbosity >= PGERROR_VERBOSE)
	{
		StringInfoData msgbuf;

		initStringInfo(&msgbuf);

		if (edata->funcname && edata->filename)
			appendStringInfo(&msgbuf, "%s, %s:%d",
							 edata->funcname, edata->filename,
							 edata->lineno);
		else if (edata->filename)
			appendStringInfo(&msgbuf, "%s:%d",
							 edata->filename, edata->lineno);
		appendCSVLiteral(&buf, msgbuf.data);
		pfree(msgbuf.data);
	}

	appendStringInfoChar(&buf, '\n');

	/* If in the syslogger process, try to write messages direct to file */
	if (processType == PT_LOGGER)
		write_syslogger_file(buf.data, buf.len, LOG_DESTINATION_CSVLOG);
	else
		write_pipe_chunks(buf.data, buf.len, LOG_DESTINATION_CSVLOG);

	pfree(buf.data);
}