Coroutines Homework

app/src/main/kotlin/ru/otus/coroutineshomework/ui/login/LoginFragment.kt

@@ -7,6 +7,9 @@ import android.view.ViewGroup
 import androidx.core.view.isVisible
 import androidx.fragment.app.Fragment
 import androidx.fragment.app.viewModels
+import androidx.lifecycle.lifecycleScope
+import kotlinx.coroutines.flow.collect
+import kotlinx.coroutines.launch
 import ru.otus.coroutineshomework.databinding.ContentBinding
 import ru.otus.coroutineshomework.databinding.FragmentLoginBinding
 import ru.otus.coroutineshomework.databinding.LoadingBinding
@@ -42,13 +45,14 @@ class LoginFragment : Fragment() {
 
         setupLogin()
         setupContent()
-
-        loginViewModel.state.observe(viewLifecycleOwner) {
-            when(it) {
-                is LoginViewState.Login -> showLogin(it)
-                LoginViewState.LoggingIn -> showLoggingIn()
-                is LoginViewState.Content -> showContent(it)
-                LoginViewState.LoggingOut -> showLoggingOut()
+        lifecycleScope.launch {
+            loginViewModel.state.collect() {
+                when (it) {
+                    is LoginViewState.Login -> showLogin(it)
+                    LoginViewState.LoggingIn -> showLoggingIn()
+                    is LoginViewState.Content -> showContent(it)
+                    LoginViewState.LoggingOut -> showLoggingOut()
+                }
             }
         }
     }

app/src/main/kotlin/ru/otus/coroutineshomework/ui/login/LoginViewModel.kt

@@ -3,25 +3,47 @@ package ru.otus.coroutineshomework.ui.login
 import androidx.lifecycle.LiveData
 import androidx.lifecycle.MutableLiveData
 import androidx.lifecycle.ViewModel
+import androidx.lifecycle.viewModelScope
+import kotlinx.coroutines.Dispatchers
+import kotlinx.coroutines.flow.MutableStateFlow
+import kotlinx.coroutines.flow.StateFlow
+import kotlinx.coroutines.launch
+import ru.otus.coroutineshomework.ui.login.data.Credentials
+import ru.otus.coroutineshomework.ui.login.data.User
 
 class LoginViewModel : ViewModel() {
 
-    private val _state = MutableLiveData<LoginViewState>(LoginViewState.Login())
-    val state: LiveData<LoginViewState> = _state
+    private val _state = MutableStateFlow<LoginViewState>(LoginViewState.Login())
+    val state: StateFlow<LoginViewState> = _state
+    private val loginAIp = LoginApi()
 
     /**
      * Login to the network
      * @param name user name
      * @param password user password
      */
     fun login(name: String, password: String) {
-        // TODO: Implement login
+
+        viewModelScope.launch(Dispatchers.IO) {
+            _state.value = LoginViewState.LoggingIn
+
+            try {
+                val userNetworkRequest = loginAIp.login(Credentials(name, password))
+                _state.value = LoginViewState.Content(userNetworkRequest)
+            } catch (e: Exception) {
+                _state.value = LoginViewState.Login(e)
+            }
+        }
     }
 
     /**
      * Logout from the network
      */
     fun logout() {
-        // TODO: Implement logout
+        viewModelScope.launch(Dispatchers.IO) {
+            _state.value = LoginViewState.LoggingOut
+            loginAIp.logout()
+            _state.value = LoginViewState.Login()
+        }
     }
 }

app/src/main/kotlin/ru/otus/coroutineshomework/ui/network/NetworkViewModel.kt

@@ -4,8 +4,17 @@ import android.util.Log
 import androidx.lifecycle.LiveData
 import androidx.lifecycle.MutableLiveData
 import androidx.lifecycle.ViewModel
+import androidx.lifecycle.viewModelScope
+import kotlinx.coroutines.CoroutineScope
+import kotlinx.coroutines.Deferred
 import kotlinx.coroutines.Dispatchers
+import kotlinx.coroutines.Job
+import kotlinx.coroutines.async
+import kotlinx.coroutines.awaitAll
 import kotlinx.coroutines.isActive
+import kotlinx.coroutines.launch
+import kotlinx.coroutines.runBlocking
+import kotlinx.coroutines.selects.SelectClause1
 import kotlinx.coroutines.withContext
 import kotlin.random.Random
 
@@ -18,7 +27,21 @@ class NetworkViewModel : ViewModel() {
     val result: LiveData<Long?> = _result
 
     fun startTest(numberOfThreads: Int) {
-        // TODO: Implement the logic
+        _result.postValue(0L)
+        val deferredList = ArrayList<Deferred<Result<Long>>>()
+
+        viewModelScope.launch {
+            _running.postValue(true)
+
+            repeat(numberOfThreads) {
+                deferredList.add(async { emulateBlockingNetworkRequest() })
+            }
+            val middleValue =
+                deferredList.awaitAll().mapNotNull { it.getOrNull() }.average().toLong()
+
+            _running.postValue(false)
+            _result.postValue(middleValue)
+        }
     }
 
     private companion object {

app/src/main/kotlin/ru/otus/coroutineshomework/ui/timer/TimerFragment.kt

@@ -6,12 +6,13 @@ import android.view.View
 import android.view.ViewGroup
 import androidx.fragment.app.Fragment
 import androidx.lifecycle.lifecycleScope
-import kotlinx.coroutines.Job
-import kotlinx.coroutines.delay
-import kotlinx.coroutines.isActive
+import kotlinx.coroutines.Dispatchers
+import kotlinx.coroutines.flow.MutableStateFlow
 import kotlinx.coroutines.launch
 import ru.otus.coroutineshomework.databinding.FragmentTimerBinding
 import java.util.Locale
+import java.util.Timer
+import kotlin.concurrent.schedule
 import kotlin.properties.Delegates
 import kotlin.time.Duration
 import kotlin.time.Duration.Companion.milliseconds
@@ -21,9 +22,7 @@ class TimerFragment : Fragment() {
     private var _binding: FragmentTimerBinding? = null
     private val binding get() = _binding!!
 
-    private var time: Duration by Delegates.observable(Duration.ZERO) { _, _, newValue ->
-        binding.time.text = newValue.toDisplayString()
-    }
+    private var timeFlow: MutableStateFlow<Duration> = MutableStateFlow(0.milliseconds)
 
     private var started by Delegates.observable(false) { _, _, newValue ->
         setButtonsState(newValue)
@@ -33,6 +32,7 @@ class TimerFragment : Fragment() {
             stopTimer()
         }
     }
+    private var timeTicker: Timer? = null
 
     private fun setButtonsState(started: Boolean) {
         with(binding) {
@@ -53,12 +53,18 @@ class TimerFragment : Fragment() {
     override fun onViewCreated(view: View, savedInstanceState: Bundle?) {
         super.onViewCreated(view, savedInstanceState)
         savedInstanceState?.let {
-            time = it.getLong(TIME).milliseconds
+            timeFlow.value = it.getLong(TIME).milliseconds
             started = it.getBoolean(STARTED)
         }
+
         setButtonsState(started)
         with(binding) {
-            time.text = this@TimerFragment.time.toDisplayString()
+            lifecycleScope.launch {
+                timeFlow.collect {
+                    time.text = it.toDisplayString()
+                }
+            }
+
             btnStart.setOnClickListener {
                 started = true
             }
@@ -70,16 +76,23 @@ class TimerFragment : Fragment() {
 
     override fun onSaveInstanceState(outState: Bundle) {
         super.onSaveInstanceState(outState)
-        outState.putLong(TIME, time.inWholeMilliseconds)
+        outState.putLong(TIME, timeFlow.value.inWholeMilliseconds)
         outState.putBoolean(STARTED, started)
     }
 
     private fun startTimer() {
-        // TODO: Start timer
+        timeTicker = Timer()
+        timeTicker?.schedule(0L, 100L) {
+            updateTime()
+        }
+    }
+
+    private fun updateTime() {
+        timeFlow.value = timeFlow.value.plus(1.milliseconds)
     }
 
     private fun stopTimer() {
-        // TODO: Stop timer
+        timeTicker?.cancel()
     }
 
     override fun onDestroyView() {