// rconn.cpp

// 

// Copyright (c) 2009 - 2010 Accenture. All rights reserved.

// This component and the accompanying materials are made available

// under the terms of the "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:

// Accenture - Initial contribution

//

#undef SYMBIAN_ENABLE_SPLIT_HEADERS // Stopgap to handle TConnectionInfoV2 being moved in latest TB92

#include <fshell/ioutils.h>

#include <es_sock.h>

#include <es_enum.h>

#include <nifvar.h>

#include <commdbconnpref.h>

using namespace IoUtils;

class CCmdRconn : public CCommandBase

	{

public:

	static CCommandBase* NewLC();

	~CCmdRconn();

private:

	CCmdRconn();

	void ListConnectionsL();

	void StartConnectionL();

	void StopConnectionL();

private: // From CCommandBase.

	virtual const TDesC& Name() const;

	virtual void DoRunL();

	virtual void ArgumentsL(RCommandArgumentList& aArguments);

	virtual void OptionsL(RCommandOptionList& aOptions);

private:

	RSocketServ iSocketSession;

	RConnection iConnection;

	enum 

		{

		EList, EStart, EStop

		} iOperation;

	TUint iIapId;

	TUint iNetworkId;

	};

CCommandBase* CCmdRconn::NewLC()

	{

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

	CleanupStack::PushL(self);

	self->BaseConstructL();

	return self;

	}

CCmdRconn::~CCmdRconn()

	{

	iConnection.Close();

	iSocketSession.Close();

	}

CCmdRconn::CCmdRconn()

	{

	}

const TDesC& CCmdRconn::Name() const

	{

	_LIT(KName, "rconn");	

	return KName;

	}

#define CASE_RETURN_LIT(XXX) case XXX: { _LIT(_KLit, #XXX); return &_KLit; }

#define DEFAULT_RETURN_LIT(XXX) default: { _LIT(_KLit, XXX); return &_KLit; }

const TDesC* StringifyConnectionType(TConnectionType aConnectionType)

	{

	enum TConnectionType_NotPresentInTB92

		{

		EConnectionCDMA = 2500,

		EConnectionCDMA20001xRTT,

		EConnectionCDMA20001xRTTDO,

		EConnectionCDMA20001xRTTDV,

		EConnectionCDMA20003xRTT,

		};

	switch (aConnectionType)

		{

		CASE_RETURN_LIT(EConnectionGeneric);

		CASE_RETURN_LIT(EConnectionCSD);

		CASE_RETURN_LIT(EConnectionGPRS);

		CASE_RETURN_LIT(EConnectionGPRSR97);

		CASE_RETURN_LIT(EConnectionGPRSR99);

		CASE_RETURN_LIT(EConnectionGPRSRel4);

		CASE_RETURN_LIT(EConnectionGPRSRel5);

		CASE_RETURN_LIT(EConnectionCDMA);

		CASE_RETURN_LIT(EConnectionCDMA20001xRTT);

		CASE_RETURN_LIT(EConnectionCDMA20001xRTTDO);

		CASE_RETURN_LIT(EConnectionCDMA20001xRTTDV);

		CASE_RETURN_LIT(EConnectionCDMA20003xRTT);

		CASE_RETURN_LIT(EConnectionEthernet);

		CASE_RETURN_LIT(EConnectionWLAN);

		CASE_RETURN_LIT(EConnectionBTPAN);

		DEFAULT_RETURN_LIT("Unknown");

		}

	}

void CCmdRconn::DoRunL()

	{

	LeaveIfErr(iSocketSession.Connect(), _L("Couldn't open socket server session"));

	LeaveIfErr(iConnection.Open(iSocketSession), _L("Couldn't open connection handle"));

	if (!iArguments.IsPresent(0)) iOperation = EList;

	switch (iOperation)

		{

	case EList:

		ListConnectionsL();

		break;

	case EStart:

		StartConnectionL();

		break;

	case EStop:

		StopConnectionL();

		break;

		}

	}

void CCmdRconn::ListConnectionsL()

	{

	TUint numConnections;

	LeaveIfErr(iConnection.EnumerateConnections(numConnections), _L("Couldn't enumerate connections"));

	if (numConnections <= 0)

		{

		Write(_L("No connections currently up.\r\n"));

		}

	else

		{

		IoUtils::CTextFormatter* formatter = CTextFormatter::NewLC(Stdout());

		IoUtils::CTextBuffer* buf = IoUtils::CTextBuffer::NewLC(0x100);

		buf->AppendFormatL(_L("IAP\tNetwork\tType\r\n"));

		for (TInt i = 1; i <= numConnections; ++i)

			{

			TConnectionInfoV2Buf connectionInfoBuf;

			LeaveIfErr(iConnection.GetConnectionInfo(i, connectionInfoBuf), _L("Couldn't get connection info (%d of %d)"), i, numConnections);

			TConnectionInfoV2& info = connectionInfoBuf();

			buf->AppendFormatL(_L("%d\t%d\t%S\r\n"), info.iIapId, info.iNetId, StringifyConnectionType(info.ConnectionType()));

			}

		formatter->TabulateL(0, 2, buf->Descriptor());

		Write(formatter->Descriptor());

		CleanupStack::PopAndDestroy(2, formatter);

		}

	}

void CCmdRconn::StartConnectionL()

	{

	TCommDbConnPref prefs;

	if (iIapId > 0)

		{

		prefs.SetIapId(iIapId);

		prefs.SetDialogPreference(ECommDbDialogPrefDoNotPrompt);

		}

	if (iNetworkId > 0)

		{

		prefs.SetNetId(iNetworkId);

		}

	LeaveIfErr(iConnection.Start(prefs), _L("Failed to start connection"));

	}

void CCmdRconn::StopConnectionL()

	{

	TConnectionInfo connectionInfo;

	if (iIapId > 0)

		{

		connectionInfo.iIapId = iIapId;

		}

	if (iNetworkId > 0)

		{

		connectionInfo.iNetId = iNetworkId;

		}

	TPckgC<TConnectionInfo> connectionInfoPckg(connectionInfo);

	LeaveIfErr(iConnection.Attach(connectionInfoPckg, RConnection::EAttachTypeNormal), _L("Unable to attach to connection"));

	LeaveIfErr(iConnection.Stop(), _L("Unable to stop connection"));

	}

void CCmdRconn::OptionsL(RCommandOptionList& aOptions)

	{

	_LIT(KOptIapId, "iap");

	aOptions.AppendUintL(iIapId, KOptIapId);

	_LIT(KOptNetworkId, "network");

	aOptions.AppendUintL(iNetworkId, KOptNetworkId);

	}

void CCmdRconn::ArgumentsL(RCommandArgumentList& aArguments)

	{

	_LIT(KArgOperation, "operation");

	aArguments.AppendEnumL((TInt&)iOperation, KArgOperation);

	}

EXE_BOILER_PLATE(CCmdRconn)