/*********************************************************/
/*  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_driver_impl.h"
#include "toksvc_daemon_impl.h"

int32_t toks_get_server_snapshot(
	struct toks_driver_ctx *        dctx,
	struct toks_server_snapshot **  snapshot)
{
	int32_t                         status;
	void *                          hport;
	void *                          hfile;
	void *                          hsection;
	void *                          addr;
	size_t                          size;
	nt_oa                           oa;
	nt_large_integer                ssize;
	nt_sd_common_buffer             sd;
	struct _nt_tty_port_msg         msg;
	struct toks_server_snapshot *   ctx;
	struct toks_service_info *      svcinfo;
	uint32_t                        access_owner;
	uint32_t                        access_group;
	uint32_t                        access_other;
	uint32_t                        access_admin;

	hport  = toks_get_driver_hservice(dctx);

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

	msg.header.msg_type  = NT_LPC_NEW_MESSAGE;
	msg.header.data_size = sizeof(msg.ttyinfo) + sizeof(msg.svcdata);
	msg.header.msg_size  = sizeof(msg);
	msg.ttyinfo.opcode   = TOKS_DAEMON_IOCTL;
	msg.ttyinfo.opdata   = TOKS_IOCTL_GET_TOKEN_INFO;

	if ((status = ntapi->zw_request_wait_reply_port(hport,&msg,&msg)))
		return status;

	else if (msg.ttyinfo.status)
		return msg.ttyinfo.status;

	/* token info */
	hfile = msg.ttyinfo.exarg;

	/* snapshot context */
	if (!(addr = toks_calloc(1,sizeof(*ctx)))) {
		ntapi->zw_close(hfile);
		return NT_STATUS_MEMORY_NOT_ALLOCATED;
	}

	ctx     = (struct toks_server_snapshot *)addr;
	svcinfo = (struct toks_service_info *)addr;

	/* uuid */
	svcinfo->uuid.data1    = (msg.svcdata.meta[0]);

	svcinfo->uuid.data2    = (msg.svcdata.meta[1]  & 0xffff);
	svcinfo->uuid.data3    = (msg.svcdata.meta[1] >> 16);

	svcinfo->uuid.data4[0] = (msg.svcdata.meta[2] & 0xff);
	svcinfo->uuid.data4[1] = (msg.svcdata.meta[2] & 0xff00) >> 8;
	svcinfo->uuid.data4[2] = (msg.svcdata.meta[2] & 0xff0000) >> 16;
	svcinfo->uuid.data4[3] = (msg.svcdata.meta[2] & 0xff000000) >> 24;

	svcinfo->uuid.data4[4] = (msg.svcdata.meta[3] & 0xff);
	svcinfo->uuid.data4[5] = (msg.svcdata.meta[3] & 0xff00) >> 8;
	svcinfo->uuid.data4[6] = (msg.svcdata.meta[3] & 0xff0000) >> 16;
	svcinfo->uuid.data4[7] = (msg.svcdata.meta[3] & 0xff000000) >> 24;

	/* syspid, systid */
	svcinfo->syspid        = msg.svcdata.data[0];
	svcinfo->systid        = msg.svcdata.data[1];

	/* ctrlpid, csyspid */
	svcinfo->ctrlpid       = msg.svcdata.data[2];
	svcinfo->csyspid       = msg.svcdata.data[3];

	/* allocated, available, pending */
	svcinfo->allocated     = msg.svcdata.data[4];
	svcinfo->available     = msg.svcdata.data[5];
	svcinfo->pending       = msg.svcdata.data[6];

	/* used, free */
	svcinfo->tused         = msg.svcdata.data[7];
	svcinfo->tfree         = msg.svcdata.data[8];

	/* sd */
	access_owner  = NT_GENERIC_READ;
	access_group  = NT_SEC_READ_CONTROL | NT_FILE_READ_ATTRIBUTES;
	access_other  = NT_SEC_READ_CONTROL | NT_FILE_READ_ATTRIBUTES;

	access_owner |= NT_SEC_STANDARD_RIGHTS_ALL;
	access_admin  = access_owner;

	ntapi->acl_init_common_descriptor(
		&sd,0,0,0,0,
		access_owner,access_group,access_other,
		access_admin,access_owner,
		0);

	/* section */
	oa.len		= sizeof(oa);
	oa.root_dir	= 0;
	oa.obj_name	= 0;
	oa.obj_attr	= 0;
	oa.sec_desc	= &sd.sd;
	oa.sec_qos	= 0;

	addr		= 0;
	ssize.quad	= 0;

	size		= __offsetof(struct toks_token_ctx,tokens);
	size           += svcinfo->tused * sizeof(struct toks_token_info);

	status = ntapi->zw_create_section(
		&hsection,
		NT_SECTION_QUERY|NT_SECTION_MAP_READ,
		&oa,&ssize,
		NT_PAGE_READONLY,
		NT_SEC_COMMIT,
		hfile);

	if (status) {
		ntapi->zw_close(hfile);
		toks_free(ctx);
		return status;
	};

	/* section mapping */
	status = ntapi->zw_map_view_of_section(
		hsection,
		NT_CURRENT_PROCESS_HANDLE,
		&addr,0,0,0,
		&size,NT_VIEW_UNMAP,
		0,NT_PAGE_READONLY);

	ntapi->zw_close(hfile);
	ntapi->zw_close(hsection);

	if (status) {
		toks_free(ctx);
		return status;
	};

	/* all done */
	ctx->tokctx = addr;
	*snapshot   = ctx;

	return NT_STATUS_SUCCESS;
}

void toks_free_server_snapshot(struct toks_server_snapshot * snapshot)
{
	ntapi->zw_unmap_view_of_section(
		NT_CURRENT_PROCESS_HANDLE,
		(void *)snapshot->tokctx);

	toks_free(snapshot);
}