@@ -9,7 +9,7 @@ import android.content.Context
9
9
import androidx.test.ext.junit.runners.AndroidJUnit4
10
10
import androidx.test.platform.app.InstrumentationRegistry
11
11
import com.quickblox.android_ui_kit.*
12
- import com.quickblox.android_ui_kit.data.source.remote.parser.ForwardMessageParser
12
+ import com.quickblox.android_ui_kit.data.source.remote.parser.ForwardReplyMessageParser
13
13
import com.quickblox.android_ui_kit.dependency.DependencyImpl
14
14
import com.quickblox.android_ui_kit.domain.entity.DialogEntity
15
15
import com.quickblox.android_ui_kit.domain.entity.implementation.PaginationEntityImpl
@@ -25,7 +25,7 @@ import com.quickblox.android_ui_kit.domain.usecases.CreatePrivateDialogUseCase
25
25
import com.quickblox.android_ui_kit.domain.usecases.GetAllMessagesUseCase
26
26
import com.quickblox.android_ui_kit.domain.usecases.GetDialogByIdUseCase
27
27
import com.quickblox.android_ui_kit.domain.usecases.SendChatMessageUseCase
28
- import com.quickblox.android_ui_kit.domain.usecases.SendForwardMessageUseCase
28
+ import com.quickblox.android_ui_kit.domain.usecases.SendForwardReplyMessageUseCase
29
29
import com.quickblox.chat.QBChatService
30
30
import com.quickblox.chat.model.QBChatDialog
31
31
import com.quickblox.chat.model.QBChatMessage
@@ -103,10 +103,12 @@ class SendForwardMessageIntegrationTest : BaseTest() {
103
103
fun sendFiveTextForwardedMessagesFromOpponentUser_loadMessage_messageIsForwardedAndIncoming (): Unit = runBlocking {
104
104
val messageCount = 5
105
105
106
- sendXMessagesByOpponent(createdDialog?.getDialogId()!! , messagesCount = messageCount)
106
+ val messageContentText = " opponent_user_forwarded_test_message_${System .currentTimeMillis()} "
107
+
108
+ sendXMessagesByOpponent(createdDialog?.getDialogId()!! , messageContentText, messageCount)
107
109
val loadedMessages = loadXChatMessages(messagesCount = messageCount)
108
110
109
- sendForwardedMessageByOpponent(loadedMessages)
111
+ sendForwardedMessageByOpponent(loadedMessages, messageContentText )
110
112
111
113
val dialogEntity = GetDialogByIdUseCase (createdDialog?.getDialogId()!! ).execute()
112
114
@@ -121,21 +123,26 @@ class SendForwardMessageIntegrationTest : BaseTest() {
121
123
assertEquals(messageCount, message.getForwardedRepliedMessages()!! .size)
122
124
assertEquals(OPPONENT_ID , message.getForwardedRepliedMessages()!! [0 ].getSender()!! .getUserId())
123
125
assertNotNull(message.getForwardedRepliedMessages()!! [0 ].getRelatedMessageId())
126
+ assertEquals(messageContentText, message.getContent())
127
+ assertEquals(messageContentText, message.getForwardedRepliedMessages()!! [0 ].getContent())
124
128
}
125
129
126
130
@Test
127
131
@ExperimentalCoroutinesApi
128
132
fun sendFiveTextForwardedMessagesFromLoggedUser_execute_messageIsForwardedAndOutgoing (): Unit = runBlocking {
129
133
val messageCount = 5
130
134
131
- sendXMessagesByLoggedUser(createdDialog?.getDialogId()!! , messagesCount = messageCount)
135
+ val forwardMessageText = " logged_user_forwarded_test_message_${System .currentTimeMillis()} "
136
+
137
+ sendXMessagesByLoggedUser(createdDialog?.getDialogId()!! , forwardMessageText, messageCount)
132
138
val loadedMessages = loadXChatMessages(messagesCount = messageCount)
133
139
134
- val relatedMessage = buildRelatedMessage(createdDialog?.getDialogId()!! )
140
+ val relatedMessageText = " related_message_${System .currentTimeMillis()} "
141
+ val relatedMessage = buildRelatedMessage(createdDialog?.getDialogId()!! , relatedMessageText)
135
142
136
143
val createdMessage = CreateForwardMessageUseCase (loadedMessages, relatedMessage).execute()
137
144
138
- SendForwardMessageUseCase (createdMessage!! , createdDialog?.getDialogId()!! ).execute()
145
+ SendForwardReplyMessageUseCase (createdMessage!! , createdDialog?.getDialogId()!! ).execute()
139
146
140
147
val dialogEntity = GetDialogByIdUseCase (createdDialog?.getDialogId()!! ).execute()
141
148
@@ -150,31 +157,30 @@ class SendForwardMessageIntegrationTest : BaseTest() {
150
157
assertEquals(messageCount, message.getForwardedRepliedMessages()!! .size)
151
158
assertEquals(USER_ID , message.getForwardedRepliedMessages()!! [0 ].getSender()!! .getUserId())
152
159
assertNotNull(message.getForwardedRepliedMessages()!! [0 ].getRelatedMessageId())
160
+ assertEquals(relatedMessageText, message.getContent())
161
+ assertEquals(forwardMessageText, message.getForwardedRepliedMessages()!! [0 ].getContent())
153
162
}
154
163
155
- private fun sendXMessagesByOpponent (dialogId : String , messagesCount : Int = 5) {
156
- val messages = createMessagesFromOpponent(dialogId, qbChatMessageCount = messagesCount)
164
+ private fun sendXMessagesByOpponent (dialogId : String , messageBodyText : String , messagesCount : Int = 5) {
165
+ val messages = createMessagesFromOpponent(dialogId, messageBodyText, messagesCount)
157
166
158
167
for (message in messages) {
159
168
sendChatMessageToDialog(message, opponentChatService!! )
160
169
}
161
170
}
162
171
163
- private fun createMessagesFromOpponent (dialogId : String , qbChatMessageCount : Int = 5): List <QBChatMessage > {
172
+ private fun createMessagesFromOpponent (
173
+ dialogId : String , messageBodyText : String , qbChatMessageCount : Int = 5
174
+ ): List <QBChatMessage > {
164
175
val builtMessages = mutableListOf<QBChatMessage >()
165
176
166
177
for (index in 1 .. qbChatMessageCount) {
167
- builtMessages.add(createMessageFromOpponent(dialogId))
178
+ builtMessages.add(createMessageFromOpponent(dialogId, messageBodyText ))
168
179
}
169
180
170
181
return builtMessages
171
182
}
172
183
173
- /* private fun createForwardMessageFromOpponent(dialogId: String, messageToForward: List<QBChatMessage>) {
174
- val qbChatMessage = buildMessageFromOpponent(dialogId)
175
- qbChatMessage.setProperty()
176
- }*/
177
-
178
184
private fun sendChatMessageToDialog (qbChatMessage : QBChatMessage , chatService : QBChatService ) {
179
185
val qbDialog = QBChatDialog ()
180
186
qbDialog.dialogId = qbChatMessage.dialogId
@@ -186,49 +192,51 @@ class SendForwardMessageIntegrationTest : BaseTest() {
186
192
qbDialog.sendMessage(qbChatMessage)
187
193
}
188
194
189
- private fun createMessageFromOpponent (dialogId : String ): QBChatMessage {
195
+ private fun createMessageFromOpponent (dialogId : String , messageBodyText : String ): QBChatMessage {
190
196
val qbChatMessage = QBChatMessage ()
191
197
qbChatMessage.dialogId = dialogId
192
- qbChatMessage.body = " opponent_user_test_message: ${ System .currentTimeMillis()} "
198
+ qbChatMessage.body = messageBodyText
193
199
qbChatMessage.setSaveToHistory(true )
194
200
195
201
return qbChatMessage
196
202
}
197
203
198
- private suspend fun sendXMessagesByLoggedUser (dialogId : String , messagesCount : Int = 5) {
199
- val messages = createMessagesFromLoggedUser(dialogId, messageCount = messagesCount)
204
+ private suspend fun sendXMessagesByLoggedUser (dialogId : String , messageBodyText : String , messagesCount : Int = 5) {
205
+ val messages = createMessagesFromLoggedUser(dialogId, messageBodyText, messagesCount)
200
206
201
207
for (message in messages) {
202
208
SendChatMessageUseCase (message).execute()
203
209
}
204
210
}
205
211
206
- private fun createMessagesFromLoggedUser (dialogId : String , messageCount : Int = 5): List <OutgoingChatMessageEntity > {
212
+ private fun createMessagesFromLoggedUser (
213
+ dialogId : String , messageBodyText : String , messageCount : Int = 5
214
+ ): List <OutgoingChatMessageEntity > {
207
215
val builtMessages = mutableListOf<OutgoingChatMessageEntity >()
208
216
209
217
for (index in 1 .. messageCount) {
210
- builtMessages.add(createMessageFromLoggedUser(dialogId))
218
+ builtMessages.add(createMessageFromLoggedUser(dialogId, messageBodyText ))
211
219
}
212
220
213
221
return builtMessages
214
222
}
215
223
216
- private fun createMessageFromLoggedUser (dialogId : String ): OutgoingChatMessageEntity {
224
+ private fun createMessageFromLoggedUser (dialogId : String , messageBodyText : String ): OutgoingChatMessageEntity {
217
225
val message = OutgoingChatMessageEntityImpl (
218
226
OutgoingChatMessageEntity .OutgoingStates .SENT , ChatMessageEntity .ContentTypes .TEXT
219
227
)
220
228
message.setParticipantId(OPPONENT_ID )
221
229
message.setDialogId(dialogId)
222
- message.setContent(" logged_user_test_message_ ${ System .currentTimeMillis()} " )
230
+ message.setContent(messageBodyText )
223
231
224
232
return message
225
233
}
226
234
227
- private fun buildRelatedMessage (dialogId : String , title : String? = "normal" ): OutgoingChatMessageEntity {
235
+ private fun buildRelatedMessage (dialogId : String , messageBodyText : String ): OutgoingChatMessageEntity {
228
236
val message = OutgoingChatMessageEntityImpl (null , ChatMessageEntity .ContentTypes .TEXT )
229
237
message.setDialogId(dialogId)
230
238
message.setParticipantId(OPPONENT_ID )
231
- message.setContent(" $title : test_message: ${ System .currentTimeMillis()} " )
239
+ message.setContent(messageBodyText )
232
240
message.setTime(System .currentTimeMillis())
233
241
234
242
return message
@@ -256,9 +264,9 @@ class SendForwardMessageIntegrationTest : BaseTest() {
256
264
return loadedMessages
257
265
}
258
266
259
- private fun sendForwardedMessageByOpponent (messages : List <ForwardedRepliedMessageEntity >) {
260
- val qbChatMessage = createMessageFromOpponent(createdDialog?.getDialogId()!! )
261
- val properties = ForwardMessageParser .parsePropertiesFrom (messages)
267
+ private fun sendForwardedMessageByOpponent (messages : List <ForwardedRepliedMessageEntity >, messageBodyText : String ) {
268
+ val qbChatMessage = createMessageFromOpponent(createdDialog?.getDialogId()!! , messageBodyText )
269
+ val properties = ForwardReplyMessageParser .parseForwardPropertiesFrom (messages)
262
270
263
271
for ((key, value) in properties) {
264
272
qbChatMessage.setProperty(key, value)
0 commit comments