mirror of
https://github.com/permissionlesstech/bitchat-android.git
synced 2026-08-29 07:16:08 +00:00
test: sign background geohash events
This commit is contained in:
parent
c737412f14
commit
e07e3c9118
@ -36,17 +36,21 @@ class NostrBackgroundEventProcessorTest {
|
||||
fun `cold start processes more events than the removed handoff queue capacity`() = runBlocking {
|
||||
val application = ApplicationProvider.getApplicationContext<Application>()
|
||||
val processor = NostrBackgroundEventProcessor(application, scope)
|
||||
val identity = NostrIdentity.generate()
|
||||
val expectedIds = mutableSetOf<String>()
|
||||
|
||||
repeat(300) { index ->
|
||||
val event = NostrEvent(
|
||||
pubkey = identity.publicKeyHex,
|
||||
createdAt = index + 1,
|
||||
kind = NostrKind.EPHEMERAL_EVENT,
|
||||
tags = listOf(listOf("g", "u4pruy")),
|
||||
content = "message-$index"
|
||||
).sign(identity.privateKeyHex)
|
||||
expectedIds += event.id
|
||||
|
||||
processor.onGeohashMessage(
|
||||
event = NostrEvent(
|
||||
id = "cold-start-$index",
|
||||
pubkey = index.toString(16).padStart(64, '0'),
|
||||
createdAt = 1,
|
||||
kind = NostrKind.EPHEMERAL_EVENT,
|
||||
tags = listOf(listOf("g", "u4pruy")),
|
||||
content = "message-$index"
|
||||
),
|
||||
event = event,
|
||||
geohash = "u4pruy"
|
||||
)
|
||||
}
|
||||
@ -58,7 +62,7 @@ class NostrBackgroundEventProcessorTest {
|
||||
}
|
||||
|
||||
assertEquals(
|
||||
(0 until 300).map { "cold-start-$it" }.toSet(),
|
||||
expectedIds,
|
||||
AppStateStore.channelMessages.value["geo:u4pruy"].orEmpty().map { it.id }.toSet()
|
||||
)
|
||||
}
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user