kio/kio/metainfojob.cpp

   1 // -*- c++ -*-
   2 // vim: ts=4 sw=4 et
   3 /*  This file is part of the KDE libraries
   4     Copyright (C) 2002 Rolf Magnus <ramagnus@kde.org>
   5
   6     This library is free software; you can redistribute it and/or
   7     modify it under the terms of the GNU Library General Public
   8     License as published by the Free Software Foundation version 2.0.
   9
  10     This library is distributed in the hope that it will be useful,
  11     but WITHOUT ANY WARRANTY; without even the implied warranty of
  12     MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  13     Library General Public License for more details.
  14
  15     You should have received a copy of the GNU Library General Public License
  16     along with this library; see the file COPYING.LIB.  If not, write to
  17     the Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor,
  18     Boston, MA 02110-1301, USA.
  19  */
  20
  21 #include "metainfojob.h"
  22
  23 #include <kfileitem.h>
  24 #include <kdebug.h>
  25 #include <kfilemetainfo.h>
  26 #include <kservicetypetrader.h>
  27
  28 #include <QtCore/QTimer>
  29
  30 #include "jobuidelegate.h"
  31 #include "job_p.h"
  32
  33 using namespace KIO;
  34
  35 class KIO::MetaInfoJobPrivate: public KIO::JobPrivate
  36 {
  37 public:
  38     KFileItemList          items;       // all the items we got
  39     int                    currentItem;
  40     bool                   succeeded;   // if the current item is ok
  41
  42     Q_DECLARE_PUBLIC(MetaInfoJob)
  43 };
  44
  45 MetaInfoJob::MetaInfoJob(const KFileItemList& items, KFileMetaInfo::WhatFlags,
  46      int, int, const QStringList&, const QStringList&)
  47     : KIO::Job(*new MetaInfoJobPrivate)
  48 {
  49     Q_D(MetaInfoJob);
  50     d->succeeded    = false;
  51     d->items        = items;
  52     d->currentItem  = 0;
  53
  54     if (d->items.isEmpty())
  55     {
  56         kDebug(7007) << "nothing to do for the MetaInfoJob\n";
  57         emitResult();
  58         return;
  59     }
  60
  61     kDebug(7007) << "starting MetaInfoJob\n";
  62
  63     // Return to event loop first, determineNextFile() might delete this;
  64     // (no idea what that means, it comes from previewjob)
  65     QTimer::singleShot(0, this, SLOT(start()));
  66 }
  67
  68 MetaInfoJob::~MetaInfoJob()
  69 {
  70 }
  71
  72 void MetaInfoJob::start()
  73 {
  74     getMetaInfo();
  75 }
  76
  77 void MetaInfoJob::removeItem(const KFileItem& item)
  78 {
  79     Q_D(MetaInfoJob);
  80     if (d->items.at( d->currentItem ) == item)
  81     {
  82         KJob* job = subjobs().first();
  83         job->kill();
  84         removeSubjob( job );
  85         determineNextFile();
  86     }
  87
  88     d->items.removeAll(item);
  89 }
  90
  91 void MetaInfoJob::determineNextFile()
  92 {
  93     Q_D(MetaInfoJob);
  94     if (d->currentItem >= d->items.count() - 1)
  95     {
  96         kDebug(7007) << "finished MetaInfoJob\n";
  97         emitResult();
  98         return;
  99     }
 100
 101     ++d->currentItem;
 102     d->succeeded = false;
 103
 104     // does the file item already have the needed info? Then shortcut
 105     KFileItem item = d->items.at( d->currentItem );
 106     if (item.metaInfo(false).isValid())
 107     {
 108 //        kDebug(7007) << "Is already valid *************************\n";
 109         emit gotMetaInfo(item);
 110         determineNextFile();
 111         return;
 112     }
 113
 114     getMetaInfo();
 115 }
 116
 117 void MetaInfoJob::slotResult( KJob *job )
 118 {
 119     removeSubjob(job);
 120     Q_ASSERT(!hasSubjobs()); // We should have only one job at a time ...
 121
 122     determineNextFile();
 123 }
 124
 125 void MetaInfoJob::getMetaInfo()
 126 {
 127     Q_D(MetaInfoJob);
 128     KFileItem item = d->items.at( d->currentItem );
 129     Q_ASSERT(!item.isNull());
 130
 131     KUrl URL;
 132     URL.setProtocol("metainfo");
 133     URL.setPath(item.url().path());
 134
 135     KIO::TransferJob* job = KIO::get(URL, NoReload, HideProgressInfo);
 136     addSubjob(job);
 137
 138     connect(job,  SIGNAL(data(KIO::Job *, const QByteArray &)),
 139             this, SLOT(slotMetaInfo(KIO::Job *, const QByteArray &)));
 140
 141     job->addMetaData("mimeType", item.mimetype());
 142 }
 143
 144
 145 void MetaInfoJob::slotMetaInfo(KIO::Job*, const QByteArray &data)
 146 {
 147     Q_D(MetaInfoJob);
 148     KFileMetaInfo info;
 149     QDataStream s(data);
 150
 151     s >> info;
 152
 153     KFileItem item = d->items.at( d->currentItem );
 154     item.setMetaInfo(info);
 155     emit gotMetaInfo(item);
 156     d->succeeded = true;
 157 }
 158
 159 KIO_EXPORT MetaInfoJob *KIO::fileMetaInfo( const KFileItemList& items)
 160 {
 161     return new MetaInfoJob(items);
 162 }
 163
 164 KIO_EXPORT MetaInfoJob *KIO::fileMetaInfo( const KUrl::List &items)
 165 {
 166     KFileItemList fileItems;
 167     foreach (const KUrl& url, items) {
 168         fileItems.append(KFileItem(KFileItem::Unknown, KFileItem::Unknown, url,
 169             true));
 170     }
 171     MetaInfoJob *job = new MetaInfoJob(fileItems);
 172     job->setUiDelegate(new JobUiDelegate());
 173     return job;
 174 }
 175
 176 #include "metainfojob.moc"