/*
* Copyright (c) 2005-2009 Nokia Corporation and/or its subsidiary(-ies).
* All rights reserved.
* This component and the accompanying materials are made available
* under the terms of "Eclipse Public License v1.0"
* which accompanies this distribution, and is available
* at the URL "http://www.eclipse.org/legal/epl-v10.html".
*
* Initial Contributors:
* Nokia Corporation - initial contribution.
*
* Contributors:
*
* Description: 
*
*/



 /************************************************************************* 
 *
 * System Includes
 *
 *************************************************************************/

/*************************************************************************
 *
 * Local Includes
 *
 *************************************************************************/
#include "assert.h"
#include "stat.h"
#include "stat_interfaces.h"
#include "stat_controller.h"
#include "stat_engine.h"


/*************************************************************************
 *
 * Definitions
 *
 *************************************************************************/

/*************************************************************************
 *
 * CStatController - Construction
 *
 *************************************************************************/
CStatController *CStatController::NewL()
{
    CStatController *self = new (ELeave) CStatController();
    CleanupStack::PushL(self);
	self->ConstructL();
	CleanupStack::Pop();
    return self;
}

CStatController::CStatController() : CActive(EPriorityHigh), iFs( NULL ), iMsg( NULL )
{
}

void CStatController::ConstructL( void ) 
{
	// add me to the active scheduler
	CActiveScheduler::Add(this); 

	// params
	iEngine = NULL;
	iSessionStatus = EIdle;
	iTransport = NULL;
	iUI = NULL;
	iConnectedSuccessfully = EFalse;
	iUserInitiatedExitRequest = EFalse;
	iFs =	NULL;
	iMsg = NULL;

	// wait for notifications
	iStatus = KRequestPending;
	SetActive();
}

CStatController::~CStatController()
{
	// clear notification -- deque (and CActive destructor) will fail otherwise
	Notify( KErrCancel );
	Deque();

	// make sure the session is closed
	asserte( iSessionStatus == EIdle );
	asserte( iEngine == NULL );
	asserte( iTransport == NULL );
}

/*************************************************************************
 *
 * CStatController - public interface
 *
 *************************************************************************/
TInt CStatController::StartSession( TStatConnectType aConnectType, TDesC *aConnectParams, MNotifyUI *aUI, RFs *const aSession, MNotifyLogMessage *const aMsg )
{
	TInt exp =	KErrNone;

	iFs =	aSession;
	iMsg =	aMsg;

    if(!aConnectParams) {
        return -1;
    }

	// this is the notification sink for this session
	iUI = aUI;
	iConnectType = aConnectType;
	asserte( aConnectParams->Length() <= KAddressTextLimit );
    iConnectParams.Copy( *aConnectParams );
		
	// create the engine with a callback interface to the controller, create the 
	// appropriate transport, and start the engine
	iConnectedSuccessfully = EFalse;
	TRAP( exp, (iEngine = CStatEngine::NewL(this, iFs, iMsg)) );
	if( exp != KErrNone ) {
		return -1;
	}

	// if the start transport leaves then its because it failed to create an object. This
	// is either because the network or transport creation failed left. If it was the
	// transport then the network may still have memory allocated.
	TRAP( exp, (iTransport = StartTransportL(iConnectType)) );
	if( exp != KErrNone ) {
		if( iSerialNetwork != NULL ) {
			delete iSerialNetwork;
		}
		return -1;
	}

	iEngine->StartEngine( iTransport, iConnectType, &iConnectParams );

	// this controller only supports one session which always has ID = 1
	return 1;
}

TInt CStatController::StopSession( TInt aSessionId )
{
	// make sure this is a valid, active, session
	if( (aSessionId != 1) || (iSessionStatus == EIdle) )
	{
		// If the session is valid and idle then it is not
		// initialised and connected correctly.
		// Call Notify to cancel the outstanding asynchronous events
		// we are registered for.
		// This fixes a problem that appears when the engine fails to
		// start correctly (due to COM port failures for example) and
		// caused the CActiveScheduler never to stop as this object
		// never received a callback when it needs one to remove
		// itself from the active state.
		// If the CActiveScheduler does not shut down then the
		// program never exits and blocks.
		Notify( KErrNone );
		//
		return KErrBadHandle;
	}

	iMsg->Msg( _L("CONTROLLER: Stopping session.") );

	// tell the engine to stop and then wait for an asynchronous response
	iUserInitiatedExitRequest = ETrue;
	iEngine->StopEngine();
	return KErrNone;
}

TInt CStatController::SessionStatus( TInt aSessionId )
{
	if( aSessionId != 1 )
		return KErrBadHandle;
	return iSessionStatus;
}

void CStatController::SetStatus( TCommStatus aNewStatus )
{
	iSessionStatus = aNewStatus;
	if( iUI != NULL )
		iUI->HandleStatusChange( 1, iSessionStatus );
	if( aNewStatus == EConnected ) 
		iConnectedSuccessfully = ETrue;
}

