//
//  RhomModel.m
//  SyncClientTest
//
//  Created by evgeny vovchenko on 8/23/10.
//  Copyright 2010 RhoMobile. All rights reserved.
//  Copyright 2011-2016 Symbol Technologies. All rights reserved.
//

#import "RhomModel.h"
#import "RhoConnectClient/RhoConnectClient.h"
#include "sync/SyncThread.h"
#import "RhoConnectClient.h"

@implementation RhomModel

@synthesize name;
@synthesize partition;
@synthesize sync_type;
@synthesize source_id;
@synthesize model_type;
@synthesize associations;
@synthesize blob_attribs;

- (id)init
{
	self = [super init];
	partition = @"user";
	sync_type = RST_INCREMENTAL;
	model_type = RMT_PROPERTY_BAG;
	source_id = 0;
	associations = NULL;
	blob_attribs = [[NSMutableString alloc] init];

	return self;
}

- (void)dealloc;
{
	[name release];
	[partition release];
	if (associations)
	{
		[associations release];
	}
	[blob_attribs release];
	[super dealloc];
}

- (RhoConnectNotify *)sync
{
	char *res = (char *)rho_sync_doSyncSourceByName([name cStringUsingEncoding:[NSString defaultCStringEncoding]]);

	RHO_CONNECT_NOTIFY oNotify = { 0 };

	rho_connectclient_parsenotify(res, &oNotify);
	rho_sync_free_string(res);

	return [[[RhoConnectNotify alloc] init:&oNotify] autorelease];
}

- (void)sync:(SEL)callback target:(id)target
{
	[RhoConnectClient setNotification:callback target:target];

	rho_sync_doSyncSourceByName([name cStringUsingEncoding:[NSString defaultCStringEncoding]]);
}

- (void)setNotification:(SEL)callback target:(id)target
{
	[RhoConnectClient setModelNotification:source_id callback:callback target:target];
}

- (void)clearNotification
{
	rho_sync_clear_notification(source_id);
}

- (void)add_blob_attribute:(NSString *)attr_name
{
	[self add_blob_attribute:attr_name overwrite:NO];
}

- (void)add_blob_attribute:(NSString *)attr_name overwrite:(BOOL)attr_overwrite
{
	if (0 < [blob_attribs length])
	{
		[blob_attribs appendString:@","];
	}
	[blob_attribs appendString:attr_name];
	[blob_attribs appendString:@","];
	[blob_attribs appendString:attr_overwrite ? @"1":@"0"];
}

- (void)create:(NSMutableDictionary *)data
{
	unsigned long item = rho_connectclient_hash_create();

	for (NSString *key in data)
	{
		rho_connectclient_hash_put(item,
								   [key cStringUsingEncoding:[NSString defaultCStringEncoding]],
								   [[data objectForKey:key] cStringUsingEncoding:[NSString defaultCStringEncoding]]
								   );
	}

	rho_connectclient_create_object([name cStringUsingEncoding:[NSString defaultCStringEncoding]],
									item);
	const char *szValue = rho_connectclient_hash_get(item, "object");
	if (szValue)
	{
		[data setValue:[NSString stringWithUTF8String:szValue] forKey:@"object"];
	}
	else
	{
		[data setValue:@"" forKey:@"object"];
	}

	szValue = rho_connectclient_hash_get(item, "source_id");
	if (szValue)
	{
		[data setValue:[NSString stringWithUTF8String:szValue] forKey:@"source_id"];
	}
	else
	{
		[data setValue:@"" forKey:@"source_id"];
	}

	rho_connectclient_hash_delete(item);
}

- (BOOL)is_changed
{
	return rho_connectclient_is_changed([name cStringUsingEncoding:[NSString defaultCStringEncoding]]) == 1 ? TRUE : FALSE;
}

- (void)setSyncType:(int)type
{
	sync_type = type;
	rho_connectclient_set_synctype([name cStringUsingEncoding:[NSString defaultCStringEncoding]], type);
}

int enum_func(const char *szKey, const char *szValue, void *pThis)
{
	NSMutableDictionary *data = (NSMutableDictionary *)pThis;

	[data setValue:[NSString stringWithUTF8String:szValue] forKey:[NSString stringWithUTF8String:szKey]];
	return 1;
}

- (NSMutableDictionary *)find:(NSString *)object_id
{
	unsigned long item = rho_connectclient_find(
			[name cStringUsingEncoding:[NSString defaultCStringEncoding]],
			[object_id cStringUsingEncoding:[NSString defaultCStringEncoding]]);

	if (item == 0)
	{
		return NULL;
	}
	NSMutableDictionary *data = [[NSMutableDictionary alloc] init];
	rho_connectclient_hash_enumerate(item, &enum_func, data);

	rho_connectclient_hash_delete(item);
	return [data autorelease];
}

