Add replay of events

1 files changed, 71 insertions, 0 deletions

diff --git a/examples/caldavresource/caldavresource.cpp b/examples/caldavresource/caldavresource.cpp
index 6bf1a27..3fbd624 100644
--- a/examples/caldavresource/caldavresource.cpp
+++ b/examples/caldavresource/caldavresource.cpp
@@ -107,6 +107,77 @@ protected:
     {
         return syncStore().resolveRemoteId(ENTITY_TYPE_CALENDAR, resourceID(calendar));
     }
+
+    KAsync::Job<QByteArray> replay(const Event &event, Sink::Operation operation,
+        const QByteArray &oldRemoteId, const QList<QByteArray> &changedProperties) Q_DECL_OVERRIDE
+    {
+        SinkLog() << "Replaying event";
+
+        //auto incidence = KCalCore::ICalFormat().readIncidence(rawIcal);
+
+        KDAV2::DavItem item;
+
+        switch (operation) {
+            case Sink::Operation_Creation: {
+                SinkLog() << "Replaying creation";
+
+                auto rawIcal = event.getIcal();
+                if(rawIcal == "") {
+                    return KAsync::error<QByteArray>("No ICal in event for creation replay");
+                }
+
+                auto collectionId = syncStore().resolveLocalId(ENTITY_TYPE_CALENDAR, event.getCalendar());
+
+                item.setData(rawIcal);
+                item.setContentType("text/calendar");
+                item.setUrl(urlOf(collectionId, event.getUid()));
+
+                return createItem(item).then([item] { return resourceID(item); });
+            }
+            case Sink::Operation_Removal: {
+                // We only need the URL in the DAV item for removal
+                item.setUrl(urlOf(oldRemoteId));
+
+                return removeItem(item).then([oldRemoteId] { return oldRemoteId; });
+            }
+            case Sink::Operation_Modification:
+                SinkLog() << "Replaying modification";
+
+                auto rawIcal = event.getIcal();
+                if(rawIcal == "") {
+                    return KAsync::error<QByteArray>("No ICal in event for modification replay");
+                }
+
+                item.setData(rawIcal);
+                item.setContentType("text/calendar");
+                item.setUrl(urlOf(oldRemoteId));
+
+                // It would be nice to check that the URL of the item hasn't
+                // changed and move he item if it did, but since the URL is
+                // pretty much arbitrary, whoe does that anyway?
+                return modifyItem(item).then([oldRemoteId] { return oldRemoteId; });
+        }
+    }
+
+    KAsync::Job<QByteArray> replay(const Calendar &calendar, Sink::Operation operation,
+        const QByteArray &oldRemoteId, const QList<QByteArray> &changedProperties) Q_DECL_OVERRIDE
+    {
+
+        // TODO: add the URL to list of attributes, can't do nothing otherwise
+        switch (operation) {
+            case Sink::Operation_Creation:
+                SinkLog() << "Replaying calendar creation";
+                break;
+            case Sink::Operation_Removal:
+                SinkLog() << "Replaying calendar removal";
+                break;
+            case Sink::Operation_Modification:
+                SinkLog() << "Replaying calendar modification";
+                break;
+        }
+
+        return KAsync::null<QByteArray>();
+    }
 };
 
 CalDavResource::CalDavResource(const Sink::ResourceContext &context)