// 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:

// Author: Philippe Gabriel

// A simple test program which uses the statically linked dll  "ftpprot.dll"

// 

//

// standard example header

#include "DEBUG.H"

#include <e32base.h>

#include <es_sock.h>

#include <in_sock.h>

#include <ftpsess.h>

#include "FTPTEST.H"

TBuf8<955> myBuffer8;

TBuf<2000> myBuffer;

TInt	total;

#define __CONSOLE_OUTPUT__

#define __FILERETR_TESTS__

//#define __IPV4_TESTS__

//#define __IPV6_TESTS__

class TFtpTest02Params

	{

public:

	void SetParams(const TDesC& aInetAddr, TUint aPort, const TDesC& aHostName,

		const TDesC8& aUserName, const TDesC8& aPassword, const TDesC8& aDirectoryPath,

		const TDesC8& aRemoteFileName, const TDesC& aLocalFileName);

public:

	TInetAddr iInetAddr;

	TUint iPort;

	THostName iHostName;

	TPtrC8 iUserName;

	TPtrC8 iPassword;

	TPtrC8 iDirectoryPath;

	TPtrC8 iRemoteFileName;

	TPtrC iLocalFileName;

	};

void TFtpTest02Params::SetParams(const TDesC& aInetAddr, TUint aPort, const TDesC& aHostName,

		const TDesC8& aUserName, const TDesC8& aPassword, const TDesC8& aDirectoryPath,

		const TDesC8& aRemoteFileName, const TDesC& aLocalFileName)

	{

	iInetAddr.Input(aInetAddr);

	iInetAddr.SetPort(aPort);

	iPort=aPort;

	iHostName=aHostName;

	iUserName.Set(aUserName);

	iDirectoryPath.Set(aDirectoryPath);

	iPassword.Set(aPassword);

	iRemoteFileName.Set(aRemoteFileName);

	iLocalFileName.Set(aLocalFileName);

	}

//

class CFtpTest02 : public CBase, public MFtpSessionNotifier

	{

public:

	static CFtpTest02* NewL();

	~CFtpTest02();

	void DoTest();

	void TestMain();

	void StartScheduler();

	void StopSchedulerIfNecessary();

	void Complete(void);

	// Operation completed, more data to follow

	void MoreData(void);

	// Transfer Progress report

	void TransferProgress(TUint aProgress);

	// User canceled ongoing operation

	void Cancel(void);

	// Peer reset the connection

	void ConnReset(void);

	// Connection error

	void ConnectionError(TOpComp aTConnectionError);

	// FTP server does not implement the operation requested

	void OperationNotSupported(void);

	// Local File system error

	void LocalFileSystemError(TOpComp aTLocalFileSystemError);

	// Remote File system error

	void RemoteFileSystemError(TOpComp aTRemoteFileSystemError);

	// Not specified yet

	void EUnknownError();

	// Message reported by server

	void ServerMessage(const TDesC8&);

	void ListTest();

	void RestartTest();

	void FailedRetrievalTest();

    void FailedRetrievalTestOverwrite();

	void RetriveveTestOverwrite();

	void RenameTest();

	void DeleteFileTest();

	void StoreTest();

	void DirectoryTest();

protected:

	CFtpTest02();

private:

	CFTPSession* iCFTPSession;

	TFtpTest02Params iTestParams;

	TBool iSchedulerStarted;

	};	

CFtpTest02* CFtpTest02::NewL()

	{

	CFtpTest02* self = new(ELeave) CFtpTest02();

	CleanupStack::PushL(self);

	self->iCFTPSession = CFTPSession::NewL(self);

	CleanupStack::Pop(self);

	return self;

	}

CFtpTest02::CFtpTest02()

{}

CFtpTest02::~CFtpTest02()

	{

	delete iCFTPSession;

	}

void CFtpTest02::StartScheduler()

	{

	iSchedulerStarted=ETrue;

	CActiveScheduler::Start();

	}

void CFtpTest02::StopSchedulerIfNecessary()

	{

	if(iSchedulerStarted)

		CActiveScheduler::Stop();

	iSchedulerStarted=EFalse;

	}

