// Copyright (c) 2000-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 <watcher.h>

#include <e32property.h>

#include "msvtestutils.h"

#include <ir_sock.h>

#include "irwatcher.h"

//**********************************

// Globals

//**********************************

#include <ecom/implementationproxy.h>

const TImplementationProxy ImplementationTable[] = 

	{

		IMPLEMENTATION_PROXY_ENTRY(0x10008C68, CIrWatcher::NewL)

	};

EXPORT_C const TImplementationProxy* ImplementationGroupProxy(TInt& aTableCount)

	{

	aTableCount = sizeof(ImplementationTable) / sizeof(TImplementationProxy);

	return ImplementationTable;

	}

//**********************************

// CIrWatcher

//**********************************

// static 

CIrWatcher* CIrWatcher::NewL(TAny* aWatcherParams)

	{

	TWatcherParams* params = reinterpret_cast<TWatcherParams*>(aWatcherParams);

	CIrWatcher* self = new (ELeave) CIrWatcher(EPriorityStandard, params->iLog);

	CleanupStack::PushL(self);

	self->ConstructL();

	CleanupStack::Pop();

	return self;

	}

CIrWatcher::CIrWatcher(TInt aPriority, CWatcherLog& aLog)

	: CActive(aPriority), iLog(aLog)

	{

	CActiveScheduler::Add(this);

	}

CIrWatcher::~CIrWatcher()

	{

	iProperty.Close();

	Cancel();

	}

void CIrWatcher::ConstructL()

	{

	User::LeaveIfError(iProperty.Attach(KIrdaPropertyCategory, KIrdaStatus));

	iProperty.Subscribe(iStatus);

	// Start the watcher

	iLog.Printf(_L("IrWatcher: Starting watcher"));

	SetActive();

	}

void CIrWatcher::DisplayState(TInt aState)

	{

	switch(aState)

		{

		case TIrdaStatusCodes::EIrLoaded:

			iLog.Printf(_L("IrWatcher: Loaded"));

			break;

		case TIrdaStatusCodes::EIrDiscoveredPeer:

			iLog.Printf(_L("IrWatcher: Start Discovery"));

			break;

		case TIrdaStatusCodes::EIrLostPeer:

			iLog.Printf(_L("IrWatcher: End Discovery"));

			break;

		case TIrdaStatusCodes::EIrConnected:

			iLog.Printf(_L("IrWatcher: Connected"));

			break;

		case TIrdaStatusCodes::EIrBlocked:

			iLog.Printf(_L("IrWatcher: Blocked"));

			break;

		case TIrdaStatusCodes::EIrDisconnected:

			iLog.Printf(_L("IrWatcher: Disconnected"));

			break;

		case TIrdaStatusCodes::EIrUnloaded:

			iLog.Printf(_L("IrWatcher: Unloaded"));

			break;

		default:

			iLog.Printf(_L("IrWatcher: Unknown"));

			break;

		};

	}

void CIrWatcher::RunL()

	{

	TInt state;

	iProperty.Subscribe(iStatus);

	iProperty.Get(state);

	DisplayState(state);

 	SetActive();

	}

void CIrWatcher::DoCancel()

	{

	iLog.Printf(_L("IrWatcher: DoCancel"));

	iProperty.Cancel();

	}