/*
 * Copyright 2005, Ingo Weinhold, bonefish@users.sf.net.
 * Distributed under the terms of the MIT License.
 */

#include <stdio.h>
#include <string.h>

#include <OS.h>

#include "external_commands.h"
#include "fs_shell_command_beos.h"


static port_id sReplyPort = -1;


static port_id
get_command_port()
{
	static port_id port = -1;
	static bool initialized = false;

	if (!initialized) {
		port = create_port(10, kFSShellCommandPort);
		initialized = true;
	}

	return port;
}


bool
FSShell::get_external_command(char *input, int len)
{
	// get/create the port
	port_id port = get_command_port();
	if (port < 0) {
		fprintf(stderr, "Error: Failed to create command port: %s\n",
			strerror(port));
		return false;
	}

	while (true) {
		// read a message
		char _message[sizeof(external_command_message) + kMaxCommandLength];
		external_command_message* message = (external_command_message*)_message;
		ssize_t bytesRead;
		do {
			int32 code;
			bytesRead = read_port(port, &code, message, sizeof(_message));
		} while (bytesRead == B_INTERRUPTED);

		if (bytesRead < 0) {
			fprintf(stderr, "Error: Reading from port failed: %s\n",
				strerror(bytesRead));
			return false;
		}

		// get the len of the command
		int commandLen = _message + bytesRead - message->command;
		if (commandLen <= 1) {
			fprintf(stderr, "Error: No command given.\n");
			continue;
		}
		if (commandLen > len) {
			fprintf(stderr, "Error: Command too long. Ignored.\n");
			continue;
		}

		// copy the command
		memcpy(input, message->command, commandLen);
		input[len - 1] = '\0';	// always NULL-terminate
		sReplyPort = message->reply_port;
		return true;
	}
}


void
FSShell::reply_to_external_command(int result)
{
	if (sReplyPort >= 0) {
		// prepare the message
		external_command_reply reply;
		reply.error = result;

		// send the reply
		status_t error;
		do {
			error = write_port(sReplyPort, 0, &reply, sizeof(reply));
		} while (error == B_INTERRUPTED);
		sReplyPort = -1;

		if (error != B_OK) {
			fprintf(stderr, "Error: Failed to send command result to reply "
				"port: %s\n", strerror(error));
		}
	}
}


void
FSShell::external_command_cleanup()
{
	// The port will be deleted automatically when the team exits.
}