/*
* 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 "TrkConsole.h"
#include  "trksrvclisession.h"


#define SHOW_CONSOLE

#ifdef SHOW_CONSOLE
static CTrkConsoleIO* TrkIO = NULL;
#endif

#define SafeDelete(x) { if (x) delete x; x = NULL; }




//
//
// CKeyboardInput implementation
//
//

//
// CKeyboardInput constructor
//
CKeyboardInput::CKeyboardInput(CConsoleBase* aConsole)
	: CActive(EPriorityUserInput),
	  iConsole(aConsole)
{
	CActiveScheduler::Add(this);
}

//
// CKeyboardInput destructor
//
CKeyboardInput::~CKeyboardInput()
{
	Cancel();
	Deque();
}

//
// CKeyboardInput::ListenToKeyboard
//
// Wait for a key to be pressed
//
void CKeyboardInput::ListenToKeyboard()
{
	iConsole->Read(iStatus);
	SetActive();
}

//
// CKeyboardInput::RunL
//
// Called when a key is pressed
//
void CKeyboardInput::RunL()
{
	TKeyCode key = iConsole->KeyCode();
	if (key == 'q' || key == 'Q')
		CActiveScheduler::Stop();
	else
		ListenToKeyboard();
}

//
// CKeyboardInput::DoCancel
//
// Stop waiting for keyboard input
//
void CKeyboardInput::DoCancel()
{
	iConsole->ReadCancel();
}


//
//
// CTrkConsoleIO implementation
//
//

//
// CTrkConsoleIO constructor
//
CTrkConsoleIO::CTrkConsoleIO()
	: iConsole(0),
	  iKeyboardInput(0)
{
	TRAPD(error, iConsole = Console::NewL(_L("TRK"), TSize(KConsFullScreen, KConsFullScreen)));
	if (error != KErrNone)
		User::Panic(_L("TRK failed to allocate CConsoleBase"), __LINE__);

	iKeyboardInput = new CKeyboardInput(iConsole);
	if (iKeyboardInput == 0)
		User::Panic(_L("TRK failed to allocate CKeyboardInput"), __LINE__);

	iKeyboardInput->ListenToKeyboard();
}

//
// CTrkConsoleIO destructor
//
CTrkConsoleIO::~CTrkConsoleIO()
{
	SafeDelete(iKeyboardInput);
	SafeDelete(iConsole);
}

//
// CTrkConsoleIO::PrintToScreen
//
//	Print a message to the screen
//
void CTrkConsoleIO::PrintToScreen(TRefByValue<const TDesC> aFmt, ...)
{
	VA_LIST(l);
	VA_START(l, aFmt);
	iBuffer.FormatList(aFmt, l);

	iConsole->Printf(iBuffer);
}

//
// CTrkConsoleIO::Terminating
//
//	Notify user of termination
//
void CTrkConsoleIO::Terminating()
{
	iConsole->Printf(_L("\r\nPress any key to exit."));
	iKeyboardInput->Cancel();
	iConsole->Getch();
}
//
// MainL
//
// Create the engine and the communications interface and start the active scheduler
//
void MainL()
{
	RProcess().SetPriority(EPriorityHigh);
	RThread().SetPriority(EPriorityAbsoluteHigh);
	
	RTrkSrvCliSession trkSession;
	TTrkConnStatus iConnStatus;
	TBuf<KMaxPath> buf;
	TInt majorVersion, minorVersion, majorAPIVersion, minorAPIVersion, buildNumber;
	
	TInt err = trkSession.ConnectToServer();
	if (!err)
	{
	    // Ideally we need to connect here, but when the TRK server is started, connect automatically happens.
	    // So we don't need to explicitly connect here. If the server is changed not to connect automatically at startup
	    // then we need to connect here.	 
	    //err = trkSession.Connect();	        
        if(!err)
        {
            trkSession.GetDebugConnStatus(iConnStatus, buf);
            trkSession.GetTrkVersion(majorVersion, minorVersion, majorAPIVersion, minorAPIVersion, buildNumber);
        }
	 }

#ifdef SHOW_CONSOLE		
	TrkIO->PrintToScreen(_L("Welcome to TRK for Symbian OS\r\n"));
	TrkIO->PrintToScreen(_L("Version %d.%d.%d\r\n"), majorVersion, minorVersion, buildNumber);
	TrkIO->PrintToScreen(_L("Implementing TRK API version %d.%d\r\n"), majorAPIVersion, minorAPIVersion);
	TrkIO->PrintToScreen(_L("Press 'Q' to quit.\r\n\r\n"));
#endif
  	
#ifdef SHOW_CONSOLE	
	_LIT(KLfCr, "\r\n");
	
	TPtrC ptr(buf);
	TInt pos = 0;
	TInt lineStart = 0;
	TInt length = 0;
	
	while (KErrNotFound != (pos = ptr.Find(KLfCr)))
	{
		ptr.Set(&buf[lineStart], pos);
		lineStart = lineStart + pos + 2;
		TrkIO->PrintToScreen(ptr);
		TrkIO->PrintToScreen(KLfCr);
		length = buf.Length() - lineStart;
		if (length > 0)
		{
			ptr.Set(&buf[lineStart], length);
		}
	}
#endif

	CActiveScheduler::Start();
	
	trkSession.DisConnect();
	trkSession.ShutDownServer();
	trkSession.Close();
}

//
// EXE entrypoint
//
TInt E32Main()
{	
	__UHEAP_MARK;

	CTrapCleanup* cleanupStack = CTrapCleanup::New();
	if (cleanupStack == 0)
		User::Panic(_L("TRK failed to allocate CTrapCleanup"), __LINE__);
	
	CActiveScheduler* scheduler = new CActiveScheduler;
	if (scheduler == 0)
		User::Panic(_L("TRK failed to allocate CActiveScheduler"), __LINE__);

	CActiveScheduler::Install(scheduler);

#ifdef SHOW_CONSOLE
	TrkIO = new CTrkConsoleIO;
	
	if (!TrkIO)
		User::Panic(_L("TRK failed to allocate CTrkConsoleIO"), __LINE__);
#endif
	
	TRAPD(error, MainL());

#ifdef SHOW_CONSOLE
	if (error != KErrNone)
	{
		TrkIO->PrintToScreen(_L("\r\nUnexpected error %d"), error);
		TrkIO->Terminating();
	}
	SafeDelete(TrkIO);
#endif
	
	SafeDelete(scheduler);
	SafeDelete(cleanupStack);

	__UHEAP_MARKEND;

	User::Exit(0);
	return 0;
}