/*
 * Copyright 2005-2007, Ingo Weinhold, bonefish@cs.tu-berlin.de.
 * Distributed under the terms of the MIT License.
 */

#include "fs_shell_command_beos.h"

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

#include <OS.h>

#include "fs_shell_command.h"


bool gUsesFifos = false;


bool
send_external_command(const char *command, int *result)
{
	int commandLen = strlen(command);
	if (commandLen > kMaxCommandLength) {
		fprintf(stderr, "Error: Command line too long.\n");
		return false;
	}

	char _message[sizeof(external_command_message) + kMaxCommandLength];
	external_command_message* message = (external_command_message*)_message;
	strcpy(message->command, command);

	// find the command port
	port_id commandPort = find_port(kFSShellCommandPort);
	if (commandPort < 0) {
		fprintf(stderr, "Error: Couldn't find fs_shell command port.\n");
		return false;
	}

	// create a reply port
	port_id replyPort = create_port(1, "fs shell reply port");
	if (replyPort < 0) {
		fprintf(stderr, "Error: Failed to create a reply port: %s\n",
			strerror(replyPort));
		return false;
	}
	message->reply_port = replyPort;

	// send the command message
	status_t error;
	do {
		error = write_port(commandPort, 0, message,
			sizeof(external_command_message) + commandLen);
	} while (error == B_INTERRUPTED);

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

	// wait for the reply
	external_command_reply reply;
	ssize_t bytesRead;
	do {
		int32 code;
		bytesRead = read_port(replyPort, &code, &reply, sizeof(reply));
	} while (bytesRead == B_INTERRUPTED);

	if (bytesRead < 0) {
		fprintf(stderr, "Error: Failed to read reply from fs_shell: %s\n",
			strerror(bytesRead));
		return false;
	}

	*result = reply.error;
	return true;
}