// Copyright (c) 1997-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 "rasdef.h"
#include <cdblen.h>

CRasConnect::CRasConnect(CNtRas* aNtRas)
	: iNtRas(aNtRas)
	{
	__DECLARE_NAME(_S("CRasConnect"));
	}

CRasConnect::~CRasConnect()
	{

	if(iCommOpen)
		{
		Disconnect();
		CommClose();
		}
	CommDelete();
	TimerDelete();
	delete iChat;
	}

CRasConnect* CRasConnect::NewL(CNtRas* aRas)
	{
	CRasConnect* p = new (ELeave) CRasConnect(aRas);
	CleanupStack::PushL(p);
	p->ConstructL();
	CleanupStack::Pop();
	return p;
	}

void CRasConnect::ConstructL()
	{

	CommConstructL(KCommReadPriority,KCommWritePriority);
	TimerConstructL(KCommTimerPrioiry);
	iState = ERasConClosed;
	iChat = new (ELeave) CCommChatter(this, KChatterPriority);
	iChat->CreateL(KChatBufferSize);
	iNtRas->ReadInt(NIF_IFSERVERMODE, iServerMode);

	if(iServerMode)
		iString=CCommChatString::NewL(_L8("CLIENT"), EFalse);
	else
		iString=CCommChatString::NewL(_L8("SERVER"), EFalse);

	iChat->AddString(iString);
	TFileName csy;
	TName port;

	TBuf<KCommsDbSvrMaxColumnNameLength> columnName=TPtrC(MODEM);
	columnName.Append(TChar(KSlashChar));
	columnName.Append(TPtrC(MODEM_CSY_NAME));
	User::LeaveIfError(iNtRas->ReadDes(columnName, csy));

	columnName.SetLength(0);
	columnName=TPtrC(MODEM);
	columnName.Append(TChar(KSlashChar));
	columnName.Append(TPtrC(MODEM_PORT_NAME));
	User::LeaveIfError(iNtRas->ReadDes(columnName, port));

	TInt err;
	err = CommOpen(csy, port, ECommShared);
	if (err==KErrNotFound)
		{
		Util::CommInit();
		err = CommOpen(csy, port, ECommShared);
		}
	User::LeaveIfError(err);
	iCommOpen=ETrue;
	StartL();
	}

void CRasConnect::StartL()
	{
	User::LeaveIfError(InitComm());
	iCommPort.ResetBuffers();
	Disconnect(); // Will drop the lines
	TimerAfter(KCommLineDropTime);
	iState = ERasConDropLines;
	}

TPtrC8 CRasConnect::ExcessData()
	{
	return TPtrC8(iRxBuf.Ptr()+iRxBufOffset, iRxBuf.Length()-iRxBufOffset);
	}

void CRasConnect::CommReadComplete(TInt aStatus)
	{
	if (aStatus!=KErrNone)
		{
		Complete(aStatus);
		return;
		}
	for (iRxBufOffset=0; iRxBufOffset<iRxBuf.Length() && iState!=ERasConConnected; iRxBufOffset++)
		iChat->AddChar(iRxBuf[iRxBufOffset]);
	if (iState==ERasConConnected)
		{
		Complete(KErrNone);
		}
	else
		{
		CommReadOneOrMore(iRxBuf);
		iRxBufOffset = 0;
		}
	}

void CRasConnect::CommWriteComplete(TInt aStatus)
	{
	if (aStatus!=KErrNone)
		{
		Complete(aStatus);
		return;
		}
	else if (iState==ERasConConnecting)
		{
		iTries = 0;
		SendToken();
		}
	}

void CRasConnect::TimerComplete(TInt /*aStatus */)
	{
	if (iState == ERasConDropLines)
		{
		TInt ret;
		if (ret = InitComm(), ret!=KErrNone)
			{
			Complete(ret);
			return;
			}

		iCommPort.SetSignalsToMark(KSignalRTS | KSignalDTR);

		if(iServerMode)
			{
			CommReadOneOrMore(iRxBuf);
			}
		else
			{
		    CommWriteReady();
		    TimerAfter(KCommTimeout);
			}
		iState = ERasConConnecting;
		}
	else
		{
		Complete(KErrTimedOut);
		}
	}

void CRasConnect::ChatStringMatch(CCommChatString* /*aString */)
	{
	if(iState==ERasConTokenSent)
		{
	    iState = ERasConConnected;
		if(iServerMode)
			iRxBufOffset=0;
		}
	else if(iServerMode && iState!=ERasConTokenSent && !CommIsWriting())
	    {
		iChat->RemoveString(iString);
		delete iString;
        TRAPD(res, iString=CCommChatString::NewL(_L8("~"), EFalse);)
		if(res!=KErrNone)  // Comment out here
			{
			Complete(res);
			return;
			}
		CommWriteReady();
		}
	}

void CRasConnect::ChatTimeout()
	{
	SendToken();
	}

void CRasConnect::SendToken()
	{
	
	// Changed to work on PPPD machines, comment line below and uncomment block for
	// NTRas to work
	//iNtRas->ConnectComplete(KErrNone);
	
	iState = ERasConTokenSent;
	if (iTries++>=KChatMaxTries)
		{
		Complete(KErrCouldNotConnect);
		return;
		}
	if(iServerMode)
		CommWrite(_L8("SERVER"));
	else
	    CommWrite(_L8("CLIENT"));

	if(!CommIsReading())
	    CommReadOneOrMore(iRxBuf);
	iChat->StartTimer(KChatTimeout);
	//*/
	}

void CRasConnect::Complete(TInt aStatus)
	{
	CommCancel();
	TimerCancel();
	iChat->StopTimer();
	iNtRas->ConnectComplete(aStatus);
	}

void CRasConnect::Disconnect()
	{

	CommCancel();

	//TInt ret;
	TCommConfig cbuf;
	TCommConfigV01 &cfg=cbuf();
	iCommPort.Config(cbuf);
	cfg.iHandshake = KConfigFreeRTS	| KConfigFreeDTR;
	iCommPort.SetConfig(cbuf);
	iCommPort.SetSignalsToSpace(KSignalRTS | KSignalDTR);
	}

TInt CRasConnect::InitComm()
	{
	TInt ret;
	TCommConfig cbuf;
	TCommConfigV01 &cfg=cbuf();
	iCommPort.Config(cbuf);

	TUint32 spd;
	iNtRas->ReadInt(RAS_COMMSPEED, spd);
	ret = Util::GetCommSpeed(spd, cfg.iRate);	
	
	TBuf<32> buf;
	buf.SetMax();
	iNtRas->ReadDes(RAS_COMMDATA, buf);
	if (ret = Util::GetCommFormat(buf, cfg.iDataBits, cfg.iStopBits, cfg.iParity), ret!=KErrNone)
		return ret;
	
	buf.SetMax();
	iNtRas->ReadDes(RAS_COMMHANDSHAKE, buf);
	if (ret = Util::GetCommHandshake(buf, cfg.iHandshake), ret!=KErrNone)
		return ret;

	if (ret = iCommPort.SetConfig(cbuf), ret!=KErrNone)
		return ret;

	return KErrNone;
	}