- (NSMutableDictionary *)find_first:(NSDictionary *)cond
{
	unsigned long condhash = rho_connectclient_hash_create();

	for (NSString *key in cond)
	{
		rho_connectclient_hash_put(condhash,
								   [key cStringUsingEncoding:[NSString defaultCStringEncoding]],
								   [[cond objectForKey:key] cStringUsingEncoding:[NSString defaultCStringEncoding]]
								   );
	}

	unsigned long item = rho_connectclient_find_first([name cStringUsingEncoding:[NSString defaultCStringEncoding]], condhash);
	rho_connectclient_hash_delete(condhash);

	if (item == 0)
	{
		return NULL;
	}
	NSMutableDictionary *data = [[NSMutableDictionary alloc] init];
	rho_connectclient_hash_enumerate(item, &enum_func, data);

	rho_connectclient_hash_delete(item);
	return [data autorelease];
}

- (NSMutableArray *)find_all:(NSDictionary *)cond
{
	unsigned long condhash = rho_connectclient_hash_create();

	if (cond)
	{
		for (NSString *key in cond)
		{
			rho_connectclient_hash_put(condhash,
									   [key cStringUsingEncoding:[NSString defaultCStringEncoding]],
									   [[cond objectForKey:key] cStringUsingEncoding:[NSString defaultCStringEncoding]]
									   );
		}
	}

	unsigned long items = rho_connectclient_find_all([name cStringUsingEncoding:[NSString defaultCStringEncoding]], condhash);
	rho_connectclient_hash_delete(condhash);

	if (items == 0)
	{
		return NULL;
	}

	int nSize = rho_connectclient_strhasharray_size(items);
	NSMutableArray *arRes = [[NSMutableArray alloc] initWithCapacity:nSize];
	for (int i = 0; i < nSize; i++)
	{
		NSMutableDictionary *data = [[NSMutableDictionary alloc] init];
		rho_connectclient_hash_enumerate(rho_connectclient_strhasharray_get(items, i), &enum_func, data);

		[arRes addObject:data];
		[data release];
	}

	rho_connectclient_strhasharray_delete(items);
	return [arRes autorelease];
}

- (NSMutableArray *)find_bysql:(NSString *)sql args:(NSArray *)sql_args
{
	unsigned long ar_params = 0;

	if (sql_args != NULL && [sql_args count] > 0)
	{
		ar_params = rho_connectclient_strarray_create();
		for (NSString *param in sql_args)
		{
			rho_connectclient_strarray_add(ar_params, [param cStringUsingEncoding:[NSString defaultCStringEncoding]]);
		}
	}

	unsigned long items = rho_connectclient_findbysql(
			[name cStringUsingEncoding:[NSString defaultCStringEncoding]],
			[sql cStringUsingEncoding:[NSString defaultCStringEncoding]],
			ar_params);

	if (items == 0)
	{
		return NULL;
	}

	int nSize = rho_connectclient_strhasharray_size(items);
	NSMutableArray *arRes = [[NSMutableArray alloc] initWithCapacity:nSize];
	for (int i = 0; i < nSize; i++)
	{
		NSMutableDictionary *data = [[NSMutableDictionary alloc] init];
		rho_connectclient_hash_enumerate(rho_connectclient_strhasharray_get(items, i), &enum_func, data);

		[arRes addObject:data];
		[data release];
	}

	rho_connectclient_strhasharray_delete(items);
	return [arRes autorelease];
}

- (void)save:(NSDictionary *)data
{
	unsigned long item = rho_connectclient_hash_create();

	for (NSString *key in data)
	{
		rho_connectclient_hash_put(item,
								   [key cStringUsingEncoding:[NSString defaultCStringEncoding]],
								   [[data objectForKey:key] cStringUsingEncoding:[NSString defaultCStringEncoding]]
								   );
	}

	rho_connectclient_save([name cStringUsingEncoding:[NSString defaultCStringEncoding]], item);

	rho_connectclient_hash_delete(item);
}

- (void)destroy:(NSDictionary *)data
{
	unsigned long item = rho_connectclient_hash_create();

	for (NSString *key in data)
	{
		rho_connectclient_hash_put(item,
								   [key cStringUsingEncoding:[NSString defaultCStringEncoding]],
								   [[data objectForKey:key] cStringUsingEncoding:[NSString defaultCStringEncoding]]
								   );
	}

	rho_connectclient_itemdestroy([name cStringUsingEncoding:[NSString defaultCStringEncoding]],
								  item);

	rho_connectclient_hash_delete(item);
}

- (void)startBulkUpdate
{
	rho_connectclient_start_bulkupdate([name cStringUsingEncoding:[NSString defaultCStringEncoding]]);
}

- (void)stopBulkUpdate
{
	rho_connectclient_stop_bulkupdate([name cStringUsingEncoding:[NSString defaultCStringEncoding]]);
}

- (void)pushChanges
{
	rho_connectclient_push_changes([name cStringUsingEncoding:[NSString defaultCStringEncoding]]);
}

@end