/*
* Copyright (c) 2004 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 "TrkSocketCommPort.h"
#include "TrkFramingLayer.h"
#include "TrkEngine.h"
#include <e32cons.h>


CTrkSocketCommPort::CTrkSocketCommPort()
	: CTrkCommPort(CActive::EPriorityStandard),
	  iConnected(EFalse)
{
}

void CTrkSocketCommPort::ConstructL(const TDesC &/*aInitFilePath*/, TDes& /*aErrorMessage*/)
{
	CActiveScheduler::Add(this); 
}

void CTrkSocketCommPort::IssueReadRequest()
{
	iNextReadChar = 0;
	TSockXfrLength len;
	iSocket.RecvOneOrMore(iReceivedChars, 0, iStatus, len);

	SetActive();
}

void CTrkSocketCommPort::DoCancel()
{
	iSocket.CancelRead();
}

void CTrkSocketCommPort::RunL()
{
	if (iStatus.Int() == KErrNone)
		while (iNextReadChar < iReceivedChars.Length())
			iFramingLayer->HandleByte(iReceivedChars[iNextReadChar++]);

	IssueReadRequest();
}


CTrkSocketCommPort::~CTrkSocketCommPort()
{
	Cancel();
//	iSocket.Close();
	iConnected = EFalse;
	iSocketServ.Close();
}


CTrkSocketCommPort* CTrkSocketCommPort::NewL(const TDesC& aInitFilePath, TDes& aErrorMessage)
{
	CTrkSocketCommPort* self = new(ELeave) CTrkSocketCommPort;
	CleanupStack::PushL(self);
	self->ConstructL(aInitFilePath, aErrorMessage);
	CleanupStack::Pop(self);
	return self;
}


void CTrkSocketCommPort::OpenPortL()
{
	TInt error = KErrNone;
	
	error = iSocketServ.Connect();
	if (error != KErrNone)
		User::Leave(100);

	error = iSocket.Open(iSocketServ, KAfInet, KSockStream, KProtocolInetTcp);
	if (error != KErrNone)
		User::Leave(101);

	TUint protocols = 0;
	
	error = iSocketServ.NumProtocols(protocols);
	
	TProtocolDesc desc;
	
	for (TUint i=0; i<protocols; i++)
	{
		error = iSocketServ.GetProtocolInfo(i, desc);
	}
	
}

void CTrkSocketCommPort::ConnectL()
{
	TInetAddr address;
	TInt err = KErrNone;
	
//	address.SetPort(10000);
//	err = address.Input(_L("10.86.2.93"));
//
//	TRequestStatus stat;
//	iSocket.Connect(address, stat);
//	User::WaitForRequest(stat);

//	iConnected = ETrue;

//	TSockAddr test;
//	iSocket.LocalName(test);
//	TUint lp = iSocket.LocalPort();

	
	address.SetPort(6110);
	err = address.Input(_L("127.0.0.1"));
//	err = address.Input(_L("0.0.0.0"));

	err = iSocket.Bind(address);
	if (err != KErrNone)
	{
		User::Leave(err);
	}

	err = iSocket.Listen(1);
	if (err != KErrNone)
	{
		User::Leave(err);
	}

	RSocket blankSocket;
	err = blankSocket.Open(iSocketServ);

	TRequestStatus stat;
	iSocket.Accept(blankSocket, stat);
//	SetActive();
	User::WaitForRequest(stat);
	User::Leave(5000);

//	iSocket.Connect(address, iStatus);

	iConnected = ETrue;
}

void CTrkSocketCommPort::ClosePort()
{
	Cancel();
	
	if (iConnected)
	{
		iSocket.Close();
		iConnected = EFalse;
	}

	iSocketServ.Close();
}

void CTrkSocketCommPort::SendDataL(const TDesC8& aBuffer)
{
	TRequestStatus status;
	iSocket.Write(aBuffer, status);
	User::WaitForRequest(status);

	User::LeaveIfError(status.Int());
}

void CTrkSocketCommPort::Listen(CTrkFramingLayer */*aFramingLayer*/)
{
//#warning - can leave
//	if (!iConnected)
//		ConnectL();
//	iFramingLayer = aFramingLayer;
//	CActiveScheduler::Add(this);
//	IssueReadRequest();
}

void CTrkSocketCommPort::StopListening()
{
	Cancel();
	Deque();
}