Fix quotest

quotient-im · Nov 30, 2024 · 1cecf8d · 1cecf8d
1 parent f059e78
commit 1cecf8d
Showing 1 changed file with 25 additions and 16 deletions.
diff --git a/quotest/quotest.cpp b/quotest/quotest.cpp
@@ -878,22 +878,31 @@ TEST_IMPL(visitResources)
 
 TEST_IMPL(thread)
 {
-    auto txnId = targetRoom->postPlainText("Threadroot"_L1);
-    targetRoom->whenMessageMerged(txnId)
-        .then(this, [this, thisTest, txnId](const RoomEvent& rootEvt) -> PendingEventItem::future_type {
-            const auto relation = EventRelation::replyInThread(rootEvt.id(), true, {});
-            auto txnId = targetRoom->post<RoomMessageEvent>(u"Thread reply 1"_s, RoomMessageEvent::MsgType::Text, nullptr, relation)->transactionId();
-            return targetRoom->whenMessageMerged(txnId);
-        })
-        .unwrap()
-        .then(this, [this, thisTest](const RoomEvent& replyEvt) {
-            const auto rmReplyEvt = eventCast<const RoomMessageEvent>(&replyEvt);
-            const auto thread = targetRoom->threads()[rmReplyEvt->threadRootEventId()];
-            FINISH_TEST(thread.threadRootId == rmReplyEvt->threadRootEventId() &&
-                        thread.latestEventId == rmReplyEvt->id() &&
-                        thread.size == 2
-            );
-        });
+    auto rootTxnId = targetRoom->postPlainText("Threadroot"_L1);
+    connect(targetRoom, &Room::pendingEventAboutToMerge, this, [this, thisTest, rootTxnId](Quotient::RoomEvent* rootEvt) {
+        if (rootEvt->transactionId() == rootTxnId) {
+            const auto relation = EventRelation::replyInThread(rootEvt->id(), true, rootEvt->id());
+            auto replyTxnId = targetRoom->post<RoomMessageEvent>(u"Thread reply 1"_s, RoomMessageEvent::MsgType::Text, nullptr, relation)->transactionId();
+            connect(targetRoom, &Room::pendingEventAboutToMerge, this, [this, thisTest, replyTxnId](Quotient::RoomEvent* replyEvt) {
+                if (replyEvt->transactionId() == replyTxnId) {
+                    connect(targetRoom, &Room::pendingEventMerged, this, [this, thisTest, replyEvt]() {
+                        replyEvt->switchOnType(
+                            [&](const RoomMessageEvent& rmReplyEvt) {
+                                const auto thread = targetRoom->threads()[rmReplyEvt.threadRootEventId()];
+                                clog << thread.threadRootId.toStdString() << rmReplyEvt.threadRootEventId().toStdString() << thread.latestEventId.toStdString() << rmReplyEvt.id().toStdString() << thread.size;
+                                FINISH_TEST(thread.threadRootId == rmReplyEvt.threadRootEventId() &&
+                                            thread.latestEventId == rmReplyEvt.id() &&
+                                            thread.size == 2
+                                );
+                            },
+                            [this, thisTest](const RoomEvent&) { FAIL_TEST(); }
+                        );
+                    });
+                }
+            });
+        }
+    });
+
     return false;
 }