@@ -311,17 +311,15 @@ class MessageUtils(num: Int) : BaseController(num) {
311
311
CoroutineScope (Dispatchers .IO ).launch {
312
312
val peer = messagesController.getInputPeer(dialogId)
313
313
val fromId = MessagesController .getInputPeer(userConfig.currentUser)
314
- doSearchMessages(fragment, peer = peer, replyMessageId = replyMessageId, fromId = fromId, offsetId = Int .MAX_VALUE , hash = 0 ).let { it ->
314
+ doSearchMessages(fragment, peer = peer, replyMessageId = replyMessageId, fromId = fromId, offsetId = Int .MAX_VALUE , hash = 0 , before = before ).let {
315
315
if (it.isNotEmpty()) {
316
-
317
316
val lists = ArrayList <ArrayList <Int >>().apply {
318
317
for (i in 0 .. it.size / 100 ) {
319
318
add(ArrayList (it.subList(i * 100 , min((i + 1 ) * 100 , it.size))))
320
319
}
321
320
}
322
321
323
322
val deleteAction = Runnable {
324
- Log .d(" deleteAction" )
325
323
for (list in lists) {
326
324
messagesController.deleteMessages(list, null , null , dialogId, true , false )
327
325
}
@@ -379,7 +377,7 @@ class MessageUtils(num: Int) : BaseController(num) {
379
377
var newOffsetId = offsetId
380
378
for (message in response.messages) {
381
379
newOffsetId = min(newOffsetId.toDouble(), message.id.toDouble()).toInt()
382
- if (! message.out || message.post || message.date < = before) {
380
+ if (! message.out || message.post || message.date > = before) {
383
381
continue
384
382
}
385
383
messagesId.add(message.id)
0 commit comments