diff options
author | Nicolas Werner <nicolas.werner@hotmail.de> | 2020-01-13 12:37:02 +0100 |
---|---|---|
committer | Nicolas Werner <nicolas.werner@hotmail.de> | 2020-01-13 12:37:02 +0100 |
commit | 62f17dffbd30a3d2e69d5110359055eed0cdca5a (patch) | |
tree | 5c226113911e0af0a0acb3f95da0cd305c102777 /src | |
parent | Allow replying with an image (diff) | |
download | nheko-62f17dffbd30a3d2e69d5110359055eed0cdca5a.tar.xz |
Fix replies in encrypted rooms
The relation needs to be unencrypted...
Diffstat (limited to 'src')
-rw-r--r-- | src/Olm.cpp | 18 | ||||
-rw-r--r-- | src/Olm.h | 2 | ||||
-rw-r--r-- | src/timeline/TimelineModel.cpp | 12 |
3 files changed, 22 insertions, 10 deletions
diff --git a/src/Olm.cpp b/src/Olm.cpp index 5859fe8e..4fa473d3 100644 --- a/src/Olm.cpp +++ b/src/Olm.cpp @@ -159,15 +159,22 @@ handle_pre_key_olm_message(const std::string &sender, } mtx::events::msg::Encrypted -encrypt_group_message(const std::string &room_id, - const std::string &device_id, - const std::string &body) +encrypt_group_message(const std::string &room_id, const std::string &device_id, nlohmann::json body) { using namespace mtx::events; - // Always chech before for existence. + nhlog::crypto()->info("message body {}", body.dump()); + + // relations shouldn't be encrypted... + mtx::common::RelatesTo relation; + if (body["content"].count("m.relates_to") != 0) { + relation = body["content"]["m.relates_to"]; + body["content"].erase("m.relates_to"); + } + + // Always check before for existence. auto res = cache::getOutboundMegolmSession(room_id); - auto payload = olm::client()->encrypt_group_message(res.session, body); + auto payload = olm::client()->encrypt_group_message(res.session, body.dump()); // Prepare the m.room.encrypted event. msg::Encrypted data; @@ -176,6 +183,7 @@ encrypt_group_message(const std::string &room_id, data.session_id = res.data.session_id; data.device_id = device_id; data.algorithm = MEGOLM_ALGO; + data.relates_to = relation; auto message_index = olm_outbound_group_session_message_index(res.session); nhlog::crypto()->info("next message_index {}", message_index); diff --git a/src/Olm.h b/src/Olm.h index ae4e0659..501a1621 100644 --- a/src/Olm.h +++ b/src/Olm.h @@ -62,7 +62,7 @@ handle_pre_key_olm_message(const std::string &sender, mtx::events::msg::Encrypted encrypt_group_message(const std::string &room_id, const std::string &device_id, - const std::string &body); + nlohmann::json body); void mark_keys_as_published(); diff --git a/src/timeline/TimelineModel.cpp b/src/timeline/TimelineModel.cpp index a1367bf3..3064ab4a 100644 --- a/src/timeline/TimelineModel.cpp +++ b/src/timeline/TimelineModel.cpp @@ -734,6 +734,10 @@ TimelineModel::decryptEvent(const mtx::events::EncryptedEvent<mtx::events::msg:: body["origin_server_ts"] = e.origin_server_ts; body["unsigned"] = e.unsigned_data; + // relations are unencrypted in content... + if (json old_ev = e; old_ev["content"].count("m.relates_to") != 0) + body["content"]["m.relates_to"] = old_ev["content"]["m.relates_to"]; + json event_array = json::array(); event_array.push_back(body); @@ -843,13 +847,13 @@ TimelineModel::sendEncryptedMessage(const std::string &txn_id, nlohmann::json co using namespace mtx::events; using namespace mtx::identifiers; - json doc{{"type", "m.room.message"}, {"content", content}, {"room_id", room_id}}; + json doc = {{"type", "m.room.message"}, {"content", content}, {"room_id", room_id}}; try { // Check if we have already an outbound megolm session then we can use. if (cache::outboundMegolmSessionExists(room_id)) { - auto data = olm::encrypt_group_message( - room_id, http::client()->device_id(), doc.dump()); + auto data = + olm::encrypt_group_message(room_id, http::client()->device_id(), doc); http::client()->send_room_message<msg::Encrypted, EventType::RoomEncrypted>( room_id, @@ -902,7 +906,7 @@ TimelineModel::sendEncryptedMessage(const std::string &txn_id, nlohmann::json co std::make_shared<StateKeeper>([megolm_payload, room_id, doc, txn_id, this]() { try { auto data = olm::encrypt_group_message( - room_id, http::client()->device_id(), doc.dump()); + room_id, http::client()->device_id(), doc); http::client() ->send_room_message<msg::Encrypted, EventType::RoomEncrypted>( |