/*

 * Copyright (c) 2010 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: Subscribe source implementation for getting contact status  

 *              notification from publisher.

 *

 */

#include "contactsubscriber.h"

#include "mylocationlogger.h"

#include <locationservicedefines.h>

const TUid KContactPropertyCat={0x20022EF9};

enum TMyPropertyKeys {EMyPropertyInteger=0x1, EMyPropertyType=0x2};

const TInt KBufferSize=16;

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

// CContactSubscriber::NewL()

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

//

CContactSubscriber* CContactSubscriber::NewL(MNotifyChange* aNotifyChange)

{

    CContactSubscriber* self = CContactSubscriber::NewLC(aNotifyChange);

    CleanupStack::Pop(self);

    return self;

}

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

// CContactSubscriber::NewLC()

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

//

CContactSubscriber* CContactSubscriber::NewLC(

        MNotifyChange* aNotifyChange)

{

    CContactSubscriber* self = new (ELeave) CContactSubscriber(

            aNotifyChange);

    CleanupStack::PushL(self);

    self->ConstructL();

    return self;

}

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

// CContactSubscriber::ConstructL()

// Symbian 2nd phase constructor can leave.

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

//

void CContactSubscriber::ConstructL()

{

    __TRACE_CALLSTACK;

    CActiveScheduler::Add(this);

    TInt ret = iProperty.Attach(KContactPropertyCat, EMyPropertyInteger);

    if (KErrNone == ret)

    {

        SubscribeChangeNotiFication();

    }

}

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

// CContactSubscriber::SubscribeChangeNotiFication()

// start subscribe for contact entry

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

//

void CContactSubscriber::SubscribeChangeNotiFication()

{

    __TRACE_CALLSTACK;

    if (IsActive())

      {

          Cancel();

      }

    // resubscribe before processing new value to prevent missing updates

    iProperty.Subscribe(iStatus);   

    SetActive();

}

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

// CContactSubscriber::CContactSubscriber()

// Default constructor .

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

//

CContactSubscriber::CContactSubscriber(MNotifyChange* aNotifyChange) :

    CActive(EPriorityStandard),

    iNotifyChange(*aNotifyChange)

{

}

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

// CContactSubscriber::~CContactSubscriber()

// default destuctor.

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

//

CContactSubscriber::~CContactSubscriber()

{

    __TRACE_CALLSTACK;

    Cancel();

    iProperty.Close();

}

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

// CContactSubscriber::RunL()

// Assyncronous request handler , on completion of notification

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

//

void CContactSubscriber::RunL()

{

    __TRACE_CALLSTACK;

    SubscribeChangeNotiFication();

    // property updated, get new value 

    TBuf8 <KBufferSize> value; 

    TPtrC8  id; 

    TPtrC8  sourceType; 

    TPtrC8  addressCount; 

    if ( KErrNone == iProperty.Get( value ) )

    { 

        TInt pos =  value.Locate(TChar('-')); 

        id.Set( value.Left(pos) ); 

        TPtrC8 ptr = value.Right(3); 

        sourceType.Set(ptr.Left(1)); 

        addressCount.Set(ptr.Right(1)); 

        TInt appId = -1, addressType = -1, addressTypeCount = -1; 

        TLex8 lex(id); 

        lex.Val(appId); 

        TLex8 lex1(sourceType); 

        lex1.Val( addressType ); 

        TLex8 lex2(addressCount); 

        lex2.Val(addressTypeCount); 

        iNotifyChange.GetChangeNotificationL( appId, addressType,addressTypeCount ); 

    } 

}

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

// CContactSubscriber::DoCancel()

// Handels the error condition on assynchronous request

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

//

void CContactSubscriber::DoCancel()

{

    iProperty.Cancel();

}

//End of file