package chat.rocket.android.createChannel.addMembers.presentation

import chat.rocket.android.core.lifecycle.CancelStrategy
import chat.rocket.android.members.viewmodel.MemberViewModelMapper
import chat.rocket.android.server.domain.GetCurrentServerInteractor
import chat.rocket.android.server.infraestructure.RocketChatClientFactory
import chat.rocket.android.util.extensions.launchUI
import chat.rocket.android.util.retryIO
import chat.rocket.common.RocketChatException
import chat.rocket.common.util.ifNull
import chat.rocket.core.internal.rest.queryUsers
import javax.inject.Inject

class AddMembersPresenter @Inject constructor(
    private val view: AddMembersView,
    private val strategy: CancelStrategy,
    private val serverInteractor: GetCurrentServerInteractor,
    private val mapper: MemberViewModelMapper,
    factory: RocketChatClientFactory
) {
    private val client = factory.create(serverInteractor.get()!!)

    fun queryUsersFromRegex(queryParam: String, offset: Long = 0) {
        view.showLoading()
        launchUI(strategy) {
            try {
                val allMembers = retryIO("queryUsers($queryParam)") {
                    client.queryUsers(queryParam, 60, offset)
                }
                val memberViewModelMapper = mapper.mapToViewModelList(allMembers.result)
                view.showMembers(memberViewModelMapper, allMembers.total)
            } catch (ex: RocketChatException) {
                ex.message?.let {
                    view.showMessage(it)
                }.ifNull {
                    view.showGenericErrorMessage()
                }
            } finally {
                view.hideLoading()
            }
        }
    }
}