Prepare Flow UseCase2 for the exercise

Author: LukasLechnerDev

app/src/main/AndroidManifest.xml

@@ -99,6 +99,10 @@
             android:name=".usecases.flow.usecase1.FlowUseCase1Activity"
             android:exported="true" />
 
+        <activity
+            android:name=".usecases.flow.usecase2.FlowUseCase2Activity"
+            android:exported="true" />
+
     </application>
 
 </manifest>

app/src/main/java/com/lukaslechner/coroutineusecasesonandroid/base/UseCase.kt

@@ -24,6 +24,7 @@ import com.lukaslechner.coroutineusecasesonandroid.usecases.coroutines.usecase7.
 import com.lukaslechner.coroutineusecasesonandroid.usecases.coroutines.usecase8.RoomAndCoroutinesActivity
 import com.lukaslechner.coroutineusecasesonandroid.usecases.coroutines.usecase9.DebuggingCoroutinesActivity
 import com.lukaslechner.coroutineusecasesonandroid.usecases.flow.usecase1.FlowUseCase1Activity
+import com.lukaslechner.coroutineusecasesonandroid.usecases.flow.usecase2.FlowUseCase2Activity
 import kotlinx.parcelize.Parcelize
 
 @Parcelize
@@ -148,6 +149,7 @@ private val coroutinesUseCases =
     )
 
 const val flowUseCase1Description = "#1 Flow Basics"
+const val flowUseCase2Description = "#2 Basic Intermediate operators"
 
 private val flowUseCases =
     UseCaseCategory(
@@ -156,6 +158,9 @@ private val flowUseCases =
             UseCase(
                 flowUseCase1Description,
                 FlowUseCase1Activity::class.java
+            ),UseCase(
+                flowUseCase2Description,
+                FlowUseCase2Activity::class.java
             )
         )
     )

app/src/main/java/com/lukaslechner/coroutineusecasesonandroid/usecases/flow/usecase2/FlowUseCase2Activity.kt

@@ -0,0 +1,60 @@
+package com.lukaslechner.coroutineusecasesonandroid.usecases.flow.usecase2
+
+import android.os.Bundle
+import androidx.activity.viewModels
+import com.lukaslechner.coroutineusecasesonandroid.base.BaseActivity
+import com.lukaslechner.coroutineusecasesonandroid.base.flowUseCase2Description
+import com.lukaslechner.coroutineusecasesonandroid.databinding.ActivityFlowUsecase1Binding
+import com.lukaslechner.coroutineusecasesonandroid.utils.setGone
+import com.lukaslechner.coroutineusecasesonandroid.utils.setVisible
+import com.lukaslechner.coroutineusecasesonandroid.utils.toast
+import kotlinx.coroutines.Dispatchers
+import org.joda.time.LocalDateTime
+import org.joda.time.format.DateTimeFormat
+
+class FlowUseCase2Activity : BaseActivity() {
+
+    private val binding by lazy { ActivityFlowUsecase1Binding.inflate(layoutInflater) }
+    private val adapter = StockAdapter()
+
+    private val viewModel: FlowUseCase2ViewModel by viewModels {
+        ViewModelFactory(
+            NetworkStockPriceDataSource(mockApi(applicationContext)),
+            Dispatchers.Default
+        )
+    }
+
+    override fun onCreate(savedInstanceState: Bundle?) {
+        super.onCreate(savedInstanceState)
+        setContentView(binding.root)
+        binding.recyclerView.adapter = adapter
+
+        viewModel.currentStockPriceAsLiveData.observe(this) { uiState ->
+            if (uiState != null) {
+                render(uiState)
+            }
+        }
+    }
+
+    private fun render(uiState: UiState) {
+        when (uiState) {
+            is UiState.Loading -> {
+                binding.progressBar.setVisible()
+                binding.recyclerView.setGone()
+            }
+            is UiState.Success -> {
+                binding.recyclerView.setVisible()
+                binding.lastUpdateTime.text =
+                    "lastUpdateTime: ${LocalDateTime.now().toString(DateTimeFormat.fullTime())}"
+                adapter.stockList = uiState.stockList
+                binding.progressBar.setGone()
+            }
+            is UiState.Error -> {
+                toast(uiState.message)
+                binding.progressBar.setGone()
+            }
+        }
+    }
+
+    override fun getToolbarTitle() = flowUseCase2Description
+}

app/src/main/java/com/lukaslechner/coroutineusecasesonandroid/usecases/flow/usecase2/FlowUseCase2ViewModel.kt

@@ -0,0 +1,27 @@
+package com.lukaslechner.coroutineusecasesonandroid.usecases.flow.usecase2
+
+import androidx.lifecycle.LiveData
+import com.lukaslechner.coroutineusecasesonandroid.base.BaseViewModel
+import kotlinx.coroutines.CoroutineDispatcher
+
+class FlowUseCase2ViewModel(
+    stockPriceDataSource: StockPriceDataSource,
+    defaultDispatcher: CoroutineDispatcher
+) : BaseViewModel<UiState>() {
+
+    /*
+
+    Flow exercise 1 Goals
+        1) only update stock list when Alphabet(Google) (stock.name ="Alphabet (Google)") stock price is > 2300$
+        2) only show stocks of "United States" (stock.country == "United States")
+        3) show the correct rank (stock.rank) within "United States", not the world wide rank
+        4) filter out Apple  (stock.name ="Apple") and Microsoft (stock.name ="Microsoft"), so that Google is number one
+        5) only show company if it is one of the biggest 10 companies of the "United States" (stock.rank <= 10)
+        6) stop flow collection after 10 emissions from the dataSource
+        7) log out the number of the current emission so that we can check if flow collection stops after exactly 10 emissions
+        8) Perform all flow processing on a background thread
+
+     */
+
+    val currentStockPriceAsLiveData: LiveData<UiState> = TODO()
+}

