jobs: SetRoomStateJob (with or without state key); setting room topic

6 files changed, 118 insertions, 1 deletions

diff --git a/CMakeLists.txt b/CMakeLists.txt
index 9e3abce1..e55335ec 100644
--- a/CMakeLists.txt
+++ b/CMakeLists.txt
@@ -74,6 +74,7 @@ set(libqmatrixclient_SRCS
    jobs/checkauthmethods.cpp
    jobs/passwordlogin.cpp
    jobs/sendeventjob.cpp
+   jobs/setroomstatejob.cpp
    jobs/postreceiptjob.cpp
    jobs/joinroomjob.cpp
    jobs/leaveroomjob.cpp
diff --git a/events/roomtopicevent.h b/events/roomtopicevent.h
index fb849afe..95ad0e04 100644
--- a/events/roomtopicevent.h
+++ b/events/roomtopicevent.h
@@ -25,6 +25,9 @@ namespace QMatrixClient
     class RoomTopicEvent: public RoomEvent
     {
         public:
+            explicit RoomTopicEvent(const QString& topic)
+                : RoomEvent(Type::RoomTopic), _topic(topic)
+            { }
             explicit RoomTopicEvent(const QJsonObject& obj)
                 : RoomEvent(Type::RoomTopic, obj)
                 , _topic(contentJson()["topic"].toString())
@@ -32,6 +35,15 @@ namespace QMatrixClient
 
             QString topic() const { return _topic; }
 
+            QJsonObject toJson() const
+            {
+                QJsonObject obj;
+                obj.insert("topic", _topic);
+                return obj;
+            }
+
+            static constexpr const char* TypeId = "m.room.topic";
+
         private:
             QString _topic;
     };
diff --git a/jobs/setroomstatejob.cpp b/jobs/setroomstatejob.cpp
new file mode 100644
index 00000000..c2beb87b
--- /dev/null
+++ b/jobs/setroomstatejob.cpp
@@ -0,0 +1,32 @@
+/******************************************************************************
+ * Copyright (C) 2015 Felix Rohrbach <kde@fxrh.de>
+ *
+ * This library is free software; you can redistribute it and/or
+ * modify it under the terms of the GNU Lesser General Public
+ * License as published by the Free Software Foundation; either
+ * version 2.1 of the License, or (at your option) any later version.
+ *
+ * This library is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this library; if not, write to the Free Software
+ * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301  USA
+ */
+
+#include "setroomstatejob.h"
+
+using namespace QMatrixClient;
+
+BaseJob::Status SetRoomStateJob::parseJson(const QJsonDocument& data)
+{
+    _eventId = data.object().value("event_id").toString();
+    if (!_eventId.isEmpty())
+        return Success;
+
+    qCDebug(JOBS) << data;
+    return { UserDefinedError, "No event_id in the JSON response" };
+}
+
diff --git a/jobs/setroomstatejob.h b/jobs/setroomstatejob.h
new file mode 100644
index 00000000..1c72f31c
--- /dev/null
+++ b/jobs/setroomstatejob.h
@@ -0,0 +1,65 @@
+/******************************************************************************
+ * Copyright (C) 2015 Felix Rohrbach <kde@fxrh.de>
+ *
+ * This library is free software; you can redistribute it and/or
+ * modify it under the terms of the GNU Lesser General Public
+ * License as published by the Free Software Foundation; either
+ * version 2.1 of the License, or (at your option) any later version.
+ *
+ * This library is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this library; if not, write to the Free Software
+ * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301  USA
+ */
+
+#pragma once
+
+#include "basejob.h"
+
+#include "connectiondata.h"
+
+namespace QMatrixClient
+{
+    class SetRoomStateJob: public BaseJob
+    {
+        public:
+            /**
+             * Constructs a job that sets a state using an arbitrary room event
+             * with a state key.
+             */
+            template <typename EvT>
+            SetRoomStateJob(const ConnectionData* connection, const QString& roomId,
+                            const EvT* event, const QString& stateKey)
+                : BaseJob(connection, HttpVerb::Put, "SetRoomStateJob",
+                          QStringLiteral("_matrix/client/r0/rooms/%1/state/%2/%3")
+                              .arg(roomId, EvT::TypeId, stateKey),
+                          Query(),
+                          Data(event->toJson()))
+            { }
+            /**
+             * Constructs a job that sets a state using an arbitrary room event
+             * without a state key.
+             */
+            template <typename EvT>
+            SetRoomStateJob(const ConnectionData* connection, const QString& roomId,
+                            const EvT* event)
+                : BaseJob(connection, HttpVerb::Put, "SetRoomStateJob",
+                          QStringLiteral("_matrix/client/r0/rooms/%1/state/%2")
+                              .arg(roomId, EvT::TypeId),
+                          Query(),
+                          Data(event->toJson()))
+            { }
+
+            QString eventId() const { return _eventId; }
+
+        protected:
+            Status parseJson(const QJsonDocument& data) override;
+
+        private:
+            QString _eventId;
+    };
+}  // namespace QMatrixClient
diff --git a/room.cpp b/room.cpp
index ae8c7e63..2ba3766a 100644
--- a/room.cpp
+++ b/room.cpp
@@ -26,6 +26,7 @@
 #include <QtCore/QHash>
 #include <QtCore/QStringBuilder> // for efficient string concats (operator%)
 #include <QtCore/QElapsedTimer>
+#include <jobs/setroomstatejob.h>
 
 #include "connection.h"
 #include "state.h"
@@ -595,6 +596,12 @@ void Room::postMessage(RoomMessageEvent* event)
     connection()->callApi<SendEventJob>(id(), event);
 }
 
+void Room::setTopic(const QString& newTopic)
+{
+    RoomTopicEvent evt(newTopic);
+    connection()->callApi<SetRoomStateJob>(id(), &evt);
+}
+
 void Room::getPreviousContent(int limit)
 {
     d->getPreviousContent(limit);
@@ -1032,4 +1039,3 @@ bool MemberSorter::operator()(User *u1, User *u2) const
         n2.remove(0, 1);
     return n1.localeAwareCompare(n2) < 0;
 }
-
diff --git a/room.h b/room.h
index 5ea89418..393dced3 100644
--- a/room.h
+++ b/room.h
@@ -153,6 +153,7 @@ namespace QMatrixClient
             void postMessage(RoomMessageEvent* event);
             /** @deprecated */
             void postMessage(const QString& type, const QString& plainText);
+            void setTopic(const QString& newTopic);
 
             void getPreviousContent(int limit = 10);