Skip to content

Commit ea32754

Browse files
committed
Remove unused currentGroup.
1 parent 388ed6b commit ea32754

5 files changed

Lines changed: 10 additions & 35 deletions

File tree

stream-chat-android-state/src/main/java/io/getstream/chat/android/state/event/handler/grouped/internal/ChannelGroupResolver.kt

Lines changed: 2 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,7 @@ import io.getstream.chat.android.models.Channel
2222
* Resolves the set of group keys a [Channel] belongs to for the purposes of grouped channel
2323
* lists driven by `queryGroupedChannels`.
2424
*
25-
* Used by [GroupAwareChatEventHandler] to decide whether an incoming event-bearing channel
25+
* Used by [GroupAwareChatEventHandler] to decide whether an incoming channel-bearing event
2626
* should be added to, removed from, or skipped by a query identified by
2727
* [io.getstream.chat.android.client.internal.state.plugin.QueryChannelsIdentifier.Grouped].
2828
* Classification is performed against the channel's own `extraData`.
@@ -31,11 +31,8 @@ internal fun interface ChannelGroupResolver {
3131

3232
/**
3333
* @param channel The channel whose group membership is being resolved.
34-
* @param currentGroup The group key of the query asking. Most resolvers will not need this,
35-
* but it allows a single resolver instance to be shared across multiple grouped queries and
36-
* still differentiate behavior per asker (e.g. logging, short-circuiting, per-group rules).
3734
* @return The set of group keys this channel belongs to. A channel can belong to multiple
3835
* groups (e.g. an explicit group plus an `"all"` sentinel).
3936
*/
40-
fun resolve(channel: Channel, currentGroup: String): Set<String>
37+
fun resolve(channel: Channel): Set<String>
4138
}

stream-chat-android-state/src/main/java/io/getstream/chat/android/state/event/handler/grouped/internal/DefaultChannelGroupResolver.kt

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -34,8 +34,7 @@ internal class DefaultChannelGroupResolver(
3434
private val allGroupKey: String? = DEFAULT_ALL_GROUP_KEY,
3535
) : ChannelGroupResolver {
3636

37-
override fun resolve(channel: Channel, currentGroup: String): Set<String> = buildSet {
38-
// currentGroup is intentionally unused — the channel's group membership is asker-independent.
37+
override fun resolve(channel: Channel): Set<String> = buildSet {
3938
(channel.extraData[groupFieldName] as? String)?.let(::add)
4039
allGroupKey?.let(::add)
4140
}

stream-chat-android-state/src/main/java/io/getstream/chat/android/state/event/handler/grouped/internal/GroupAwareChatEventHandler.kt

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -117,7 +117,7 @@ internal class GroupAwareChatEventHandler(
117117
}
118118

119119
private fun channelBelongsHere(channel: Channel): Boolean =
120-
resolver.resolve(channel, groupKey).contains(groupKey)
120+
resolver.resolve(channel).contains(groupKey)
121121

122122
/**
123123
* Returns `true` if the current user is known to be a member of [cachedChannel].

stream-chat-android-state/src/test/java/io/getstream/chat/android/state/event/handler/grouped/internal/DefaultChannelGroupResolverTest.kt

Lines changed: 5 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,6 @@
1717
package io.getstream.chat.android.state.event.handler.grouped.internal
1818

1919
import io.getstream.chat.android.randomChannel
20-
import io.getstream.chat.android.randomString
2120
import org.junit.jupiter.api.Assertions.assertEquals
2221
import org.junit.jupiter.api.Test
2322

@@ -28,7 +27,7 @@ internal class DefaultChannelGroupResolverTest {
2827
val channel = randomChannel(extraData = mapOf("group" to "vip"))
2928
val resolver = DefaultChannelGroupResolver()
3029

31-
val result = resolver.resolve(channel, currentGroup = randomString())
30+
val result = resolver.resolve(channel)
3231

3332
assertEquals(setOf("vip", "all"), result)
3433
}
@@ -38,7 +37,7 @@ internal class DefaultChannelGroupResolverTest {
3837
val channel = randomChannel(extraData = emptyMap())
3938
val resolver = DefaultChannelGroupResolver()
4039

41-
val result = resolver.resolve(channel, currentGroup = randomString())
40+
val result = resolver.resolve(channel)
4241

4342
assertEquals(setOf("all"), result)
4443
}
@@ -48,7 +47,7 @@ internal class DefaultChannelGroupResolverTest {
4847
val channel = randomChannel(extraData = mapOf("tier" to "gold", "group" to "ignored"))
4948
val resolver = DefaultChannelGroupResolver(groupFieldName = "tier")
5049

51-
val result = resolver.resolve(channel, currentGroup = randomString())
50+
val result = resolver.resolve(channel)
5251

5352
assertEquals(setOf("gold", "all"), result)
5453
}
@@ -58,7 +57,7 @@ internal class DefaultChannelGroupResolverTest {
5857
val channel = randomChannel(extraData = mapOf("group" to "vip"))
5958
val resolver = DefaultChannelGroupResolver(allGroupKey = null)
6059

61-
val result = resolver.resolve(channel, currentGroup = randomString())
60+
val result = resolver.resolve(channel)
6261

6362
assertEquals(setOf("vip"), result)
6463
}
@@ -68,7 +67,7 @@ internal class DefaultChannelGroupResolverTest {
6867
val channel = randomChannel(extraData = mapOf("group" to 42))
6968
val resolver = DefaultChannelGroupResolver()
7069

71-
val result = resolver.resolve(channel, currentGroup = randomString())
70+
val result = resolver.resolve(channel)
7271

7372
assertEquals(setOf("all"), result)
7473
}

stream-chat-android-state/src/test/java/io/getstream/chat/android/state/event/handler/grouped/internal/GroupAwareChatEventHandlerTest.kt

Lines changed: 1 addition & 21 deletions
Original file line numberDiff line numberDiff line change
@@ -273,7 +273,7 @@ internal class GroupAwareChatEventHandlerTest {
273273
val currentUser = randomUser()
274274
val channel = randomChannel(extraData = mapOf("tier" to "vip"))
275275
val cachedChannel = channel.copy(membership = randomMember(user = currentUser))
276-
val customResolver = ChannelGroupResolver { ch, _ ->
276+
val customResolver = ChannelGroupResolver { ch ->
277277
setOfNotNull(ch.extraData["tier"] as? String)
278278
}
279279
val handler = handlerFor(
@@ -289,26 +289,6 @@ internal class GroupAwareChatEventHandlerTest {
289289
assertEquals(EventHandlingResult.Add(channel), result)
290290
}
291291

292-
@Test
293-
fun `Given custom resolver Should receive the handler's groupKey as currentGroup`() {
294-
val channel = randomChannel(extraData = mapOf("group" to "vip"))
295-
var capturedGroup: String? = null
296-
val capturingResolver = ChannelGroupResolver { _, currentGroup ->
297-
capturedGroup = currentGroup
298-
setOf("vip")
299-
}
300-
val handler = handlerFor(
301-
groupKey = "vip",
302-
cachedChannels = emptyMap(),
303-
resolver = capturingResolver,
304-
)
305-
val event = randomChannelUpdatedEvent(cid = channel.cid, channel = channel)
306-
307-
handler.handleChatEvent(event, Filters.neutral(), cachedChannel = null)
308-
309-
assertEquals("vip", capturedGroup)
310-
}
311-
312292
private fun handlerFor(
313293
groupKey: String,
314294
cachedChannels: Map<String, Channel>,

0 commit comments

Comments
 (0)