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

// Active object to perform DNS lookup

// Author:	Philippe Gabriel

// Performs DNS lookup for the FTP client

// 

//

/**

 @file RESOLVER.CPP

 @internalComponent

*/

#include "FTPDEF.H"

#include "DEBUG.H"

#include "RESOLVER.H"

#include "FTPPROT.H"

#include <e32base.h>

#include <in_sock.h>

CFTPResolver::CFTPResolver(MFTPResolverNotifier* aNotifier

						   ):CActive(CActive::EPriorityStandard)

	{

	FTPPROTDEBUG(_DBGResolver,_L("CFTPResolver::CFTPResolver called\n"));

	iNotifier = aNotifier;

	}

CFTPResolver* CFTPResolver::NewL(MFTPResolverNotifier* aNotifier,RSocketServ& aSockServ)

	{

	CFTPResolver* self = new (ELeave) CFTPResolver(aNotifier);

    CleanupStack::PushL(self);

    self->ConstructL(aSockServ);

    CleanupStack::Pop();

	return self;

	} 

void CFTPResolver::ConstructL(RSocketServ& aSockServ)

	{

	FTPPROTDEBUG(_DBGResolver,_L("CFTPResolver::ConstructL called\n"));

	User::LeaveIfError(iResolver.Open(aSockServ, KAfInet, KProtocolInetTcp));

	CActiveScheduler::Add(this);

	} 

void CFTPResolver::DoCancel()

	{

	iResolver.Cancel();

	}

void CFTPResolver::RunL()

	{

	FTPPROTDEBUG(_DBGResolver,_L("CFTPResolver::RunL called "));

	switch (iStatus.Int())

		{

		case KErrNone:

			FTPPROTDEBUG(_DBGResolver,_L("iStatus: NoError\n"));

			// Call Upper layer notifier

			iNotifier->FTPResolverNotifier(MFTPResolverNotifier::EDtpLookupComplete);

			break;

		default:

			FTPPROTDEBUG(_DBGResolver,_L("iStatus: Error\n"));

			iNotifier->FTPResolverNotifier(MFTPResolverNotifier::EDtpLookupFailed);

			break;

		}

	} 

CFTPResolver::~CFTPResolver()

	{

	FTPPROTDEBUG(_DBGResolver,_L("CFTPResolver::~CFTPResolver called\n"));

	iResolver.Close();

	}

void CFTPResolver::Lookup(const THostName& aServerName)

{

	FTPPROTDEBUG(_DBGResolver,_L("CFTPResolver::Lookup resolving:>"));

	FTPPROTDEBUG(_DBGResolver,aServerName);

	FTPPROTDEBUG(_DBGResolver,_L("<\n"));

	iResolver.GetByName(aServerName, iNameEntry, iStatus);

	SetActive();

}

void CFTPResolver::SetAddress(TInetAddr& aAddress)

{

	// Get the 1st entry resolved

	iNameRecord = iNameEntry();

	// Save the address (take care not to overwrite the port, might have been already set)

	if (TInetAddr::Cast(iNameRecord.iAddr).Family() == KAfInet)

		aAddress.SetAddress(TInetAddr::Cast(iNameRecord.iAddr).Address());

	else

		aAddress.SetAddress(TInetAddr::Cast(iNameRecord.iAddr).Ip6Address());

#if defined(__FTPPROTDEBUG__)

	TBuf<512> debugBuffer; // A Buffer to output the resolved IP 

	aAddress.Output(debugBuffer);

	debugBuffer.Append(_L(","));

	debugBuffer.AppendNum(aAddress.Port(), EDecimal); 

	debugBuffer.Append(_L("\n"));

#endif

	FTPPROTDEBUG(_DBGResolver,_L("Resolved address is:"));

	FTPPROTDEBUG(_DBGResolver,debugBuffer);

}