|
6 | 6 | import io.getstream.chat.java.models.Message; |
7 | 7 | import io.getstream.chat.java.models.Message.MessageRequestObject; |
8 | 8 | import io.getstream.chat.java.models.Message.MessageType; |
9 | | -import io.getstream.chat.java.models.User; |
10 | 9 | import java.util.Arrays; |
11 | 10 | import java.util.List; |
12 | 11 | import org.junit.jupiter.api.Assertions; |
@@ -38,17 +37,7 @@ void whenMarkingChannelsDelivered_thenNoException() throws StreamException { |
38 | 37 | confirmation.setCid(testChannel.getCId()); |
39 | 38 | confirmation.setId(message.getId()); |
40 | 39 |
|
41 | | - // Create mark delivered options with both user and userId |
42 | | - MarkDeliveredOptions options = new MarkDeliveredOptions(); |
43 | | - options.setLatestDeliveredMessages(Arrays.asList(confirmation)); |
44 | | - |
45 | | - // Set both user object and userId string |
46 | | - User user = new User(); |
47 | | - user.setId(testUserRequestObject.getId()); |
48 | | - options.setUser(user); |
49 | | - options.setUserId(testUserRequestObject.getId()); |
50 | | - |
51 | | - // Mark channels as delivered |
| 40 | + // Mark channels as delivered using the fluent API |
52 | 41 | MarkDeliveredOptions.MarkDeliveredResponse response = |
53 | 42 | MarkDeliveredOptions.markChannelsDelivered(Arrays.asList(confirmation)) |
54 | 43 | .userId(testUserRequestObject.getId()) |
@@ -80,9 +69,13 @@ void whenMarkingChannelsDeliveredWithOptions_thenNoException() throws StreamExce |
80 | 69 | confirmation.setCid(testChannel.getCId()); |
81 | 70 | confirmation.setId(message.getId()); |
82 | 71 |
|
83 | | - // Mark channels as delivered with user_id as parameter |
| 72 | + // Create mark delivered options |
| 73 | + MarkDeliveredOptions options = new MarkDeliveredOptions(); |
| 74 | + options.setLatestDeliveredMessages(Arrays.asList(confirmation)); |
| 75 | + |
| 76 | + // Mark channels as delivered using the fluent API |
84 | 77 | MarkDeliveredOptions.MarkDeliveredResponse response = |
85 | | - MarkDeliveredOptions.markChannelsDelivered(Arrays.asList(confirmation)) |
| 78 | + MarkDeliveredOptions.markChannelsDelivered(options) |
86 | 79 | .userId(testUserRequestObject.getId()) |
87 | 80 | .request(); |
88 | 81 |
|
@@ -121,7 +114,7 @@ void whenMarkingChannelsDeliveredWithMultipleMessages_thenNoException() throws S |
121 | 114 | createConfirmation(testChannel.getCId(), messages.get(0).getId()), |
122 | 115 | createConfirmation(testChannel.getCId(), messages.get(1).getId())); |
123 | 116 |
|
124 | | - // Mark channels as delivered with user_id as parameter |
| 117 | + // Mark channels as delivered using the fluent API |
125 | 118 | MarkDeliveredOptions.MarkDeliveredResponse response = |
126 | 119 | MarkDeliveredOptions.markChannelsDelivered(confirmations) |
127 | 120 | .userId(testUserRequestObject.getId()) |
|
0 commit comments