/*********************************************************/
/*  toksvc: a framework-native token broker service      */
/*  Copyright (C) 2020  Z. Gilboa                        */
/*  Released under GPLv2 and GPLv3; see COPYING.TOKSVC.  */
/*********************************************************/

#include <psxtypes/psxtypes.h>
#include <ntapi/ntapi.h>

#include <toksvc/toksvc.h>
#include "toksvc_daemon_impl.h"
#include "toksvc_driver_impl.h"

static int32_t toks_daemon_client_wait(void * rapunzel)
{
	struct toks_client_ctx * client;

	client = (struct toks_client_ctx *)rapunzel;

	ntapi->zw_set_event(client->hswap,0);
	ntapi->zw_close(client->hswap);

	ntapi->zw_wait_for_single_object(
		client->hprocess,
		NT_SYNC_NON_ALERTABLE,
		0);

	ntapi->zw_close(client->hprocess);
	ntapi->zw_close(client->hport);

	return ntapi->zw_terminate_thread(
		NT_CURRENT_THREAD_HANDLE,
		NT_STATUS_SUCCESS);
}

static int32_t toks_daemon_client_instance(struct toks_client_ctx * client)
{
	int32_t			status;
	nt_thread_params	params;

	if ((status = ntapi->tt_create_private_event(
			&client->hswap,
			NT_NOTIFICATION_EVENT,
			NT_EVENT_NOT_SIGNALED)))
		return status;

	ntapi->tt_aligned_block_memset(
		&params,0,sizeof(params));

	params.hprocess		  = NT_CURRENT_PROCESS_HANDLE;
	params.start		  = toks_daemon_client_wait;
	params.ext_ctx            = client;
	params.ext_ctx_size       = sizeof(*client);
	params.stack_size_commit  = 4 * 1024;
	params.stack_size_reserve = 4 * 1024;
	params.creation_flags	  = NT_CREATE_LOCAL_THREAD;

	if ((status = ntapi->tt_create_thread(&params)))
		return status;

	if ((status = ntapi->zw_wait_for_single_object(
			client->hswap,
			NT_SYNC_NON_ALERTABLE,
			0)))
		return status;

	return ntapi->zw_close(params.hthread);
}

int32_t __stdcall toks_daemon_connect(struct toks_daemon_ctx * dctx)
{
	int32_t                     status;
	nt_tty_port_msg *           msg;
	struct toks_client_ctx      client;
	nt_oa                       oa;

	msg                   = &dctx->reply;
	msg->ttyinfo.exarg    = 0;

	client.hport          = 0;
	client.hprocess       = 0;
	client.hswap          = 0;
	client.cid.process_id = msg->header.client_id.process_id;
	client.cid.thread_id  = 0;

	oa.len      = sizeof(oa);
	oa.root_dir = 0;
	oa.obj_name = 0;
	oa.obj_attr = 0;
	oa.sec_desc = 0;
	oa.sec_qos  = 0;

	status = ntapi->zw_open_process(
		&client.hprocess,
		NT_PROCESS_SYNCHRONIZE | NT_PROCESS_QUERY_INFORMATION,
		&oa,&client.cid);

	status = ntapi->zw_accept_connect_port(
		&client.hport,
		client.cid.process_id,
		&msg->header,
		NT_LPC_ACCEPT_CONNECTION,0,0);

	if (status) {
		ntapi->zw_close(client.hprocess);
		return status;
	}

	ntapi->zw_complete_connect_port(client.hport);

	return toks_daemon_client_instance(&client);
}