#include "mxeventpresenter.h"

#include "decomp.h"
#include "mxautolocker.h"
#include "mxeventmanager.h"
#include "mxomni.h"
#include "mxvariabletable.h"

DECOMP_SIZE_ASSERT(MxEventPresenter, 0x54);

// FUNCTION: LEGO1 0x100c2b70
MxEventPresenter::MxEventPresenter()
{
	Init();
}

// FUNCTION: LEGO1 0x100c2d40
MxEventPresenter::~MxEventPresenter()
{
	Destroy();
}

// FUNCTION: LEGO1 0x100c2da0
void MxEventPresenter::Init()
{
	m_data = NULL;
}

// FUNCTION: LEGO1 0x100c2db0
MxResult MxEventPresenter::AddToManager()
{
	MxResult ret = FAILURE;

	if (EventManager()) {
		ret = SUCCESS;
		EventManager()->RegisterPresenter(*this);
	}

	return ret;
}

// FUNCTION: LEGO1 0x100c2de0
void MxEventPresenter::Destroy()
{
	if (EventManager()) {
		EventManager()->UnregisterPresenter(*this);
	}

	m_criticalSection.Enter();

	if (m_data) {
		delete[] m_data;
	}

	Init();

	m_criticalSection.Leave();
}

// FUNCTION: LEGO1 0x100c2e30
void MxEventPresenter::CopyData(MxStreamChunk* p_chunk)
{
	m_data = new MxU8[p_chunk->GetLength()];
	memcpy(m_data, p_chunk->GetData(), p_chunk->GetLength());
}

// FUNCTION: LEGO1 0x100c2e70
void MxEventPresenter::ReadyTickle()
{
	MxStreamChunk* chunk = NextChunk();

	if (chunk) {
		CopyData(chunk);
		m_subscriber->DestroyChunk(chunk);
		ParseExtra();
		ProgressTickleState(e_starting);
	}
}

// FUNCTION: LEGO1 0x100c2eb0
void MxEventPresenter::StartingTickle()
{
	MxStreamChunk* chunk = CurrentChunk();

	if (chunk && m_action->GetElapsedTime() >= chunk->GetTime()) {
		ProgressTickleState(e_streaming);
	}
}

// FUNCTION: LEGO1 0x100c2ef0
MxResult MxEventPresenter::PutData()
{
	MxAutoLocker lock(&m_criticalSection);

	if (IsEnabled()) {
		if (m_currentTickleState >= e_streaming &&
			(m_currentTickleState <= e_repeating || m_currentTickleState == e_done)) {
			if (m_currentChunk && m_currentChunk->GetLength()) {
				if (m_data[12] == 2) {
					const char* data = (const char*) m_currentChunk->GetData();
					MxVariableTable* variableTable = VariableTable();

					const char* key = data;
					const char* value = &data[strlen(data) + 1];
					strlen(value);
					variableTable->SetVariable(key, value);
				}

				if (m_currentTickleState == e_streaming) {
					m_subscriber->DestroyChunk(m_currentChunk);
				}
				m_currentChunk = NULL;
			}
		}
	}

	return SUCCESS;
}