Differential D28560 Diff 79334 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​
23​#include <AkonadiCore/CollectionColorAttribute>
24​#include <AkonadiCore/CollectionModifyJob>
25​#include <AkonadiCore/EntityDisplayAttribute>
26​#include <AkonadiCore/ItemModifyJob>
27​#include <AkonadiCore/ItemFetchJob>
28​#include <AkonadiCore/ItemFetchScope>
29​#include <Akonadi/Calendar/BlockAlarmsAttribute>
30​
31​#include <KGAPI/Account>
32​#include <KGAPI/Tasks/TaskList>
33​#include <KGAPI/Tasks/TaskListCreateJob>
34​#include <KGAPI/Tasks/TaskListDeleteJob>
35​#include <KGAPI/Tasks/TaskListFetchJob>
36​#include <KGAPI/Tasks/TaskListModifyJob>
37​#include <KGAPI/Tasks/Task>
38​#include <KGAPI/Tasks/TaskCreateJob>
39​#include <KGAPI/Tasks/TaskDeleteJob>
40​#include <KGAPI/Tasks/TaskFetchJob>
41​#include <KGAPI/Tasks/TaskModifyJob>
42​#include <KGAPI/Tasks/TaskMoveJob>
43​
44​#include <KCalendarCore/Todo>
45​
46​#include "googletasks_debug.h"
47​
48​#define TASK_PROPERTY "_KGAPI2::TaskPtr"
49​
50​using namespace KGAPI2;
51​using namespace Akonadi;
52​
53​QString TaskHandler::mimetype()
54​{
55​ return KCalendarCore::Todo::todoMimeType();
56​}
57​
58​bool TaskHandler::canPerformTask(const Item &item)
59​{
60​ return m_resource->canPerformTask<KCalendarCore::Todo::Ptr>(item, mimetype());
61​}
62​
63​void TaskHandler::setupCollection(Collection &collection, const TaskListPtr &taskList)
64​{
65​ collection.setContentMimeTypes({ mimetype() });
66​ collection.setName(taskList->uid());
67​ collection.setParentCollection(m_resource->rootCollection());
68​ collection.setRemoteId(taskList->uid());
69​ collection.setRights(Collection::CanChangeCollection
70​ |Collection::CanCreateItem
71​ |Collection::CanChangeItem
72​ |Collection::CanDeleteItem);
73​
74​ EntityDisplayAttribute *attr = collection.attribute<EntityDisplayAttribute>(Collection::AddIfMissing);
75​ attr->setDisplayName(taskList->title());
76​ attr->setIconName(QStringLiteral("view-pim-tasks"));
77​}
78​
79​void TaskHandler::retrieveCollections()
80​{
81​ Q_EMIT m_resource->status(AgentBase::Running, i18nc("@info:status", "Retrieving task lists"));
82​ qCDebug(GOOGLE_TASKS_LOG) << "Retrieving tasks...";
83​ auto job = new TaskListFetchJob(m_settings->accountPtr(), this);
84​ connect(job, &TaskListFetchJob::finished, this, &TaskHandler::slotCollectionsRetrieved);
85​}
86​
87​void TaskHandler::slotCollectionsRetrieved(KGAPI2::Job *job)
88​{
89​ if (!m_resource->handleError(job)) {
90​ return;
91​ }
92​ qCDebug(GOOGLE_TASKS_LOG) << "Task lists retrieved";
93​
94​ const ObjectsList taskLists = qobject_cast<TaskListFetchJob *>(job)->items();
95​ const QStringList activeTaskLists = m_settings->taskLists();
96​ Collection::List collections;
97​ for (const ObjectPtr &object : taskLists) {
98​ const TaskListPtr &taskList = object.dynamicCast<TaskList>();
99​ qCDebug(GOOGLE_TASKS_LOG) << " -" << taskList->title() << "(" << taskList->uid() << ")";
100​
101​ if (!activeTaskLists.contains(taskList->uid())) {
102​ qCDebug(GOOGLE_TASKS_LOG) << "Skipping, not subscribed";
103​ continue;
104​ }
105​
106​ Collection collection;
107​ setupCollection(collection, taskList);
108​ collections << collection;
109​ }
110​
111​ m_resource->collectionsRetrievedFromHandler(collections);
112​}
113​
114​void TaskHandler::retrieveItems(const Collection &collection)
115​{
116​ Q_EMIT m_resource->status(AgentBase::Running, i18nc("@info:status", "Retrieving tasks for list '%1'", collection.displayName()));
117​ qCDebug(GOOGLE_TASKS_LOG) << "Retrieving tasks for list" << collection.remoteId();
118​ // https://bugs.kde.org/show_bug.cgi?id=308122: we can only request changes in
119​ // max. last 25 days, otherwise we get an error.
120​ int lastSyncDelta = -1;
121​ if (!collection.remoteRevision().isEmpty()) {
122​ lastSyncDelta = QDateTime::currentDateTimeUtc().toSecsSinceEpoch() - collection.remoteRevision().toULongLong();
123​ }
124​
125​ auto job = new TaskFetchJob(collection.remoteId(), m_settings->accountPtr(), this);
126​ if (lastSyncDelta > -1 && lastSyncDelta < 25 * 25 * 3600) {
127​ job->setFetchOnlyUpdated(collection.remoteRevision().toULongLong());
128​ job->setFetchDeleted(true);
129​ } else {
130​ // No need to fetch deleted items for non-incremental update
131​ job->setFetchDeleted(false);
132​ }
133​ job->setProperty(COLLECTION_PROPERTY, QVariant::fromValue(collection));
134​ connect(job, &TaskFetchJob::finished, this, &TaskHandler::slotItemsRetrieved);
135​}
136​
137​void TaskHandler::slotItemsRetrieved(KGAPI2::Job *job)
138​{
139​ if (!m_resource->handleError(job)) {
140​ return;
141​ }
142​ Item::List changedItems, removedItems;
143​
144​ const ObjectsList &objects = qobject_cast<FetchJob *>(job)->items();
145​ Collection collection = job->property(COLLECTION_PROPERTY).value<Collection>();
mlaurentUnsubmitted
Done

const Object &objects

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