- Updated applications to SDK 5.1.0

Author: MarinTolic

samplejava/build.gradle

@@ -30,6 +30,8 @@ android {
 
 dependencies {
     // Add new dependencies
+    implementation "androidx.lifecycle:lifecycle-livedata-ktx:2.4.1"
+
     implementation "io.getstream:stream-chat-android-ui-components:5.1.0"
     implementation "com.google.android.material:material:1.6.0"
     implementation "androidx.activity:activity-ktx:1.4.0"

samplejava/src/main/java/com/example/chattutorial/ChannelActivity3.java

@@ -3,11 +3,14 @@
 import android.content.Context;
 import android.content.Intent;
 import android.os.Bundle;
-import android.widget.TextView;
 
 import androidx.activity.OnBackPressedCallback;
+import androidx.annotation.NonNull;
 import androidx.annotation.Nullable;
 import androidx.appcompat.app.AppCompatActivity;
+import androidx.lifecycle.FlowLiveDataConversions;
+import androidx.lifecycle.LiveData;
+import androidx.lifecycle.Transformations;
 import androidx.lifecycle.ViewModelProvider;
 
 import com.example.chattutorial.databinding.ActivityChannel3Binding;
@@ -20,15 +23,22 @@
 import java.util.ArrayList;
 import java.util.List;
 
+import io.getstream.chat.android.client.ChatClient;
 import io.getstream.chat.android.client.models.Channel;
 import io.getstream.chat.android.client.models.Message;
+import io.getstream.chat.android.client.models.TypingEvent;
+import io.getstream.chat.android.offline.extensions.ChatClientExtensions;
+import io.getstream.chat.android.offline.plugin.state.channel.ChannelState;
 import io.getstream.chat.android.ui.message.input.viewmodel.MessageInputViewModelBinding;
 import io.getstream.chat.android.ui.message.list.adapter.viewholder.attachment.AttachmentFactoryManager;
 import io.getstream.chat.android.ui.message.list.header.MessageListHeaderView;
 import io.getstream.chat.android.ui.message.list.header.viewmodel.MessageListHeaderViewModel;
 import io.getstream.chat.android.ui.message.list.header.viewmodel.MessageListHeaderViewModelBinding;
 import io.getstream.chat.android.ui.message.list.viewmodel.MessageListViewModelBinding;
 import io.getstream.chat.android.ui.message.list.viewmodel.factory.MessageListViewModelFactory;
+import kotlinx.coroutines.Dispatchers;
+import kotlinx.coroutines.flow.Flow;
+import kotlinx.coroutines.flow.FlowKt;
 
 public class ChannelActivity3 extends AppCompatActivity {
 
@@ -110,11 +120,41 @@ public void handleOnBackPressed() {
         });
 
         // Custom typing info header bar
-        TextView typingHeaderView = findViewById(R.id.typingHeaderView);
         String nobodyTyping = "nobody is typing";
-        typingHeaderView.setText(nobodyTyping);
+        binding.typingHeaderView.setText(nobodyTyping);
+
+        // Observe typing events and update typing header depending on its state.
+        Flow<ChannelState> channelStateFlow = ChatClientExtensions.watchChannelAsState(ChatClient.instance(), cid, 30);
+        LiveData<TypingEvent> typingEventLiveData = Transformations.switchMap(
+                FlowLiveDataConversions.asLiveData(channelStateFlow),
+                channelState -> FlowLiveDataConversions.asLiveData(channelState.getTyping())
+        );
+
+        typingEventLiveData.observe(this, typingEvent -> {
+            String headerText;
+
+            if (typingEvent.getUsers().size() != 0) {
+                headerText = "typing: " + joinTypingUpdatesToUserNames(typingEvent);
+            } else {
+                headerText = nobodyTyping;
+            }
+
+            binding.typingHeaderView.setText(headerText);
+        });
+    }
+
+    @NonNull
+    private String joinTypingUpdatesToUserNames(@NonNull TypingEvent typingEvent) {
+        StringBuilder joinedString = new StringBuilder();
+
+        for (int i = 0; i < typingEvent.getUsers().size(); i++) {
+            if (i < typingEvent.getUsers().size() - 1) {
+                joinedString.append(typingEvent.getUsers().get(i).getName()).append(", ");
+            } else {
+                joinedString.append(typingEvent.getUsers().get(i).getName());
+            }
+        }
 
-        //TODO implemet an OP based solution here once the Core team introduces extensions for StateFlow
-        // based values
+        return joinedString.toString();
     }
 }

samplekotlin/src/main/java/com/example/chattutorial/ChannelActivity3.kt

@@ -15,14 +15,15 @@ import com.getstream.sdk.chat.viewmodel.messages.MessageListViewModel.Mode.Threa
 import com.getstream.sdk.chat.viewmodel.messages.MessageListViewModel.State.NavigateUp
 import io.getstream.chat.android.client.ChatClient
 import io.getstream.chat.android.client.models.Channel
-import io.getstream.chat.android.offline.extensions.globalState
+import io.getstream.chat.android.offline.extensions.watchChannelAsState
 import io.getstream.chat.android.ui.message.input.viewmodel.bindView
 import io.getstream.chat.android.ui.message.list.adapter.viewholder.attachment.AttachmentFactoryManager
 import io.getstream.chat.android.ui.message.list.header.viewmodel.MessageListHeaderViewModel
 import io.getstream.chat.android.ui.message.list.header.viewmodel.bindView
 import io.getstream.chat.android.ui.message.list.viewmodel.bindView
 import io.getstream.chat.android.ui.message.list.viewmodel.factory.MessageListViewModelFactory
-import kotlinx.coroutines.flow.collect
+import kotlinx.coroutines.flow.filterNotNull
+import kotlinx.coroutines.flow.flatMapLatest
 
 class ChannelActivity3 : AppCompatActivity() {
 
@@ -95,7 +96,10 @@ class ChannelActivity3 : AppCompatActivity() {
 
         // Observe typing events and update typing header depending on its state.
         lifecycleScope.launchWhenStarted {
-            ChatClient.instance().globalState.typingUpdates.collect {
+            ChatClient.instance().watchChannelAsState(cid, 30)
+                .filterNotNull()
+                .flatMapLatest { it.typing }
+                .collect {
                 binding.typingHeaderView.text = when {
                     it.users.isNotEmpty() -> it.users.joinToString(prefix = "typing: ") { user -> user.name }
                     else -> nobodyTyping