/*************************************************************************
 *
 * CStatController - MNotifyStatController
 *
 *************************************************************************/
void CStatController::HandleStatusChange( TCommStatus aNewStatus )
{
	// If the engine has gone idle then everything is done and we can kill
	// everything off. But, this function was called by the engine, so we
	// can't kill it here -- send self an event to clean things up.
	if( aNewStatus == EIdle ) {
		Notify( KErrNone );
		return;
	}
	
	// update the status
	SetStatus( aNewStatus );
}

// The engine deals with the transports in the face of errors itself, and the 
// interaction with the engine is really handled via HandleStatusChange. This
// function is mainly here to be able to pass information up from the transport
// and the engine to the UI / user
void CStatController::HandleError( TInt aError, void *aErrorData )
{
	if( iUI != NULL ) 
		iUI->HandleError( aError, aErrorData );
}

// Info is for end-user consumption only and is sent directly to the UI.
void CStatController::HandleInfo( const TDesC *aInfo )
{
	if( iUI != NULL )
		iUI->HandleInfo( aInfo );
}

/*************************************************************************
 *
 * CStatController - CActive
 *
 *************************************************************************/
void CStatController::RunL()
{
	// delete the engine and the transport
	delete iEngine;
	iEngine = NULL;
	KillTransport();

	// now change the status to idle
	SetStatus( EIdle );

	// wait again
	iStatus = KRequestPending;
	SetActive();

	// But if this wasn't a user requested exit -- and the last connection
	// did connect successfully, then restart. Otherwise clear the flags.
	if( (iConnectedSuccessfully) && (!iUserInitiatedExitRequest) ) {
		iConnectedSuccessfully = EFalse;
		iEngine = CStatEngine::NewL( this, iFs, iMsg );
		iTransport = StartTransportL( iConnectType );
		iEngine->StartEngine( iTransport, iConnectType, &iConnectParams );
	} else {
		iUserInitiatedExitRequest = EFalse;
		iConnectedSuccessfully = EFalse;
	}
}		

void CStatController::DoCancel()
{
}

void CStatController::Notify( TInt aErrorStatus )
{
	TRequestStatus *pstatus;
	pstatus = &iStatus;
	TRequestStatus *&rstatus = pstatus;
	User::RequestComplete( rstatus, aErrorStatus );
}

/*************************************************************************
 *
 * CStatController - Private
 *
 *************************************************************************/
MStatApiTransport *CStatController::StartTransportL( TStatConnectType aConnectType )
{
	switch( aConnectType ) {

#ifndef LIGHT_MODE
	case ETCPIP:
		iTcpipTransport = CStatTransportTCPIP::NewL( );
		iPacketisationTransport = CStatTransportPacketisation::NewL( iEngine, iTcpipTransport, iTcpipTransport->GetPacketSize() );
		return iPacketisationTransport;

	case EInfrared:
		iSerialNetwork = CStatApiSerial::NewL( _L("IrCOMM") );
		iPacketisationTransport = CStatTransportPacketisation::NewL( iEngine, iSerialNetwork, iSerialNetwork->GetPacketSize() );
		return iPacketisationTransport;

	case EBluetooth:
		iBluetoothTransport = CStatTransportBT::NewL();
		iPacketisationTransport = CStatTransportPacketisation::NewL( iEngine, iBluetoothTransport, iBluetoothTransport->GetPacketSize() );
		return iPacketisationTransport;
	
	case EUsb:
		iUsbNetwork = CStatApiUsb::NewL();
		iPacketisationTransport = CStatTransportPacketisation::NewL( iEngine, iUsbNetwork, iUsbNetwork->GetPacketSize() );
		return iPacketisationTransport;

		
		
#endif // ifndef LIGHT_MODE

	case ESerial:
		iSerialNetwork = CStatApiSerial::NewL( _L("ECUART") );
		iPacketisationTransport = CStatTransportPacketisation::NewL( iEngine, iSerialNetwork, iSerialNetwork->GetPacketSize() );
		return iPacketisationTransport;

	default:
		;
	}
	return NULL;
}

void CStatController::KillTransport()
{
	switch( iConnectType ) {

#ifndef LIGHT_MODE
	case ETCPIP:
		delete iTcpipTransport;
		delete iPacketisationTransport;
		iPacketisationTransport = NULL;
		iTcpipTransport = NULL;
		break;

	case EBluetooth:
		delete iBluetoothTransport;
		delete iPacketisationTransport;
		iBluetoothTransport = NULL;
		iPacketisationTransport = NULL;
		break;

	case EInfrared:
		delete iSerialNetwork;
		delete iPacketisationTransport;
		iSerialNetwork = NULL;
		iPacketisationTransport = NULL;
		break;
#endif // ifndef LIGHT_MODE

	case ESerial:
		delete iSerialNetwork;
		delete iPacketisationTransport;
		iSerialNetwork = NULL;
		iPacketisationTransport = NULL;
		break;

	default:
		;
	}
	iTransport = NULL;	
}