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


#include <e32std.h>
#include "cmscontact.h"
#include "cmssession.h"
#include "cmscontactfield.h"
#include "cmscontactfielditem.h"
#include "cmsnotificationhandlerapi.h"
#include "cmscontactnotifier.h"
#include "cmscommondefines.h"


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

// ----------------------------------------------------------
// CCmsContactNotifier::CCmsContactNotifier
// ----------------------------------------------------------
//
CCmsContactNotifier::CCmsContactNotifier( 
    RCmsContact& aContact, 
    MCmsNotificationHandlerAPI& aObserver,
    CCmsContactFieldItem::TCmsContactNotification aType )
    : CActive( CActive::EPriorityStandard), 
    iContact( aContact ),
    iStreamDesc( ( TText* )"", 0, 0 ), 
    iObserver( aObserver ),
    iPresenceStarted( EFalse ),
    iPhonebookStarted( EFalse ),
    iDestroyedPtr( NULL ),
    iType( aType ),
    iContactField( NULL )
    {
    }

// ----------------------------------------------------------
// CCmsContactNotifier::~CCmsContactNotifier
// ----------------------------------------------------------
//
CCmsContactNotifier::~CCmsContactNotifier()
    {        
    Cancel();
    delete iStreamBuffer;
    delete iContactField;     
    if ( iDestroyedPtr )
        {
        // We are called inside callback
        *iDestroyedPtr = ETrue;
        iDestroyedPtr = NULL;
        }
    }
    
// ----------------------------------------------------------
// CCmsContactNotifier::NewL
// ----------------------------------------------------------
//
CCmsContactNotifier* CCmsContactNotifier::NewL(
    RCmsContact& aContact, 
    MCmsNotificationHandlerAPI& aObs,
    CCmsContactFieldItem::TCmsContactNotification aType )
    {
    CCmsContactNotifier* self = new (ELeave) CCmsContactNotifier( aContact, aObs, aType );
    CleanupStack::PushL( self );
    self->ConstructL(   );
    CleanupStack::Pop( self );
    return self;
    }
    
// ---------------------------------------------------------------------------
// CCmsContactNotifier::ConstructL
// ---------------------------------------------------------------------------
//
void CCmsContactNotifier::ConstructL( )
    {
    CActiveScheduler::Add(this);        
    }
    
// ---------------------------------------------------------------------------
// CCmsContactNotifier::StartOrderL
// ---------------------------------------------------------------------------
//
void CCmsContactNotifier::StartOrderL( TBool aAskMore )
    {
    #ifdef _DEBUG
        RCmsSession::WriteToLog( _L8( "CCmsContactNotifier::StartOrderL() - Ask more: %d" ), aAskMore );
    #endif 

    if ( IsActive() )
    	{
    	User::Leave( KErrInUse );
    	}
    else
        {        
        }
    
    if ( iType & CCmsContactFieldItem::ECmsPresenceAllNotification )
        {
        #ifdef _DEBUG
        RCmsSession::WriteToLog( _L8( "  Presence notification ordered type=%d" ), iType );
        #endif
        StartPresenceNotifyL( aAskMore );             
        } 
    else if ( iType & CCmsContactFieldItem::ECmsPhonebookNotification )
        {
        #ifdef _DEBUG
        RCmsSession::WriteToLog( _L8( "  Phonebook notification ordered" ) );
        #endif
        StartPhoneboookNotifyL( aAskMore );            
        }
    else
        {
        User::Leave( KErrNotSupported );
        }                      	    
    }

// ---------------------------------------------------------------------------
// CCmsContactNotifier::StartPhoneboookNotifyL
//
// ---------------------------------------------------------------------------
//
void CCmsContactNotifier::StartPhoneboookNotifyL( TBool aAskMore )
    {
    #ifdef _DEBUG
        RCmsSession::WriteToLog( _L8( "CCmsContactNotifier::StartPhoneboookNotifyL()" ) );
    #endif
    if( !iPhonebookStarted )
        {
        delete iStreamBuffer; 
        iStreamBuffer = NULL;
        iStreamBuffer = HBufC::NewL( 5 );
        iStreamDesc.Set( iStreamBuffer->Des() );
        TIpcArgs arguments( iType, &iStreamDesc );
        if( !aAskMore )
            {
            iContact.SendMessage( ECmsOrderNotification, arguments, iStatus );         
            }
        else
            {
            iContact.SendMessage( ECmsOrderNextNotification, arguments, iStatus );      
            }
        iPhonebookStarted = ETrue;
        SetActive();
        #ifdef _DEBUG
            RCmsSession::WriteToLog( _L8( "  Notification started" ) );
        #endif
        }
    else
        {
        #ifdef _DEBUG
            RCmsSession::WriteToLog( _L8( "  Notification already started => ignore" ) );
        #endif
        }
    }

