WIP

app/src/main/java/chat/rocket/android/chatrooms/infrastructure/ChatRoomsRepository.kt

@@ -15,6 +15,10 @@ class ChatRoomsRepository @Inject constructor(val dao: ChatRoomDao){
         }
     }
 
+    fun getChatRooms(query: String): List<ChatRoom> {
+        TODO()
+    }
+
     enum class Order {
         ACTIVITY,
         GROUPED_ACTIVITY,

app/src/main/java/chat/rocket/android/chatrooms/viewmodel/ChatRoomsViewModel.kt

@@ -9,12 +9,14 @@ import chat.rocket.android.chatrooms.adapter.RoomUiModelMapper
 import chat.rocket.android.chatrooms.domain.FetchChatRoomsInteractor
 import chat.rocket.android.chatrooms.infrastructure.ChatRoomsRepository
 import chat.rocket.android.chatrooms.infrastructure.isGrouped
+import chat.rocket.android.db.model.ChatRoom
 import chat.rocket.android.server.infraestructure.ConnectionManager
 import chat.rocket.android.util.livedata.transform
 import chat.rocket.core.internal.realtime.socket.model.State
 import kotlinx.coroutines.experimental.launch
 import kotlinx.coroutines.experimental.newSingleThreadContext
 import me.henrytao.livedataktx.distinct
+import me.henrytao.livedataktx.filter
 import me.henrytao.livedataktx.map
 import me.henrytao.livedataktx.nonNull
 import timber.log.Timber
@@ -26,6 +28,7 @@ class ChatRoomsViewModel(
     private val mapper: RoomUiModelMapper
 ) : ViewModel() {
     private val ordering: MutableLiveData<ChatRoomsRepository.Order> = MutableLiveData()
+    private val query: MutableLiveData<String> = MutableLiveData()
     private val runContext = newSingleThreadContext("chat-rooms-view-model")
 
     init {
@@ -46,6 +49,12 @@ class ChatRoomsViewModel(
         }
     }
 
+    fun spotlight(): LiveData<List<ChatRoom>> {
+        return query.filter { !it.isNullOrEmpty() }.distinct().nonNull().transform {
+            repository.getChatRooms(it!!)
+        }
+    }
+
     fun getStatus(): MutableLiveData<State> {
         return connectionManager.statusLiveData.nonNull().distinct().map { state ->
             if (state is State.Connected) {

app/src/main/java/chat/rocket/android/db/ChatRoomDao.kt

@@ -20,6 +20,10 @@ abstract class ChatRoomDao : BaseDao<ChatRoomEntity> {
         """)
     abstract fun get(id: String): ChatRoom?
 
+    @Transaction
+    @Query("$BASE_QUERY")
+    abstract fun getAllSync(): List<ChatRoom>
+
     @Transaction
     @Query("""
         $BASE_QUERY