record_utils_test.erl

-module (record_utils_test).
-author("trung@mdkt.org").

-include_lib("eunit/include/eunit.hrl").
-include("../include/types.hrl").
-include("../include/messages.hrl").

new_record(abstract_message) ->
	#abstract_message{
		clientId = 1, 
		destination = "dest", 
		messageId = "MSG-ID", 
		timestamp = 1000, 
		timeToLive = 2000, 
		headers = [{someheader}], 
		body = "body"
	};
new_record(rpc_message) ->
	#rpc_message{
		parent = new_record(abstract_message),
		remoteUsername = "userName",
		remotePassword = "password1234"
	};
new_record(remoting_message) ->
	#remoting_message{
		parent = new_record(rpc_message),
		source = "source",
		operation = "oper",
		parameters = ["1", "2"]
	};
new_record(async_message) ->
	#async_message{
		parent = new_record(abstract_message),
		correlationId = "1234",
		correlationIdBytes = [12,12,12]
	};
new_record(command_message) ->
	#command_message{
		parent = new_record(async_message),
		operation = ?UNKNOWN_OPERATION
	};

new_record(asobject) ->
    #asobject{
	    array = []
	   }.

abstract_message_set_clientId_test() ->
	NewValue = 2,
	{ok, NewR, _} = record_utils:set(new_record(abstract_message), clientId, NewValue),
	?assert(is_record(NewR, abstract_message)),
	?assertEqual(NewR#abstract_message.clientId ,  NewValue).
	
abstract_message_set_destination_test() ->
	NewValue = "new dest",
	{ok, NewR, _} = record_utils:set(new_record(abstract_message), destination, NewValue),
	?assert(is_record(NewR, abstract_message)),
	?assertEqual(NewR#abstract_message.destination ,  NewValue).
	
abstract_message_set_messageId_test() ->
	NewValue = "some value",
	{ok, NewR, _} = record_utils:set(new_record(abstract_message), messageId, NewValue),
	?assert(is_record(NewR, abstract_message)),
	?assertEqual(NewR#abstract_message.messageId ,  NewValue).

abstract_message_set_timestamp_test() ->
	NewValue = 9,
	{ok, NewR, _} = record_utils:set(new_record(abstract_message), timestamp, NewValue),
	?assert(is_record(NewR, abstract_message)),
	?assertEqual(NewR#abstract_message.timestamp ,  NewValue).

abstract_message_set_timeToLive_test() ->
	NewValue = 9,
	{ok, NewR, _} = record_utils:set(new_record(abstract_message), timeToLive, NewValue),
	?assert(is_record(NewR, abstract_message)),
	?assertEqual(NewR#abstract_message.timeToLive ,  NewValue).

abstract_message_set_headers_test() ->
	NewValue = [{newheader1}, {newheader2}],
	{ok, NewR, _} = record_utils:set(new_record(abstract_message), headers, NewValue),
	?assert(is_record(NewR, abstract_message)),
	?assertEqual(NewR#abstract_message.headers ,  NewValue).

abstract_message_set_body_test() ->
	NewValue = ["some body"],
	{ok, NewR, _} = record_utils:set(new_record(abstract_message), body, NewValue),
	?assert(is_record(NewR, abstract_message)),
	?assertEqual(NewR#abstract_message.body ,  NewValue).

rpc_message_set_parent_test() ->
	NewValue = new_record(abstract_message),
	{ok, NewR, _} = record_utils:set(new_record(rpc_message), parent, NewValue),
	?assert(is_record(NewR, rpc_message)),
	?assertEqual(NewR#rpc_message.parent ,  NewValue).

rpc_message_set_remoteUsername_test() ->
	NewValue = "newremoteuser",
	{ok, NewR, _} = record_utils:set(new_record(rpc_message), remoteUsername, NewValue),
	?assert(is_record(NewR, rpc_message)),
	?assertEqual(NewR#rpc_message.remoteUsername ,  NewValue).

rpc_message_set_remotePassword_test() ->
	NewValue = "newremotepassword",
	{ok, NewR, _} = record_utils:set(new_record(rpc_message), remotePassword, NewValue),
	?assert(is_record(NewR, rpc_message)),
	?assertEqual(NewR#rpc_message.remotePassword, NewValue).

remoting_message_set_parent_test() ->
	NewValue = new_record(rpc_message),
	{ok, NewR, _} = record_utils:set(new_record(remoting_message), parent, NewValue),
	?assert(is_record(NewR, remoting_message)),
	?assertEqual(NewR#remoting_message.parent, NewValue).

remoting_message_set_source_test() ->
	NewValue = "newsource",
	{ok, NewR, _} = record_utils:set(new_record(remoting_message), source, NewValue),
	?assert(is_record(NewR, remoting_message)),
	?assertEqual(NewR#remoting_message.source, NewValue).

remoting_message_set_operation_test() ->
	NewValue = "newoperation",
	{ok, NewR, _} = record_utils:set(new_record(remoting_message), operation, NewValue),
	?assert(is_record(NewR, remoting_message)),
	?assertEqual(NewR#remoting_message.operation, NewValue).

remoting_message_set_parameters_test() ->
	NewValue = [{newparam, 1}],
	{ok, NewR, _} = record_utils:set(new_record(remoting_message), parameters, NewValue),
	?assert(is_record(NewR, remoting_message)),
	?assertEqual(NewR#remoting_message.parameters, NewValue).

async_message_set_parent_test() ->
	NewValue = new_record(abstract_message),
	{ok, NewR, _} = record_utils:set(new_record(async_message), parent, NewValue),
	?assert(is_record(NewR, async_message)),
	?assertEqual(NewR#async_message.parent, NewValue).

async_message_set_correlationId_test() ->
	NewValue = 12,
	{ok, NewR, _} = record_utils:set(new_record(async_message), correlationId, NewValue),
	?assert(is_record(NewR, async_message)),
	?assertEqual(NewR#async_message.correlationId, NewValue).

async_message_set_correlationIdBytes_test() ->
	NewValue = [1,2,3],
	{ok, NewR, _} = record_utils:set(new_record(async_message), correlationIdBytes, NewValue),
	?assert(is_record(NewR, async_message)),
	?assertEqual(NewR#async_message.correlationIdBytes, NewValue).

command_message_set_parent_test() ->
	NewValue = new_record(async_message),
	{ok, NewR, _} = record_utils:set(new_record(command_message), parent, NewValue),
	?assert(is_record(NewR, command_message)),
	?assertEqual(NewR#command_message.parent, NewValue).
	
command_message_set_operation_test() ->
	NewValue = ?CLIENT_PING_OPERATION,
	{ok, NewR, _} = record_utils:set(new_record(command_message), operation, NewValue),
	?assert(is_record(NewR, command_message)),
	?assertEqual(NewR#command_message.operation, NewValue).

asobject_set_test() ->
    PropertyName = "some property",
    PropertyValue = "some value",
    {ok, NewR, _} = record_utils:set(new_record(asobject), PropertyName, PropertyValue),
    ?assert(is_record(NewR, asobject)),
    ?assertEqual(1, length(NewR#asobject.array)).