/*
* Copyright (c) 2005-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 <e32std.h>
#include "serialwriter.h"
#include "tefconst.h"
#include <test/tefexportconst.h>

#if defined (__WINS__)
_LIT(KPddDev, "ECDRV.PDD");
#else
_LIT(KPddDev, "EUART1");
#endif

#if defined (__WINS__)
_LIT(KLddDev, "ECOMM.LDD");
#else
_LIT(KLddDev, "ECOMM");
#endif


/**
Creates an instance of CSerialWriter object
@return a pointer to the new created CSerialWriter Object
@leave KErrNoMemory if no memory
*/
 CSerialWriter* CSerialWriter::NewL()
	{
	CSerialWriter *me = new (ELeave) CSerialWriter;
	CleanupStack::PushL(me);
	me->ConstructL();
	CleanupStack::Pop();
	return me;
	}

/**
Public Destructor
*/
CSerialWriter::~CSerialWriter()
	{
    Disconnect();
	}

//default constructor
CSerialWriter::CSerialWriter()
	{
	}

void CSerialWriter::ConstructL()
	{
	iReady = EFalse;
	
    TInt err = User::LoadPhysicalDevice(KPddDev);
    if(err!=KErrNone && err!=KErrAlreadyExists)
        User::Leave(err);

    err = User::LoadLogicalDevice(KLddDev);
    if(err!=KErrNone && err!=KErrAlreadyExists)
        User::Leave(err);
 	}

TInt CSerialWriter::Connect()
    {
    if(!iReady)
        {
        TInt err = KErrNone;
        err = iComm.Open(iPortNum);
        if(err!=KErrNone)
        	{
       		iReady = EFalse;
            return err;
        	}
        	else
		        iReady = ETrue;
        }
    return KErrNone;
    }

TInt CSerialWriter::Config()
    {
    TInt err = KErrNone;
    if(iReady)
        {
        TCommConfig2 cfgBuf;
        TCommConfigV02& cfg = cfgBuf();
        iComm.Config(cfgBuf);
        cfg.iRate = EBps115200;// default EBps9600;
        cfg.iDataBits = EData8;// default EData8;
        cfg.iStopBits = EStop1;// default EStop1;
        cfg.iParity = EParityNone;// default EParityNone;
        cfg.iHandshake = 0;// default KConfigObeyCTS;
        cfg.iParityError = KConfigParityErrorFail;
        cfg.iFifo = EFifoEnable;// default EFifoEnable;
        cfg.iSpecialRate = 0;// default 0;
        cfg.iTerminatorCount = 0;// default 0;
        cfg.iXonChar = 0x11;// default 0x11; // XON
        cfg.iXoffChar = 0x13;// default 0x13; // XOFF
        cfg.iParityErrorChar = 0;// default 0;
        cfg.iSIREnable = ESIRDisable;// default ESIRDisable;
        cfg.iSIRSettings = 0;// no default
        
        err = iComm.SetConfig(cfgBuf);
        if(err!=KErrNone && err!=KErrInUse)
            {
            iReady = EFalse;
            return(err);
            }
        }
    
    return err;
    }

TInt CSerialWriter::Disconnect()
    {
    if(iReady)
        {
	    iReady = EFalse;
        iComm.Close();
        }
    return KErrNone;
    }

TInt CSerialWriter::Write(const TDesC8& aData)
	{
	TInt err = KErrNone;
	
	if(iReady)
		{
		TRequestStatus writeStatus;
	    iComm.Write(writeStatus, aData);
    	User::WaitForRequest(writeStatus);
    	err = writeStatus.Int();  	
		}

   	return err;
	}

void CSerialWriter::AddTime(TDes8& aLogBuffer)
	{
	TTime now;
	now.UniversalTime();
	TDateTime dateTime = now.DateTime();
	_LIT8(KFormat,"%02d:%02d:%02d:%03d ");
	// add the current time 
	aLogBuffer.Append(KTEFNewLine) ; 
	aLogBuffer.AppendFormat(KFormat,dateTime.Hour(),dateTime.Minute(),dateTime.Second(),(dateTime.MicroSecond()/1000)); 
	}

void CSerialWriter::AddSeverity(TDes8& aLogBuffer, const TInt& aSeverity)
	{
	if (aSeverity < 1) 
		{
		return;
		}

	_LIT(KErr,"ERROR - ");
	_LIT(KHigh,"HIGH - ");
	_LIT(KWarn,"WARN - ");
	_LIT(KMedium,"MEDIUM - ");
	_LIT(KInfo,"INFO - ");
	_LIT(KLow,"LOW - ");

	if(aSeverity == ESevrErr)
		aLogBuffer.Append(KErr);
	else if(aSeverity == ESevrHigh)
		aLogBuffer.Append(KHigh);
	else if(aSeverity == ESevrWarn)
		aLogBuffer.Append(KWarn);
	else if(aSeverity == ESevrMedium)
		aLogBuffer.Append(KMedium);
	else if (aSeverity == ESevrInfo)
		aLogBuffer.Append(KInfo);
	else if(aSeverity == ESevrLow)
		aLogBuffer.Append(KLow);
	else //if(aSeverity == ESevrAll)
		aLogBuffer.Append(KInfo);

	}


/**
Decorates the logs with Current Time and Severity 
@returns Error code if any during writing
@leave KErrNoMemory if no memory
*/
TInt CSerialWriter::WriteDecorated(const TDesC8& aText, TInt aSeverity)	
{
	TInt ret = KErrNone; 	
	HBufC8* buffer = HBufC8::New(aText.Length()+30);
	if(buffer)
		{
		TPtr8 ptr(buffer->Des());
		AddTime(ptr);
		AddSeverity(ptr,aSeverity) ; 
		ptr.Append(aText);
		// Ignore error for the time being. Could do an ASSERT
		ret = Write(ptr) ; 
		delete buffer;
		}
	return ret ; 	
}

/**
  Overloaded for TDesC
  @returns Error code if any during writing
  @leave KErrNoMemory if no memory
  */
  TInt CSerialWriter::WriteDecorated(const TDesC& aText, TInt aSeverity)
  {
  	TPtrC8 representation((TUint8*)(&aText)->Ptr(), (&aText)->Size());
  	return WriteDecorated(representation,  aSeverity )	;
  }


TInt CSerialWriter::Settings(const TInt& aPortNumber)
	{
	  	iPortNum = aPortNumber ; 
	  	Disconnect();
	  	TInt err = Connect();
	  	if(err != KErrNone)
	  		return err;
	  	err = Config();
	  	return err;
	}