1 /*

     2  * Copyright (c) 2009 - 2010 Nokia Corporation and/or its subsidiary(-ies).

     3  * All rights reserved.

     4  * This component and the accompanying materials are made available

     5  * under the terms of "Eclipse Public License v1.0"

     6  * which accompanies this distribution, and is available

     7  * at the URL "http://www.eclipse.org/legal/epl-v10.html".

     8  *

     9  * Initial Contributors:

    10  * Nokia Corporation - initial contribution.

    11  *

    12  * Contributors:

    13  *

    14  * Description: 

    15  *

    16  */

    17 

    18 #include "nmapiheaders.h"

    19 

    20 namespace EmailClientApi

    21 {

    22 const quint32 IntervalEmitingSignals = 10000;

    23 

    24 /*!

    25    Constructor

    26  */

    27 NmApiEventNotifierPrivate::NmApiEventNotifierPrivate(QObject *parent) :

    28     QObject(parent), mEmitSignals(NULL), mEngine(NULL), mIsRunning(false)

    29 {

    30     NM_FUNCTION;

    31     mEmitSignals = new QTimer(this);

    32     mEmitSignals->setInterval(IntervalEmitingSignals);

    33     connect(mEmitSignals, SIGNAL(timeout()), this, SIGNAL(

    34         timedOut()));

    35     mEngine = NmApiEngine::instance();

    36 }

    37 

    38 /*!

    39    Destructor

    40  */

    41 NmApiEventNotifierPrivate::~NmApiEventNotifierPrivate()

    42 {

    43     NM_FUNCTION;

    44     mEmitSignals->stop();

    45     NmApiEngine::releaseInstance(mEngine);

    46 }

    47 

    48 /*!

    49    Returns true if the 

    50  */

    51 bool NmApiEventNotifierPrivate::isRunning() const

    52 {

    53     return mIsRunning;

    54 }

    55 

    56 /*!

    57    Start monitoring email events

    58    

    59    \return Value tells about monitoring system running

    60  */

    61 bool NmApiEventNotifierPrivate::start()

    62 {

    63     NM_FUNCTION;

    64     

    65     bool result(false);

    66 

    67     if (mIsRunning) {

    68         result = true;

    69     }

    70     else {

    71         qRegisterMetaType<QList<quint64> > ("QList<quint64>");

    72         qRegisterMetaType<NmApiMessage> ("NmApiMessage");

    73 

    74         connect(mEngine, SIGNAL(emailStoreEvent(NmApiMessage)), this,

    75                 SLOT(emailStoreEvent(NmApiMessage)));

    76             

    77         mEngine->startCollectingEvents();

    78             

    79         mEmitSignals->start();

    80         mIsRunning = true;

    81         result = true;

    82     }

    83     return result;

    84 }

    85 /*!

    86    \brief Stop listening events.

    87  */

    88 void NmApiEventNotifierPrivate::stop()

    89 {

    90     mIsRunning = false;

    91     mEmitSignals->stop();

    92     disconnect(mEngine, SIGNAL(emailStoreEvent(NmApiMessage)), this,

    93             SLOT(emailStoreEvent(NmApiMessage)));

    94 }

    95 

    96 /*!

    97     Returns event buffer, after function call the buffer is empty

    98  */

    99 void NmApiEventNotifierPrivate::events(QList<NmApiMessage> &events)

   100 {

   101     while (!mBufferOfEvents.isEmpty()) {

   102         events << mBufferOfEvents.takeFirst();

   103     }

   104 }

   105 

   106 /*!

   107    Add one email event into buffer.

   108    

   109    It is run by \sa NmApiEngine::emailStoreEvent signal.

   110    \sa NmApiMessage

   111    \param events It contains full info about object and it event.

   112  */

   113 void NmApiEventNotifierPrivate::emailStoreEvent(const NmApiMessage &events)

   114 {

   115     NM_FUNCTION;

   116     mBufferOfEvents << events;

   117 }

   118 

   119 void NmApiEventNotifierPrivate::cancel()

   120 {

   121     NM_FUNCTION;

   122     

   123     if (!mIsRunning) {

   124         return;

   125     }

   126 

   127     mIsRunning = false;

   128     mEmitSignals->stop();

   129 

   130     disconnect(mEngine, SIGNAL(emailStoreEvent(NmApiMessage)), this,

   131             SLOT(emailStoreEvent(NmApiMessage)));

   132 

   133     mBufferOfEvents.clear();

   134 }

   135 

   136 }

   137