#import "MucController.h"
#import "WindowManager.h"
#import "XMPPFramework.h"
#import "DDLog.h"

// Log levels: off, error, warn, info, verbose
static const int ddLogLevel = LOG_LEVEL_VERBOSE;

#define USE_MEMORY_STORAGE 0
#define USE_HYBRID_STORAGE 1

@interface MucController ()
{
#if USE_MEMORY_STORAGE
	NSArray *messages;
	NSArray *occupants;
#elif USE_HYBRID_STORAGE
	NSMutableArray *messages;
	NSMutableArray *occupants;
	
	NSArrayController *arrayController;
#endif
}

#if USE_HYBRID_STORAGE
- (NSArrayController *)arrayController;
#endif

@end

////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
#pragma mark -
////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////

@implementation MucController

- (id)initWithStream:(XMPPStream *)stream roomJID:(XMPPJID *)roomJID
{
	if ((self = [super initWithWindowNibName:@"MucWindow"]))
	{
		xmppStream = stream;
		
		#if USE_MEMORY_STORAGE
			xmppRoomStorage = [[XMPPRoomMemoryStorage alloc] init];
		#elif USE_HYBRID_STORAGE
			xmppRoomStorage = [XMPPRoomHybridStorage sharedInstance];
		#endif
		xmppRoom = [[XMPPRoom alloc] initWithRoomStorage:xmppRoomStorage jid:roomJID];
		
		[xmppRoom addDelegate:self delegateQueue:dispatch_get_main_queue()];
		// xmppRoomStorage automatically inherits the delegate(s) of it's parent xmppRoom
		
		[xmppRoom activate:xmppStream];
		[xmppRoom joinRoomUsingNickname:@"xmppFrameowrkMucTest" history:nil];
		
		#if USE_HYBRID_STORAGE
		messages  = [[NSMutableArray alloc] init];
		occupants = [[NSMutableArray alloc] init];
		#endif
	}
	return self;
}

- (void)windowWillClose:(NSNotification *)notification
{
	[xmppRoom leaveRoom];
	[xmppRoom deactivate];
	[xmppRoom removeDelegate:self];
	
	[WindowManager closeMucWindow:self];
}

- (void)dealloc
{
	DDLogVerbose(@"Deallocating self: %@", self);
	
	[[NSNotificationCenter defaultCenter] removeObserver:self];
	
	[xmppRoom deactivate];
	[xmppRoom removeDelegate:self];
}

////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
#pragma mark Properties
////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////

@synthesize xmppStream;

- (XMPPJID *)jid
{
	return xmppRoom.roomJID;
}

////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
#pragma mark IBActions
////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////

- (IBAction)sendMessage:(id)sender
{
	// Todo...
}

////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
#pragma mark NSTableView Datasource
////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////

- (NSInteger)numberOfRowsInTableView:(NSTableView *)tableView
{
	if (tableView == messagesTableView)
	{
		return [messages count];
	}
	else
	{
		return [occupants count];
	}
}

- (CGFloat)tableView:(NSTableView *)tableView heightOfRow:(NSInteger)row
{
	if (tableView == messagesTableView)
	{
		id <XMPPRoomMessage> message = [messages objectAtIndex:row];
		
		NSTableColumn *column = [[messagesTableView tableColumns] objectAtIndex:0];
		
		MessageCellView *messageCell = [tableView makeViewWithIdentifier:@"MessageCell" owner:self];
		messageCell.nicknameField.stringValue = message.nickname;
		messageCell.messageField.stringValue = message.body;
		
		[messageCell setFrameSize:NSMakeSize([column width], messageCell.frame.size.height)];
		
		return [messageCell fittingHeight];
	}
	else
	{
		return occupantsTableView.rowHeight;
	}
}

- (id)tableView:(NSTableView *)tableView viewForTableColumn:(NSTableColumn *)tableColumn row:(NSInteger)rowIndex
{
	if (tableView == messagesTableView)
	{
		id <XMPPRoomMessage> message = [messages objectAtIndex:rowIndex];
		
		MessageCellView *messageCell = [tableView makeViewWithIdentifier:@"MessageCell" owner:self];
		messageCell.nicknameField.stringValue = message.nickname;
		messageCell.messageField.stringValue = message.body;
		
		return messageCell;
	}
	else
	{
		id <XMPPRoomOccupant> occupant = [occupants objectAtIndex:rowIndex];
		
		NSTableCellView *cell = [tableView makeViewWithIdentifier:@"OccupantCell" owner:self];
		cell.textField.stringValue = occupant.nickname;
		
		return cell;
	}
}

