diff --git a/amethyst/src/main/java/com/vitorpamplona/amethyst/service/relayClient/eoseManagers/PerUserEoseManager.kt b/amethyst/src/main/java/com/vitorpamplona/amethyst/service/relayClient/eoseManagers/PerUserEoseManager.kt index ec7854a2e..1bbe13acd 100644 --- a/amethyst/src/main/java/com/vitorpamplona/amethyst/service/relayClient/eoseManagers/PerUserEoseManager.kt +++ b/amethyst/src/main/java/com/vitorpamplona/amethyst/service/relayClient/eoseManagers/PerUserEoseManager.kt @@ -42,7 +42,7 @@ abstract class PerUserEoseManager( allKeys: () -> Set, val invalidateAfterEose: Boolean = false, ) : BaseEoseManager(client, allKeys) { - private val latestEOSEs = EOSEAccountFast() + private val latestEOSEs = EOSEAccountFast() private val userSubscriptionMap = mutableMapOf() fun since(key: T) = latestEOSEs.since(user(key)) diff --git a/amethyst/src/main/java/com/vitorpamplona/amethyst/service/relayClient/reqCommand/user/watchers/UserWatcherSubAssembler.kt b/amethyst/src/main/java/com/vitorpamplona/amethyst/service/relayClient/reqCommand/user/watchers/UserWatcherSubAssembler.kt index d2f29ed1f..5736d67af 100644 --- a/amethyst/src/main/java/com/vitorpamplona/amethyst/service/relayClient/reqCommand/user/watchers/UserWatcherSubAssembler.kt +++ b/amethyst/src/main/java/com/vitorpamplona/amethyst/service/relayClient/reqCommand/user/watchers/UserWatcherSubAssembler.kt @@ -33,7 +33,7 @@ class UserWatcherSubAssembler( allKeys: () -> Set, ) : SingleSubEoseManager(client, allKeys) { var lastUsersOnFilter: Set = emptySet() - var latestEOSEs: EOSEAccountFast = EOSEAccountFast(2000) + var latestEOSEs: EOSEAccountFast = EOSEAccountFast(2000) override fun newEose( relayUrl: String, @@ -69,7 +69,7 @@ class UserWatcherSubAssembler( fun groupByRelayPresence( users: Iterable, - eoseCache: EOSEAccountFast, + eoseCache: EOSEAccountFast, ): Collection> = users .groupBy { eoseCache.since(it)?.keys?.hashCode() } @@ -81,7 +81,7 @@ class UserWatcherSubAssembler( fun findMinimumEOSEsForUsers( users: List, - eoseCache: EOSEAccountFast, + eoseCache: EOSEAccountFast, ): Map { val minLatestEOSEs = mutableMapOf() diff --git a/amethyst/src/main/java/com/vitorpamplona/amethyst/service/relays/EOSE.kt b/amethyst/src/main/java/com/vitorpamplona/amethyst/service/relays/EOSE.kt index d96fc9bcb..e7bf85b8b 100644 --- a/amethyst/src/main/java/com/vitorpamplona/amethyst/service/relays/EOSE.kt +++ b/amethyst/src/main/java/com/vitorpamplona/amethyst/service/relays/EOSE.kt @@ -122,13 +122,13 @@ class EOSEAccount( ) = addOrUpdate(user, listCode, relayUrl, time) } -class EOSEAccountFast( +class EOSEAccountFast( cacheSize: Int = 20, ) { - private val users: LruCache = LruCache(cacheSize) + private val users: LruCache = LruCache(cacheSize) fun addOrUpdate( - user: User, + user: T, relayUrl: String, time: Long, ) { @@ -143,14 +143,14 @@ class EOSEAccountFast( } } - fun removeDataFor(user: User) { + fun removeDataFor(user: T) { users.remove(user) } - fun since(key: User) = users[key]?.relayList + fun since(key: T) = users[key]?.relayList fun newEose( - user: User, + user: T, relayUrl: String, time: Long, ) = addOrUpdate(user, relayUrl, time)