/*
* Copyright (c) 2004 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: 
*
*/


#include "TrkEngineModel.h"
#include "TrkEngine.h"
#ifdef __USE_NEW_DEBUG_API__
#include "trkdispatchlayer2.h"
#else
#include "TrkDispatchLayer.h"
#endif

#ifndef __NOKIA_TEXT_SHELL__
#include "TrkSerialCommPort.h"
#endif

#ifndef __TEXT_SHELL__
#include "TrkBtSocketCommPort.h"
#include "TrkUsbPortListener.h"
#include "TrkDbgTrcCommPort.h"
#endif //__TEXT_SHELL__

#ifdef __OEM_TRK__	  
#include "TrkDccCommPort.h"

#ifdef __ENABLE_XTI__
#include "TrkXtiCommPort.h"
#endif
#endif //__OEM_TRK__


//
//
// CTrkEngine implementation
//
//

//
// CTrkEngine::NewL
//
EXPORT_C CTrkEngine* CTrkEngine::NewL()
{
	CTrkEngine* self = new(ELeave) CTrkEngine;
	self->ConstructL();
	return self;
}

//
// CTrkEngine::NewLC
//
EXPORT_C CTrkEngine* CTrkEngine::NewLC()
{
	CTrkEngine* self = new(ELeave) CTrkEngine;
	CleanupStack::PushL(self);
	
	self->ConstructL();
	
	return self;
}


EXPORT_C CTrkEngine* CTrkEngine::NewL(MTrkEngineCallback* aCallback)
{
	CTrkEngine* self = new(ELeave) CTrkEngine;
	self->ConstructL(aCallback);
	return self;
}

//
// CTrkEngine::NewLC
//
EXPORT_C CTrkEngine* CTrkEngine::NewLC(MTrkEngineCallback* aCallback)
{
	CTrkEngine* self = new(ELeave) CTrkEngine;
	CleanupStack::PushL(self);
	
	self->ConstructL(aCallback);
	
	return self;
}

//
// CTrkEngine destructor
//
CTrkEngine::CTrkEngine()
:iCommPort(NULL),
 iDispatchLayer(NULL),
 iModel(NULL),
 iCommPortListener(NULL),
 iInactivityTimerDisabler(NULL),
 iCallback(NULL),
 iCurrentConnType(ETrkBt)
{
}

//
// CTrkEngine::ConstructL
//

void CTrkEngine::ConstructL(MTrkEngineCallback* aCallback)
{	
    // make sure the kernel side device driver is not already loaded
    User::FreeLogicalDevice(KMetroTrkDriverName);
    // load the kernel side device driver
#ifndef __WINS__
    TInt err = User::LoadLogicalDevice(_L("TrkDriver.ldd"));
    if ((KErrAlreadyExists != err) && (KErrNone != err))
        User::Leave(err);       
#endif

	iModel = CTrkEngineModel::NewL();
	iCallback = aCallback;
}

//
// CTrkEngine destructor
//
EXPORT_C CTrkEngine::~CTrkEngine()
{
    #ifndef __TEXT_SHELL__
    // if USB connection, then stop the cable listener as well.
    if (iCurrentConnType == ETrkUsbDbgTrc)
    {
    	iCommPortListener->StopListening();
    }
	#endif
    
    //Unload the driver stuff
#ifndef __WINS__
    TInt err = User::FreeLogicalDevice(KMetroTrkDriverName);
    if (KErrNone != err)
        User::Panic(_L("FreeLogicalDevice failed"), err);
#endif
    
	SafeDelete(iDispatchLayer);
	SafeDelete(iModel);
	SafeDelete(iCommPortListener);	
	SafeDelete(iInactivityTimerDisabler);
}

//
// CTrkEngine::Start
//
EXPORT_C void CTrkEngine::StartL()
{
	iModel->GetConnData(iCurrentConnData);
	iCurrentConnType = iCurrentConnData.iConnType;
	
	DoStartL();
}

//
// CTrkEngine::Start
//
EXPORT_C void CTrkEngine::StartL(TTrkConnType aConnType)
{
	iModel->GetDefaultConnData(aConnType, iCurrentConnData);
	iCurrentConnType = iCurrentConnData.iConnType;
	
	DoStartL();
}

//
// CTrkEngine::Stop
//
EXPORT_C void CTrkEngine::Stop()
{
	if (iDispatchLayer)
	{
		iDispatchLayer->StopListening();	
		SafeDelete(iDispatchLayer);
		iCommPort = NULL; //port is deleted by the framing layer
	}
}

//
// CTrkEngine::GetVersionInfo
//
EXPORT_C void CTrkEngine::GetVersionInfo(TInt &aMajorVersion, TInt &aMinorVersion, TInt &aMajorAPIVersion, TInt &aMinorAPIVersion, TInt &aBuildNumber)
{
	CTrkDispatchLayer::GetVersionInfo(aMajorVersion, aMinorVersion, aMajorAPIVersion, aMinorAPIVersion, aBuildNumber);
}

//
// CTrkEngine::GetConnectionInfo
//
EXPORT_C void CTrkEngine::GetConnectionInfo(TDes& aMessage)
{
	aMessage = KNullDesC;
	if (iCommPort)
	{
		iCommPort->GetConnectionInfo(aMessage);
	}
}
//
// CTrkEngine::GetConnectionInfo
//
EXPORT_C TTrkConnStatus CTrkEngine::GetConnectionStatus()
{
    if (iCommPort)
    {
        
        return(iCommPort->GetConnectionStatus());
    }
    else
        return ETrkConnectionError;
        
}
//
// CTrkEngine::GetErrorInfo
//
EXPORT_C void CTrkEngine::GetErrorInfo(TDes& aMessage)
{
	if (iCommPort)
	{
		iCommPort->GetErrorInfo(aMessage);
	}
	else
	{
		aMessage = iErrorMessage;
	}
}

