open62541/OPCUAServer/src/opcua_secureChannelLayer.c

/*
 * opcua_secureChannelLayer.c
 *
 *  Created on: Jan 13, 2014
 *      Author: opcua
 */
#include "opcua_secureChannelLayer.h"

SL_getRequestHeader()
{

}
/*
 * opens a secureChannel (server side)
 */
void SL_secureChannel_open(UA_connection     *connection,
		AD_RawMessage                        *secureChannelMessage,
		SL_SecureConversationMessageHeader   *SCM_Header,
		SL_AsymmetricAlgorithmSecurityHeader *AAS_Header)
{

	TL_send();
	//connection->secureLayer.
}
/*
void SL_secureChannel_Request_get(AD_RawMessage        *secureChannelMessage,
		                          secureChannelRequest *SC_request)
{

}
*/
/*
 * closes a secureChannel (server side)
 */
void SL_secureChannel_close(UA_connection *connection)
{

}
/*
 * receive and process data from underlying layer
 */
void SL_receive(UA_connection *connection,
		        AD_RawMessage *serviceMessage)
{
	AD_RawMessage* secureChannelMessage;
	SL_SecureConversationMessageHeader SCM_Header;
	SL_AsymmetricAlgorithmSecurityHeader AAS_Header;

	//get data from transport layer
	TL_receive(UA_connection, secureChannelMessage);

	//get the Secure Channel Message Header
	UInt32 readPosition = SL_secureChannel_SCMHeader_get(connection,secureChannelMessage,&SCM_Header);

	//get the Secure Channel Asymmetric Algorithm Security Header
	readPosition = SL_secureChannel_AASHeader_get(connection,secureChannelMessage,readPosition,&AAS_Header);

	//get Secure Channel Message
	SL_secureChannel_Message_get(connection,secureChannelMessage,readPosition,serviceMessage);


	if (secureChannelMessage.length > 0)
	{
		switch (SCM_Header.MessageType)
		{
		case packetType_MSG:
			if (connection->secureLayer.connectionState
					== connectionState_ESTABLISHED)
			{

			}
			else //receiving message, without secure channel
			{
				//TODO send back Error Message
			}
			break;
		case packetType_OPN:
			if (openSecureChannelHeader_check(connection, secureChannelMessage))
			{
				SL_secureChannel_open(connection, serviceMessage);
			}
			else
			{
				//TODO send back Error Message
			}
			//TODO free memory for secureChannelMessage
			break;
		case packetType_CLO:
			SL_secureChannel_close(connection, secureChannelMessage);

			//TODO free memory for secureChannelMessage
			break;
	}

}
UInt32 SL_secureChannel_SCMHeader_get(UA_connection *connection, AD_RawMessage *rawMessage, SL_SecureConversationMessageHeader* SC_Header)
{
	Int32 pos = 0;
	SC_Header->MessageType = TL_getPacketType(rawMessage);
	pos += TL_MESSAGE_TYPE_LEN;
	SC_Header->IsFinal = rawMessage[pos];
	pos += sizeof(Byte);
	SC_Header->MessageSize = convertToUInt32(rawMessage,pos);
	pos += sizeof(UInt32);
	SC_Header->SecureChannelId = convertToUInt32(rawMessage,pos);
	pos += sizeof(UInt32);
	return pos;

}
UInt32 SL_secureChannel_AASHeader_get(UA_connection *connection, AD_RawMessage *rawMessage,UInt32 pos, SL_AsymmetricAlgorithmSecurityHeader* AAS_Header)
{
	AAS_Header->SecurityPolicyUri.Length = convertToInt32(rawMessage,pos);

	pos += sizeof(Int32);
	AAS_Header->SecurityPolicyUri.Data = rawMessage[pos];

	if(AAS_Header->SecurityPolicyUri.Length < 0)
	{
		AAS_Header->SecurityPolicyUri.Length = 0;
	}
	pos +=  AAS_Header->SecurityPolicyUri.Length;

	AAS_Header->SenderCertificate.Length = convertToInt32(rawMessage,pos);
	pos += sizeof(Int32);
	if(AAS_Header->SenderCertificate.Length < 0)
	{
		AAS_Header->SenderCertificate.Length = 0;
	}
	AAS_Header->SenderCertificate.Data = rawMessage[pos];

	pos += AAS_Header->SenderCertificate.Length;

	AAS_Header->ReceiverThumbprint.Length = convertToInt32(rawMessage,pos);
	pos += sizeof(Int32);

	if(AAS_Header->ReceiverThumbprint.Length < 0)
	{
		AAS_Header->ReceiverThumbprint.Length = 0;
	}
	AAS_Header->ReceiverThumbprint.Data = rawMessage[pos];

	pos += AAS_Header->ReceiverThumbprint.Length;
	return pos;
}
void SL_secureChannel_Footer_get()
{


}
void SL_secureChannel_Message_get(UA_connection *connection, AD_RawMessage *rawMessage,UInt32 pos, AD_RawMessage *message)
{

}