// cConnector.cpp: implementation of the cConnector class.
//
//////////////////////////////////////////////////////////////////////


#include "stdafx.h"
#include "cPacket.h"
#include "cBuffer.h"
#include "cSystem.h"
#include "cConnector.h"
#include "../include/cSingleton.h"




//////////////////////////////////////////////////////////////////////
// Construction/Destruction
//////////////////////////////////////////////////////////////////////

cConnector::cConnector() : m_ID(-1), m_sequence(0), m_packet(NULL)
{
	Init();
}

cConnector::~cConnector()
{
	Destroy();
}

void cConnector::Init()
{
	uint32 maxPacket = cSingleton<cSystem>::GetInstance()->GetPacket();
	uint32 encoding = cSingleton<cSystem>::GetInstance()->GetEncoding();

	m_packet = new cPacket( encoding );
	m_storage.Create( maxPacket * 4 );
	m_temporary.Create( maxPacket * 4 );
}

void cConnector::Destroy()
{
	if(m_packet)
	{
		delete m_packet;
		m_packet = NULL;
	}
}

//////////////////////////////////////////////////////////////////////
// operation
//////////////////////////////////////////////////////////////////////

BOOL cConnector::SendPacket(	const uint32 command,
								const uint8* buffer,
								const uint32 length )
{
	m_packet->Make(	static_cast<uint16>(command), 
					buffer, 
					static_cast<uint16>(length),
					static_cast<uint8>(GetSequence()) );

	return Send( m_packet->GetBuffer(), m_packet->GetLength() );
}

void cConnector::OnConnected()
{
	cSystem* system = cSingleton<cSystem>::GetInstance();
		
	PushCommand( 
		system->GetConnectEvent(),
		NULL,
		0 );

	m_sequence = 0;
}


void cConnector::OnDisconnected()
{
	cSystem* system = cSingleton<cSystem>::GetInstance();
	
	PushCommand( 
		system->GetDisconnectEvent(),
		NULL,
		0 );
}

void cConnector::OnReceived( uint8* buffer, const uint32 length )
{
	// ÀӽùöÆÛ¿¡ º¸°üµÈ µ¥ÀÌŸ¿Í ÇöÀç¹ÞÀº µ¥ÀÌŸ¸¦ º¹»çÇÑ´Ù
	if( !m_temporary.Copy( m_storage.GetBuffer(), m_storage.GetLength() ) ) 
	{
		return;
	}
	if( !m_temporary.Append( buffer, length ) ) 
	{
		return;
	}
		 
	m_storage.Erase();

	// ÀӽùöÆÛ¿¡ ÀúÀåµÈ ÆÐŶÀ» °Ë»çÇÏ°í ÇÁ·ÎÅäÄÝ º°·Î ³ª´©¾î¼­ command queue¿¡ push
	CheckPacket( m_temporary.GetBuffer(), m_temporary.GetLength() );
}

void cConnector::CheckPacket( uint8* buffer, uint32 length )
{
	// ÆÐŶÀÇ À¯È¿¼º °Ë»ç
	if( length < sizeof(cHeader) )	
	{
		// Çì´õº¸´Ù ÀÛÀº ÆÐŶÀÌ µé¾î¿ÔÀ» °æ¿ì ó¸®ÇÏÁö ¾Ê´Â´Ù
		m_storage.Copy( buffer, length );
		return;
	}
	
	// Çì´õÁ¤º¸ °Ë»ç
	cHeader* header = reinterpret_cast<cHeader*>(buffer);
	//if( !header->IsPerfect() ) // 2011-02-25 youngdie, À¯È¿¼º °Ë»ç »èÁ¦
	//{
	//	// À߸øµÈ Çì´õ°¡ µé¾î¿ÔÀ»¶§ ÆÐŶÀ» dropÇÑ´Ù
	//	return;
	//}

	// ÆÐŶ Çì´õ¿¡ µû¸¥ ±æÀÌ °Ë»ç
	uint32 packetLength = sizeof(cHeader) + header->GetPayload();
	if( length < packetLength ) // ÆÐŶ±æÀÌ°¡ Àß·Á¼­ µé¾î¿Ô´Ù
	{
		// ÀúÀåÇÏ°í ¸®ÅÏ
		m_storage.Copy( buffer, length );
	}
	else if( length == packetLength ) // ÆÐŶ±æÀÌ°¡ Á¤È®ÇÏ°Ô µé¾î¿Ô´Ù
	{
		PushCommand(	header->GetCommand(),
						buffer + sizeof(cHeader), 
						header->GetPayload() );
	}
	else if( length > packetLength )	// ÆÐŶ±æÀÌ°¡ ºÙ¾î¼­ µé¾î¿Ô´Ù
	{
		PushCommand(	header->GetCommand(),
						buffer + sizeof(cHeader), 
						header->GetPayload() );

		// ´ÙÀ½ ¹öÆÛ Æ÷ÀÎÅÍ·Î À̵¿ÇÏ¿© Àç°Ë»ç
		CheckPacket( buffer + packetLength, length - packetLength );
	}
}

void cConnector::PushCommand( uint32 command, uint8* buffer, uint32 length )
{
	// ¹ÞÀº ÆÐŶÀ» CommandÅ¥¿¡ ÀÔ·ÂÇÑ´Ù
	cCommandQueue* commandQueue = cSingleton<cSystem>::GetInstance()->GetCommandQueue();
	if( commandQueue )
	{
		commandQueue->PushCommand(		GetIdentity(),
										command,
										buffer,
										static_cast<uint16>(length) );
	}
}