1 /*

     2 * Copyright (c) 2009 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 #include "activityclient_p.h"

    18 #include "activityclient.h"

    19 #include "activitydatastorage.h"

    20 #include <hsactivitydbclient.h>

    21 

    22 #include <QStringList>

    23 #include <QTimer>

    24 

    25 ActivityClientPrivate::ActivityClientPrivate(ActivityClient *q) : QObject(q)

    26 {

    27     mDataStorage = new ActivityDataStorage();

    28     mServerClient = new HsActivityDbClient();

    29     mServerClient->connect();

    30     connect(mServerClient, SIGNAL(activityRequested(QString)), q, SIGNAL(activityRequested(QString)));

    31 }

    32 

    33 ActivityClientPrivate::~ActivityClientPrivate()

    34 {

    35     delete mServerClient;

    36     delete mDataStorage;

    37 }

    38 

    39 bool ActivityClientPrivate::addActivity(const QString &activityId, const QVariant &data, const QVariantHash &parameters)

    40 {

    41     QVariantHash activity(parameters);

    42     mDataStorage->addActivity(activityId, data);

    43     RProcess process;

    44     

    45     activity.insert(ActivityApplicationKeyword, static_cast<int>(process.SecureId().iId));

    46     activity.insert(ActivityActivityKeyword, activityId);

    47     mServerClient->addActivity(activity);

    48     

    49     // @todo make those operations atomic

    50     // @todo return real result

    51     return true;

    52 }

    53 

    54 bool ActivityClientPrivate::removeActivity(const QString &activityId)

    55 {

    56     QVariantHash activity;

    57     RProcess process;

    58     activity.insert(ActivityApplicationKeyword, static_cast<int>(process.SecureId().iId));

    59     activity.insert(ActivityActivityKeyword, activityId);

    60     mDataStorage->removeActivity(activityId); 

    61     mServerClient->removeActivity(activity); 

    62     // @todo make those operations atomic

    63     // @todo return real result

    64     return true;

    65 }

    66 

    67 bool ActivityClientPrivate::updateActivity(const QString &activityId, const QVariant &data, const QVariantHash &parameters)

    68 {

    69     QVariantHash activity(parameters);

    70     RProcess process;

    71     activity.insert(ActivityApplicationKeyword, static_cast<int>(process.SecureId().iId));

    72     activity.insert(ActivityActivityKeyword, activityId);

    73     mDataStorage->updateActivity(activityId, data);

    74     mServerClient->updateActivity(activity);

    75     // @todo make those operations atomic

    76     // @todo return real result

    77     return true;

    78 }

    79 

    80 QList<QVariantHash> ActivityClientPrivate::activities() const

    81 {

    82     QVariantHash activity;

    83     RProcess process;

    84     activity.insert(ActivityApplicationKeyword, static_cast<int>(process.SecureId().iId));

    85 

    86     QList<QVariantHash> activities;

    87 

    88     mServerClient->applicationActivities(activities, activity);

    89     return activities;

    90 }

    91 

    92 QVariant ActivityClientPrivate::activityData(const QString &activityId) const

    93 {

    94     return mDataStorage->activityData(activityId);

    95 }

    96 

    97 bool ActivityClientPrivate::waitActivity()

    98 {

    99     RProcess process;

   100     QVariantHash activity;

   101     activity.insert(ActivityApplicationKeyword, static_cast<int>(process.SecureId().iId));

   102     return !mServerClient->waitActivity(activity);

   103 }