/****************************************************************
 *								*
 * Copyright (c) 2001-2023 Fidelity National Information	*
 * Services, Inc. and/or its subsidiaries. All rights reserved.	*
 *								*
 *	This source code contains the intellectual property	*
 *	of its copyright holder(s), and is made available	*
 *	under a license.  If you do not know the terms of	*
 *	the license, please stop and do not read further.	*
 *								*
 ****************************************************************/

#include "mdef.h"

#include <sys/types.h>
#include <errno.h>
#include "gtm_string.h"
#include "gtm_fcntl.h"
#include "gtm_unistd.h"
#include "gtm_stat.h"
#include "gtm_stdio.h"

#include <rtnhdr.h>
#include <auto_zlink.h>
#include "zroutines.h"
#include "compiler.h"
#include "srcline.h"
#include "gtmio.h"
#include "eintr_wrappers.h"
#include "op.h"
#include "zbreak.h"
#include "hashtab_mname.h"
#include "gdsroot.h"
#include "gtm_facility.h"
#include "fileinfo.h"
#include "gdsbt.h"
#include "gdsfhead.h"
#include "gv_trigger.h"
#include "gtm_trigger.h"
#include "cdb_sc.h"
#include "tp_frame.h" /* for tp_frame */
#include "t_retry.h"
#include "trigger_read_andor_locate.h"
#include "gtm_trigger_trc.h"
#include "zr_unlink_rtn.h"
#include "stack_frame.h"
#include "rtn_src_chksum.h"
#include "cmd_qlf.h"
#include "arlinkdbg.h"

#define RT_TBL_SZ 20

STATICFNDCL boolean_t fill_src_tbl(routine_source **src_tbl_result, rhdtyp *rtn_vector);
STATICFNDCL boolean_t fill_src_tbl_via_litpool(routine_source **src_tbl_result, rhdtyp *rtn_vector);
STATICFNDCL boolean_t fill_src_tbl_via_mfile(routine_source **src_tbl_result, rhdtyp *rtn_vector);

GBLREF uint4		dollar_tlevel;
GBLREF unsigned int	t_tries;
GBLREF stack_frame	*frame_pointer;
GBLREF tp_frame		*tp_pointer;

LITDEF char		litconst_space = ' ';
LITREF mval		literal_null;

error_def(ERR_TXTSRCFMT);
error_def(ERR_SYSCALL);

