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

/*  ntapi: Native API core library                      */

/*  Copyright (C) 2013--2021  SysDeer Technologies, LLC */

/*  Released under GPLv2 and GPLv3; see COPYING.NTAPI.  */

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

#include <psxtypes/psxtypes.h>

#include <pemagine/pemagine.h>

#include <ntapi/nt_status.h>

#include <ntapi/nt_object.h>

#include <ntapi/nt_thread.h>

#include <ntapi/nt_process.h>

#include <ntapi/nt_string.h>

#include <ntapi/ntapi.h>

#include "ntapi_impl.h"

#define NT_PROCESS_SPAWN_FLAG_DEBUG_MASK                \

		(NT_PROCESS_SPAWN_FLAG_DEBUG_EXECUTION   \

		 | NT_PROCESS_SPAWN_FLAG_DEBUG_SUSPENDED)

typedef int32_t win32_create_process_utf16(

	__in_opt	wchar16_t *			appname,

	__in_out_opt	wchar16_t *			cmdline,

	__in_opt	nt_sa *				process_sa_attr,

	__in_opt	nt_sa *				thread_sa_attr,

	__in		int32_t				inherit_handles,

	__in		uint32_t			creation_flags,

	__in		wchar16_t *			environment,

	__in_opt	wchar16_t *			cwd,

	__in		nt_process_startup_info *	startup_info,

	__out		nt_process_info *		process_info);

static int32_t __stdcall __tt_spawn_return(

	nt_runtime_data_block *	rtblock,

	void *			hprocess,

	void *			hthread,

	int32_t			status)

{

	if (hprocess) {

		__ntapi->zw_terminate_process(

			hprocess,status);

		__ntapi->zw_close(hprocess);

		__ntapi->zw_close(hthread);

	}

	__ntapi->zw_free_virtual_memory(

		NT_CURRENT_PROCESS_HANDLE,

		&rtblock->addr,

		&rtblock->size,

		NT_MEM_RELEASE);

	return status;

}

int32_t __stdcall __ntapi_tt_spawn_foreign_process(nt_spawn_process_params * sparams)