void CFtpTest02::ServerMessage(const TDesC8& aMessage)

	{

	myBuffer.Copy(aMessage);

#ifdef __CONSOLE_OUTPUT__

	__FTPDebugConsole->Write(myBuffer);

#endif

	FTPPROTDEBUG(0xffff,myBuffer);

	}

void CFtpTest02::TransferProgress(TUint aProgress)

	{

	total += aProgress;

#ifdef __CONSOLE_OUTPUT__

	__FTPDebugConsole->Printf(_L("CFtpTest02::TransferProgress total:>%d< Packet:>%d<\n"),total,aProgress);

#endif

	FTPPROTDEBUG3(0xffff, _L("CFtpTest02::TransferProgress total:>%d< Packet:>%d<\n"),total,aProgress);

	}

void CFtpTest02::Complete(void)

	{

#ifdef __CONSOLE_OUTPUT__

	__FTPDebugConsole->Write(_L("CFtpTest02::Complete\n"));

#endif

	FTPPROTDEBUG(0xffff, _L("CFtpTest02::Complete\n"));

	StopSchedulerIfNecessary();

	}

void CFtpTest02::Cancel(void){}

void CFtpTest02::ConnReset(void)

	{

#ifdef __CONSOLE_OUTPUT__

	__FTPDebugConsole->Write(_L("CFtpTest02::ConnReset\n"));

#endif

	FTPPROTDEBUG(0xffff, _L("CFtpTest02::ConnReset\n"));

	StopSchedulerIfNecessary();

	}

void CFtpTest02::ConnectionError(TOpComp /*aTConnectionError*/)

	{

#ifdef __CONSOLE_OUTPUT__

	__FTPDebugConsole->Write(_L("CFtpTest02::ConnectionError\n"));

#endif

	FTPPROTDEBUG(0xffff, _L("CFtpTest02::ConnectionError\n"));

	StopSchedulerIfNecessary();

	}

void CFtpTest02::OperationNotSupported(void){}

void CFtpTest02::LocalFileSystemError(TOpComp /*aTLocalFileSystemError*/)

	{

#ifdef __CONSOLE_OUTPUT__

	__FTPDebugConsole->Write(_L("CFtpTest02::LocalFileSystemError\n"));

#endif

	FTPPROTDEBUG(0xffff, _L("CFtpTest02::LocalFileSystemError\n"));

	StopSchedulerIfNecessary();

	}

void CFtpTest02::RemoteFileSystemError(TOpComp /*aTRemoteFileSystemError*/)

	{

	StopSchedulerIfNecessary();

#ifdef __CONSOLE_OUTPUT__

	__FTPDebugConsole->Write(_L("CFtpTest02::RemoteFileSystemError\n"));

#endif

	FTPPROTDEBUG(0xffff, _L("CFtpTest02::RemoteFileSystemError\n"));

	}

void CFtpTest02::EUnknownError(void)

	{

#ifdef __CONSOLE_OUTPUT__

	__FTPDebugConsole->Write(_L("Test02Notifier::EUnknownError\n"));

#endif

	FTPPROTDEBUG(0xffff, _L("Test02Notifier::EUnknownError\n"));

	StopSchedulerIfNecessary();

	}

void CFtpTest02::MoreData(void)	

	{

#ifdef __CONSOLE_OUTPUT__

	__FTPDebugConsole->Write(_L("CFtpTest02::Notification called EPacketReceived\n"));

	__FTPDebugConsole->Write(_L("----------Packet from DTP Channel---------\n"));

	__FTPDebugConsole->Write(myBuffer);

	__FTPDebugConsole->Write(_L("\n----------End of Packet from DTP Channel---------\n"));

#endif

	FTPPROTDEBUG(0xffff,_L("CFtpTest02::Notification called EPacketReceived\n"));

	FTPPROTDEBUG(0xffff,_L("----------Packet from DTP Channel---------\n"));

	FTPPROTDEBUG(0xffff,myBuffer);

	FTPPROTDEBUG(0xffff,_L("\n----------End of Packet from DTP Channel---------\n"));

	iCFTPSession->ListDirectory(_L8(""),myBuffer8);

	return;

	}

