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

/*  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 <ntapi/nt_termios.h>

#include "toksvc_daemon_impl.h"

#include "toksvc_driver_impl.h"

#include "toksvc_log_impl.h"

static int32_t toks_daemon_ioctl_get_token_count(struct toks_daemon_ctx * dctx)

{

	nt_tty_port_msg * msg = &dctx->reply;

	msg->ttyinfo.exarg = (void *)(intptr_t)toks_get_driver_ntokens(dctx->driver_ctx);

	return NT_STATUS_SUCCESS;

}

static int32_t toks_daemon_ioctl_set_token_count(struct toks_daemon_ctx * dctx)

{

	nt_tty_port_msg * msg;

	int               ntokens;

	msg     = &dctx->reply;

	ntokens = (int)(intptr_t)msg->ttyinfo.exarg;

	if (ntokens < 0)

		return NT_STATUS_INVALID_PARAMETER;

	else if (ntokens > toks_get_driver_atokens(dctx->driver_ctx))

		return NT_STATUS_BUFFER_TOO_SMALL;

	toks_set_driver_ntokens(dctx->driver_ctx,ntokens);

	dctx->ftokens = (dctx->utokens < ntokens)

		? ntokens - dctx->utokens : 0;

	return toks_daemon_release(dctx);

}

static int32_t toks_daemon_ioctl_get_log_level(struct toks_daemon_ctx * dctx)

{

	nt_tty_port_msg * msg = &dctx->reply;

	msg->ttyinfo.exarg = (void *)(intptr_t)dctx->driver_ctx->cctx->loglevel;

	return NT_STATUS_SUCCESS;

}

static int32_t toks_daemon_ioctl_set_log_level(struct toks_daemon_ctx * dctx)

{

	nt_tty_port_msg * msg;

	int               loglevel;

	msg      = &dctx->reply;

	loglevel = (int)(intptr_t)msg->ttyinfo.exarg;

	if ((loglevel < 0) || (loglevel > 9))

		return NT_STATUS_INVALID_PARAMETER;

	toks_set_driver_log_level(dctx->driver_ctx,loglevel);

	toks_log_service_info(dctx);

	return NT_STATUS_SUCCESS;

}

static int32_t toks_daemon_ioctl_get_service_info(struct toks_daemon_ctx * dctx)

{

	nt_tty_port_msg * msg = &dctx->reply;

	/* uuid */

	msg->svcdata.meta[0]  = (dctx->driver_ctx->cctx->uuid->data1);

	msg->svcdata.meta[1]  = (dctx->driver_ctx->cctx->uuid->data2);

	msg->svcdata.meta[1] |= (dctx->driver_ctx->cctx->uuid->data3 << 16);

	msg->svcdata.meta[2]  = (dctx->driver_ctx->cctx->uuid->data4[0]);

	msg->svcdata.meta[2] |= (dctx->driver_ctx->cctx->uuid->data4[1] << 8);

	msg->svcdata.meta[2] |= (dctx->driver_ctx->cctx->uuid->data4[2] << 16);

	msg->svcdata.meta[2] |= (dctx->driver_ctx->cctx->uuid->data4[3] << 24);

	msg->svcdata.meta[3]  = (dctx->driver_ctx->cctx->uuid->data4[4]);

	msg->svcdata.meta[3] |= (dctx->driver_ctx->cctx->uuid->data4[5] << 8);

	msg->svcdata.meta[3] |= (dctx->driver_ctx->cctx->uuid->data4[6] << 16);

	msg->svcdata.meta[3] |= (dctx->driver_ctx->cctx->uuid->data4[7] << 24);

	/* syspid, systid */

	msg->svcdata.data[0]  = pe_get_current_process_id();

	msg->svcdata.data[1]  = pe_get_current_thread_id();

	/* ctrlpid, csyspid */

	msg->svcdata.data[2]  = dctx->ctrlpid;

	msg->svcdata.data[3]  = dctx->csyspid;

	/* allocated, available */

	msg->svcdata.data[4]  = toks_get_driver_atokens(dctx->driver_ctx);

	msg->svcdata.data[5]  = toks_get_driver_ntokens(dctx->driver_ctx);

	/* used, free */

	msg->svcdata.data[6]  = dctx->utokens;

	msg->svcdata.data[7]  = dctx->ftokens;

	return NT_STATUS_SUCCESS;

}

static int32_t toks_daemon_ioctl_log_service_info(struct toks_daemon_ctx * dctx)

{

	toks_log_service_info(dctx);

	return NT_STATUS_SUCCESS;

}

static int32_t toks_daemon_ioctl_log_token_info(struct toks_daemon_ctx * dctx)

{

	toks_log_token_info(dctx);

	return NT_STATUS_SUCCESS;

}

int32_t __stdcall toks_daemon_ioctl(struct toks_daemon_ctx * dctx)

{

	nt_tty_port_msg * msg;

	uint32_t          ctlcode;

	msg     = &dctx->reply;

	ctlcode = msg->ttyinfo.opdata;

	switch (ctlcode) {

		case TOKS_IOCTL_GET_TOKEN_COUNT:

			return toks_daemon_ioctl_get_token_count(dctx);

		case TOKS_IOCTL_SET_TOKEN_COUNT:

			return toks_daemon_ioctl_set_token_count(dctx);

		case TOKS_IOCTL_GET_SERVICE_INFO:

			return toks_daemon_ioctl_get_service_info(dctx);

		case TOKS_IOCTL_LOG_SERVICE_INFO:

			return toks_daemon_ioctl_log_service_info(dctx);

		case TOKS_IOCTL_LOG_TOKEN_INFO:

			return toks_daemon_ioctl_log_token_info(dctx);

		case TOKS_IOCTL_GET_LOG_LEVEL:

			return toks_daemon_ioctl_get_log_level(dctx);

		case TOKS_IOCTL_SET_LOG_LEVEL:

			return toks_daemon_ioctl_set_log_level(dctx);

		default:

			return NT_STATUS_NOT_IMPLEMENTED;

	}

}