- (void)tableViewColumnDidResize:(NSNotification *)notification
{
	if (notification.object == messagesTableView)
	{
		[messagesTableView noteHeightOfRowsWithIndexesChanged:
		    [NSIndexSet indexSetWithIndexesInRange:NSMakeRange(0, [messages count])]];
	}
}

////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
#pragma mark XMPPRoom Delegate
////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////

- (void)xmppRoomDidCreate:(XMPPRoom *)sender
{
	DDLogVerbose(@"%@: %@", THIS_FILE, THIS_METHOD);
	[logField setStringValue:@"did create room"];
}

- (void)xmppRoomDidJoin:(XMPPRoom *)sender
{
	DDLogVerbose(@"%@: %@", THIS_FILE, THIS_METHOD);
	[logField setStringValue:@"did join room"];
}

- (void)xmppRoomDidLeave:(XMPPRoom *)sender
{
	DDLogVerbose(@"%@: %@", THIS_FILE, THIS_METHOD);
	[logField setStringValue:@"did leave room"];
}

- (void)xmppRoom:(XMPPRoom *)sender occupantDidJoin:(XMPPJID *)occupantJID
{
	DDLogVerbose(@"%@: %@", THIS_FILE, THIS_METHOD);
	[logField setStringValue:[NSString stringWithFormat:@"occupant did join: %@", [occupantJID resource]]];
}

- (void)xmppRoom:(XMPPRoom *)sender occupantDidLeave:(XMPPJID *)occupantJID
{
	DDLogVerbose(@"%@: %@", THIS_FILE, THIS_METHOD);
	[logField setStringValue:[NSString stringWithFormat:@"occupant did join: %@", [occupantJID resource]]];
}

- (void)xmppRoom:(XMPPRoom *)sender didReceiveMessage:(XMPPMessage *)message fromOccupant:(XMPPJID *)occupantJID
{
	DDLogVerbose(@"%@: %@", THIS_FILE, THIS_METHOD);
	[logField setStringValue:[NSString stringWithFormat:@"did receive msg from: %@", [occupantJID resource]]];
}

////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
#pragma mark Core Data
////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
#if USE_HYBRID_STORAGE

- (NSArrayController *)arrayController
{
	if (arrayController == nil)
	{
		XMPPRoomHybridStorage *hybridStorage = (XMPPRoomHybridStorage *)xmppRoomStorage;
		
		NSPredicate *predicate = [NSPredicate predicateWithFormat:@"roomJIDStr == %@", xmppRoom.roomJID];
		
		NSSortDescriptor *sortDescriptor = [NSSortDescriptor sortDescriptorWithKey:@"localTimestamp" ascending:YES];
		
		arrayController = [[NSArrayController alloc] initWithContent:nil];
		arrayController.managedObjectContext = [hybridStorage mainThreadManagedObjectContext];
		arrayController.entityName = hybridStorage.messageEntityName;
		arrayController.fetchPredicate = predicate;
		arrayController.sortDescriptors = [NSArray arrayWithObject:sortDescriptor];
		
	//	NSError *error = nil;
	//	if (![arrayController fetchWithRequest:nil merge:NO error:&error])
	//	{
	//		DDLogError(@"arrayController fetch error: %@", error);
	//	}
		
		arrayController.automaticallyPreparesContent = YES;
	}
	
	return arrayController;
}

#endif
////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
#pragma mark XMPPRoomMemoryStorage Delegate
////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
#if USE_MEMORY_STORAGE

- (void)xmppRoomMemoryStorage:(XMPPRoomMemoryStorage *)sender
              occupantDidJoin:(XMPPRoomOccupantMemoryStorageObject *)occupant
                      atIndex:(NSUInteger)index
                      inArray:(NSArray *)allOccupants {
	
	DDLogVerbose(@"%@: %@", THIS_FILE, THIS_METHOD);
	
	occupants = allOccupants;
	
	NSIndexSet *indexes = [NSIndexSet indexSetWithIndex:index];
	
	[occupantsTableView beginUpdates];
	[occupantsTableView insertRowsAtIndexes:indexes withAnimation:NSTableViewAnimationEffectGap];
	[occupantsTableView endUpdates];
}


- (void)xmppRoomMemoryStorage:(XMPPRoomMemoryStorage *)sender
             occupantDidLeave:(XMPPRoomOccupantMemoryStorageObject *)occupant
                      atIndex:(NSUInteger)index
                    fromArray:(NSArray *)allOccupants {
	
	DDLogVerbose(@"%@: %@", THIS_FILE, THIS_METHOD);
	
	occupants = allOccupants;
	
	NSIndexSet *indexes = [NSIndexSet indexSetWithIndex:index];
	
	[occupantsTableView beginUpdates];
	[occupantsTableView removeRowsAtIndexes:indexes withAnimation:NSTableViewAnimationEffectGap];
	[occupantsTableView endUpdates];
}


