cgit.sxemacs.org Git - harmattan/cameraplus/blob - src/postcapturemodel.cpp

   1 /*!
   2  * This file is part of CameraPlus.
   3  *
   4  * Copyright (C) 2012-2013 Mohammed Sameer <msameer@foolab.org>
   5  *
   6  * This library is free software; you can redistribute it and/or
   7  * modify it under the terms of the GNU Lesser General Public
   8  * License as published by the Free Software Foundation; either
   9  * version 2.1 of the License, or (at your option) any later version.
  10  *
  11  * This library is distributed in the hope that it will be useful,
  12  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  13  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  14  * Lesser General Public License for more details.
  15  *
  16  * You should have received a copy of the GNU Lesser General Public
  17  * License along with this library; if not, write to the Free Software
  18  * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301  USA
  19  */
  20
  21 #include "postcapturemodel.h"
  22 #include <QSparqlConnection>
  23 #include <QSparqlQuery>
  24 #include <QSparqlResult>
  25 #include <QSparqlError>
  26 #if defined(QT4)
  27 #include <QDeclarativeInfo>
  28 #elif defined(QT5)
  29 #include <QQmlInfo>
  30 #endif
  31 #include <QDateTime>
  32 #include <QDBusConnection>
  33 #include <QStringList>
  34 #include <QDBusMetaType>
  35 #include <QDBusArgument>
  36
  37 #define DRIVER "QTRACKER_DIRECT"
  38 #define QUERY "SELECT rdf:type(?urn) AS ?type nie:url(?urn) AS ?url nie:contentCreated(?urn) AS ?created nie:title(?urn) AS ?title nfo:fileName(?urn) AS ?filename nie:mimeType(?urn) AS ?mimetype tracker:available(?urn) AS ?available nfo:fileLastModified(?urn) as ?lastmod tracker:id(?urn) AS ?trackerid (EXISTS { ?urn nao:hasTag nao:predefined-tag-favorite }) AS ?favorite WHERE { ?urn nfo:equipment ?:equipment . {?urn a nfo:Video} UNION {?urn a nfo:Image}} ORDER BY DESC(?created)"
  39
  40 #define UPDATE_QUERY "SELECT rdf:type(?urn) AS ?type nie:url(?urn) AS ?url nie:contentCreated(?urn) AS ?created nie:title(?urn) AS ?title nfo:fileName(?urn) AS ?filename nie:mimeType(?urn) AS ?mimetype tracker:available(?urn) AS ?available nfo:fileLastModified(?urn) as ?lastmod tracker:id(?urn) AS ?trackerid (EXISTS { ?urn nao:hasTag nao:predefined-tag-favorite }) AS ?favorite WHERE {?urn a nfo:Visual . FILTER (tracker:id(?urn) IN (%1)) }"
  41
  42 #define TRACKER_SERVICE "org.freedesktop.Tracker1"
  43 #define TRACKER_RESOURCE_PATH "/org/freedesktop/Tracker1/Resources"
  44 #define TRACKER_RESOURCE_INTERFACE "org.freedesktop.Tracker1.Resources"
  45 #define TRACKER_RESOURCE_SIGNAL "GraphUpdated"
  46 #define PHOTO_CLASS "http://www.tracker-project.org/temp/nmm#Photo"
  47 #define VIDEO_CLASS "http://www.tracker-project.org/temp/nmm#Video"
  48 #define TRACKER_RESOURCE_SIGNAL_SIGNATURE "sa(iiii)a(iiii)"
  49
  50 class Quad {
  51 public:
  52   int graph;
  53   int subject;
  54   int predicate;
  55   int object;
  56 };
  57
  58 Q_DECLARE_METATYPE(Quad);
  59 Q_DECLARE_METATYPE(QList<Quad>);
  60
  61 QDBusArgument& operator<<(QDBusArgument& argument, const Quad& t) {
  62   argument.beginStructure();
  63   argument << t.graph << t.subject << t.predicate << t.object;
  64   argument.endStructure();
  65   return argument;
  66 }
  67
  68 const QDBusArgument& operator>>(const QDBusArgument& argument, Quad& t) {
  69   argument.beginStructure();
  70   argument >> t.graph >> t.subject >> t.predicate >> t.object;
  71   argument.endStructure();
  72   return argument;
  73 }
  74
  75 PostCaptureModel::PostCaptureModel(QObject *parent) :
  76   QAbstractListModel(parent),
  77   m_connection(0),
  78   m_connected(false) {
  79
  80   qDBusRegisterMetaType<Quad>();
  81   qDBusRegisterMetaType<QList<Quad> >();
  82
  83   QHash<int, QByteArray> roles;
  84   roles.insert(Item, "item");
  85
  86   setRoleNames(roles);
  87 }
  88
  89 PostCaptureModel::~PostCaptureModel() {
  90   qDeleteAll(m_items);
  91   m_items.clear();
  92
  93   delete m_connection; m_connection = 0;
  94 }
  95
  96 void PostCaptureModel::reload() {
  97   delete m_connection; m_connection = 0;
  98
  99   if (!m_items.isEmpty()) {
 100     beginRemoveRows(QModelIndex(), 0, m_items.size() - 1);
 101     qDeleteAll(m_items);
 102     m_items.clear();
 103     endRemoveRows();
 104   }
 105
 106   m_connection = new QSparqlConnection(DRIVER, QSparqlConnectionOptions(), this);
 107   if (!m_connection->isValid()) {
 108     emit error(tr("Failed to create SPARQL connection"));
 109     return;
 110   }
 111
 112   QString equipment = QString("urn:equipment:%1:%2:").arg(m_manufacturer).arg(m_model);
 113
 114   QSparqlQuery q(QUERY, QSparqlQuery::SelectStatement);
 115   q.bindValue("equipment", equipment);
 116   exec(q);
 117
 118   if (!m_connected) {
 119     const char *slot = SLOT(graphUpdated(const QString&,
 120                                          const QList<Quad>&,
 121                                          const QList<Quad>&));
 122     m_connected = QDBusConnection::sessionBus().connect(TRACKER_SERVICE, TRACKER_RESOURCE_PATH,
 123                                                         TRACKER_RESOURCE_INTERFACE,
 124                                                         TRACKER_RESOURCE_SIGNAL,
 125                                                         TRACKER_RESOURCE_SIGNAL_SIGNATURE,
 126                                                         this, slot);
 127   }
 128
 129   if (!m_connected) {
 130     qmlInfo(this) << "Failed to connect to tracker " << TRACKER_RESOURCE_SIGNAL;
 131   }
 132 }
 133
 134 void PostCaptureModel::exec(QSparqlQuery& query) {
 135   if (!m_connection) {
 136     qWarning() << "No connection to query";
 137     return;
 138   }
 139
 140   QSparqlResult *result = m_connection->exec(query);
 141
 142   if (result->hasError()) {
 143     QSparqlError error = result->lastError();
 144     qmlInfo(this) << "Error executing SPARQL query" << error.message();
 145
 146     delete result;
 147
 148     emit PostCaptureModel::error(tr("Failed to query tracker"));
 149   }
 150
 151   if (result) {
 152     QObject::connect(result, SIGNAL(dataReady(int)), this, SLOT(dataReady(int)));
 153     QObject::connect(result, SIGNAL(finished()), result, SLOT(deleteLater()));
 154   }
 155 }
 156
 157 int PostCaptureModel::rowCount(const QModelIndex& parent) const {
 158   if (parent.isValid()) {
 159     return 0;
 160   }
 161
 162   return m_items.size();
 163 }
 164
 165 QVariant PostCaptureModel::data(const QModelIndex& index, int role) const {
 166   if (!index.isValid() || index.row() < 0 || index.row() >= m_items.size()) {
 167     return QVariant();
 168   }
 169
 170   if (role == Item) {
 171     return QVariant::fromValue(dynamic_cast<QObject *>(m_items[index.row()]));
 172   }
 173
 174   return QVariant();
 175 }
 176
 177 QString PostCaptureModel::manufacturer() const {
 178   return m_manufacturer;
 179 }
 180
 181 void PostCaptureModel::setManufacturer(const QString& manufacturer) {
 182   if (m_manufacturer != manufacturer) {
 183     m_manufacturer = manufacturer;
 184     emit manufacturerChanged();
 185   }
 186 }
 187
 188 QString PostCaptureModel::model() const {
 189   return m_model;
 190 }
 191
 192 void PostCaptureModel::setModel(const QString& model) {
 193   if (m_model != model) {
 194     m_model = model;
 195     emit modelChanged();
 196   }
 197 }
 198
 199 void PostCaptureModel::dataReady(int totalCount) {
 200   Q_UNUSED(totalCount);
 201
 202   QSparqlResult *result = dynamic_cast<QSparqlResult *>(sender());
 203   if (!result) {
 204     return;
 205   }
 206
 207   while (result->next()) {
 208     addRow(new PostCaptureModelItem(result->current(), this));
 209   }
 210
 211   result->previous();
 212 }
 213
 214 void PostCaptureModel::addRow(PostCaptureModelItem *item) {
 215   if (m_hash.contains(item->trackerId())) {
 216     m_hash[item->trackerId()]->update(item);
 217     delete item;
 218     return;
 219   }
 220
 221   beginInsertRows(QModelIndex(), m_items.size(), m_items.size());
 222   m_items << item;
 223   m_hash.insert(item->trackerId(), item);
 224
 225   endInsertRows();
 226 }
 227
 228 void PostCaptureModel::remove(QObject *item) {
 229   PostCaptureModelItem *i = dynamic_cast<PostCaptureModelItem *>(item);
 230   if (!i) {
 231     qmlInfo(this) << "Invalid item to remove";
 232     return;
 233   }
 234
 235   int index = m_items.indexOf(i);
 236   if (index == -1) {
 237     qmlInfo(this) << "Item" << i->trackerId() << "not found in model";
 238     return;
 239   }
 240
 241   beginRemoveRows(QModelIndex(), index, index);
 242   m_items.takeAt(index);
 243   m_hash.remove(i->trackerId());
 244   endRemoveRows();
 245
 246   i->deleteLater();
 247 }
 248
 249 void PostCaptureModel::graphUpdated(const QString& className, const QList<Quad>& deleted,
 250                                     const QList<Quad>& inserted) {
 251
 252   // We will just assume tracker:available has changed and that's it.
 253   // We are not really interested in the rest of properties.
 254
 255   if (!(className == QLatin1String(PHOTO_CLASS) || className == QLatin1String(VIDEO_CLASS))) {
 256     return;
 257   }
 258
 259   QList<int> items;
 260
 261   for (int x = 0; x < deleted.size(); x++) {
 262     Quad q = deleted[x];
 263     if (m_hash.contains(q.subject) && items.indexOf(q.subject) == -1) {
 264       items << q.subject;
 265     }
 266   }
 267
 268   for (int x = 0; x < inserted.size(); x++) {
 269     Quad q = inserted[x];
 270     if (m_hash.contains(q.subject) && items.indexOf(q.subject) == -1) {
 271       items << q.subject;
 272     }
 273   }
 274
 275   for (int x = 0; x < items.size(); x++) {
 276     QString query = QString(UPDATE_QUERY).arg(items[x]);
 277     QSparqlQuery q(query, QSparqlQuery::SelectStatement);
 278
 279     exec(q);
 280   }
 281 }
 282
 283 #if defined(QT5)
 284 QHash<int, QByteArray> PostCaptureModel::roleNames() const {
 285   return m_roles;
 286 }
 287
 288 void PostCaptureModel::setRoleNames(const QHash<int, QByteArray>& roles) {
 289   m_roles = roles;
 290 }
 291 #endif
 292
 293 PostCaptureModelItem::PostCaptureModelItem(const QSparqlResultRow& row, QObject *parent) :
 294   QObject(parent) {
 295
 296   for (int x = 0; x < row.count(); x++) {
 297     QSparqlBinding b = row.binding(x);
 298     m_data.insert(b.name(), b.value());
 299   }
 300 }
 301
 302 QString PostCaptureModelItem::type() const {
 303   return value("type").toString();
 304 }
 305
 306 QUrl PostCaptureModelItem::url() const {
 307   return value("url").toUrl();
 308 }
 309
 310 QString PostCaptureModelItem::created() const {
 311   return formatDateTime(value("created").toDateTime());
 312 }
 313
 314 QString PostCaptureModelItem::title() const {
 315   return value("title").toString();
 316 }
 317
 318 QString PostCaptureModelItem::fileName() const {
 319   return value("filename").toString();
 320 }
 321
 322 QString PostCaptureModelItem::mimeType() const {
 323   return value("mimetype").toString();
 324 }
 325
 326 bool PostCaptureModelItem::available() const {
 327   return value("available", false).toBool();
 328 }
 329
 330 QString PostCaptureModelItem::lastModified() const {
 331   return formatDateTime(value("lastmod").toDateTime());
 332 }
 333
 334 unsigned PostCaptureModelItem::trackerId() const {
 335   return value("trackerid").toUInt();
 336 }
 337
 338 bool PostCaptureModelItem::favorite() const {
 339   return value("favorite", false).toBool();
 340 }
 341
 342 void PostCaptureModelItem::setFavorite(bool add) {
 343   if (favorite() != add) {
 344     m_data["favorite"] = add;
 345
 346     emit favoriteChanged();
 347   }
 348 }
 349
 350 QString PostCaptureModelItem::formatDateTime(const QDateTime& dt) const {
 351   return dt.toString();
 352 }
 353
 354 void PostCaptureModelItem::update(PostCaptureModelItem *other) {
 355   // We will only update available, favorite and title:
 356 #if 0
 357   qDebug() << "i" << trackerId() << other->trackerId()  << "\n"
 358            << "a" << available() << other->available() << "\n"
 359            << "t" << title() << other->title() << "\n"
 360            << "f" << favorite() << other->favorite();
 361 #endif
 362
 363   if (available() != other->available()) {
 364     m_data["available"] = other->available();
 365     emit availableChanged();
 366   }
 367
 368   if (title() != other->title()) {
 369     m_data["title"] = other->title();
 370     emit titleChanged();
 371   }
 372
 373   if (favorite() != other->favorite()) {
 374     m_data["favorite"] = other->favorite();
 375     emit favoriteChanged();
 376   }
 377 }
 378
 379 QVariant PostCaptureModelItem::value(const QString& id, const QVariant& def) const {
 380   return m_data.contains(id) ? m_data[id] : def;
 381 }