// ---------------------------------------------------------------------------
// CCmsContactNotifier::StartPresenceNotifyL
//
// ---------------------------------------------------------------------------
//
void CCmsContactNotifier::StartPresenceNotifyL( TBool aAskMore )
    {
    #ifdef _DEBUG
        RCmsSession::WriteToLog( _L8( "CCmsContactNotifier::StartPresenceNotifyL()" ) );
    #endif
    delete iContactField;
    iContactField = NULL;    
    iContactField = CCmsContactField::NewL( iContact, iStatus, 
                    CCmsContactFieldItem::ECmsPresenceData ); 
    TIpcArgs arguments( iType, iContactField->StreamDesc8() );
    if( !aAskMore )
        {
        iContact.SendMessage( ECmsOrderNotification, arguments, iContactField->Activate() );         
        }
    else
        {
        iContact.SendMessage( ECmsOrderNextNotification, arguments, iContactField->Activate() );         
        }  
    SetActive();    
    }
        
// ----------------------------------------------------------
// CCmsContactNotifier::RunL
// ----------------------------------------------------------
//
void CCmsContactNotifier::RunL()
    {
    #ifdef _DEBUG
        RCmsSession::WriteToLog( _L8( "CCmsContactNotifier::RunL() - Status: %d" ), iStatus.Int() );
    #endif 
    TInt pbEvent = KErrGeneral;
    TInt status = iStatus.Int();
    if( status )
        {
        RunError( status );
        }
    else
        {
        // Set the member to point to stack variable
        TBool destroyed( EFalse );
        iDestroyedPtr = &destroyed;
        if ( CCmsContactFieldItem::ECmsPresenceAllNotification & Type() )
            {
            TRAP_IGNORE( iObserver.HandlePresenceNotificationL( iContactField ) );
            }
        else if( CCmsContactFieldItem::ECmsPhonebookNotification == Type() )
            {
            TLex lex( iStreamDesc );
            TInt event = KErrNotFound;
            lex.Val( event );
            iPhonebookStarted = EFalse;            
            TRAP_IGNORE( iObserver.HandlePhonebookNotificationL( ( TCmsPhonebookEvent  )event ) );
            pbEvent = event;
            }
        else
            {
            RunError( KErrNotSupported );
            }
        if ( !destroyed )
            {
            iDestroyedPtr = NULL;
            }
        CheckRestartL( destroyed, ( TCmsPhonebookEvent  )pbEvent );
        }
    }

// ----------------------------------------------------------
// CCmsContactNotifier::CheckRestartL
//
// ----------------------------------------------------------
//
void CCmsContactNotifier::CheckRestartL( TBool aDestroyed, TCmsPhonebookEvent aEvent )
    {
    #ifdef _DEBUG
        RCmsSession::WriteToLog( _L8( "CCmsContactNotifier::CheckRestartL()" ) );
    #endif
    //If the object has been deleted inside the callback or
    //if the contact handle has been deleted in the server,
    //notifications must not be re-ordered
    if( !aDestroyed && ECmsContactDeleted != aEvent )
        {
        // Ownership is transferred
        iContactField = NULL;                 
        StartOrderL( ETrue );
        #ifdef _DEBUG
            RCmsSession::WriteToLog( _L8( "  Notification renewed" ) );
        #endif
        }         
    } 
   
// ----------------------------------------------------------
// CCmsContactNotifier::RunError
// ----------------------------------------------------------
//
TInt CCmsContactNotifier::RunError( TInt aError )
    {
    #ifdef _DEBUG
        RCmsSession::WriteToLog( _L8( "CCmsContactNotifier::RunError() - Error: %d" ), aError );
    #endif       
    // Save this since we ask to delete ourself and members cannot be used anymore.
    MCmsNotificationHandlerAPI& observer = iObserver; 
    CCmsContactFieldItem::TCmsContactNotification myType = Type();    
    iContact.DeleteNotifier( myType );
    observer.CmsNotificationTerminatedL( aError, myType );
    return KErrNone;          
    }          

// ----------------------------------------------------------
// CCmsContactNotifier::DoCancel
// ----------------------------------------------------------
//
void CCmsContactNotifier::DoCancel()
    {
    #ifdef _DEBUG
        RCmsSession::WriteToLog( _L8( "CCmsContactNotifier::DoCancel()" ) );
    #endif
    TIpcArgs arguments( iType );
    iContact.SendMessage( ECmsCancelNotification, arguments );
    if ( CCmsContactFieldItem::ECmsPresenceAllNotification & Type() )
        {
        iContactField->Cancel();
        }
    }

// ----------------------------------------------------------
//
CCmsContactFieldItem::TCmsContactNotification CCmsContactNotifier::Type()
    {
    return iType;
    }