/*

 * Copyright (c) 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 FILES

#include    <e32base.h>

#include    <badesca.h>

#include    <e32def.h>

#include    <s32file.h>

#include    <msvids.h>

#include    <mtmdef.h>

//#include    <eikenv.h>

#include    <apgcli.h>

#include    <CMsvMimeHeaders.h>

#include    <AknNoteWrappers.h>

#include    <mmsservercommon.h>

#include    "mmsconst.h"

#include    "mmsclient.h"

#include    "mmsheaders.h"

#include    "mmsreadfile.h"

#include    "mmsmmboxviewheaders.h"

#include    "mmsmmboxmessageheaders.h"

#include    "mmsmmboxflags.h"

#include    "mmssettings.h"

// EXTERNAL DATA STRUCTURES

// EXTERNAL FUNCTION PROTOTYPES

// CONSTANTS

const TInt KMmsGranularity = 8;

_LIT( K1970, "19700000:000000.000000" );    // 1-Jan 1970 0:00:00

// MACROS

// LOCAL CONSTANTS AND MACROS

// MODULE DATA STRUCTURES

// LOCAL FUNCTION PROTOTYPES

// ==================== LOCAL FUNCTIONS ====================

// ================= MEMBER FUNCTIONS =======================

// C++ default constructor can NOT contain any code, that

// might leave.

//

CMmsReadFile::CMmsReadFile()

    {

    // all member variables in a class derived from CBase

    // are automatically set to 0.

    }

//

void CMmsReadFile::ConstructL(RFs& aFs, RFileReadStream& aReadStream )

    {

    // iRowBuffer = HBufC8::NewMaxL( 500 ); // Max row length!!!!

    iFs = aFs;

    iReader = &aReadStream;

    iByteBuffer = HBufC8::NewL( DefaultBufLen );

    iAliasArray = new ( ELeave ) CDesCArrayFlat( KMmsGranularity );

    iAttaStructures = new ( ELeave ) CArrayPtrFlat<CMmsAttaStructure>( KMmsGranularity );

    Reset();

    }

// Two-phased constructor.

CMmsReadFile* CMmsReadFile::NewL(RFs& aFs, RFileReadStream& aReadStream )

    {

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

    CleanupStack::PushL( self );

    self->ConstructL( aFs, aReadStream );

    CleanupStack::Pop();

    return self;

    }

// Destructor

CMmsReadFile::~CMmsReadFile()

    {

    Reset(); // resets and destroys all array data

    if (iAliasArray != NULL) iAliasArray->Reset();

    delete iByteBuffer;

    delete iAliasArray;

    delete iAttaStructures;

    }

void CMmsReadFile::Reset()

    {

    // reset all arrays

    if (iAttaStructures != NULL) iAttaStructures->ResetAndDestroy();

    iAttaCount = 0;

    iAttaRoot = 0;

    }

// ---------------------------------------------------------

// CMmsReadFile()::CompleteTest

// ---------------------------------------------------------

//

TInt CMmsReadFile::CompleteTestL( TInt aMessageCounter, CMmsHeaders& aMmsHeaders )

{

    Reset(); // new message

    TUint32 val;

    TUint   limit = 1000000;

    TUint   sizeLimit = 1000 * 1024; //max message size 1000 kB!

    TUint   allLimit = 999999;

    TInt    error;

    TRadix  radix = EDecimal;

    TLex16  lex;

    TTestReadStatus readStatus = ETestUnknown;

    CMmsAttaStructure* oneAtta = NULL;

	TInt    index;

    TTime y1970( K1970 );

    TTimeIntervalMicroSeconds interval;

    TTime date;

    TInt order = 0;

    TInt16 shortInteger = 0;

    //iso luuppi, joka kiertää ja lukee kunnes EOF tule vastaan

    //Big Loop, which passes around and read until the EOF

    iMessageType = iNextMessageType;

    while(readStatus != ETestEof)

        {

        readStatus = ReadRowL();

        if ( readStatus ==  ETestEof )

            {

            return(-1);

            }

        if ( readStatus == ETestUnknown )

            {

            // A line containing only comments, or an unknown tag

            // As using the scripts to test settings is no longer supported,

            // any old keywords used to test CMmsSettings class are ignored

            continue;

            }

        if( readStatus == ETestNewMessage )

            {

            iNextMessageType = readStatus;

            if(aMessageCounter++)

                {

                return(NULL);

                }

            else

                {

                iMessageType = iNextMessageType;

                continue;

                }

            }

        if ( iMessageType == ETestNewMessage)

            {

            switch(readStatus)

                {

                case ETestFrom:

                    aMmsHeaders.SetSenderL( iValueBuffer );

                    break;

                case ETestFromAlias:

					index = FindAlias(iValueBuffer);

					if(index >= 0)

    					{

                        aMmsHeaders.SetSenderL( iAliasArray->MdcaPoint(index).Mid(iAliasArray->MdcaPoint(index).Locate('=') + 1 ) );

	    				}

                    break;

                case ETestTo:

                    aMmsHeaders.AddTypedAddresseeL( iValueBuffer, EMsvRecipientTo );

                    break;

                case ETestToAlias:

					index = FindAlias(iValueBuffer);

					if(index >= 0)

    					{

                        aMmsHeaders.AddTypedAddresseeL( iAliasArray->MdcaPoint(index).Mid(iAliasArray->MdcaPoint(index).Locate('=') + 1 ), EMmsTo );

						}

                    break;

                case ETestCc:

                    aMmsHeaders.AddTypedAddresseeL( iValueBuffer, EMsvRecipientCc );

                    break;

                case ETestCcAlias:

					index = FindAlias(iValueBuffer);

					if(index >= 0)

    					{

                        aMmsHeaders.AddTypedAddresseeL( iAliasArray->MdcaPoint(index).Mid(iAliasArray->MdcaPoint(index).Locate('=') + 1 ), EMmsCc );

						}

                    break;

                case ETestBcc:

                    aMmsHeaders.AddTypedAddresseeL( iValueBuffer, EMsvRecipientBcc );

                    break;

                case ETestBccAlias:

					index = FindAlias(iValueBuffer);

					if(index >= 0)

    					{

                        aMmsHeaders.AddTypedAddresseeL( iAliasArray->MdcaPoint(index).Mid(iAliasArray->MdcaPoint(index).Locate('=') + 1 ), EMmsBcc );

						}

                    break;

                case ETestSubject:

                    aMmsHeaders.SetSubjectL( iValueBuffer );

                    break;

                case ETestExpiryRel:

                    lex.Assign(iValueBuffer);

                    error = lex.Val(val,radix,limit);

                    if (error == KErrNone)

                        {

                        aMmsHeaders.SetExpiryInterval( val );

                        }

                    break;

                case ETestExpiryAbs:

                    error = iDate.Set(iValueBuffer);

                    interval = iDate.MicroSecondsFrom( y1970 );

                    // expiry date in seconds from 1.1.1970.

                    aMmsHeaders.SetExpiryDate( (interval.Int64())/1000000 );

                    break;

                case ETestDeliveryTimeRel:

                    lex.Assign(iValueBuffer);

                    error = lex.Val(val,radix,limit);

                    if (error == KErrNone)

                        {

                        aMmsHeaders.SetDeliveryTimeInterval( val );

                        }

                    break;

                case ETestDeliveryTimeAbs:

                    error = iDate.Set(iValueBuffer);

                    interval = iDate.MicroSecondsFrom( y1970 );

                    aMmsHeaders.SetDeliveryDate( (interval.Int64())/1000000 );

                    break;

                case ETestDate:

                    error = iDate.Set(iValueBuffer);

                    interval = iDate.MicroSecondsFrom( y1970 );

                    aMmsHeaders.SetDate( (interval.Int64())/1000000 );

                case ETestPriority:

                    val = 0;

                    if ((iValueBuffer.CompareF(KLow)) == 0)

                        {

                        val = EMmsPriorityLow;

                        }

                    else if ((iValueBuffer.CompareF(KNormal)) == 0)

                        {

                        val = EMmsPriorityNormal;

                        }

                    else if ((iValueBuffer.CompareF(KHigh)) == 0)

                        {

                        val = EMmsPriorityHigh;

                        }

                    else

                        {

                        val = KMmsTestIllegalValue;

                        }

                    aMmsHeaders.SetMessagePriority( val );

                    break;

                case ETestSenderVisibility:

                    val = 0;

                    if ((iValueBuffer.CompareF(KHide)) == 0)

                        {

                        val = EMmsSenderVisibilityHide;

                        }

                    else if ((iValueBuffer.CompareF(KShow)) == 0)

                        {

                        val = EMmsSenderVisibilityShow;

                        }

                    else

                        {

                        val = KMmsTestIllegalValue;

                        }

                    aMmsHeaders.SetSenderVisibility( val );

                    break;

                case ETestDeliveryReport:

                    val = 0;

                    if ((iValueBuffer.CompareF(KYes)) == 0)

                        {

                        val = EMmsYes;

                        }

                    else if ((iValueBuffer.CompareF(KNo)) == 0)

                        {

                        val = EMmsNo;

                        }

                    else

                        {

                        val = KMmsTestIllegalValue;

                        }

                    aMmsHeaders.SetDeliveryReport( val );

                    break;

                case ETestDelivReportSendAllow:

                    val = 0;

                    if ((iValueBuffer.CompareF(KYes)) == 0)

                        {

                        val = EMmsYes;

                        }

                    else if ((iValueBuffer.CompareF(KNo)) == 0)

                        {

                        val = EMmsNo;

                        }

                    else

                        {

                        val = KMmsTestIllegalValue;

                        }

                    aMmsHeaders.SetReportAllowed( val );

                    break;

                case ETestReadReply:

                    val = 0;

                    if ((iValueBuffer.CompareF(KYes)) == 0)

                        {

                        val = EMmsYes;

                        }

                    else if ((iValueBuffer.CompareF(KNo)) == 0)

                        {

                        val = EMmsNo;

                        }

                    else

                        {

                        val = KMmsTestIllegalValue;

                        }

                    aMmsHeaders.SetReadReply( val );

                    break;

                case ETestNewAttachment:

                    oneAtta = CMmsAttaStructure::NewL();

                    iAttaStructures->AppendL(oneAtta);

                    oneAtta->iAtta->Des().Copy( iValueBuffer );

                    iAttaCount++;

                    break;

                case ETestAttachmentType:

                    if (oneAtta != NULL)

                        {

                        oneAtta->iAttaType->Des().Copy( iValueBuffer );

                        }

                    break;

                case ETestAttachmentContLoc:

                    if (oneAtta != NULL)

                        {

                        oneAtta->iAttaName->Des().Copy( iValueBuffer );

                        }

                    break;

                case ETestAttaRecommendedName:

                    if (oneAtta != NULL)

                        {

                        oneAtta->iAttaRecommendedName->Des().Copy( iValueBuffer );

                        }

                    break;

                case ETestAttachmentCharset:

                    lex.Assign(iValueBuffer);

                    error = lex.Val(val,radix,limit);

                    if (error == KErrNone)

                        {

                        if (oneAtta != NULL)

                            {

                            oneAtta->iAttaCharset = val;

                            }

                        }

                    break;

                case ETestAttachmentCid:

                    if (oneAtta != NULL)

                        {

                        oneAtta->iAttaCid->Des().Copy(iValueBuffer);

                        }

                    break;

                case ETestAttContTypeParamName:

                    iByteBuffer->Des().Copy( iValueBuffer );

                    if (oneAtta != NULL)

                        {

                        oneAtta->iContentTypeParams->AppendL(iByteBuffer->Des());

                        }

                    break;

                case ETestAttContTypeParamValue:

                    iByteBuffer->Des().Copy( iValueBuffer );

                    if (oneAtta != NULL)

                        {

                        oneAtta->iContentTypeParams->AppendL(iByteBuffer->Des());

                        }

                    break;

                case ETestAttXTypeParamName:

                    iByteBuffer->Des().Copy( iValueBuffer );

                    if (oneAtta != NULL)

                        {

                        oneAtta->iXTypeParams->AppendL(iByteBuffer->Des());

                        }

                    break;

                case ETestAttXTypeParamValue:

                    iByteBuffer->Des().Copy( iValueBuffer );

                    if (oneAtta != NULL)

                        {

                        oneAtta->iXTypeParams->AppendL(iByteBuffer->Des());

                        }

                    break;

                case ETestAttachmentRoot:

                    iAttaRoot = iAttaCount;

                    break;

                case ETestAlias:

                    // all aliases are global even if they appear

                    // in the middle of a message

                    iAliasArray->AppendL( iValueBuffer );

                    iAliasCount++;

				    break;

                case ETestMessageClass: // should be handled!

                    val = EMmsClassPersonal;

                    if ((iValueBuffer.CompareF(KPersonal)) == 0)

                        {

                        val = EMmsClassPersonal;

                        }

                    else if ((iValueBuffer.CompareF(KAdvertisement)) == 0)

                        {

                        val = EMmsClassAdvertisement;

                        }

                    else if ((iValueBuffer.CompareF(KInformational)) == 0)

                        {

                        val = EMmsClassInformational;

                        }

                    else if ((iValueBuffer.CompareF(KAuto)) == 0)

                        {

                        val = EMmsClassAuto;

                        }

                    else

                        {

                        val = (TMmsMessageClass)KMmsTestIllegalValue;

                        }

                    aMmsHeaders.SetMessageClass( val );

                    break;

                case ETestReplyCharging:

                    val = 0;

                    if ((iValueBuffer.CompareF(KRequested)) == 0)

                        {

                        val = KMmsReplyChargingRequested;

                        }

                    else if ((iValueBuffer.CompareF(KReqTextOnly)) == 0)

                        {

                        val = KMmsReplyChargingRequestedTextOnly;

                        }

                    else if ((iValueBuffer.CompareF(KAccepted)) == 0)

                        {

                        val = KMmsReplyChargingAccepted;

                        }

                    else if ((iValueBuffer.CompareF(KAccTextOnly)) == 0)

                        {

                        val = KMmsReplyChargingAcceptedTextOnly;

                        }

                    else

                        {

                        val = KMmsTestIllegalValue;

                        }

                    aMmsHeaders.SetReplyCharging( val );

                    break;

                case ETestReplyChargAbs:

                    error = date.Set(iValueBuffer);

                    if ( error == KErrNone )

                        {

                        interval = date.MicroSecondsFrom( y1970 );

                        aMmsHeaders.SetReplyChargingDate( (interval.Int64())/1000000 );

                        }

                    break;

                case ETestReplyChargRel:

                    lex.Assign(iValueBuffer);

                    error = lex.Val(val,radix,limit);

                    if (error == KErrNone)

                        {

                        aMmsHeaders.SetReplyChargingInterval( val );

                        }

                    break;

                case ETestReplyChargSize:

                    lex.Assign(iValueBuffer);

                    error = lex.Val(val,radix,sizeLimit);

                    if (error == KErrNone)

                        {

                        aMmsHeaders.SetReplyChargingSize( val );

                        }

                    break;

                case ETestReplyChargID:

                    iByteBuffer->Des().Copy( iValueBuffer );

                    aMmsHeaders.SetReplyChargingIdL( iByteBuffer->Des() );

                    break;

                case ETestTID:

                    iByteBuffer->Des().Copy( iValueBuffer );

                    aMmsHeaders.SetTidL( iByteBuffer->Des() );

                    break;

                case ETestContentLocation:

                    iByteBuffer->Des().Copy( iValueBuffer );

                    if ( aMmsHeaders.MessageType() == KMmsMessageTypeMboxViewReq ||

                        aMmsHeaders.MessageType() == KMmsMessageTypeMboxViewConf ||

                        aMmsHeaders.MessageType() == KMmsMessageTypeMBoxDeleteReq )

                        {

                        aMmsHeaders.MMBoxMessageHeadersL().ContentLocationList().AppendL( iByteBuffer->Des() );

                        }

                    else if ( aMmsHeaders.MessageType() == KMmsMessageTypeMBoxDeleteConf )

                        {

                        aMmsHeaders.InsertDeleteContentLocationL( order, iByteBuffer->Des() );

                        }

                    else

                        {

                        aMmsHeaders.SetContentLocationL( iByteBuffer->Des() );

                        }

                    break;

                case ETestPreviouslySentIndex:

                    lex.Assign(iValueBuffer);

                    error = lex.Val(val,radix,limit);

                    order = val;

                    break;

                case ETestPreviouslySentBy:

                    aMmsHeaders.InsertPreviouslySentByL( order, iValueBuffer );

                    break;

                case ETestPreviouslySentDate:

                    error = date.Set(iValueBuffer);

                    if ( error == KErrNone )

                        {

                        interval = date.MicroSecondsFrom( y1970 );

                        aMmsHeaders.InsertPreviouslySentDateL( order, (interval.Int64())/1000000 );

                        }

                    break;

                case ETestMessageId:

                    iByteBuffer->Des().Copy( iValueBuffer );

                    aMmsHeaders.SetMessageIdL( iByteBuffer->Des() );

                    break;

                case ETestMessageSize:

                    lex.Assign(iValueBuffer);

                    error = lex.Val(val,radix,sizeLimit);