LOCAL_C void doExampleL()

    {

	CActiveScheduler* exampleScheduler=new (ELeave) CActiveScheduler;

    CleanupStack::PushL(exampleScheduler);

    CActiveScheduler::Install(exampleScheduler);

	CFtpTest02* myFtpTest02 = CFtpTest02::NewL();

	CleanupStack::PushL(myFtpTest02);

#ifdef __IPV4_TESTS__

	__FTPDebugConsole->Printf(_L("FTP Test 02 Ipv4 \n\n"));

#else

#ifdef __FILERETR_TESTS__

	__FTPDebugConsole->Printf(_L("FTP Test 02 File retreive \n\n"));

#else

	__FTPDebugConsole->Printf(_L("FTP Test 02 Ipv6 \n\n"));

#endif

#endif

	__FTPDebugConsole->Printf(_L("FTP Session client \n\n"));

	myFtpTest02->TestMain();

	__FTPDebugConsole->Printf(_L("Finished test\n"));

	CleanupStack::PopAndDestroy(myFtpTest02);

	CleanupStack::PopAndDestroy(exampleScheduler);

	}

void CFtpTest02::TestMain()

	{

#ifdef __IPV4_TESTS__

	iTestParams.SetParams(_L("207.46.133.140"), 21, _L("ftp.microsoft.com"),		//params for microsoft ftp site

		_L8("anonymous"), _L8("philippe@symbian.com"), _L8("misc"), _L8("index.txt"),

		_L("index.txt"));

	DoTest();

	iTestParams.SetParams(_L("192.18.99.73"), 21, _L("ftp.sun.com"),

		_L8("anonymous"), _L8("karl.mcdowall@symbian.com"), _L8("/"), _L8("swec.dat"),

		_L("swec.dat"));

	DoTest();

#endif

#ifdef __FILERETR_TESTS__

	iTestParams.SetParams(_L("10.16.113.6"), 21, _L("ftp-images"),

		_L8("roms"), _L8("integrator"), _L8("/"), _L8("psdagt_udeb.htm"),

		_L("psdagt_udeb.htm"));

	iCFTPSession->Connect(iTestParams.iInetAddr,iTestParams.iUserName,	//Login using passive mode

		iTestParams.iPassword,CFTPSession::Epassive);

	StartScheduler();

	RetriveveTestOverwrite();

	FailedRetrievalTestOverwrite();

	FailedRetrievalTest();

    iCFTPSession->Close();

	StartScheduler();

#endif

#ifdef __IPV6_TESTS__

	iTestParams.SetParams(_L("2001:618:400:6a:2c0:4fff:fe8a:a918"),	//params for snus6

		21, _L("snus6.intra6"),  _L8("karlm"), _L8("karlm"),

		_L8("/usr/home/karlm"), _L8("test.cpp"), _L("test.cpp"));

	DoTest();

	iTestParams.SetParams(_L("2001:618:400:6a:210:5aff:febf:531"),	//params for 6pack6

		21, _L("6pack6.intra6"), _L8("anonymous"), _L8("karlm"),

		_L8("/usr"), _L8("anything"), _L("anything"));

	DoTest();

#endif

	}

void CFtpTest02::DoTest()

	{

//Removed teporarily due to problem with host resolution

//	iCFTPSession->Connect(iTestParams.iHostName,iTestParams.iUserName,	//Login using hostname

//		iTestParams.iPassword,CFTPSession::EActive,iTestParams.iPort);	

//	StartScheduler();

//	iCFTPSession->Close();

//	StartScheduler();

	iCFTPSession->Connect(iTestParams.iInetAddr,iTestParams.iUserName,	//Login using Active mode

		iTestParams.iPassword,CFTPSession::EActive);

	StartScheduler();

	iCFTPSession->Close();

	StartScheduler();

	iCFTPSession->Connect(iTestParams.iInetAddr,iTestParams.iUserName,	//Login using passive mode

		iTestParams.iPassword,CFTPSession::Epassive);

	StartScheduler();

	iCFTPSession->ChangeDirectory(iTestParams.iDirectoryPath);			//Move to appropriate directory.

	StartScheduler();

	ListTest();

	RetriveveTestOverwrite();

	FailedRetrievalTest();

	FailedRetrievalTestOverwrite();

	RenameTest();

	DeleteFileTest();

	StoreTest();

	RestartTest();

	DirectoryTest();

    iCFTPSession->Close();

	StartScheduler();

	}