int get_src_line(mval *routine, mval *label, int offset, mstr **srcret, rhdtyp **rtn_vec)
{
	int			srcrecs, *lt_ptr, size, line_indx, srcfilnamlen;
	boolean_t		found, added, eof_seen, srcstat;
	mstr			src;
	rhdtyp			*rtn_vector;
	zro_ent			*srcdir;
	mstr			*base, *current, *top, tmprtnname;
	char			buff[MAX_SRCLINE], *cptr, *srcfile_name;
	char			srcnamebuf[SIZEOF(mident_fixed) + STR_LIT_LEN(DOTM)];
	routine_source		*src_tbl;
	int			rc, fclose_res;
	char			*fgets_rc;
	FILE			*fp;
	struct stat		srcfile_stat;
	off_t			srcsize;
	unsigned char		*srcptr, *srcptr_max, *srcstart, *eol_srcstart, *prev_srcptr;
	gtm_rtn_src_chksum_ctx	checksum_ctx;
	boolean_t	is_trigger;
	DCL_THREADGBL_ACCESS;

	SETUP_THREADGBL_ACCESS;
	srcstat = 0;
	*srcret = NULL;
	rtn_vector = NULL;
	assert (routine->mvtype & MV_STR);
	/* The source to be loaded can be of two types:
	 *
	 *   1. Normal routine source to be looked up on disk
	 *   2. Trigger source located in a database.
	 *
	 * Determine which source we need.
	 */
	GTMTRIG_ONLY(IS_TRIGGER_RTN(&routine->str, is_trigger));
	DBGIFTRIGR((stderr, "get_src_line: entered $tlevel=%d and $t_tries=%d\n", dollar_tlevel, t_tries));
	if (WANT_CURRENT_RTN(routine))
	{	/* We want $TEXT for the routine currently executing - may be a recursively relinked routine copy */
		rtn_vector = CURRENT_RHEAD_ADR(frame_pointer->rvector);
		DBGARLNK((stderr, "get_src_line: Fetching source from current routine (rtnhdr 0x"lvaddr")\n", rtn_vector));
		assert(rtn_vector);
		GTMTRIG_ONLY(is_trigger=(NULL != rtn_vector->trigr_handle));
		DBGIFTRIGR((stderr, "get_src_line: entered $tlevel=%d and $t_tries=%d\n", dollar_tlevel, t_tries));
	}
	if (is_trigger && (NULL == rtn_vector))
	{	/* Need source on a trigger. Get trigger loaded and its source becomes available since all triggers
		 * are compiled with -EMBED_SOURCE.
		 */
		/* Though we should only come in here when the trigger is NOT already loaded, note that
		 * trigger_locate_andor_load() may alter the length part of the mstr to remove the +BREG
		 * region-name specification (the string component is unmodified). Pass in a copy of the mstr struct to
		 * avoid modification to routine->str as it affects the caller which relies on this variable being
		 * untouched.
		 */
		tmprtnname = routine->str;
		DBGTRIGR((stderr, "get_src_line: fetch source for %s\n", tmprtnname.addr));
		rc = trigger_locate_andor_load(&tmprtnname, &rtn_vector);
		if (0 != rc)
		{
			if (NULL != rtn_vec)
				*rtn_vec = NULL;
			return SRCNOTAVAIL;
		}
		if (NULL == rtn_vector)
		{
			if (NULL != rtn_vec)
				*rtn_vec = NULL;
			return OBJMODMISS;
		}
		DBGARLNK((stderr, "get_src_line: Fetch trigger source from rtnhdr 0x"lvaddr"\n", rtn_vector));
	} else if (NULL == rtn_vector)
	{
		assert(!is_trigger);
		if (NULL == (rtn_vector = find_rtn_hdr(&routine->str)))		/* Note assignment */
		{
			op_zlink(routine, NULL);
			rtn_vector = find_rtn_hdr(&routine->str);
			if (NULL == rtn_vector)
			{
				if (NULL != rtn_vec)
					*rtn_vec = NULL;
				return OBJMODMISS;
			}
		}
	}
#	ifdef AUTORELINK_SUPPORTED
	if (!(WANT_CURRENT_RTN(routine)) && !is_trigger)
	{	/* We have the routine now but double check if we need to load a newer one */
		DEBUG_ONLY(rtn_vector->rtn_relinked = FALSE);			/* meet expectations of assert in checker below */
		explicit_relink_check(rtn_vector, TRUE);			/* meant for code invokers, not code displayers */
		rtn_vector = (TABENT_PROXY).rtnhdr_adr;
		assert(NULL != rtn_vector);
		DBGARLNK((stderr, "get_src_line: Fetching routine source for rtnhdr 0x"lvaddr"\n", rtn_vector));
	}
#	endif
	if (NULL != rtn_vec)
		*rtn_vec = rtn_vector;
	if (!rtn_vector->src_full_name.len)
	{
		DBGARLNK((stderr, "get_src_line: Source not available\n"));
		return SRCNOTAVAIL;
	}
	src_tbl = rtn_vector->source_code;
	DBGIFTRIGR((stderr, "get_src_line: routine %lx has source_code 0x%lx (%d)\n",
		    rtn_vector, src_tbl, (src_tbl)? src_tbl->srcrecs : 0));
	if (NULL == src_tbl)
	{	/* Load source from where it makes sense - note all triggers are compiled with -EMBED_SOURCE
		 * so we'll always load source from the routine's literal pool. Verify if trigger, not calling
		 * without source being available.
		 */
		assert(!is_trigger || (rtn_vector->compiler_qlf & CQ_EMBED_SOURCE));
		srcstat = fill_src_tbl(&src_tbl, rtn_vector);
		src_tbl->srcstat = srcstat;
		rtn_vector->source_code = src_tbl;
	} else
		srcstat |= src_tbl->srcstat;
	DBGIFTRIGR((stderr, " get_src_line: $tlevel %d\t", dollar_tlevel));
	lt_ptr = (int *)find_line_addr(rtn_vector, &label->str, 0, NULL);
	if (!lt_ptr)
	{
		DBGARLNK((stderr, "get_src_line: label not found\n"));
		srcstat |= LABELNOTFOUND;
	} else if (!(srcstat & (SRCNOTFND | SRCNOTAVAIL)))
	{
		line_indx = (int)(lt_ptr - (int *)LNRTAB_ADR(rtn_vector));
		line_indx += offset;
		DBGIFTRIGR((stderr, "get_src_line: line_indx %d\n", line_indx));
		if (line_indx == 0)
			srcstat |= ZEROLINE;
		else if (line_indx < 0)
			srcstat |= NEGATIVELINE;
		else if (line_indx >= rtn_vector->lnrtab_len)
			srcstat |= AFTERLASTLINE;
		else	/* successfully located line */
		{
			*srcret = &src_tbl->srclines[line_indx];
			/* DBGFPF((stderr, "get_src_line: returning string %.*s\n", (*srcret)->len, (*srcret)->addr)); */
		}
	}
#	if defined(DEBUG_TRIGR) || defined(DEBUG_ARLINK)
	DBGFPF((stderr, "get_src_line: exiting with srcstat %d\n", srcstat));
#	endif
	return srcstat;
}

