package mx.trackermap.TrackerMap.android.session import android.util.Log import androidx.lifecycle.LiveData import androidx.lifecycle.MutableLiveData import androidx.lifecycle.ViewModel import androidx.lifecycle.viewModelScope import com.zhuinden.eventemitter.EventEmitter import com.zhuinden.eventemitter.EventSource import kotlinx.coroutines.DelicateCoroutinesApi import kotlinx.coroutines.flow.collect import kotlinx.coroutines.launch import mx.trackermap.TrackerMap.client.models.User import mx.trackermap.TrackerMap.controllers.SessionController import org.koin.core.component.KoinComponent import org.koin.core.component.inject @DelicateCoroutinesApi class UserInformationViewModel : ViewModel(), KoinComponent { private val sessionController: SessionController by inject() init { Log.d("UserInformationVM", "Initializing User Information View Model") } private val _user = MutableLiveData() val user: LiveData get() = _user private val loginStateEmitter = EventEmitter() val loginState: EventSource = loginStateEmitter init { viewModelScope.launch { setupLoginStateObserver() } viewModelScope.launch { setupUserObserver() } } private suspend fun setupLoginStateObserver() { sessionController.loginStateFlow.collect { it?.let { loginStateEmitter.emit(it) } } } private suspend fun setupUserObserver() { sessionController.userFlow.collect { it?.let { _user.postValue(it) } } } fun fetchUserInfo() { viewModelScope.launch { loginStateEmitter.emit(SessionController.LoginState.Loading) try { sessionController.getSession() loginStateEmitter.emit(SessionController.LoginState.Success) } catch (e: Exception) { loginStateEmitter.emit(SessionController.LoginState.Failure) } } } fun signOut(token: String?) { viewModelScope.launch { sessionController.logout(token) } } }