void CFtpTest02::ListTest()

	{

	iCFTPSession->ListDirectory(_L8("."),myBuffer8);

	StartScheduler();

	}

void CFtpTest02::RestartTest()

	{	

//	Note: Restart is a synchronous function

	iCFTPSession->Restart(50000);

	}

void CFtpTest02::RetriveveTestOverwrite()

	{

	total =0;

	iCFTPSession->Retrieve(iTestParams.iRemoteFileName,iTestParams.iLocalFileName,

		CFTPSession::EOverwrite,CFTPSession::EBinary,CFTPSession::EStream);

	StartScheduler();

	}

void CFtpTest02::FailedRetrievalTest()

	{

	iCFTPSession->Retrieve(_L8("NoExist"),_L("NoExist"),CFTPSession::ENoOverwrite,CFTPSession::EBinary,CFTPSession::EStream);

	StartScheduler();

	}

void CFtpTest02::FailedRetrievalTestOverwrite()

	{

	iCFTPSession->Retrieve(_L8("NoExist"),iTestParams.iLocalFileName,CFTPSession::EOverwrite,CFTPSession::EBinary,CFTPSession::EStream);

	StartScheduler();

	}

void CFtpTest02::DeleteFileTest()

	{

	iCFTPSession->DeleteFile(iTestParams.iRemoteFileName);

	StartScheduler();

	}

void CFtpTest02::StoreTest()

	{

	iCFTPSession->Store(iTestParams.iLocalFileName,iTestParams.iRemoteFileName,

		EFalse, CFTPSession::EBinary,CFTPSession::EStream);

	StartScheduler();

	}

void CFtpTest02::RenameTest()

	{

	iCFTPSession->RenameFile(iTestParams.iRemoteFileName, _L8("tempName"));

	StartScheduler();

	iCFTPSession->RenameFile(_L8("tempName"), iTestParams.iRemoteFileName);

	StartScheduler();

	}

void CFtpTest02::DirectoryTest()

	{

	iCFTPSession->CreateDirectory(_L8("TestDir0"));

	StartScheduler();

	iCFTPSession->DeleteDirectory(_L8("TestDir1"));

	StartScheduler();

	}

//Old IP4 ftp sites. Might be worth keeping as a record in case the ones currently being used 

//stop working.

//

//	TInetAddr myaddr(INET_ADDR(207,200,71,59),21);// ftp.netscape.com

//	TPtrC	DNSName(_L("ftp.netscape.com"));

//	TPtrC	userName(_L("anonymous"));

//	TPtrC	passwd(_L("philippe@symbian.com"));

//	TPtrC	directoryPath(_L("pub/communicator/extras/import/eudora"));

//	TPtrC	fileName(_L("Readme.txt"));

//

//	TInetAddr myaddr(INET_ADDR(209,77,154,25),21);// ftp.insignia.com (home of the braves)

//	TPtrC	DNSName(_L("ftp.insignia.com"));

//	TPtrC	userName(_L("anonymous"));

//	TPtrC	passwd(_L("philippe@symbian.com"));

//	TPtrC	directoryPath(_L("special/ntrigue/"));

//	TPtrC	fileName(_L("read4a.txt"));

//

//	TInetAddr myaddr(INET_ADDR(194,129,2,201),21);// sparky

//	TPtrC	DNSName(_L("sparky"));

//	TPtrC	userName(_L("philippe"));

//	TPtrC	passwd(_L("massilia"));

//	TPtrC	directoryPath(_L("ftptest"));

//	TPtrC	fileName(_L("testfile.bin"));

//	TPtrC	fileName(_L("map.gif"));

//	TPtrC	localFile(_L("motodemo.zip"));

//