void free_src_tbl(rhdtyp *rtn_vector)
{
	routine_source		*src_tbl;

	src_tbl = rtn_vector->source_code;
	if (NULL != src_tbl)
	{	/* Release the source. Entries and source are malloc'd in two blocks on UNIX */
		if (NULL != src_tbl->srcbuff)
			free(src_tbl->srcbuff);
		free(src_tbl);
		rtn_vector->source_code = NULL;
	}
}

STATICFNDEF boolean_t fill_src_tbl(routine_source **src_tbl_result, rhdtyp *rtn_vector)
{
	if (rtn_vector->compiler_qlf & CQ_EMBED_SOURCE)
		return fill_src_tbl_via_litpool(src_tbl_result, rtn_vector);
	else
		return fill_src_tbl_via_mfile(src_tbl_result, rtn_vector);
}

STATICFNDEF boolean_t fill_src_tbl_via_litpool(routine_source **src_tbl_result, rhdtyp *rtn_vector)
{
	int			srcrecs, size;
	mstr			*current, *top;
	routine_source		*src_tbl;
	off_t			srcsize;
	unsigned char		*srcptr, *srcptr_max, *srcstart, *prev_srcptr;

	srcrecs = (int)rtn_vector->lnrtab_len;
	/* Each line of source (srcrecs of them) resides at end of lit pool (srcptr) */
	USHBIN_ONLY(srcptr = rtn_vector->literal_text_adr + rtn_vector->routine_source_offset);
	USHBIN_ONLY(srcsize = rtn_vector->literal_text_len - rtn_vector->routine_source_offset);
	NON_USHBIN_ONLY(srcptr = (unsigned char *)rtn_vector->routine_source_offset);
	NON_USHBIN_ONLY(srcsize = (int)rtn_vector->routine_source_length);
	srcptr_max = srcptr + srcsize;
	src_tbl = (routine_source *)malloc(SIZEOF(routine_source) + ((srcrecs - 1) * SIZEOF(mstr)));
	src_tbl->srcbuff = NULL;
	src_tbl->srcrecs = srcrecs;
	for (current = src_tbl->srclines + 1, top = src_tbl->srclines + srcrecs ; current < top ; current++)
	{
		prev_srcptr = srcptr++;
		while ((srcptr < srcptr_max) && (*(srcptr - 1) != '\n')) /* find end of current line */
			srcptr++;
		size = (int4)(srcptr - prev_srcptr);
		if (*(srcptr - 1) == '\n')
			size--; /* Strip trailing '\n' */
		if (size)
		{
			current->len = size;
			current->addr = (char *)prev_srcptr;
		} else
		{
			current->len = 1;
			current->addr = (char *)&litconst_space;
		}
	}
	/* NOTE: no need to verify source checksum. no chance of mismatch */
	*src_tbl_result = src_tbl;
	return FALSE;
}

