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

#include "tavsrcController.h"

#include <remconinterfaceselector.h>
#include <remconcoreapicontroller.h>
#include <remconbeareravrcp.h>

CTavsrcController* CTavsrcController::NewL(CRemConInterfaceSelector& aIfSel, CActiveConsole& aConsole)
	{
	CTavsrcController* controller = new(ELeave) CTavsrcController(aIfSel, aConsole);
	CleanupStack::PushL(controller);
	controller->ConstructL();
	CleanupStack::Pop(controller);
	return controller;
	}
	
CTavsrcController::CTavsrcController(CRemConInterfaceSelector& aIfSel, CActiveConsole& aConsole)
	: CActive(EPriorityStandard), iState(EControllerNotConnected), iSelector(&aIfSel), iConsole(aConsole)
	{
	CActiveScheduler::Add(this);
	}

void CTavsrcController::ConstructL()
	{
	iCoreController = CRemConCoreApiController::NewL(*iSelector, *this);
	iGoConnectionOrientedSent = EFalse;
	}
	
CTavsrcController::~CTavsrcController()
	{
	Cancel();
	}

TInt CTavsrcController::Command(TRemConCoreApiOperationId aOpId)
	{
	TInt err = KErrNotReady;
	
	if(!IsActive())
		{
		err = KErrNone;
		
		if(iState == EControllerConnected)
			{
			IssueCommand(aOpId);
			}
		else
			{
			// Need to connect first
			TRAP(err, ConnectL());
			}
		}
	
	return err;
	}


void CTavsrcController::MrccacoResponse(TRemConCoreApiOperationId aOperationId, TInt aError)
	{
	iConsole.Console().Printf(_L("Received Response for Operation %d, Result %d\n"), aOperationId, aError);
	}

void CTavsrcController::IssueCommand(TRemConCoreApiOperationId aOpId)
	{
	switch(aOpId)
		{
	case ERemConCoreApiVolumeDown:
		iCoreController->VolumeDown(iStatus, iNumRemotes, ERemConCoreApiButtonClick);
		break;
	case ERemConCoreApiVolumeUp:
		iCoreController->VolumeUp(iStatus, iNumRemotes, ERemConCoreApiButtonPress);
		break;
	case ERemConCoreApiForward:
		iCoreController->Forward(iStatus, iNumRemotes, ERemConCoreApiButtonClick);
		break;
	case ERemConCoreApiBackward:
		iCoreController->Backward(iStatus, iNumRemotes, ERemConCoreApiButtonClick);
		break;
	case ERemConCoreApiPlay:
		iCoreController->Play(iStatus, iNumRemotes, ERemConCoreApiButtonClick);
		break;
	case ERemConCoreApiStop:
		iCoreController->Stop(iStatus, iNumRemotes, ERemConCoreApiButtonClick);
		break;
	default:
		// Cos we don't want to SetActive(), alright?
		return;
		}
	
	iConsole.Console().Printf(_L("Sending Command Operation %d\n"), aOpId);	
	SetActive();
	}

void CTavsrcController::ConnectL()
	{
	//Ask user which device address we should connect to...	
	iState = ESearchingForDevice;
	User::LeaveIfError(iNotify.Connect());
	iNotify.StartNotifierAndGetResponse(iStatus, KDeviceSelectionNotifierUid, iPckg, iResPckg);
	SetActive();
	}
	
void CTavsrcController::RunL()
	{
	switch(iState)
		{
	case EControllerConnected:
		{
		// We don't care what the result was really
		// Ask Tim about the display logging and 
		// log it
		break;
		}
	case EControllerNotConnected:
		{
		iConsole.Console().Printf(_L("AVRCP connection completed, result = %d\n"), iStatus.Int());

		if(iStatus.Int() == KErrNone)
			{
			// Connected ok, now issue command
			iState = EControllerConnected;
			IssueCommand(iOutstandingOperation);	
			}
		break;
		}
	case ESearchingForDevice:
		{
		if (iStatus.Int() == KErrNone)
			{
			iState = EControllerNotConnected;
			
			iNotify.CancelNotifier(KDeviceSelectionNotifierUid);
			iNotify.Close();
			
			iConsole.Console().Printf(_L("Opening AVRCP connection...\n"));

			TBTDevAddr btAddr = iResPckg().BDAddr();
			// Store as 8 bit machine readable
			RBuf8 bearerData;
			bearerData.CreateL(btAddr.Des());

			// Form the RemCon Addr from the AVRCP Uid and the 
			// bluetooth address
			TRemConAddress addr;
			addr.BearerUid() = TUid::Uid(KRemConBearerAvrcpImplementationUid);
			addr.Addr() = bearerData;

			if (iGoConnectionOrientedSent)
				{
				// Only allowed to call GoConnectionOrientedL() once on pain of RemCon panic,
				// ERemConClientPanicAlreadyConnectionOriented. Solution is to call GoConnectionlessL()
				// before recalling GoConnectionOrientedL()
				iSelector->GoConnectionlessL();
				}
			iSelector->GoConnectionOrientedL(addr);
			iSelector->ConnectBearer(iStatus);
			iGoConnectionOrientedSent = ETrue;

			SetActive();
			break;
			}
		}
	default:
		{
		// hmm shouldn't be here
		__DEBUGGER();
		break;
		}
		}
	}
	
void CTavsrcController::DoCancel()
	{
	iCoreController->Cancel();
	}