{

	int32_t				status;

	nt_process_info			processinfo;

	nt_create_process_params	cparams;

	nt_runtime_data_block		rtblock;

	nt_unicode_string *		imgname;

	nt_peb * 			peb;

	char *				patharg;

	void *				hkernel32;

	void *				hat;

	void *				hfile;

	uint32_t			written;

	wchar16_t *			imgbuf;

	char **				parg;

	char *				mark;

	char *				ch;

	char *				ch_arg;

	char *				ch_cap;

	int				fquote;

	uint32_t			finherit;

	uint32_t			fsuspended;

	uint32_t			fdebug;

	wchar16_t *			cmdline;

	nt_strconv_mbtonative		uparams;

	nt_unicode_string		nt_image;

	nt_unicode_string		nt_cmd_line;

	win32_create_process_utf16 *	create_process_fn;

	char				create_process_fn_name[]

					= "CreateProcessW";

	/* validation */

	if (!sparams->argv)

		return NT_STATUS_INVALID_PARAMETER;

	if (!sparams->himage && !sparams->patharg)

		return NT_STATUS_OBJECT_PATH_INVALID;

	if (!(peb = (nt_peb *)pe_get_peb_address()))

		return NT_STATUS_INTERNAL_ERROR;

	if (!peb->process_params)

		return NT_STATUS_INTERNAL_ERROR;

	if (sparams->rtctx || sparams->hsession || sparams->hready)

		return NT_STATUS_INVALID_PARAMETER;

	/* hkernel32 */

	if (!(hkernel32 = pe_get_kernel32_module_handle()))

		return NT_STATUS_DLL_NOT_FOUND;

	if (!(create_process_fn = (win32_create_process_utf16 *)

			(pe_get_procedure_address(

				hkernel32,create_process_fn_name))))

		return NT_STATUS_PROCEDURE_NOT_FOUND;

	/* hat */

	hat = (sparams->hroot && (sparams->argv[0][0] == '/'))

		? sparams->hroot

		: sparams->hcwd

			? sparams->hcwd

			: peb->process_params->cwd_handle;

	/* patharg */

	patharg = sparams->patharg

		? (sparams->patharg[0] == '/')

			? (sparams->patharg[1] == '?')

				? &sparams->patharg[0]

				: &sparams->patharg[1]

			: &sparams->patharg[0]

		: 0;

	/* rtblock, rdata */

	rtblock.addr		= 0;

	rtblock.size		= 0x40000;

	rtblock.remote_addr	= 0;

	rtblock.remote_size	= 0;

	rtblock.flags		= 0;

	if ((status = __ntapi->zw_allocate_virtual_memory(

			NT_CURRENT_PROCESS_HANDLE,

			&rtblock.addr,0,

			&rtblock.size,

			NT_MEM_COMMIT,

			NT_PAGE_READWRITE)))

		return status;

	__ntapi->tt_aligned_block_memset(

		rtblock.addr,0,rtblock.size);

	/* imgbuf */

	imgbuf  = (wchar16_t *)rtblock.addr;

	imgbuf += 0x30000 / sizeof(*imgbuf);

	/* hfile */

	if (sparams->himage)

		hfile = sparams->himage;

	else if ((status = __ntapi_tt_open_file_utf8(

			&hfile,hat,patharg,1,

			imgbuf,0x2000)))

		return status;

	/* imgname */

	if ((status = __ntapi->zw_query_object(

			hfile,

			NT_OBJECT_NAME_INFORMATION,

			imgbuf,0x10000,&written)))

		return __tt_spawn_return(

			&rtblock,0,0,status);

	imgname = (nt_unicode_string *)imgbuf;

	/* argv --> cmdline (utf8) */

	ch_arg = (char *)rtblock.addr;

	ch_cap = ch_arg + 0x10000;

	for (parg=sparams->argv; *parg; parg++) {

		for (ch=*parg, fquote=0; *ch && !fquote; ch++)

			fquote = ((*ch == ' ')

					|| (*ch == '\t')

					|| (*ch == '"'));

		if (fquote)

			*ch_arg++ = '"';

		for (ch=*parg; *ch; ) {

			if (ch[0] == '\\') {

				for (mark=&ch[1]; *mark=='\\'; )

					mark++;

				if ((ch_arg + 2*(mark-ch)) >= ch_cap)

					return __tt_spawn_return(

						&rtblock,0,0,

						NT_STATUS_NAME_TOO_LONG);

				if (!mark[0] && fquote) {

					for (; *ch=='\\'; ch++) {

						*ch_arg++ = '\\';

						*ch_arg++ = '\\';

					}

				} else if (mark[0] == '"') {

					for (; *ch=='\\'; ch++) {

						*ch_arg++ = '\\';

						*ch_arg++ = '\\';

					}

				} else {

					*ch_arg++ = *ch++;

				}

			} else if (ch[0] == '"') {

				*ch_arg++ = '\\';

				*ch_arg++ = *ch++;

			} else {

				*ch_arg++ = *ch++;

			}

		}

		if (fquote)

			*ch_arg++ = '"';

		*ch_arg++ = ' ';

		if (ch_arg >= ch_cap)

			return __tt_spawn_return(

				&rtblock,0,0,

				NT_STATUS_NAME_TOO_LONG);

	}

	ch_arg[-1] = 0;

	/* cmdline (utf8) --> cmdline (utf16) */

	cmdline  = (wchar16_t *)rtblock.addr;

	cmdline += (0x10000 / sizeof(wchar16_t));

	uparams.src                = (unsigned char *)rtblock.addr;

	uparams.src_size_in_bytes  = 0;

	uparams.dst                = cmdline;

	uparams.dst_size_in_bytes  = 0x10000 - sizeof(wchar16_t);

	uparams.code_points        = 0;

	uparams.bytes_written      = 0;

	if ((status = __ntapi->uc_convert_unicode_stream_utf8_to_utf16(&uparams)))

		return __tt_spawn_return(

			&rtblock,0,0,status);

	else if (uparams.leftover_count)

		return __tt_spawn_return(

			&rtblock,0,0,

			NT_STATUS_ILLEGAL_CHARACTER);

	cmdline[uparams.bytes_written / sizeof(wchar16_t)] = 0;

	/* nt_cmd_line */

	nt_cmd_line.strlen = uparams.bytes_written;

	nt_cmd_line.maxlen = uparams.bytes_written + sizeof(wchar16_t);

	nt_cmd_line.buffer = cmdline;

	/* nt_image */

	nt_image.buffer  = (wchar16_t *)rtblock.addr;

	nt_image.buffer += (0x20000 / sizeof(wchar16_t));

	uparams.src                = (unsigned char *)sparams->argv[0];

	uparams.src_size_in_bytes  = 0;

	uparams.dst                = nt_image.buffer;

	uparams.dst_size_in_bytes  = 0x10000 - sizeof(wchar16_t);

	uparams.code_points        = 0;

	uparams.bytes_written      = 0;

	if ((status = __ntapi->uc_convert_unicode_stream_utf8_to_utf16(&uparams)))

		return __tt_spawn_return(

			&rtblock,0,0,status);

	else if (uparams.leftover_count)

		return __tt_spawn_return(

			&rtblock,0,0,

			NT_STATUS_ILLEGAL_CHARACTER);

	nt_image.strlen = uparams.bytes_written;

	nt_image.maxlen = uparams.bytes_written + sizeof(wchar16_t);

	nt_image.buffer[uparams.bytes_written / sizeof(wchar16_t)] = 0;

	/* cparams */

	__ntapi->tt_aligned_block_memset(

		&cparams,0,sizeof(cparams));

	cparams.image_name		= imgname->buffer;

	cparams.creation_flags_thread	= NT_PROCESS_CREATE_FLAGS_CREATE_THREAD_SUSPENDED;

	/* process_params */

	if ((status = __ntapi->rtl_create_process_parameters(

			&cparams.process_params,

			&nt_image,

			(nt_unicode_string *)0,

			(nt_unicode_string *)0,

			&nt_cmd_line,

			__ntapi->tt_get_peb_env_block_utf16(),

			(nt_unicode_string *)0,

			(nt_unicode_string *)0,

			(nt_unicode_string *)0,

			(nt_unicode_string *)0)))

		return status;

	__ntapi->rtl_normalize_process_params(cparams.process_params);

	if (sparams->startupinfo) {

		cparams.process_params->hstdin  = sparams->startupinfo->hstdin;

		cparams.process_params->hstdout = sparams->startupinfo->hstdout;

		cparams.process_params->hstderr = sparams->startupinfo->hstderr;

	}

	/* inherit handles? */

	if (cparams.process_params->hstdin

			|| cparams.process_params->hstdout

			|| cparams.process_params->hstderr)

		finherit = 1;

	else if (sparams->processflags & NT_PROCESS_CREATE_FLAGS_INHERIT_HANDLES)

		finherit = 1;

	else

		finherit = 0;

	/* process flags */

	fsuspended = 0;

	fdebug     = 0;

	if (sparams->processflags & NT_PROCESS_CREATE_FLAGS_CREATE_THREAD_SUSPENDED)

		fsuspended = NT_CREATE_SUSPENDED;

	else if (sparams->threadflags & NT_CREATE_SUSPENDED)

		fsuspended = NT_CREATE_SUSPENDED;

	else if (sparams->spawnflags & NT_PROCESS_SPAWN_FLAG_DEBUG_SUSPENDED)

		fsuspended = NT_CREATE_SUSPENDED;

	else if (sparams->spawnflags & NT_PROCESS_SPAWN_FLAG_DEBUG_EXECUTION)

		fdebug = NT_CREATE_SUSPENDED;

	/* hoppla: try either via kernel32 (sparams->startupinfo), or natively */

	if (sparams->spawnflags & NT_PROCESS_SPAWN_FLAG_DELEGATE_TO_SYSTEM_LIBRARY) {

		processinfo.hprocess   = 0;

		processinfo.hthread    = 0;

		processinfo.process_id = 0;

		processinfo.thread_id  = 0;

		if (!(create_process_fn(

				nt_image.buffer,

				nt_cmd_line.buffer,

				0,

				0,

				finherit,

				sparams->interopflags | fsuspended | fdebug,

				0,

				sparams->cwd,

				sparams->startupinfo,

				&processinfo)))

			return __tt_spawn_return(

				&rtblock,0,0,status);

		if ((status = __ntapi->zw_query_information_process(

			processinfo.hprocess,

			NT_PROCESS_BASIC_INFORMATION,

			&cparams.pbi,sizeof(cparams.pbi),

			0)))

			return __tt_spawn_return(

				&rtblock,0,0,status);

		cparams.hprocess = processinfo.hprocess;

		cparams.hthread  = processinfo.hthread;

		cparams.cid.process_id = processinfo.process_id;

		cparams.cid.thread_id  = processinfo.thread_id;

	} else {

		cparams.creation_flags_thread = NT_PROCESS_CREATE_FLAGS_CREATE_THREAD_SUSPENDED;

		if (finherit)

			cparams.creation_flags_process |= NT_PROCESS_CREATE_FLAGS_INHERIT_HANDLES;

		if ((status = __ntapi->tt_create_native_process(&cparams)))

			return __tt_spawn_return(

				&rtblock,0,0,status);

	}

	/* debug */

	if (sparams->spawnflags & NT_PROCESS_SPAWN_FLAG_DEBUG_MASK)

		if ((status = __ntapi->tt_debug_create_attach_object(

				&sparams->hdbgobj,

				cparams.hprocess,

				NT_DEBUG_KILL_ON_EXIT)))

			return __tt_spawn_return(

				&rtblock,

				cparams.hprocess,

				cparams.hthread,

				status);

	/* tidy up */

	if (!sparams->himage)

		__ntapi->zw_close(hfile);

	/* output */

	sparams->hprocess = cparams.hprocess;

	sparams->hthread  = cparams.hthread;

	sparams->cid.process_id = cparams.pbi.unique_process_id;

	sparams->cid.thread_id  = cparams.cid.thread_id;

	__ntapi->tt_generic_memcpy(

		&sparams->pbi,

		&cparams.pbi,

		sizeof(nt_pbi));

	/* create suspended? */

	if (fsuspended)

		return __tt_spawn_return(

			&rtblock,0,0,NT_STATUS_SUCCESS);

	/* tada */

	if ((status = __ntapi->zw_resume_thread(cparams.hthread,0)))

		return __tt_spawn_return(

			&rtblock,

			cparams.hprocess,

			cparams.hthread,

			status);

	/* all done */

	return __tt_spawn_return(

		&rtblock,0,0,NT_STATUS_SUCCESS);

}