nick/amethyst
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 1 Wiki Activity

Updating all user's relays when new ContactLists arrive

Browse Source
This commit is contained in:
Vitor Pamplona
2023-02-22 18:12:21 -05:00
parent bf3847eeaa
commit e4b94e2fea
1 changed files with 11 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files
app/src/main/java/com/vitorpamplona/amethyst/model/LocalCache.kt
+11 -15
View File
@@ -1,7 +1,6 @@
package com.vitorpamplona.amethyst.model package com.vitorpamplona.amethyst.model
import android.util.Log import android.util.Log
import android.util.LruCache
import androidx.lifecycle.LiveData import androidx.lifecycle.LiveData
import com.fasterxml.jackson.databind.DeserializationFeature import com.fasterxml.jackson.databind.DeserializationFeature
import com.fasterxml.jackson.module.kotlin.jacksonObjectMapper import com.fasterxml.jackson.module.kotlin.jacksonObjectMapper
@@ -24,8 +23,6 @@ import java.time.ZoneId
import java.time.format.DateTimeFormatter import java.time.format.DateTimeFormatter
import java.util.concurrent.ConcurrentHashMap import java.util.concurrent.ConcurrentHashMap
import java.util.concurrent.atomic.AtomicBoolean import java.util.concurrent.atomic.AtomicBoolean
import kotlin.time.ExperimentalTime
import kotlin.time.measureTimedValue
import kotlinx.coroutines.CoroutineScope import kotlinx.coroutines.CoroutineScope
import kotlinx.coroutines.Dispatchers import kotlinx.coroutines.Dispatchers
import kotlinx.coroutines.Job import kotlinx.coroutines.Job
@@ -227,20 +224,19 @@ object LocalCache {
) )
// Saves relay list only if it's a user that is currently been seen // Saves relay list only if it's a user that is currently been seen
if (user.liveSet?.isInUse() == true) { try {
try { if (event.content.isNotEmpty()) {
if (event.content.isNotEmpty()) { val relays: Map<String, ContactListEvent.ReadWrite> =
val relays: Map<String, ContactListEvent.ReadWrite> = Event.gson.fromJson(
Event.gson.fromJson( event.content,
event.content, object : TypeToken<Map<String, ContactListEvent.ReadWrite>>() {}.type
object : TypeToken<Map<String, ContactListEvent.ReadWrite>>() {}.type )
)
user.updateRelays(relays) user.updateRelays(relays)
}
} catch (e: Exception) {
e.printStackTrace()
} }
} catch (e: Exception) {
println("relay import issue")
e.printStackTrace()
} }
Log.d( Log.d(