--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/commands/rsocket/rsocket.cpp	Wed Jun 23 15:52:26 2010 +0100
@@ -0,0 +1,191 @@
+// rsocket.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
+//
+
+#include <fshell/ioutils.h>
+#include <es_sock.h>
+#include <es_enum.h>
+#include <in_sock.h>
+#include <nifvar.h>
+#include <commdbconnpref.h>
+
+using namespace IoUtils;
+
+class CCmdRsocket : public CCommandBase
+	{
+public:
+	static CCommandBase* NewLC();
+	~CCmdRsocket();
+private:
+	CCmdRsocket();
+	void StartConnectionL();
+	void TcpConnectL();
+	void TcpDisconnect();
+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;
+	RSocket iSocket;
+	enum 
+		{
+		EConnect, EListen
+		} iOperation;
+	HBufC* iHost;
+	TUint iPort;
+	TUint iIapId;
+	TUint iNetworkId;
+	TBool iVerbose;
+	};
+
+
+CCommandBase* CCmdRsocket::NewLC()
+	{
+	CCmdRsocket* self = new(ELeave) CCmdRsocket();
+	CleanupStack::PushL(self);
+	self->BaseConstructL();
+	return self;
+	}
+
+CCmdRsocket::~CCmdRsocket()
+	{
+	delete iHost;
+	iSocket.Close();
+	iConnection.Close();
+	iSocketSession.Close();
+	}
+
+CCmdRsocket::CCmdRsocket()
+	{
+	}
+
+const TDesC& CCmdRsocket::Name() const
+	{
+	_LIT(KName, "rsocket");	
+	return KName;
+	}
+
+void CCmdRsocket::DoRunL()
+	{
+	LeaveIfErr(iSocketSession.Connect(), _L("Couldn't open socket server session"));
+	LeaveIfErr(iConnection.Open(iSocketSession), _L("Couldn't open connection handle"));
+
+	switch (iOperation)
+		{
+		case EConnect:
+			TcpConnectL();
+			break;
+		case EListen:
+			LeaveIfErr(KErrNotSupported, _L("Listen operation not yet implemented"));
+			break;
+		};
+	}
+
+void CCmdRsocket::StartConnectionL()
+	{
+	if (iVerbose)
+		{
+		Write(_L("Starting RConnection...\r\n"));
+		}
+
+	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 CCmdRsocket::TcpConnectL()
+	{
+	StartConnectionL();
+
+	TInetAddr addr(iPort);
+	TInt err = addr.Input(*iHost);
+	if (err)
+		{
+		if (iVerbose)
+			{
+			Write(_L("Resolving name...\r\n"));
+			}
+		RHostResolver resolver;
+		LeaveIfErr(resolver.Open(iSocketSession, KAfInet, KProtocolInetTcp, iConnection), _L("Unable to open host resolver"));
+		CleanupClosePushL(resolver);
+		TNameEntry nameEntry;
+		LeaveIfErr(resolver.GetByName(*iHost, nameEntry), _L("Unable to resolve name \"%S\""), iHost);
+		addr.SetAddress(TInetAddr::Cast(nameEntry().iAddr).Address());
+		CleanupStack::PopAndDestroy(&resolver);
+		}
+
+	if (iVerbose)
+		{
+		Write(_L("Opening socket...\r\n"));
+		}
+	LeaveIfErr(iSocket.Open(iSocketSession, KAfInet, KSockStream, KProtocolInetTcp, iConnection), _L("Unable to open TCP socket"));
+
+	if (iVerbose)
+		{
+		Write(_L("Connecting socket...\r\n"));
+		}
+	TRequestStatus status;
+	iSocket.Connect(addr, status);
+	User::WaitForRequest(status);
+	LeaveIfErr(status.Int(), _L("Unable to connect to %S : %u"), iHost, iPort);
+
+	TcpDisconnect();
+	}
+
+void CCmdRsocket::TcpDisconnect()
+	{
+	if (iVerbose)
+		{
+		Write(_L("Shutting down socket...\r\n"));
+		}
+	TRequestStatus status;
+	iSocket.Shutdown(RSocket::ENormal, status);
+	User::WaitForRequest(status);
+	}
+
+void CCmdRsocket::ArgumentsL(RCommandArgumentList& aArguments)
+	{
+	_LIT(KArgOperation, "operation");
+	aArguments.AppendEnumL((TInt&)iOperation, KArgOperation);
+
+	_LIT(KOptHost, "host");
+	aArguments.AppendStringL(iHost, KOptHost);
+
+	_LIT(KOptPort, "port");
+	aArguments.AppendUintL(iPort, KOptPort);
+	}
+
+void CCmdRsocket::OptionsL(RCommandOptionList& aOptions)
+	{
+	_LIT(KOptVerbose, "verbose");
+	aOptions.AppendBoolL(iVerbose, KOptVerbose);
+
+	_LIT(KOptIapId, "iap");
+	aOptions.AppendUintL(iIapId, KOptIapId);
+
+	_LIT(KOptNetworkId, "network");
+	aOptions.AppendUintL(iNetworkId, KOptNetworkId);
+	}
+
+
+EXE_BOILER_PLATE(CCmdRsocket)
+