1/*
2 Copyright (c) 2012 Volker Krause <vkrause@kde.org>
3
4 This library is free software; you can redistribute it and/or modify it
5 under the terms of the GNU Library General Public License as published by
6 the Free Software Foundation; either version 2 of the License, or (at your
7 option) any later version.
8
9 This library is distributed in the hope that it will be useful, but WITHOUT
10 ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
11 FITNESS FOR A PARTICULAR PURPOSE. See the GNU Library General Public
12 License for more details.
13
14 You should have received a copy of the GNU Library General Public License
15 along with this library; see the file COPYING.LIB. If not, write to the
16 Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA
17 02110-1301, USA.
18*/
19
20#ifndef AKONADI_RECURSIVEMOVER_P_H
21#define AKONADI_RECURSIVEMOVER_P_H
22
23#include <akonadi/collection.h>
24#include <akonadi/item.h>
25#include "agentbase_p.h"
26
27#include <kcompositejob.h>
28
29namespace Akonadi {
30
31/**
32 * Helper class for expanding inter-resource collection moves inside ResourceBase.
33 *
34 * @note This is intentionally not an Akonadi::Job since we don't need autostarting
35 * here.
36 */
37class RecursiveMover : public KCompositeJob
38{
39 Q_OBJECT
40public:
41 explicit RecursiveMover(AgentBasePrivate *parent);
42
43 /// Set the collection that is actually moved.
44 void setCollection(const Akonadi::Collection &collection, const Akonadi::Collection &parentCollection);
45
46 virtual void start();
47
48 /// Call once the last replayed change has been processed.
49 void changeProcessed();
50
51public Q_SLOTS:
52 /// Trigger the next change replay, will call emitResult() once everything has been replayed
53 void replayNext();
54
55private:
56 void replayNextCollection();
57 void replayNextItem();
58
59private Q_SLOTS:
60 void collectionListResult(KJob *job);
61 void collectionFetchResult(KJob *job);
62 void itemListResult(KJob *job);
63 void itemFetchResult(KJob *job);
64
65private:
66 AgentBasePrivate *m_agentBase;
67 Collection m_movedCollection;
68 /// sorted queue of collections still to be processed
69 Collection::List m_pendingCollections;
70 /// holds up-to-date full collection objects, used for e.g. having proper parent collections for collectionAdded
71 QHash<Collection::Id, Collection> m_collections;
72 Item::List m_pendingItems;
73
74 Collection m_currentCollection;
75 Item m_currentItem;
76
77 enum CurrentAction {
78 None,
79 AddCollection,
80 AddItem
81 } m_currentAction;
82
83 int m_runningJobs;
84 bool m_pendingReplay;
85};
86
87}
88
89Q_DECLARE_METATYPE(Akonadi::RecursiveMover *)
90
91#endif // AKONADI_RECURSIVEMOVER_P_H
92