// Copyright (c) 2001-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 <in_sock.h>
#include <c32comm.h>
#include <e32base.h>
#include <es_sock.h>
#include <TFTPENG.H>
#include <nifman.h>

// Device driver names
#ifndef __EPOC32__
#define PDD_NAME _L("ECDRV")
#define LDD_NAME _L("ECOMM")
#else
#define PDD_NAME _L("EUART1")
#define LDD_NAME _L("ECOMM")
#endif

LOCAL_C void InitCommsL();
LOCAL_C void ProgramL();

//temporary const for TFTP server on own machine
_LIT(KInetTempAddr, "10.159.24.32");
//const for file to be moved
_LIT(KFileToMove, "test.cpp");

class CCommandParser: public CAsyncOneShot, public MTftpNotifier 
	{

public:
	~CCommandParser();
	static CCommandParser* NewL(CConsoleBase& aConsole);

protected:
    CCommandParser(CConsoleBase& aConsole);
    void ConstructL(); 
    virtual void RunL();
	virtual void OpComplete(TOpComp aResult, TInt aOp);
	virtual void ProgressNotification();
private:
	CConsoleBase& iConsole;
	CTftpEngine* iEngine;
    };

GLDEF_C TInt E32Main()
	{
	__UHEAP_MARK;
	CTrapCleanup* trap = CTrapCleanup::New();
	if(trap==NULL)
		return KErrNoMemory;

	TInt err = KErrNone;

	TRAP(err, ProgramL());

	delete trap;
	__UHEAP_MARKEND;
	return err;
	}

//
// Set up Epoc environment. Put in separate function so we can
// let heap allocations fail and leave, trapping them all in 
// one place above.
//
LOCAL_C void ProgramL()
	{
	CActiveScheduler* pS = new(ELeave) CActiveScheduler;
	CleanupStack::PushL(pS);

	//initialization for COMM port (TFTP server on comm2)
	InitCommsL();
	
    CActiveScheduler::Install(pS);
	//create console for output
	CConsoleBase* console = Console::NewL(_L("TFTP"),TSize(KConsFullScreen,KConsFullScreen));
	CleanupStack::PushL(console);
	CCommandParser* compars= CCommandParser::NewL(*console);
	compars->Call();
	   
	CActiveScheduler::Start();

	delete compars;
	CleanupStack::PopAndDestroy(console);
	CleanupStack::PopAndDestroy(pS);
	}

LOCAL_C void InitCommsL()
//
// Initialisation code - loads the serial LDD and PDD
// starts the comm subsystem (for EPOC32 builds)
// On a full EPOC implementation, this code would not
// be required because higher level components (EIKON) 
// automatically start the services.
//
	{
	// Load the physical device driver
	// The OS will automatically append .PDD and 
	// search /System/Libs on all drives.
	TInt r=User::LoadPhysicalDevice(PDD_NAME);
	if (r != KErrNone && r!= KErrAlreadyExists)
		User::Leave(r);
	//test(r==KErrNone || r==KErrAlreadyExists);

	// Similarly for the Logical device driver
	r=User::LoadLogicalDevice(LDD_NAME);
	if (r != KErrNone && r != KErrAlreadyExists)
		User::Leave(r);
	//test(r==KErrNone|| r==KErrAlreadyExists);

//	User::LeaveIfError(Nifman::CheckIniConfig());
	}

CCommandParser::~CCommandParser()
//
// C++ D'tor
//
    {
	delete iEngine;
	}

CCommandParser::CCommandParser(CConsoleBase& aConsole)
    : CAsyncOneShot(0), iConsole(aConsole)
//
// C++ C'tor
//
    {
    }

void CCommandParser::ConstructL()
//
// E32 C'tor
//
    {
	iEngine = CTftpEngine::NewL(0, *this); 
    }

void CCommandParser::RunL()
//
// Run method
//
    {
	iConsole.Printf(_L("TFTP>"));
	TBuf<0x100> command;
	TKeyCode key;
	while((key=iConsole.Getch())!=EKeyEnter)
		{
		if(command.Length()>=0x100)
			User::Beep(440, 500000);
		else if(key == EKeyBackspace)
			{
			if(command.Length())
				{
				iConsole.Printf(_L("%c"), key);
				command.SetLength(command.Length()-1);
				}
			}
		else
			{
			iConsole.Printf(_L("%c"), key);
			command.Append(TChar(key));
			}
		}

	iConsole.Printf(_L("\n Command %S\n"), &command);
	if(!command.CompareF(_L("quit")))
		CActiveScheduler::Stop();
	else if(!command.CompareF(_L("get")))

		iEngine->Get(KInetTempAddr,KFileToMove);
	else if(!command.CompareF(_L("put")))
		iEngine->Put(KInetTempAddr,KFileToMove);
	else
		{
		iConsole.Printf(_L("Unknown Function\n"));
		Call();
		}
	}

void CCommandParser::OpComplete(TOpComp aResult, TInt aOp)
//
// Operation completed
//
	{
	iConsole.Printf(_L("\nOperation %d completed %d\n"), aOp, aResult);
	Call();
	}

void CCommandParser::ProgressNotification()
//
// Progress indication
//
	{
	iConsole.Printf(_L("."));
	}	

CCommandParser* CCommandParser::NewL(CConsoleBase& aConsl)
//
// Create and connect client with leaving
//
    {
    CCommandParser* p = new (ELeave) CCommandParser(aConsl);
    CleanupStack::PushL(p);
    p->ConstructL();
    CleanupStack::Pop(p);
    return p;
    }