//
// CTrkEngine::GetConnectionData
//
EXPORT_C void CTrkEngine::GetConnectionData(TTrkConnData& aConnData)
{
	iModel->GetConnData(aConnData);
}

//
// CTrkEngine::SetConnectionData
//
EXPORT_C TInt CTrkEngine::SetConnectionData(TTrkConnData& aConnData)
{
	return iModel->SetConnData(aConnData);
}

//
// CTrkEngine::IsDebugging
//
EXPORT_C TInt CTrkEngine::IsDebugging()
{
	if (iDispatchLayer)
	{
		return iDispatchLayer->IsDebugging();
	}
	return EFalse;
}

//
// CTrkEngine::GetConnectionType
//
EXPORT_C TTrkConnType CTrkEngine::GetConnectionType()
{
    return iCurrentConnType;
}
//
// CTrkEngine::GetPlugPlaySetting()
//
EXPORT_C TBool CTrkEngine::GetPlugPlaySetting()
{
    TBool PlugPLaySetting;
    PlugPLaySetting = iModel->GetPlugPlaySettingValue();
    return PlugPLaySetting;
    
}
//
// CTrkEngine::DoStartL
//
void CTrkEngine::DoStartL()
{
	CreateCommInterfaceL();

	// ownership of the comm port is passed down to CTrkFramingLayer
	iDispatchLayer = CTrkDispatchLayer::NewL(iCommPort, this);
		
#ifndef __TEXT_SHELL__		
	// start listening for the cable connection.	
	/* not required here as server starts listening
	 
	if (iCurrentConnType == ETrkUsbDbgTrc)
	{
		if (!iCommPortListener) // create the listener only once
			iCommPortListener = new CTrkUsbPortListener(this);

		iCommPortListener->ListenL();
	}
	*/
#endif //__TEXT_SHELL__	

	iCommPort->OpenPortL();
	if (iCommPort->IsConnectionEstablished())
	{	  
		iDispatchLayer->Listen();
	
		if (iCurrentConnData.iConnType == ETrkBt || iCurrentConnData.iConnType == ETrkSerial)
			iCommPort->SendDataL(_L8("Trk for Symbian OS started"));
	}

}

//
// CTrkEngine::CreateCommInterfaceL
//
void CTrkEngine::CreateCommInterfaceL()
{
	iCommPort = NULL;

	switch (iCurrentConnData.iCommType)
	{

	#ifndef __NOKIA_TEXT_SHELL__		
		case ESerialComm:
		{
			iCommPort = CTrkSerialCommPort::NewL(iCurrentConnData, iErrorMessage);
			break;
		}
	#endif
	
	#ifndef __TEXT_SHELL__		
		case EBtSocket:
		{
			iCommPort = CTrkBtSocketCommPort::NewL(iCurrentConnData, iErrorMessage, this);			
			break;
		}
		case EDbgTrcComm:
		{
			iCommPort = CTrkDbgTrcCommPort::NewL(iCurrentConnData, iErrorMessage);
			break;
		}
	#endif //__TEXT_SHELL__
		
	#ifdef __OEM_TRK__	  
		case EDcc:
		{
			iCommPort = CTrkDccCommPort::NewL(iCurrentConnData, iErrorMessage);			
			break;
		}
		
		#ifdef __ENABLE_XTI__
		case EXti:
		{
			iCommPort = CTrkXtiCommPort::NewL(iCurrentConnData, iErrorMessage);			
			break;
		}		
		#endif
	#endif //__OEM_TRK__
	
		default:
		{
			User::Leave(KErrNotFound);
		}
	}
	}
	
/*
 * This is called by when BT socket finds the port and started to listen  
 * 
 */
void CTrkEngine::AsyncConnectionSuccessfulL()
{
    iDispatchLayer->Listen();    

    if (iCurrentConnData.iConnType == ETrkBt || iCurrentConnData.iConnType == ETrkSerial)
        iCommPort->SendDataL(_L8("Trk for Symbian OS started"));
    
    if (iCallback)
			iCallback->OnConnection();
	}

/*
 * This is called when PC rejects the connection
 * 
 */
void CTrkEngine::AsyncConnectionFailed()
{
    iCallback->OnAsyncConnectionFailed();   
}

//
// CTrkEngine::DebuggingStarted
// Called from the dispatch layer to indicate the start of a debug session
//
void CTrkEngine::DebuggingStarted()
{
	//start the inactivity timer
	StartInactivityTimerDisabler();
	
	if (iCallback)
		iCallback->DebuggingStarted();
}

//
// CTrkEngine::DebuggingEnded
// Called from the dispatch layer when a debug session ends.
//
void CTrkEngine::DebuggingEnded()
{	
	if (iCallback)
		iCallback->DebuggingEnded();
	//deactivate inactivity timer
	SafeDelete(iInactivityTimerDisabler);
}

// CTrkEngine::StartInactivityTimerDisabler 
//
void CTrkEngine::StartInactivityTimerDisabler()
{	
	iInactivityTimerDisabler = new(ELeave) CInactivityTimerDisabler;
    iInactivityTimerDisabler->ConstructL();  
    iInactivityTimerDisabler->Activate();
}

//
// DLL Entry point
//
#ifndef EKA2
TInt E32Dll(TDllReason)
{
	return KErrNone;
}
#endif