app/src/main/java/com/lukaslechner/coroutineusecasesonandroid/usecases/flow/usecase2/MockApiBehavior.kt

@@ -0,0 +1,18 @@
+package com.lukaslechner.coroutineusecasesonandroid.usecases.flow.usecase2
+
+import android.content.Context
+import com.google.gson.Gson
+import com.lukaslechner.coroutineusecasesonandroid.usecases.flow.mock.createFlowMockApi
+import com.lukaslechner.coroutineusecasesonandroid.usecases.flow.mock.fakeCurrentStockPrices
+import com.lukaslechner.coroutineusecasesonandroid.utils.MockNetworkInterceptor
+
+fun mockApi(context: Context) =
+    createFlowMockApi(
+        MockNetworkInterceptor()
+            .mock(
+                path = "/current-stock-prices",
+                body = { Gson().toJson(fakeCurrentStockPrices(context)) },
+                status = 200,
+                delayInMs = 1500
+            )
+    )

app/src/main/java/com/lukaslechner/coroutineusecasesonandroid/usecases/flow/usecase2/StockAdapter.kt

@@ -0,0 +1,43 @@
+package com.lukaslechner.coroutineusecasesonandroid.usecases.flow.usecase2
+
+import android.view.LayoutInflater
+import android.view.View
+import android.view.ViewGroup
+import androidx.recyclerview.widget.RecyclerView
+import com.lukaslechner.coroutineusecasesonandroid.R
+import com.lukaslechner.coroutineusecasesonandroid.databinding.RecyclerviewItemStockBinding
+import com.lukaslechner.coroutineusecasesonandroid.usecases.flow.mock.Stock
+import java.text.NumberFormat
+
+class StockAdapter: RecyclerView.Adapter<StockAdapter.ViewHolder>() {
+
+    var stockList: List<Stock>? = null
+    set(value) {
+        field = value
+        notifyDataSetChanged()
+    }
+
+    private val formatter: NumberFormat = NumberFormat.getCurrencyInstance()
+
+    class ViewHolder(view: View) : RecyclerView.ViewHolder(view) {
+        val binding = RecyclerviewItemStockBinding.bind(view)
+    }
+
+    override fun onCreateViewHolder(parent: ViewGroup, viewType: Int): ViewHolder {
+        val view = LayoutInflater.from(parent.context).inflate(R.layout.recyclerview_item_stock, parent, false)
+        return ViewHolder(view)
+    }
+
+    override fun onBindViewHolder(holder: ViewHolder, position: Int) = with(holder.binding){
+        val stock = stockList?.get(position) ?: return@with
+        rank.text = stock.rank.toString()
+        name.text = stock.name
+        val currentPriceFormatted: String = formatter.format(stock.currentPrice)
+        currentPrice.text = currentPriceFormatted
+    }
+
+    override fun getItemCount(): Int {
+        return stockList?.size ?: 0
+    }
+
+}

app/src/main/java/com/lukaslechner/coroutineusecasesonandroid/usecases/flow/usecase2/StockPriceDataSource.kt

@@ -0,0 +1,24 @@
+package com.lukaslechner.coroutineusecasesonandroid.usecases.flow.usecase2
+
+import com.lukaslechner.coroutineusecasesonandroid.usecases.flow.mock.FlowMockApi
+import com.lukaslechner.coroutineusecasesonandroid.usecases.flow.mock.Stock
+import kotlinx.coroutines.delay
+import kotlinx.coroutines.flow.Flow
+import kotlinx.coroutines.flow.flow
+import timber.log.Timber
+
+interface StockPriceDataSource {
+    val latestStockList: Flow<List<Stock>>
+}
+
+class NetworkStockPriceDataSource(mockApi: FlowMockApi) : StockPriceDataSource {
+
+    override val latestStockList: Flow<List<Stock>> = flow {
+        while (true) {
+            Timber.tag("Flow").d("Fetching current stock prices")
+            val currentStockList = mockApi.getCurrentStockPrices()
+            emit(currentStockList)
+            delay(5_000)
+        }
+    }
+}

app/src/main/java/com/lukaslechner/coroutineusecasesonandroid/usecases/flow/usecase2/UiState.kt

@@ -0,0 +1,9 @@
+package com.lukaslechner.coroutineusecasesonandroid.usecases.flow.usecase2
+
+import com.lukaslechner.coroutineusecasesonandroid.usecases.flow.mock.Stock
+
+sealed class UiState {
+    object Loading : UiState()
+    data class Success(val stockList: List<Stock>) : UiState()
+    data class Error(val message: String) : UiState()
+}

app/src/main/java/com/lukaslechner/coroutineusecasesonandroid/usecases/flow/usecase2/ViewModelFactory.kt

@@ -0,0 +1,20 @@
+package com.lukaslechner.coroutineusecasesonandroid.usecases.flow.usecase2
+
+import androidx.lifecycle.ViewModel
+import androidx.lifecycle.ViewModelProvider
+import kotlinx.coroutines.CoroutineDispatcher
+
+class ViewModelFactory(
+    private val stockPriceDataSource: StockPriceDataSource,
+    private val defaultDispatcher: CoroutineDispatcher
+) :
+    ViewModelProvider.Factory {
+
+    override fun <T : ViewModel> create(modelClass: Class<T>): T {
+        return modelClass.getConstructor(
+            StockPriceDataSource::class.java,
+            CoroutineDispatcher::class.java
+        )
+            .newInstance(stockPriceDataSource, defaultDispatcher)
+    }
+}