@@ -329,8 +329,7 @@ test.describe("Read receipts", () => {
329
329
} ) ;
330
330
331
331
test . describe ( "in threads" , ( ) => {
332
- // XXX: fails because it flakes saying the room is unread when it should be read
333
- test . skip ( "Redacting the threaded message pointed to by my receipt leaves the room read" , async ( {
332
+ test ( "Redacting the threaded message pointed to by my receipt leaves the room read" , async ( {
334
333
roomAlpha : room1 ,
335
334
roomBeta : room2 ,
336
335
util,
@@ -339,18 +338,18 @@ test.describe("Read receipts", () => {
339
338
// Given I have some threads
340
339
await util . goTo ( room1 ) ;
341
340
await util . receiveMessages ( room2 , [
342
- "Root " ,
343
- msg . threadedOff ( "Root " , "ThreadMsg1" ) ,
344
- msg . threadedOff ( "Root " , "ThreadMsg2" ) ,
341
+ "Root1 " ,
342
+ msg . threadedOff ( "Root1 " , "ThreadMsg1" ) ,
343
+ msg . threadedOff ( "Root1 " , "ThreadMsg2" ) ,
345
344
"Root2" ,
346
345
msg . threadedOff ( "Root2" , "Root2->A" ) ,
347
346
] ) ;
348
347
await util . assertUnread ( room2 , 5 ) ;
349
348
350
349
// And I have read them
351
350
await util . goTo ( room2 ) ;
352
- await util . assertUnreadThread ( "Root " ) ;
353
- await util . openThread ( "Root " ) ;
351
+ await util . assertUnreadThread ( "Root1 " ) ;
352
+ await util . openThread ( "Root1 " ) ;
354
353
await util . assertUnreadLessThan ( room2 , 4 ) ;
355
354
await util . openThread ( "Root2" ) ;
356
355
await util . assertRead ( room2 ) ;
@@ -364,7 +363,7 @@ test.describe("Read receipts", () => {
364
363
// Then the room and thread are still read
365
364
await util . assertStillRead ( room2 ) ;
366
365
await util . goTo ( room2 ) ;
367
- await util . assertReadThread ( "Root " ) ;
366
+ await util . assertReadThread ( "Root1 " ) ;
368
367
} ) ;
369
368
test ( "Reading an unread thread after a redaction of the latest message makes it read" , async ( {
370
369
roomAlpha : room1 ,
@@ -536,8 +535,7 @@ test.describe("Read receipts", () => {
536
535
await util . goTo ( room2 ) ;
537
536
await util . assertReadThread ( "Root" ) ;
538
537
} ) ;
539
- // XXX: fails because it flakes - sometimes the room is still unread after opening the thread (initially)
540
- test . skip ( "Reacting to a redacted message leaves the thread read" , async ( {
538
+ test ( "Reacting to a redacted message leaves the thread read" , async ( {
541
539
roomAlpha : room1 ,
542
540
roomBeta : room2 ,
543
541
util,
@@ -726,8 +724,7 @@ test.describe("Read receipts", () => {
726
724
await util . goTo ( room2 ) ;
727
725
await util . assertReadThread ( "Root" ) ;
728
726
} ) ;
729
- // XXX: fails because it flakes
730
- test . skip ( "A thread with a read redaction is still read after restart" , async ( {
727
+ test ( "A thread with a read redaction is still read after restart" , async ( {
731
728
roomAlpha : room1 ,
732
729
roomBeta : room2 ,
733
730
util,
@@ -736,16 +733,16 @@ test.describe("Read receipts", () => {
736
733
// Given my receipt points at a redacted thread message
737
734
await util . goTo ( room1 ) ;
738
735
await util . receiveMessages ( room2 , [
739
- "Root " ,
740
- msg . threadedOff ( "Root " , "ThreadMsg1" ) ,
741
- msg . threadedOff ( "Root " , "ThreadMsg2" ) ,
736
+ "Root1 " ,
737
+ msg . threadedOff ( "Root1 " , "ThreadMsg1" ) ,
738
+ msg . threadedOff ( "Root1 " , "ThreadMsg2" ) ,
742
739
"Root2" ,
743
740
msg . threadedOff ( "Root2" , "Root2->A" ) ,
744
741
] ) ;
745
742
await util . assertUnread ( room2 , 5 ) ;
746
743
await util . goTo ( room2 ) ;
747
- await util . assertUnreadThread ( "Root " ) ;
748
- await util . openThread ( "Root " ) ;
744
+ await util . assertUnreadThread ( "Root1 " ) ;
745
+ await util . openThread ( "Root1 " ) ;
749
746
await util . assertUnreadLessThan ( room2 , 4 ) ;
750
747
await util . openThread ( "Root2" ) ;
751
748
await util . assertRead ( room2 ) ;
@@ -755,7 +752,7 @@ test.describe("Read receipts", () => {
755
752
await util . receiveMessages ( room2 , [ msg . redactionOf ( "ThreadMsg2" ) ] ) ;
756
753
await util . assertStillRead ( room2 ) ;
757
754
await util . goTo ( room2 ) ;
758
- await util . assertReadThread ( "Root " ) ;
755
+ await util . assertReadThread ( "Root1 " ) ;
759
756
760
757
// When I restart
761
758
await util . saveAndReload ( ) ;
0 commit comments