STATICFNDEF boolean_t fill_src_tbl_via_mfile(routine_source **src_tbl_result, rhdtyp *rtn_vector)
{
	boolean_t		found, added, eof_seen, srcstat;
	char			buff[MAX_SRCLINE], *cptr, *fgets_rc, *srcfile_name;
	char			srcnamebuf[SIZEOF(mident_fixed) + STR_LIT_LEN(DOTM) + 1];
	FILE			*fp;
	gtm_rtn_src_chksum_ctx	checksum_ctx;
	int			fclose_res, fdd, fsd, line_indx, *lt_ptr, rc, srcfilnamlen, srcrecs;
	unsigned int		size = 0;
	mstr			*base, *current, src, *top;
	off_t			srcsize;
	routine_source		*src_tbl;
	struct stat		srcfile_stat;
	unsigned char		*srcptr, *srcptr_max, *srcstart, *eol_srcstart, *prev_srcptr = NULL;
	zro_ent			*srcdir;

	srcstat = 0;
	srcfile_name = malloc(rtn_vector->src_full_name.len + 1);
	memcpy(srcfile_name, rtn_vector->src_full_name.addr, rtn_vector->src_full_name.len);
	*(srcfile_name + rtn_vector->src_full_name.len) = '\0';	/* Ensure string is null terminated */
	/* At this point, it is not clear if Fopen will handle zos tagging correctly in all cases.
	 * especially when tagged with other than ISO8859-1 or IBM-1047. When we resurrect the zOS
	 * platform, we need to test this out.
	 */
	Fopen(fp, srcfile_name, "r");
	if (NULL == fp)
	{
		found = FALSE;
		free(srcfile_name);
		srcfile_name = NULL;
		srcfilnamlen = (int)rtn_vector->routine_name.len;
		memcpy((void *)srcnamebuf, rtn_vector->routine_name.addr, srcfilnamlen);
		if (srcnamebuf[0] == '%')	/* percents are translated to _ on filenames */
			srcnamebuf[0] = '_';
		MEMCPY_LIT(&srcnamebuf[srcfilnamlen], DOTM);
		src.addr = srcnamebuf;
		src.len = INTCAST(srcfilnamlen + STR_LIT_LEN(DOTM));
		src.addr[src.len] = 0;
		zro_search(NULL, NULL, &src, &srcdir, TRUE);
		if (srcdir)
		{
			OPENFILE(srcdir->str.addr, O_RDONLY, fdd);
			if (-1 == fdd)
				srcdir = NULL;
			else
			{	/* having latched on to the directory, openat ensures no jiggering of path between find and open */
				OPENAT(fdd, src.addr, O_RDONLY, fsd);
				if (-1 != fsd)
				{
					FDOPEN(fp, fsd, "r");
					if (NULL != fp)
					{
						found = TRUE;
						srcfile_name = malloc(src.len + srcdir->str.len + 2);
						memcpy(srcfile_name, srcdir->str.addr, srcdir->str.len);
						cptr = srcfile_name + srcdir->str.len;
						*cptr++ = '/';
						memcpy(cptr, src.addr, src.len);
						cptr += src.len;
						*cptr++ = 0;
					}
				}
				CLOSEFILE(fdd, fclose_res);
			}
		}
	} else
		found = TRUE;
	if (!found)
	{
		srcstat |= SRCNOTFND;
		srcrecs = 0;
		srcsize = 0;
	} else
	{
		srcrecs = (int)rtn_vector->lnrtab_len;
		/* Find out how big the file is so we can allocate the memory in one shot */
		if ((NULL != fp) && !(srcstat & (SRCNOTFND | SRCNOTAVAIL)))
		{
			rc = stat(srcfile_name, &srcfile_stat);
			if (0 != rc)
			{
				free(srcfile_name);
				RTS_ERROR_CSA_ABT(NULL, VARLSTCNT(8) ERR_SYSCALL,
					5, LEN_AND_LIT("stat"), CALLFROM, rc);
			}
			srcsize = srcfile_stat.st_size;
		} else
			srcsize = 0;
	}
	if (NULL != srcfile_name)
		free(srcfile_name);
	assert((found && srcrecs >= 1) || (srcrecs == 0));

	/* Allocate source mstr structure. Since structure has one mstr in it, allocate one less.
	 * Note, the size we get from lnrtab_len has an extra [0] origin entry in the total. This
	 * entry is not used in the source array for direct referencing ease.
	 */
	src_tbl = (routine_source *)malloc(SIZEOF(routine_source) + ((srcrecs - 1) * SIZEOF(mstr)));
	src_tbl->srcbuff = (0 < srcsize) ? malloc(srcsize + 1) : NULL;
	base = src_tbl->srclines;
	srcptr = src_tbl->srcbuff;
	srcptr_max = srcptr + srcsize;
	src_tbl->srcrecs = srcrecs;
	eof_seen = FALSE;
	for (current = base + 1, top = base + srcrecs ; current < top ; current++)
	{
		assert(found && (NULL != fp));
		if (!eof_seen)
		{
			FGETS(buff, MAX_SRCLINE, fp, fgets_rc);
			if (NULL == fgets_rc)
			{
				if (ferror(fp))
				{
					FCLOSE(fp, fclose_res);
					assert(!fclose_res);
					if (src_tbl->srcbuff)
						free(src_tbl->srcbuff);
					free(src_tbl);
					rts_error_csa(CSA_ARG(NULL) VARLSTCNT(3) ERR_TXTSRCFMT, 0, errno);
					assert(FALSE);
				} else
				{
					eof_seen = TRUE;
					assert(feof(fp));
					size = 0;
				}
			} else
			{
				size = strlen(buff);
				prev_srcptr = srcptr;
				srcptr += size;
				if ((NULL == src_tbl->srcbuff) || (srcptr > srcptr_max))
				{	/* source file has been concurrently overwritten (and extended or truncated) */
					srcstat |= CHECKSUMFAIL;
					eof_seen = TRUE;
					size = 0;
				} else
				{	/* Read size fits in the destination buffer */
					memcpy((void *)prev_srcptr, (void *)buff, (size_t)size);
					/* Strip trailing '\n' if any (if at least one byte was read in) */
					if (size && ('\n' == buff[size - 1]))
						size--;
				}
			}
		} else	/* eof seen; nothing more to read in file */
			size = 0;
		if (size)
		{
			assert(prev_srcptr);
			assert((prev_srcptr + size) <= srcptr_max);
			assert((0 <= size) && (MAXPOSINT4 >= size));
			current->len = (mstr_len_t)size;
			current->addr = (char *)prev_srcptr;
		} else
		{
			current->addr = (char *)&litconst_space;
			current->len = 1;
		}
	}
	if (found)
	{
		if (srcrecs > 1)
			*base = *(base + 1);
		/* Ensure we have reached the end of the source file. If not, we need to issue a CHECKSUMFAIL
		 * error. Most often the !eof_seen part of the check is not needed since the checksums will not
		 * match. But if it so happens that the checksums do match, then this extra check helps us
		 * correctly identify a TXTSRCMAT error.
		 */
		if (!eof_seen)
		{
			FGETS(buff, MAX_SRCLINE, fp, fgets_rc);
			if ((NULL == fgets_rc) && !ferror(fp))
			{
				eof_seen = TRUE;
				assert(feof(fp));
			}
		}
		if (srcsize && ('\n' != *(src_tbl->srcbuff + srcsize - 1)))
			*(src_tbl->srcbuff + srcsize++) = '\n';		/* add \n in case last line was unterminated */
		rtn_src_chksum_buffer(&checksum_ctx, src_tbl->srcbuff, srcsize);
		if (!eof_seen
			|| !rtn_src_chksum_match(get_ctx_checksum(&checksum_ctx), get_rtnhdr_checksum(rtn_vector)))
			srcstat |= CHECKSUMFAIL;
		FCLOSE(fp, fclose_res);
		assert(!fclose_res);
	}
	*src_tbl_result = src_tbl;
	return srcstat;
}