Skip to content

Commit

Permalink
temp revert priority
Browse files Browse the repository at this point in the history
  • Loading branch information
giannis-rdx committed Jul 1, 2024
1 parent 73a2f98 commit 2ecff44
Show file tree
Hide file tree
Showing 2 changed files with 13 additions and 15 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -149,23 +149,21 @@ class IncomingRequestRepositoryImpl @Inject constructor(
}

// Put high priority item below any internal request and mobile connect requests
val topQueueItem = requestQueue.peekFirst()
if (topQueueItem is QueueItem.RequestItem &&
(topQueueItem.incomingRequest.isInternal || topQueueItem.incomingRequest.isMobileConnectRequest)
) {
requestQueue.add(1, QueueItem.HighPriorityScreen)
} else {
requestQueue.addFirst(QueueItem.HighPriorityScreen)
}
// val index = requestQueue.indexOfFirst {
// val item = it as? QueueItem.RequestItem
// item != null && !item.incomingRequest.isInternal && !item.incomingRequest.isMobileConnectRequest
// }
// if (index != -1) {
// requestQueue.add(index, QueueItem.HighPriorityScreen)
// val topQueueItem = requestQueue.peekFirst()
// if (topQueueItem is QueueItem.RequestItem && topQueueItem.incomingRequest.isInternal) {
// requestQueue.add(1, QueueItem.HighPriorityScreen)
// } else {
// requestQueue.addFirst(QueueItem.HighPriorityScreen)
// }
val index = requestQueue.indexOfFirst {
val item = it as? QueueItem.RequestItem
item != null && !item.incomingRequest.isInternal
}
if (index != -1) {
requestQueue.add(index, QueueItem.HighPriorityScreen)
} else {
requestQueue.addFirst(QueueItem.HighPriorityScreen)
}
Timber.d("🗂 Temporarily pausing incoming message queue")
}
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -289,7 +289,7 @@ class MainViewModel @Inject constructor(
// if (request.isMobileConnectRequest) {
// incomingRequestRepository.addPriorityRequest(request)
// } else {
incomingRequestRepository.add(request)
incomingRequestRepository.add(request)
// }
}
}.onFailure { error ->
Expand Down

0 comments on commit 2ecff44

Please sign in to comment.