kget/dbus/dbusmodelobserver.cpp

   1 /* This file is part of the KDE project
   2
   3    Copyright (C) 2007 by Javier Goday <jgoday@gmail.com>
   4
   5    This program is free software; you can redistribute it and/or
   6    modify it under the terms of the GNU General Public
   7    License as published by the Free Software Foundation; either
   8    version 2 of the License, or (at your option) any later version.
   9 */
  10
  11
  12 #include "dbusmodelobserver.h"
  13 #include "core/kget.h"
  14 #include "core/transfergrouphandler.h"
  15 #include "core/transferhandler.h"
  16 #include "core/job.h"
  17
  18 #include <QObject>
  19
  20 DBusModelObserver::DBusModelObserver(QObject *parent)
  21     : m_transfers(),
  22     m_transferGroupObserver(this),
  23     m_transferGroupHandlers()
  24 {
  25     Q_UNUSED(parent)
  26
  27     // Add the observer to kget to see all operations through the transferGroups
  28     KGet::addObserver(this);
  29
  30     QObject::connect(&m_transferGroupObserver, SIGNAL(transferAdded(TransferHandler *)),
  31                      this, SLOT(addTransferHandler(TransferHandler *)));
  32     QObject::connect(&m_transferGroupObserver, SIGNAL(transferDeleted(TransferHandler *)) ,
  33                     this, SLOT(deleteTransferHandler(TransferHandler *)));
  34     QObject::connect(&m_transferGroupObserver, SIGNAL(transferGroupChanged(TransferGroupHandler *)),
  35                     this, SLOT(slotTransferGroupChanged(TransferGroupHandler *)));
  36 }
  37
  38 void DBusModelObserver::addedTransferGroupEvent(TransferGroupHandler *group)
  39 {
  40     group->addObserver(&m_transferGroupObserver);
  41
  42     m_transferGroupHandlers.append(group);
  43 }
  44
  45 void DBusModelObserver::removedTransferGroupEvent(TransferGroupHandler *group)
  46 {
  47     group->delObserver(&m_transferGroupObserver);
  48
  49     m_transferGroupHandlers.removeAll(group);
  50 }
  51
  52 QVariantMap DBusModelObserver::transfers() const
  53 {
  54     return m_transfers;
  55 }
  56
  57 int DBusModelObserver::transfersSpeed() const
  58 {
  59     return m_speed;
  60 }
  61
  62 void DBusModelObserver::addTransferHandler(TransferHandler *handler)
  63 {
  64     m_transfers[handler->source().pathOrUrl()] = getAttributesFromTransfer(handler);
  65 }
  66
  67 void DBusModelObserver::deleteTransferHandler(TransferHandler *handler)
  68 {
  69     m_transfers.remove(handler->source().pathOrUrl());
  70 }
  71
  72 void DBusModelObserver::slotTransferGroupChanged(TransferGroupHandler *handler)
  73 {
  74     // TODO: update the this transfers in the  transfers map
  75     foreach(TransferHandler *t_handler, handler->transfers()) {
  76         m_transfers[t_handler->source().pathOrUrl()] = getAttributesFromTransfer(t_handler);
  77     }
  78
  79     m_speed = handler->speed();
  80 //    emit transfersChanged(m_transfers);
  81 }
  82
  83 QStringList DBusModelObserver::getAttributesFromTransfer(TransferHandler *handler)
  84 {
  85     QStringList attributes;
  86     QString status = (handler->status () == Job::Running) ? "1" : "0";
  87
  88     attributes << handler->source().fileName();
  89     attributes << QString::number(handler->percent());
  90     attributes << QString::number(handler->totalSize());
  91     attributes << status;
  92     attributes << QString::number(handler->downloadSpeed());
  93
  94     return attributes;
  95 }