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

BugFix: Some events not loading.

Browse Source
This commit is contained in:
Vitor Pamplona
2023-03-30 18:16:14 -04:00
parent 04a3fe2f4c
commit ef5980e90b
2 changed files with 2 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
app/src/main/java/com/vitorpamplona/amethyst/service/NostrSingleEventDataSource.kt
+1 -3
View File
@@ -82,8 +82,6 @@ object NostrSingleEventDataSource : NostrDataSource("SingleEventFeed") {
return null return null
} }
val now = Date().time / 1000
return reactionsToWatch.map { return reactionsToWatch.map {
TypedFilter( TypedFilter(
types = FeedType.values().toSet(), types = FeedType.values().toSet(),
@@ -151,7 +149,7 @@ object NostrSingleEventDataSource : NostrDataSource("SingleEventFeed") {
val addresses = createAddressFilter() val addresses = createAddressFilter()
val addressReactions = createTagToAddressFilter() val addressReactions = createTagToAddressFilter()
singleEventChannel.typedFilters = listOfNotNull(reactions, missing, addresses, addressReactions).flatten().ifEmpty { null } singleEventChannel.typedFilters = listOfNotNull(missing, addresses, reactions, addressReactions).flatten().ifEmpty { null }
} }
fun add(eventId: Note) { fun add(eventId: Note) {
app/src/main/java/com/vitorpamplona/amethyst/service/relays/Relay.kt
+1 -1
View File
@@ -182,7 +182,7 @@ class Relay(
val filters = Client.getSubscriptionFilters(requestId).filter { activeTypes.intersect(it.types).isNotEmpty() } val filters = Client.getSubscriptionFilters(requestId).filter { activeTypes.intersect(it.types).isNotEmpty() }
if (filters.isNotEmpty()) { if (filters.isNotEmpty()) {
val request = val request =
"""["REQ","$requestId",${filters.take(10).joinToString(",") { it.filter.toJson(url) }}]""" """["REQ","$requestId",${filters.take(40).joinToString(",") { it.filter.toJson(url) }}]"""
// println("FILTERSSENT $url $request") // println("FILTERSSENT $url $request")
socket?.send(request) socket?.send(request)
eventUploadCounterInBytes += request.bytesUsedInMemory() eventUploadCounterInBytes += request.bytesUsedInMemory()