1 /****************************************************************************

     2 **

     3 ** Copyright (C) 2010 Nokia Corporation and/or its subsidiary(-ies).

     4 ** All rights reserved.

     5 ** Contact: Nokia Corporation (qt-info@nokia.com)

     6 **

     7 ** This file is part of the Qt Mobility Components.

     8 **

     9 ** $QT_BEGIN_LICENSE:LGPL$

    10 ** No Commercial Usage

    11 ** This file contains pre-release code and may not be distributed.

    12 ** You may use this file in accordance with the terms and conditions

    13 ** contained in the Technology Preview License Agreement accompanying

    14 ** this package.

    15 **

    16 ** GNU Lesser General Public License Usage

    17 ** Alternatively, this file may be used under the terms of the GNU Lesser

    18 ** General Public License version 2.1 as published by the Free Software

    19 ** Foundation and appearing in the file LICENSE.LGPL included in the

    20 ** packaging of this file.  Please review the following information to

    21 ** ensure the GNU Lesser General Public License version 2.1 requirements

    22 ** will be met: http://www.gnu.org/licenses/old-licenses/lgpl-2.1.html.

    23 **

    24 ** In addition, as a special exception, Nokia gives you certain additional

    25 ** rights.  These rights are described in the Nokia Qt LGPL Exception

    26 ** version 1.1, included in the file LGPL_EXCEPTION.txt in this package.

    27 **

    28 ** If you have questions regarding the use of this file, please contact

    29 ** Nokia at qt-info@nokia.com.

    30 **

    31 **

    32 **

    33 **

    34 **

    35 **

    36 **

    37 **

    38 ** $QT_END_LICENSE$

    39 **

    40 ****************************************************************************/

    41 

    42 

    43 #include <QtTracker/ontologies/nco.h>

    44 

    45 #include "trackerchangelistener.h"

    46 #include "qcontact.h"

    47 

    48 using namespace SopranoLive;

    49 

    50 TrackerChangeListener::TrackerChangeListener(QContactManagerEngine *eng, QObject* parent) :

    51     QObject(parent), engine(eng)

    52 {

    53     signaler_contact = SopranoLive::BackEnds::Tracker::ClassUpdateSignaler::get(nco::Contact::iri());

    54     if (signaler_contact)

    55     {

    56         SopranoLive::BackEnds::Tracker::ClassUpdateSignaler * signaler = signaler_contact;

    57         connect(signaler, SIGNAL(subjectsAdded(const QStringList &)), SLOT(contactsAdded(const QStringList &)));

    58         connect(signaler,SIGNAL(subjectsRemoved(const QStringList &)),SLOT(contactsRemoved(const QStringList &)));

    59         connect(signaler,SIGNAL(subjectsChanged(const QStringList &)),SLOT(contactsChanged(const QStringList &)));

    60     }

    61 

    62     signaler_imaccount = SopranoLive::BackEnds::Tracker::ClassUpdateSignaler::get(nco::IMAccount::iri());

    63     if (signaler_imaccount)

    64     {

    65         // same for all signals - emit selfContact changed

    66         SopranoLive::BackEnds::Tracker::ClassUpdateSignaler * signaler = signaler_imaccount;

    67         connect(signaler, SIGNAL(subjectsAdded(const QStringList &)),SLOT(imAccountsChanged(const QStringList &)));

    68         connect(signaler,SIGNAL(subjectsRemoved(const QStringList &)),SLOT(imAccountsChanged(const QStringList &)));

    69         connect(signaler,SIGNAL(subjectsChanged(const QStringList &)),SLOT(imAccountsChanged(const QStringList &)));

    70     }

    71 

    72     signaler_imaddress = SopranoLive::BackEnds::Tracker::ClassUpdateSignaler::get(nco::IMAddress::iri());

    73     if (signaler_imaddress)

    74     {

    75         // same for all signals - contact changed to be emitted

    76         SopranoLive::BackEnds::Tracker::ClassUpdateSignaler * signaler = signaler_imaddress;

    77         connect(signaler, SIGNAL(subjectsAdded(const QStringList &)),SLOT(imAddressesChanged(const QStringList &)));

    78         connect(signaler,SIGNAL(subjectsRemoved(const QStringList &)),SLOT(imAddressesChanged(const QStringList &)));

    79         connect(signaler,SIGNAL(subjectsChanged(const QStringList &)),SLOT(imAddressesChanged(const QStringList &)));

    80     }

    81 

    82 }

    83 

    84 TrackerChangeListener::~TrackerChangeListener()

    85 {

    86     if (signaler_imaddress)

    87         signaler_imaddress->disconnect(this);

    88     if (signaler_contact)

    89         signaler_contact->disconnect(this);

    90     if (signaler_imaccount)

    91         signaler_imaccount->disconnect(this);

    92 }

    93 

    94 QContactLocalId url2UniqueId(const QString &contactUrl)

    95 {

    96     /* handle conatact:interger URL types comming from

    97        which are non telepathy url's

    98     */

    99     QRegExp rx("(\\d+)");

   100     bool conversion = false;

   101     QContactLocalId id = 0;

   102     if( rx.indexIn(contactUrl) != -1 )

   103     {

   104         id = rx.cap(1).toUInt(&conversion, 10);

   105     }

   106     if( !conversion )

   107         qWarning() << Q_FUNC_INFO << "unparsed uri to uniqueI:" << contactUrl;

   108     return id;

   109 }

   110 

   111 void TrackerChangeListener::contactsAdded(const QStringList &subjects)

   112 {

   113     QList<QContactLocalId> added;

   114     foreach(const QString &uri, subjects)

   115     {

   116         added << url2UniqueId(uri);

   117     }

   118     emit contactsAdded(added);

   119 }

   120 

   121 void TrackerChangeListener::contactsRemoved(const QStringList &subjects)

   122 {

   123     QList<QContactLocalId> added;

   124     foreach(const QString &uri, subjects)

   125     {

   126         added << url2UniqueId(uri);

   127     }

   128     emit contactsRemoved(added);

   129 }

   130 

   131 

   132 void TrackerChangeListener::contactsChanged(const QStringList &subjects)

   133 {

   134     QList<QContactLocalId> changed;

   135     foreach(const QString &uri, subjects) {

   136         QContactLocalId id = url2UniqueId(uri);

   137         if (changed.contains(id) == false) {

   138             changed << id;

   139         }

   140     }

   141     emit contactsChanged(changed);

   142 }

   143 

   144 void TrackerChangeListener::imAccountsChanged(const QStringList &subjects)

   145 {

   146     Q_UNUSED(subjects)

   147     QContactManager::Error error;

   148     QContactLocalId selfId = engine->selfContactId(&error);

   149     if (engine && QContactManager::NoError == error) {

   150         emit contactsChanged(QList<QContactLocalId>()<<selfId);

   151     } else {

   152         qWarning() << __PRETTY_FUNCTION__ << "Signal not propagated:" << engine << error;

   153     }

   154 }

   155 

   156 void TrackerChangeListener::imAddressesChanged(const QStringList &subjects)

   157 {

   158     Q_UNUSED(subjects)

   159     // TODO use QHash in engine - mapping IMAddress URIs to contacts

   160     qWarning() << __PRETTY_FUNCTION__ << "Not implemented";

   161 }