- (void)xmppRoomMemoryStorage:(XMPPRoomMemoryStorage *)sender
            occupantDidUpdate:(XMPPRoomOccupantMemoryStorageObject *)occupant
                    fromIndex:(NSUInteger)oldIndex
                      toIndex:(NSUInteger)newIndex
                      inArray:(NSArray *)allOccupants {
	
	DDLogVerbose(@"%@: %@", THIS_FILE, THIS_METHOD);
	
	occupants = allOccupants;
	
	if (oldIndex == newIndex)
	{
		NSIndexSet *rowIndexes = [NSIndexSet indexSetWithIndex:oldIndex];
		NSIndexSet *colIndexes = [NSIndexSet indexSetWithIndex:0];
		
		[occupantsTableView beginUpdates];
		[occupantsTableView reloadDataForRowIndexes:rowIndexes columnIndexes:colIndexes];
		[occupantsTableView endUpdates];
	}
	else
	{
		[occupantsTableView beginUpdates];
		[occupantsTableView moveRowAtIndex:oldIndex toIndex:newIndex];
		[occupantsTableView endUpdates];
	}
}


- (void)xmppRoomMemoryStorage:(XMPPRoomMemoryStorage *)sender
			didReceiveMessage:(XMPPRoomMessageMemoryStorageObject *)message
                 fromOccupant:(XMPPRoomOccupantMemoryStorageObject *)occupantJID
                      atIndex:(NSUInteger)index
                      inArray:(NSArray *)allMessages {
	
	DDLogVerbose(@"%@: %@", THIS_FILE, THIS_METHOD);
	
	messages = allMessages;
	
	NSIndexSet *indexes = [NSIndexSet indexSetWithIndex:index];
	
	[messagesTableView beginUpdates];
	[messagesTableView insertRowsAtIndexes:indexes withAnimation:NSTableViewAnimationSlideUp];
	[messagesTableView endUpdates];
}

#endif
////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
#pragma mark XMPPRoomHybridStorage Delegate
////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
#if USE_HYBRID_STORAGE

- (void)xmppRoomHybridStorage:(XMPPRoomHybridStorage *)sender
              occupantDidJoin:(XMPPRoomOccupantHybridMemoryStorageObject *)occupant
{
	NSIndexSet *indexes = [NSIndexSet indexSetWithIndex:[occupants count]];
	[occupants addObject:occupant];
	
	[occupantsTableView beginUpdates];
	[occupantsTableView insertRowsAtIndexes:indexes withAnimation:NSTableViewAnimationEffectGap];
	[occupantsTableView endUpdates];
}

- (void)xmppRoomHybridStorage:(XMPPRoomHybridStorage *)sender
             occupantDidLeave:(XMPPRoomOccupantHybridMemoryStorageObject *)occupant
{
	NSUInteger index = [occupants indexOfObject:occupant];
	if (index == NSNotFound) return;
	
	NSIndexSet *indexes = [NSIndexSet indexSetWithIndex:index];
	[occupants removeObjectAtIndex:index];
	
	[occupantsTableView beginUpdates];
	[occupantsTableView removeRowsAtIndexes:indexes withAnimation:NSTableViewAnimationEffectGap];
	[occupantsTableView endUpdates];
}

- (void)xmppRoomHybridStorage:(XMPPRoomHybridStorage *)sender
            occupantDidUpdate:(XMPPRoomOccupantHybridMemoryStorageObject *)occupant
{
	NSUInteger index = [occupants indexOfObject:occupant];
	if (index == NSNotFound) return;
	
	NSIndexSet *rowIndexes = [NSIndexSet indexSetWithIndex:index];
	NSIndexSet *colIndexes = [NSIndexSet indexSetWithIndex:0];
	
	[occupants replaceObjectAtIndex:index withObject:occupant];
	
	[occupantsTableView beginUpdates];
	[occupantsTableView reloadDataForRowIndexes:rowIndexes columnIndexes:colIndexes];
	[occupantsTableView endUpdates];
}

#endif

@end

////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
#pragma mark -
////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////

@implementation MessageCellView

@synthesize nicknameField;
@synthesize messageField;

- (CGFloat)fittingHeight
{
	// Calculated how much room we need to fit the message (may span multiple lines).
	
	NSRect messageBounds = messageField.bounds;
	messageBounds.size.height = CGFLOAT_MAX;
	
	CGSize messageSize = [[messageField cell] cellSizeForBounds:messageBounds];
	
	// The fitting height will be the existing height plus the difference.
	
	return (self.frame.size.height + (messageSize.height - messageField.frame.size.height));
}

@end