From 40d417038ed2d275c4d2fa666576a030165031f2 Mon Sep 17 00:00:00 2001 From: Vitor Pamplona Date: Wed, 29 Oct 2025 18:28:59 -0400 Subject: [PATCH] adds a Start request to the req listener --- .../quartz/nip01Core/relay/client/pool/PoolRequests.kt | 8 +++++++- .../nip01Core/relay/client/reqs/IRequestListener.kt | 5 +++++ 2 files changed, 12 insertions(+), 1 deletion(-) diff --git a/quartz/src/commonMain/kotlin/com/vitorpamplona/quartz/nip01Core/relay/client/pool/PoolRequests.kt b/quartz/src/commonMain/kotlin/com/vitorpamplona/quartz/nip01Core/relay/client/pool/PoolRequests.kt index dfda9bed5..4847a747c 100644 --- a/quartz/src/commonMain/kotlin/com/vitorpamplona/quartz/nip01Core/relay/client/pool/PoolRequests.kt +++ b/quartz/src/commonMain/kotlin/com/vitorpamplona/quartz/nip01Core/relay/client/pool/PoolRequests.kt @@ -148,7 +148,13 @@ class PoolRequests { cmd: Command, ) { when (cmd) { - is ReqCmd -> subState(cmd.subId).onOpenReq(relay, cmd.filters) + is ReqCmd -> { + subState(cmd.subId).onOpenReq(relay, cmd.filters) + desiredSubListeners.get(cmd.subId)?.onStartReq( + relay = relay.url, + forFilters = cmd.filters, + ) + } is CloseCmd -> subState(cmd.subId).onCloseReq(relay) } } diff --git a/quartz/src/commonMain/kotlin/com/vitorpamplona/quartz/nip01Core/relay/client/reqs/IRequestListener.kt b/quartz/src/commonMain/kotlin/com/vitorpamplona/quartz/nip01Core/relay/client/reqs/IRequestListener.kt index 2acd595ad..57f114c3e 100644 --- a/quartz/src/commonMain/kotlin/com/vitorpamplona/quartz/nip01Core/relay/client/reqs/IRequestListener.kt +++ b/quartz/src/commonMain/kotlin/com/vitorpamplona/quartz/nip01Core/relay/client/reqs/IRequestListener.kt @@ -48,4 +48,9 @@ interface IRequestListener { message: String, forFilters: List?, ) {} + + fun onStartReq( + relay: String, + forFilters: List, + ) {} }