/*

 RDP event queuing 

 Copyright 2013 Thincast Technologies GmbH, Author: Dorian Johnson

 This Source Code Form is subject to the terms of the Mozilla Public License, v. 2.0. 

 If a copy of the MPL was not distributed with this file, You can obtain one at http://mozilla.org/MPL/2.0/.

 */

#include "ios_freerdp_events.h"

#pragma mark -

#pragma mark Sending compacted input events (from main thread)

// While this function may be called from any thread that has an autorelease pool allocated, it is not threadsafe: caller is responsible for synchronization

BOOL ios_events_send(mfInfo* mfi, NSDictionary * event_description)

{		

	NSData * encoded_description = [NSKeyedArchiver archivedDataWithRootObject:event_description];

	if ([encoded_description length] > 32000 || (mfi->event_pipe_producer == -1) )

		return FALSE;

	uint32_t archived_data_len = (uint32_t)[encoded_description length];

	//NSLog(@"writing %d bytes to input event pipe", archived_data_len);

	if (write(mfi->event_pipe_producer, &archived_data_len, 4) == -1)

	{

		NSLog(@"%s: Failed to write length descriptor to pipe.", __func__);

		return FALSE;

	}

	if (write(mfi->event_pipe_producer, [encoded_description bytes], archived_data_len) == -1)

	{

		NSLog(@"%s: Failed to write %d bytes into the event queue (event type: %@).", __func__, (int)[encoded_description length], [event_description objectForKey:@"type"]);

		return FALSE;

	}

	return TRUE;	

}

#pragma mark -

#pragma mark Processing compacted input events (from connection thread runloop)

static BOOL ios_events_handle_event(mfInfo* mfi, NSDictionary * event_description)

{

	NSString * event_type = [event_description objectForKey:@"type"];

	BOOL should_continue = TRUE;

	freerdp* instance = mfi->instance;

	if ([event_type isEqualToString:@"mouse"])

	{        

		instance->input->MouseEvent(instance->input, 

                                    [[event_description objectForKey:@"flags"] unsignedShortValue],

                                    [[event_description objectForKey:@"coord_x"] unsignedShortValue],

                                    [[event_description objectForKey:@"coord_y"] unsignedShortValue]);

	}

	else if ([event_type isEqualToString:@"keyboard"])

	{

		if ([[event_description objectForKey:@"subtype"] isEqualToString:@"scancode"])

			instance->input->KeyboardEvent(instance->input, 

                                           [[event_description objectForKey:@"flags"] unsignedShortValue],

                                           [[event_description objectForKey:@"scancode"] unsignedShortValue]);

		else if ([[event_description objectForKey:@"subtype"] isEqualToString:@"unicode"])

			instance->input->UnicodeKeyboardEvent(instance->input,

                                                  [[event_description objectForKey:@"flags"] unsignedShortValue],

                                                  [[event_description objectForKey:@"unicode_char"] unsignedShortValue]);

		else

			NSLog(@"%s: doesn't know how to send keyboard input with subtype %@", __func__, [event_description objectForKey:@"subtype"]);

	}

	else if ([event_type isEqualToString:@"disconnect"])

		should_continue = FALSE;

	else

		NSLog(@"%s: unrecognized event type: %@", __func__, event_type);

	return should_continue;

}

BOOL ios_events_check_fds(mfInfo* mfi, fd_set* rfds)

{	

	if ( (mfi->event_pipe_consumer == -1) || !FD_ISSET(mfi->event_pipe_consumer, rfds))

		return TRUE;

	uint32_t archived_data_length = 0;

	ssize_t bytes_read;

	// First, read the length of the blob

	bytes_read = read(mfi->event_pipe_consumer, &archived_data_length, 4);

	if (bytes_read == -1 || archived_data_length < 1 || archived_data_length > 32000)

	{

		NSLog(@"%s: just read length descriptor. bytes_read=%ld, archived_data_length=%u", __func__, bytes_read, archived_data_length);

		return FALSE;

	}

	//NSLog(@"reading %d bytes from input event pipe", archived_data_length);

	NSMutableData * archived_object_data = [[NSMutableData alloc] initWithLength:archived_data_length];

	bytes_read = read(mfi->event_pipe_consumer, [archived_object_data mutableBytes], archived_data_length);

	if (bytes_read != archived_data_length)

	{

		NSLog(@"%s: attempted to read data; read %ld bytes but wanted %d bytes.", __func__, bytes_read, archived_data_length);

		[archived_object_data release];

		return FALSE;

	}

	id unarchived_object_data = [NSKeyedUnarchiver unarchiveObjectWithData:archived_object_data];

	[archived_object_data release];

	return ios_events_handle_event(mfi, unarchived_object_data);

}

BOOL ios_events_get_fds(mfInfo* mfi, void ** read_fds, int * read_count, void ** write_fds, int * write_count)

{

	read_fds[*read_count] = (void *)(long)(mfi->event_pipe_consumer);

	(*read_count)++;

	return TRUE;

}

// Sets up the event pipe

BOOL ios_events_create_pipe(mfInfo* mfi)

{

	int pipe_fds[2];

	if (pipe(pipe_fds) == -1)

	{

		NSLog(@"%s: pipe failed.", __func__);

		return FALSE;

	}

	mfi->event_pipe_consumer = pipe_fds[0];

	mfi->event_pipe_producer = pipe_fds[1];

	return TRUE;

}

void ios_events_free_pipe(mfInfo* mfi)

{

	int consumer_fd = mfi->event_pipe_consumer, producer_fd = mfi->event_pipe_producer;

	mfi->event_pipe_consumer = mfi->event_pipe_producer = -1;

	close(producer_fd);

	close(consumer_fd);	

}