Skip to content

Commit b42bd8d

Browse files
adityaalifnadityaalifn
committed
Reuse test user
1 parent 84271dc commit b42bd8d

File tree

1 file changed

+21
-45
lines changed

1 file changed

+21
-45
lines changed

‎src/test/java/io/getstream/chat/java/ThreadTest.java‎

Lines changed: 21 additions & 45 deletions
Original file line numberDiff line numberDiff line change
@@ -23,30 +23,22 @@ public class ThreadTest extends BasicTest {
2323
@DisplayName("Can query threads with filter parameters")
2424
@Test
2525
void whenQueryingThreadsWithFilter_thenNoException() throws StreamException {
26-
// Create a user
27-
UserRequestObject user =
28-
UserRequestObject.builder()
29-
.id("user-" + RandomStringUtils.randomAlphabetic(10))
30-
.name("User 1")
31-
.build();
32-
User.upsert().user(user).request();
33-
3426
// Create a channel with a thread
3527
String channelId = UUID.randomUUID().toString();
3628
Channel.ChannelGetResponse channel =
3729
Channel.getOrCreate("messaging", channelId)
3830
.data(
3931
ChannelRequestObject.builder()
40-
.createdBy(user)
41-
.members(List.of(ChannelMemberRequestObject.builder().user(user).build()))
32+
.createdBy(testUserRequestObject)
33+
.members(List.of(ChannelMemberRequestObject.builder().user(testUserRequestObject).build()))
4234
.build())
4335
.request();
4436

4537
// Create a parent message for the thread
4638
Message.MessageRequestObject parentMessage =
4739
Message.MessageRequestObject.builder()
4840
.text("Parent message for thread")
49-
.userId(user.getId())
41+
.userId(testUserRequestObject.getId())
5042
.build();
5143

5244
Message.MessageSendResponse parentMessageResponse =
@@ -58,7 +50,7 @@ void whenQueryingThreadsWithFilter_thenNoException() throws StreamException {
5850
Message.MessageRequestObject replyMessage =
5951
Message.MessageRequestObject.builder()
6052
.text("Reply in thread")
61-
.userId(user.getId())
53+
.userId(testUserRequestObject.getId())
6254
.parentId(parentMessageResponse.getMessage().getId())
6355
.build();
6456

@@ -69,7 +61,7 @@ void whenQueryingThreadsWithFilter_thenNoException() throws StreamException {
6961
// Query threads with filter for the specific channel
7062
Thread.QueryThreadsResponse response =
7163
Thread.queryThreads()
72-
.userId(user.getId())
64+
.userId(testUserRequestObject.getId())
7365
.filter(FilterCondition.eq("channel_cid", channel.getChannel().getCId()))
7466
.request();
7567

@@ -87,30 +79,22 @@ void whenQueryingThreadsWithFilter_thenNoException() throws StreamException {
8779
@DisplayName("Can query threads with sort parameters")
8880
@Test
8981
void whenQueryingThreadsWithSort_thenNoException() throws StreamException {
90-
// Create a user
91-
UserRequestObject user =
92-
UserRequestObject.builder()
93-
.id("user-" + RandomStringUtils.randomAlphabetic(10))
94-
.name("User 1")
95-
.build();
96-
User.upsert().user(user).request();
97-
9882
// Create two channels with threads
9983
String channel1Id = UUID.randomUUID().toString();
10084
Channel.ChannelGetResponse channel1 =
10185
Channel.getOrCreate("messaging", channel1Id)
10286
.data(
10387
ChannelRequestObject.builder()
104-
.createdBy(user)
105-
.members(List.of(ChannelMemberRequestObject.builder().user(user).build()))
88+
.createdBy(testUserRequestObject)
89+
.members(List.of(ChannelMemberRequestObject.builder().user(testUserRequestObject).build()))
10690
.build())
10791
.request();
10892

10993
// Create a parent message for the first thread
11094
Message.MessageRequestObject parentMessage1 =
11195
Message.MessageRequestObject.builder()
11296
.text("Parent message for thread 1")
113-
.userId(user.getId())
97+
.userId(testUserRequestObject.getId())
11498
.build();
11599

116100
Message.MessageSendResponse parentMessageResponse1 =
@@ -122,7 +106,7 @@ void whenQueryingThreadsWithSort_thenNoException() throws StreamException {
122106
Message.MessageRequestObject replyMessage1 =
123107
Message.MessageRequestObject.builder()
124108
.text("Reply in thread 1")
125-
.userId(user.getId())
109+
.userId(testUserRequestObject.getId())
126110
.parentId(parentMessageResponse1.getMessage().getId())
127111
.build();
128112

@@ -136,16 +120,16 @@ void whenQueryingThreadsWithSort_thenNoException() throws StreamException {
136120
Channel.getOrCreate("messaging", channel2Id)
137121
.data(
138122
ChannelRequestObject.builder()
139-
.createdBy(user)
140-
.members(List.of(ChannelMemberRequestObject.builder().user(user).build()))
123+
.createdBy(testUserRequestObject)
124+
.members(List.of(ChannelMemberRequestObject.builder().user(testUserRequestObject).build()))
141125
.build())
142126
.request();
143127

144128
// Create a parent message for the second thread
145129
Message.MessageRequestObject parentMessage2 =
146130
Message.MessageRequestObject.builder()
147131
.text("Parent message for thread 2")
148-
.userId(user.getId())
132+
.userId(testUserRequestObject.getId())
149133
.build();
150134

151135
Message.MessageSendResponse parentMessageResponse2 =
@@ -157,7 +141,7 @@ void whenQueryingThreadsWithSort_thenNoException() throws StreamException {
157141
Message.MessageRequestObject replyMessage2 =
158142
Message.MessageRequestObject.builder()
159143
.text("Reply in thread 2")
160-
.userId(user.getId())
144+
.userId(testUserRequestObject.getId())
161145
.parentId(parentMessageResponse2.getMessage().getId())
162146
.build();
163147

@@ -168,7 +152,7 @@ void whenQueryingThreadsWithSort_thenNoException() throws StreamException {
168152
// Query threads with sort by created_at in descending order
169153
Thread.QueryThreadsResponse response =
170154
Thread.queryThreads()
171-
.userId(user.getId())
155+
.userId(testUserRequestObject.getId())
172156
.sort(Sort.builder().field("created_at").direction(Sort.Direction.DESC).build())
173157
.request();
174158

@@ -195,30 +179,22 @@ void whenQueryingThreadsWithSort_thenNoException() throws StreamException {
195179
@DisplayName("Can query threads with both filter and sort parameters")
196180
@Test
197181
void whenQueryingThreadsWithFilterAndSort_thenNoException() throws StreamException {
198-
// Create a user
199-
UserRequestObject user =
200-
UserRequestObject.builder()
201-
.id("user-" + RandomStringUtils.randomAlphabetic(10))
202-
.name("User 1")
203-
.build();
204-
User.upsert().user(user).request();
205-
206182
// Create a channel with multiple threads
207183
String channelId = UUID.randomUUID().toString();
208184
Channel.ChannelGetResponse channel =
209185
Channel.getOrCreate("messaging", channelId)
210186
.data(
211187
ChannelRequestObject.builder()
212-
.createdBy(user)
213-
.members(List.of(ChannelMemberRequestObject.builder().user(user).build()))
188+
.createdBy(testUserRequestObject)
189+
.members(List.of(ChannelMemberRequestObject.builder().user(testUserRequestObject).build()))
214190
.build())
215191
.request();
216192

217193
// Create a parent message for the first thread
218194
Message.MessageRequestObject parentMessage1 =
219195
Message.MessageRequestObject.builder()
220196
.text("Parent message for thread 1")
221-
.userId(user.getId())
197+
.userId(testUserRequestObject.getId())
222198
.build();
223199

224200
Message.MessageSendResponse parentMessageResponse1 =
@@ -230,7 +206,7 @@ void whenQueryingThreadsWithFilterAndSort_thenNoException() throws StreamExcepti
230206
Message.MessageRequestObject replyMessage1 =
231207
Message.MessageRequestObject.builder()
232208
.text("Reply in thread 1")
233-
.userId(user.getId())
209+
.userId(testUserRequestObject.getId())
234210
.parentId(parentMessageResponse1.getMessage().getId())
235211
.build();
236212

@@ -242,7 +218,7 @@ void whenQueryingThreadsWithFilterAndSort_thenNoException() throws StreamExcepti
242218
Message.MessageRequestObject parentMessage2 =
243219
Message.MessageRequestObject.builder()
244220
.text("Parent message for thread 2")
245-
.userId(user.getId())
221+
.userId(testUserRequestObject.getId())
246222
.build();
247223

248224
Message.MessageSendResponse parentMessageResponse2 =
@@ -254,7 +230,7 @@ void whenQueryingThreadsWithFilterAndSort_thenNoException() throws StreamExcepti
254230
Message.MessageRequestObject replyMessage2 =
255231
Message.MessageRequestObject.builder()
256232
.text("Reply in thread 2")
257-
.userId(user.getId())
233+
.userId(testUserRequestObject.getId())
258234
.parentId(parentMessageResponse2.getMessage().getId())
259235
.build();
260236

@@ -265,7 +241,7 @@ void whenQueryingThreadsWithFilterAndSort_thenNoException() throws StreamExcepti
265241
// Query threads with filter for the specific channel and sort by created_at in descending order
266242
Thread.QueryThreadsResponse response =
267243
Thread.queryThreads()
268-
.userId(user.getId())
244+
.userId(testUserRequestObject.getId())
269245
.filter(FilterCondition.eq("channel_cid", channel.getChannel().getCId()))
270246
.sort(Sort.builder().field("created_at").direction(Sort.Direction.DESC).build())
271247
.request();

0 commit comments

Comments
 (0)