/*
* Copyright (c) 2002-2008 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:  CCntParserServerSession implementation.
*
*/


#include "cntparserserversession.h"
#include <cntdb.h>
#include "cntparsercollector.h"
#include "cntparserinfolog.h"
#include "irmcconsts.h"

#include "debug.h"

//------------------------------------------------------------
// CCntParserServerSession::CCntParserServerSession()
//------------------------------------------------------------
CCntParserServerSession::CCntParserServerSession()
    {
    }
//------------------------------------------------------------
// CCntParserServerSession::NewL(CCntParserServer* aServer)
//------------------------------------------------------------
CCntParserServerSession* CCntParserServerSession::NewL( CCntParserServer* aServer )
    {
    LOGGER_ENTERFN( "CntParserServerSession::NewL()" );

    CCntParserServerSession* self = new( ELeave ) CCntParserServerSession();
    CleanupStack::PushL( self );
    self->ConstructL( aServer );
    CleanupStack::Pop( self );
    LOGGER_LEAVEFN( "CntParserServerSession::NewL()" );
    return self;
    }
//------------------------------------------------------------
// CCntParserServerSession::ConstructL( CCntParserServer* aServer )
//------------------------------------------------------------
void CCntParserServerSession::ConstructL( CCntParserServer* aServer )
    {
    iContactsParserSrv = aServer;
    iContactsParserSrv->IncreaseSessionCountL();
    }
//------------------------------------------------------------
// CCntParserServerSession::~CCntParserServerSession()
//------------------------------------------------------------
CCntParserServerSession::~CCntParserServerSession()
    {
    LOGGER_ENTERFN( "CntParserServerSession::~CCntParserServerSession()" );
    if ( iContactsParserSrv )
        {
        iContactsParserSrv->DecreaseSessionCount();
        }
    LOGGER_LEAVEFN( "CntParserServerSession::~CCntParserServerSession()" );
    }
//------------------------------------------------------------
// CCntParserServerSession::ServiceL( const RMessage2& aMessage )
//------------------------------------------------------------
void CCntParserServerSession::ServiceL( const RMessage2& aMessage )
    {
    LOGGER_WRITE( "CntParserServerSession: ServiceL" );

    TInt err( KErrNone );
    TInt ret( KErrNone );

    TRAP( err, ret = DispatchMessageL( aMessage ) );

    if ( err != KErrNone )
        {
        LOGGER_WRITE_1( "CntParserServerSession: ServiceL: Error trapped, complete with ERR code %d", err );

        iPhoneBookRequest = EFalse; //If requested, then clear request flag
        iContactsParserSrv->SetRequests( 0 );   //Reset requests count in server to allow new requests to start..
        aMessage.Complete( err ); //If trap error, complete with it
        return;
        }   

    if ( ret == KErrNone )
        {
        LOGGER_WRITE( "CntParserServerSession: ServiceL: No complete" );
        return;
        }

    if ( ret == KPerformComplete )
        {
        LOGGER_WRITE( "CntParserServerSession: ServiceL: Normal complete" );

        aMessage.Complete( KErrNone );
        return;
        }

    if ( ret == KPBNotUpdated )
        {
        LOGGER_WRITE( "CntParserServerSession: ServiceL: Complete (PB not updated)" );

        iPhoneBookRequest = EFalse;
        aMessage.Complete( KPBNotUpdated );
        return;
        }
    LOGGER_WRITE( "CntParserServerSession: ServiceL: Error, should never come here" );
    aMessage.Complete( KErrGeneral );
    }
//------------------------------------------------------------
// CCntParserServerSession::CompletePhoneBookRequest( TInt aErr )
//------------------------------------------------------------
void CCntParserServerSession::CompletePhoneBookRequest( TInt aErr )
    {
    LOGGER_WRITE( "CntParserServerSession: CompletePhoneBookRequest" );

    if ( iPhoneBookRequest ) //If this session has requested phonebook, then the completion should be done here, as it was not done in ServiceL
        {
        LOGGER_WRITE( "CntParserServerSession: CompletePhoneBookRequest: collector or cancel" );
        iPhoneBookRequest = EFalse;
        iPhoneBookRequestMessage.Complete( aErr );
        }
    else
        {
        LOGGER_WRITE( "CntParserServerSession: CompletePhoneBookRequest: No complete for this session" );
        }
    }
//------------------------------------------------------------
// CCntParserServerSession::DispatchMessageL( const RMessage2 &aMessage )
//------------------------------------------------------------
TInt CCntParserServerSession::DispatchMessageL( const RMessage2 &aMessage )
    {
    LOGGER_WRITE( "CntParserServerSession: DispatchMessageL" );

    TInt res( KPerformComplete );

    switch( aMessage.Function() )
        {
        case ECntParserServerCreateIrMCL2:  //Create pb.vcf file
            {
            res = ETrue;

            if ( iPhoneBookRequest == EFalse )
                {
                iPhoneBookRequestMessage = aMessage;
                iPhoneBookRequest = ETrue;

                TInt sid=aMessage.SecureId();
                TInt MaxNumOfContacts = aMessage.Int0();
                TBool Forced = aMessage.Int1();
                TBuf<8> sidLit;
                sidLit.AppendNumFixedWidth( sid, EHex, 8);
                TBuf<255> path;
                path.Insert( 0, KPhoneBookFilename );

                res = iContactsParserSrv->CreateIrMCL2PhoneBookL( path, (TInt) MaxNumOfContacts, Forced );
                }
            break;
            }
        case ECntParserServerCntParsed: //How many contacts already parsed
            {
            TPckgBuf<TInt> p((TInt) iContactsParserSrv->ContactsParsed());
            aMessage.WriteL( 0, p, 0 );
            break;
            }
        case ECntParserServerTotalNumOfContacts: //How many contacts total?
            {
            TPckgBuf<TInt> p((TInt) iContactsParserSrv->TotalNumOfContacts());
            aMessage.WriteL( 0, p, 0 );
            break;
            }
        case ECntParserServerDisconnect:    //Disconnect session from server
            {
            iContactsParserSrv->Disconnect();
            break;
            }
        case ECntParserServerCancel:    //Cancel phone book request
            {
            if (iPhoneBookRequest)
                {
                iContactsParserSrv->CancelPhoneBookRequest();
                CompletePhoneBookRequest( KErrCancel );
                }
            break;
            }
        case ECntParserServerCntSaved: //How many contacts total?
            {
            TPckgBuf<TInt> p((TInt) iContactsParserSrv->ContactsSaved());
            aMessage.WriteL( 0, p, 0 );
            break;
            }
        case ECntParserServerCancelAll: //Cancel all requests, not just current?
            {
            iContactsParserSrv->CancelAllPhoneBookRequests();
            break;
            }
        // requests we don't understand
        // so panic the client here, this function also completes the message
        default:
            {
            PanicClient( EBadRequest );
            break;
            }
        }
    return res;
    }
//------------------------------------------------------------
// CCntParserServerSession::PanicClient(TInt aPanic) const
//------------------------------------------------------------
void CCntParserServerSession::PanicClient(TInt aPanic) const
    {
    User::Panic( KTxtServer,aPanic );
    }
    
// end of file