Differential D28560 Diff 79760 resources/google-groupware/taskhandler.cpp

Changeset View

Standalone View

View Options

resources/google-groupware/taskhandler.cpp

  • This file was added.
1​/*
2​ Copyright (C) 2011-2013 Daniel Vrátil <dvratil@redhat.com>
3​ 2020 Igor Poboiko <igor.poboiko@gmail.com>
4​
5​ This program is free software: you can redistribute it and/or modify
6​ it under the terms of the GNU General Public License as published by
7​ the Free Software Foundation, either version 3 of the License, or
8​ (at your option) any later version.
9​
10​ This program 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
13​ GNU General Public License for more details.
14​
15​ You should have received a copy of the GNU General Public License
16​ along with this program. If not, see <https://www.gnu.org/licenses/>.
17​*/
18​
19​#include "taskhandler.h"
20​#include "googleresource.h"
21​#include "googlesettings.h"
22​#include "googletasks_debug.h"
23​
24​#include <AkonadiCore/CollectionColorAttribute>
25​#include <AkonadiCore/CollectionModifyJob>
26​#include <AkonadiCore/EntityDisplayAttribute>
27​#include <AkonadiCore/ItemModifyJob>
28​#include <AkonadiCore/ItemFetchJob>
29​#include <AkonadiCore/ItemFetchScope>
30​#include <Akonadi/Calendar/BlockAlarmsAttribute>
31​
32​#include <KGAPI/Account>
33​#include <KGAPI/Tasks/TaskList>
34​#include <KGAPI/Tasks/TaskListCreateJob>
35​#include <KGAPI/Tasks/TaskListDeleteJob>
36​#include <KGAPI/Tasks/TaskListFetchJob>
37​#include <KGAPI/Tasks/TaskListModifyJob>
38​#include <KGAPI/Tasks/Task>
39​#include <KGAPI/Tasks/TaskCreateJob>
40​#include <KGAPI/Tasks/TaskDeleteJob>
41​#include <KGAPI/Tasks/TaskFetchJob>
42​#include <KGAPI/Tasks/TaskModifyJob>
43​#include <KGAPI/Tasks/TaskMoveJob>
44​
45​#include <KCalendarCore/Todo>
46​
47​#define TASK_PROPERTY "_KGAPI2::TaskPtr"
48​
49​using namespace KGAPI2;
50​using namespace Akonadi;
51​
52​QString TaskHandler::mimeType()
53​{
54​ return KCalendarCore::Todo::todoMimeType();
55​}
56​
57​bool TaskHandler::canPerformTask(const Item &item)
58​{
59​ return GenericHandler::canPerformTask<KCalendarCore::Todo::Ptr>(item);
60​}
61​
62​bool TaskHandler::canPerformTask(const Item::List &items)
63​{
64​ return GenericHandler::canPerformTask<KCalendarCore::Todo::Ptr>(items);
65​}
66​
67​void TaskHandler::setupCollection(Collection &collection, const TaskListPtr &taskList)
68​{
69​ collection.setContentMimeTypes({ mimeType() });
70​ collection.setName(taskList->uid());
71​ collection.setRemoteId(taskList->uid());
72​ collection.setRights(Collection::CanChangeCollection
73​ |Collection::CanCreateItem
74​ |Collection::CanChangeItem
75​ |Collection::CanDeleteItem);
76​
77​ EntityDisplayAttribute *attr = collection.attribute<EntityDisplayAttribute>(Collection::AddIfMissing);
78​ attr->setDisplayName(taskList->title());
79​ attr->setIconName(QStringLiteral("view-pim-tasks"));
80​}
81​
82​void TaskHandler::retrieveCollections(const Collection &rootCollection)
83​{
84​ m_iface->emitStatus(AgentBase::Running, i18nc("@info:status", "Retrieving task lists"));
85​ qCDebug(GOOGLE_TASKS_LOG) << "Retrieving tasks...";
86​ auto job = new TaskListFetchJob(m_settings->accountPtr(), this);
87​ connect(job, &TaskListFetchJob::finished, this, [this, rootCollection](KGAPI2::Job *job){
88​ if (!m_iface->handleError(job)) {
89​ return;
90​ }
91​ qCDebug(GOOGLE_TASKS_LOG) << "Task lists retrieved";
92​
93​ const ObjectsList taskLists = qobject_cast<TaskListFetchJob *>(job)->items();
94​ const QStringList activeTaskLists = m_settings->taskLists();
95​ Collection::List collections;
96​ for (const ObjectPtr &object : taskLists) {
97​ const TaskListPtr &taskList = object.dynamicCast<TaskList>();
98​ qCDebug(GOOGLE_TASKS_LOG) << " -" << taskList->title() << "(" << taskList->uid() << ")";
99​
100​ if (!activeTaskLists.contains(taskList->uid())) {
101​ qCDebug(GOOGLE_TASKS_LOG) << "Skipping, not subscribed";
102​ continue;
103​ }
104​
105​ Collection collection;
106​ setupCollection(collection, taskList);
107​ collection.setParentCollection(rootCollection);
108​ collections << collection;
109​ }
110​
111​ m_iface->collectionsRetrievedFromHandler(collections);
112​ });
113​}
114​
115​void TaskHandler::retrieveItems(const Collection &collection)
116​{
117​ m_iface->emitStatus(AgentBase::Running, i18nc("@info:status", "Retrieving tasks for list '%1'", collection.displayName()));
118​ qCDebug(GOOGLE_TASKS_LOG) << "Retrieving tasks for list" << collection.remoteId();
119​ // https://bugs.kde.org/show_bug.cgi?id=308122: we can only request changes in
120​ // max. last 25 days, otherwise we get an error.
121​ int lastSyncDelta = -1;
122​ if (!collection.remoteRevision().isEmpty()) {
123​ lastSyncDelta = QDateTime::currentDateTimeUtc().toSecsSinceEpoch() - collection.remoteRevision().toULongLong();
124​ }
125​
126​ auto job = new TaskFetchJob(collection.remoteId(), m_settings->accountPtr(), this);
127​ if (lastSyncDelta > -1 && lastSyncDelta < 25 * 25 * 3600) {
128​ job->setFetchOnlyUpdated(collection.remoteRevision().toULongLong());
129​ job->setFetchDeleted(true);
130​ } else {
131​ // No need to fetch deleted items for non-incremental update
132​ job->setFetchDeleted(false);
133​ }
134​ job->setProperty(COLLECTION_PROPERTY, QVariant::fromValue(collection));
135​ connect(job, &TaskFetchJob::finished, this, &TaskHandler::slotItemsRetrieved);
136​}
137​
138​void TaskHandler::slotItemsRetrieved(KGAPI2::Job *job)
139​{
140​ if (!m_iface->handleError(job)) {
141​ return;
142​ }
143​ Item::List changedItems, removedItems;
144​
145​ const ObjectsList &objects = qobject_cast<FetchJob *>(job)->items();
mlaurentUnsubmitted
Done

const Object &objects

mlaurent: const Object &objects
146​ Collection collection = job->property(COLLECTION_PROPERTY).value<Collection>();
147​ bool isIncremental = (qobject_cast<TaskFetchJob *>(job)->fetchOnlyUpdated() > 0);
148​ qCDebug(GOOGLE_TASKS_LOG) << "Retrieved" << objects.count() << "tasks for list" << collection.remoteId();
149​ for (const auto &object : objects) {
150​ const TaskPtr task = object.dynamicCast<Task>();
151​
152​ Item item;
153​ item.setMimeType( mimeType() );
154​ item.setParentCollection(collection);
155​ item.setRemoteId(task->uid());
156​ item.setRemoteRevision(task->etag());
157​ item.setPayload<KCalendarCore::Todo::Ptr>(task.dynamicCast<KCalendarCore::Todo>());
158​
159​ if (task->deleted()) {
160​ qCDebug(GOOGLE_TASKS_LOG) << " - removed" << task->uid();
161​ removedItems << item;
162​ } else {
163​ qCDebug(GOOGLE_TASKS_LOG) << " - changed" << task->uid();
164​ changedItems << item;
165​ }
166​ }
167​
168​ if (isIncremental) {
169​ m_iface->itemsRetrievedIncremental(changedItems, removedItems);
170​ } else {
171​ m_iface->itemsRetrieved(changedItems);
172​ }
173​ const QDateTime local(QDateTime::currentDateTime());
174​ const QDateTime UTC(local.toUTC());
175​
176​ collection.setRemoteRevision(QString::number(UTC.toSecsSinceEpoch()));
177​ new CollectionModifyJob(collection, this);
178​
179​ emitReadyStatus();
180​}
181​
182​void TaskHandler::itemAdded(const Item &item, const Collection &collection)
183​{
184​ m_iface->emitStatus(AgentBase::Running, i18nc("@info:status", "Adding event to calendar '%1'", collection.displayName()));
185​ KCalendarCore::Todo::Ptr todo = item.payload<KCalendarCore::Todo::Ptr>();
186​ TaskPtr task(new Task(*todo));
187​ const QString parentRemoteId = task->relatedTo(KCalendarCore::Incidence::RelTypeParent);
188​ qCDebug(GOOGLE_TASKS_LOG) << "Task added to list" << collection.remoteId() << "with parent" << parentRemoteId;
189​ auto job = new TaskCreateJob(task, item.parentCollection().remoteId(), m_settings->accountPtr(), this);
190​ job->setParentItem(parentRemoteId);
191​ connect(job, &TaskCreateJob::finished, this, [this, item](KGAPI2::Job *job){
192​ if (!m_iface->handleError(job)) {
193​ return;
194​ }
195​ Item newItem = item;
196​ const TaskPtr task = qobject_cast<TaskCreateJob *>(job)->items().first().dynamicCast<Task>();
197​ qCDebug(GOOGLE_TASKS_LOG) << "Task added";
198​ newItem.setRemoteId(task->uid());
199​ newItem.setRemoteRevision(task->etag());
200​ newItem.setGid(task->uid());
201​ m_iface->itemChangeCommitted(newItem);
202​ newItem.setPayload<KCalendarCore::Todo::Ptr>(task.dynamicCast<KCalendarCore::Todo>());
203​ new ItemModifyJob(newItem, this);
204​ emitReadyStatus();
205​ });
206​}
207​
208​void TaskHandler::itemChanged(const Item &item, const QSet< QByteArray > &/*partIdentifiers*/)
209​{
210​ m_iface->emitStatus(AgentBase::Running, i18nc("@info:status", "Changing task in list '%1'", item.parentCollection().displayName()));
211​ qCDebug(GOOGLE_TASKS_LOG) << "Changing task" << item.remoteId();
212​
213​ KCalendarCore::Todo::Ptr todo = item.payload<KCalendarCore::Todo::Ptr>();
214​ const QString parentUid = todo->relatedTo(KCalendarCore::Incidence::RelTypeParent);
215​ // First we move it to a new parent, if there is
216​ auto job = new TaskMoveJob(item.remoteId(), item.parentCollection().remoteId(), parentUid, m_settings->accountPtr(), this);
217​ connect(job, &TaskMoveJob::finished, this, [this, todo, item](KGAPI2::Job *job){
218​ if (!m_iface->handleError(job)) {
219​ return;
220​ }
221​ TaskPtr task(new Task(*todo));
222​ auto newJob = new TaskModifyJob(task, item.parentCollection().remoteId(), job->account(), this);
223​ newJob->setProperty(ITEM_PROPERTY, QVariant::fromValue(item));
224​ connect(newJob, &TaskModifyJob::finished, this, &TaskHandler::slotGenericJobFinished);
225​ });
226​}
227​
228​void TaskHandler::itemsRemoved(const Item::List &items)
229​{
230​ m_iface->emitStatus(AgentBase::Running, i18ncp("@info:status", "Removing %1 tasks", "Removing %1 task", items.count()));
231​ qCDebug(GOOGLE_TASKS_LOG) << "Removing" << items.count() << "tasks";
232​ /* Google always automatically removes tasks with all their subtasks. In KOrganizer
233​ * by default we only remove the item we are given. For this reason we have to first
234​ * fetch all tasks, find all sub-tasks for the task being removed and detach them
235​ * from the task. Only then the task can be safely removed. */
236​ auto job = new ItemFetchJob(items.first().parentCollection());
237​ job->fetchScope().fetchFullPayload(true);
238​ connect(job, &ItemFetchJob::finished, this, [this, items](KJob *job){
239​ if (job->error()) {
240​ m_iface->cancelTask(i18n("Failed to delete task: %1", job->errorString()));
241​ return;
242​ }
243​ const Item::List fetchedItems = qobject_cast<ItemFetchJob *>(job)->items();
244​ Item::List detachItems;
245​ TasksList detachTasks;
246​ for (const Item &fetchedItem : fetchedItems) {
247​ auto todo = fetchedItem.payload<KCalendarCore::Todo::Ptr>();
248​ TaskPtr task(new Task(*todo));
249​ const QString parentId = task->relatedTo(KCalendarCore::Incidence::RelTypeParent);
250​ if (parentId.isEmpty()) {
251​ continue;
252​ }
253​
254​ auto it = std::find_if(items.cbegin(), items.cend(), [&parentId](const Item &item){
255​ return item.remoteId() == parentId;
256​ });
257​ if (it != items.cend()) {
258​ Item newItem(fetchedItem);
259​ qCDebug(GOOGLE_TASKS_LOG) << "Detaching child" << newItem.remoteId() << "from" << parentId;
260​ todo->setRelatedTo(QString(), KCalendarCore::Incidence::RelTypeParent);
261​ newItem.setPayload<KCalendarCore::Todo::Ptr>(todo);
262​ detachItems << newItem;
263​ detachTasks << task;
264​ }
265​ }
266​ /* If there are no items do detach, then delete the task right now */
267​ if (detachItems.isEmpty()) {
268​ doRemoveTasks(items);
269​ return;
270​ }
271​
272​ qCDebug(GOOGLE_TASKS_LOG) << "Reparenting" << detachItems.count() << "children...";
273​ auto moveJob = new TaskMoveJob(detachTasks, items.first().parentCollection().remoteId(),
274​ QString(), m_settings->accountPtr(), this);
275​ connect(moveJob, &TaskMoveJob::finished, this, [this, items, detachItems](KGAPI2::Job *job){
276​ if (job->error()) {
277​ m_iface->cancelTask(i18n("Failed to reparent subtasks: %1", job->errorString()));
278​ return;
279​ }
280​ // Update items inside Akonadi DB too
281​ new ItemModifyJob(detachItems);
282​ // Perform actual removal
283​ doRemoveTasks(items);
284​ });
285​ });
286​}
287​
288​void TaskHandler::doRemoveTasks(const Item::List &items)
289​{
290​ // Make sure account is still valid
291​ if (!m_iface->canPerformTask()) {
292​ return;
293​ }
294​ QStringList taskIds;
295​ taskIds.reserve(items.count());
296​ std::transform(items.cbegin(), items.cend(), std::back_inserter(taskIds),
297​ [](const Item &item){
298​ return item.remoteId();
299​ });
300​
301​ /* Now finally we can safely remove the task we wanted to */
302​ auto job = new TaskDeleteJob(taskIds, items.first().parentCollection().remoteId(), m_settings->accountPtr(), this);
303​ job->setProperty(ITEMS_PROPERTY, QVariant::fromValue(items));
304​ connect(job, &TaskDeleteJob::finished, this, &TaskHandler::slotGenericJobFinished);
305​}
306​
307​void TaskHandler::itemsMoved(const Item::List &/*item*/, const Collection &/*collectionSource*/, const Collection &/*collectionDestination*/)
308​{
309​ m_iface->cancelTask(i18n("Moving tasks between task lists is not supported"));
310​}
311​
312​void TaskHandler::collectionAdded(const Collection &collection, const Collection &/*parent*/)
313​{
314​ m_iface->emitStatus(AgentBase::Running, i18nc("@info:status", "Creating new task list '%1'", collection.displayName()));
315​ qCDebug(GOOGLE_TASKS_LOG) << "Adding task list" << collection.displayName();
316​ TaskListPtr taskList(new TaskList());
317​ taskList->setTitle(collection.displayName());
318​
319​ auto job = new TaskListCreateJob(taskList, m_settings->accountPtr(), this);
320​ connect(job, &TaskListCreateJob::finished, this, [this, collection](KGAPI2::Job *job){
321​ if (!m_iface->handleError(job)) {
322​ return;
323​ }
324​
325​ TaskListPtr taskList = qobject_cast<TaskListCreateJob *>(job)->items().first().dynamicCast<TaskList>();
326​ qCDebug(GOOGLE_TASKS_LOG) << "Task list created:" << taskList->uid();
327​ // Enable newly added task list in settings
328​ m_settings->addTaskList(taskList->uid());
329​ // Populate remoteId & other stuff
330​ Collection newCollection(collection);
331​ setupCollection(newCollection, taskList);
332​ m_iface->collectionChangeCommitted(newCollection);
333​ emitReadyStatus();
334​ });
335​}
336​
337​void TaskHandler::collectionChanged(const Collection &collection)
338​{
339​ m_iface->emitStatus(AgentBase::Running, i18nc("@info:status", "Changing task list '%1'", collection.displayName()));
340​ qCDebug(GOOGLE_TASKS_LOG) << "Changing task list" << collection.remoteId();
341​
342​ TaskListPtr taskList(new TaskList());
343​ taskList->setUid(collection.remoteId());
344​ taskList->setTitle(collection.displayName());
345​ auto job = new TaskListModifyJob(taskList, m_settings->accountPtr(), this);
346​ job->setProperty(COLLECTION_PROPERTY, QVariant::fromValue(collection));
347​ connect(job, &TaskListModifyJob::finished, this, &TaskHandler::slotGenericJobFinished);
348​}
349​
350​void TaskHandler::collectionRemoved(const Collection &collection)
351​{
352​ m_iface->emitStatus(AgentBase::Running, i18nc("@info:status", "Removing task list '%1'", collection.displayName()));
353​ qCDebug(GOOGLE_TASKS_LOG) << "Removing task list" << collection.remoteId();
354​ auto job = new TaskListDeleteJob(collection.remoteId(), m_settings->accountPtr(), this);
355​ job->setProperty(COLLECTION_PROPERTY, QVariant::fromValue(collection));
356​ connect(job, &TaskListDeleteJob::finished, this, &TaskHandler::slotGenericJobFinished);
357​}