Breakes the Command and Message parsers out of the Relay class

2025-03-17 21:31:57 +01:00 · 2025-01-14 11:47:52 -05:00 · 2025-01-14 11:47:52 -05:00 · e36e49cc88
commit e36e49cc88
parent 3ac303c724
22 changed files with 879 additions and 232 deletions
--- a/ammolite/src/main/java/com/vitorpamplona/ammolite/relays/Relay.kt
+++ b/ammolite/src/main/java/com/vitorpamplona/ammolite/relays/Relay.kt
@ -21,7 +21,7 @@
 package com.vitorpamplona.ammolite.relays

 import com.vitorpamplona.ammolite.relays.relays.RelayState
-import com.vitorpamplona.ammolite.relays.relays.SimpleRelay
+import com.vitorpamplona.ammolite.relays.relays.SimpleClientRelay
 import com.vitorpamplona.ammolite.relays.relays.Subscription
 import com.vitorpamplona.ammolite.relays.relays.SubscriptionCollection
 import com.vitorpamplona.ammolite.relays.relays.sockets.WebsocketBuilderFactory
@ -96,14 +96,12 @@ class Relay(
    val activeTypes: Set<FeedType>,
    socketBuilderFactory: WebsocketBuilderFactory,
    subs: SubscriptionManager,
-) : SimpleRelay.Listener {
+) : SimpleClientRelay.Listener {
    private var listeners = setOf<Listener>()

    val relaySubFilter = RelaySubFilter(url, activeTypes, subs)
    val inner =
-        SimpleRelay(url, socketBuilderFactory.build(forceProxy), relaySubFilter, RelayStats.get(url)).apply {
-            register(this@Relay)
-        }
+        SimpleClientRelay(url, socketBuilderFactory.build(forceProxy), relaySubFilter, this@Relay, RelayStats.get(url))

    val brief = RelayBriefInfoCache.get(url)

@ -119,11 +117,11 @@ class Relay(

    fun connect() = inner.connect()

-    fun connectAndRun(onConnected: () -> Unit) {
+    fun connectAndRunAfterSync(onConnected: () -> Unit) {
        // BRB is crashing OkHttp Deflater object :(
        if (url.contains("brb.io")) return

-        inner.connectAndRun(onConnected)
+        inner.connectAndRunAfterSync(onConnected)
    }

    fun sendOutbox() = inner.sendOutbox()
@ -135,13 +133,13 @@ class Relay(
        filters: List<TypedFilter>,
    ) {
        if (read) {
-            inner.sendFilter(requestId, relaySubFilter.filter(filters))
+            inner.sendRequest(requestId, relaySubFilter.filter(filters))
        }
    }

    fun connectAndSendFiltersIfDisconnected() = inner.connectAndSendFiltersIfDisconnected()

-    fun renewFilters() = inner.renewFilters()
+    fun renewFilters() = inner.renewSubscriptions()

    fun sendOverride(signedEvent: Event) = inner.send(signedEvent)

@ -161,53 +159,59 @@ class Relay(
            activeTypes == other.feedTypes

    override fun onEvent(
-        relay: SimpleRelay,
+        relay: SimpleClientRelay,
        subscriptionId: String,
        event: Event,
        afterEOSE: Boolean,
    ) = listeners.forEach { it.onEvent(this, subscriptionId, event, afterEOSE) }

    override fun onError(
-        relay: SimpleRelay,
+        relay: SimpleClientRelay,
        subscriptionId: String,
        error: Error,
    ) = listeners.forEach { it.onError(this, subscriptionId, error) }

    override fun onEOSE(
-        relay: SimpleRelay,
+        relay: SimpleClientRelay,
        subscriptionId: String,
    ) = listeners.forEach { it.onEOSE(this, subscriptionId) }

    override fun onRelayStateChange(
-        relay: SimpleRelay,
+        relay: SimpleClientRelay,
        type: RelayState,
    ) = listeners.forEach { it.onRelayStateChange(this, type) }

    override fun onSendResponse(
-        relay: SimpleRelay,
+        relay: SimpleClientRelay,
        eventId: String,
        success: Boolean,
        message: String,
    ) = listeners.forEach { it.onSendResponse(this, eventId, success, message) }

    override fun onAuth(
-        relay: SimpleRelay,
+        relay: SimpleClientRelay,
        challenge: String,
    ) = listeners.forEach { it.onAuth(this, challenge) }

    override fun onNotify(
-        relay: SimpleRelay,
+        relay: SimpleClientRelay,
        description: String,
    ) = listeners.forEach { it.onNotify(this, description) }

+    override fun onClosed(
+        relay: SimpleClientRelay,
+        subscriptionId: String,
+        message: String,
+    ) { }
+
    override fun onSend(
-        relay: SimpleRelay,
+        relay: SimpleClientRelay,
        msg: String,
        success: Boolean,
    ) = listeners.forEach { it.onSend(this, msg, success) }

    override fun onBeforeSend(
-        relay: SimpleRelay,
+        relay: SimpleClientRelay,
        event: Event,
    ) = listeners.forEach { it.onBeforeSend(this, event) }

--- a/ammolite/src/main/java/com/vitorpamplona/ammolite/relays/RelayPool.kt
+++ b/ammolite/src/main/java/com/vitorpamplona/ammolite/relays/RelayPool.kt
@ -69,10 +69,7 @@ class RelayPool : Relay.Listener {
            } else {
                addRelay(relay)

-                relay.connectAndRun {
-                    relay.renewFilters()
-                    relay.sendOutbox()
-
+                relay.connectAndRunAfterSync {
                    whenConnected(relay)

                    GlobalScope.launch(Dispatchers.IO) {
--- a/ammolite/src/main/java/com/vitorpamplona/ammolite/relays/relays/SimpleClientRelay.kt
+++ b/ammolite/src/main/java/com/vitorpamplona/ammolite/relays/relays/SimpleClientRelay.kt
@ -21,25 +21,36 @@
 package com.vitorpamplona.ammolite.relays.relays

 import android.util.Log
+import com.vitorpamplona.ammolite.relays.relays.commands.toClient.AuthMessage
+import com.vitorpamplona.ammolite.relays.relays.commands.toClient.ClosedMessage
+import com.vitorpamplona.ammolite.relays.relays.commands.toClient.EoseMessage
+import com.vitorpamplona.ammolite.relays.relays.commands.toClient.EventMessage
+import com.vitorpamplona.ammolite.relays.relays.commands.toClient.NoticeMessage
+import com.vitorpamplona.ammolite.relays.relays.commands.toClient.NotifyMessage
+import com.vitorpamplona.ammolite.relays.relays.commands.toClient.OkMessage
+import com.vitorpamplona.ammolite.relays.relays.commands.toClient.ToClientParser
+import com.vitorpamplona.ammolite.relays.relays.commands.toRelay.AuthCmd
+import com.vitorpamplona.ammolite.relays.relays.commands.toRelay.CloseCmd
+import com.vitorpamplona.ammolite.relays.relays.commands.toRelay.CountCmd
+import com.vitorpamplona.ammolite.relays.relays.commands.toRelay.EventCmd
+import com.vitorpamplona.ammolite.relays.relays.commands.toRelay.ReqCmd
 import com.vitorpamplona.ammolite.relays.relays.sockets.WebSocket
 import com.vitorpamplona.ammolite.relays.relays.sockets.WebSocketListener
 import com.vitorpamplona.ammolite.relays.relays.sockets.WebsocketBuilder
-import com.vitorpamplona.ammolite.service.checkNotInMainThread
 import com.vitorpamplona.quartz.nip01Core.HexKey
 import com.vitorpamplona.quartz.nip01Core.core.Event
-import com.vitorpamplona.quartz.nip01Core.jackson.EventMapper
 import com.vitorpamplona.quartz.nip01Core.relays.Filter
 import com.vitorpamplona.quartz.nip42RelayAuth.RelayAuthEvent
 import com.vitorpamplona.quartz.utils.TimeUtils
 import com.vitorpamplona.quartz.utils.bytesUsedInMemory
-import com.vitorpamplona.quartz.utils.joinToStringLimited
 import java.util.concurrent.atomic.AtomicBoolean
 import kotlin.coroutines.cancellation.CancellationException

-class SimpleRelay(
+class SimpleClientRelay(
    val url: String,
    val socketBuilder: WebsocketBuilder,
    val subs: SubscriptionCollection,
+    val listener: Listener,
    val stats: RelayStat = RelayStat(),
 ) {
    companion object {
@ -47,7 +58,6 @@ class SimpleRelay(
        const val RECONNECTING_IN_SECONDS = 60 * 3
    }

-    private var listeners = setOf<Listener>()
    private var socket: WebSocket? = null
    private var isReady: Boolean = false
    private var usingCompression: Boolean = false
@ -56,30 +66,28 @@ class SimpleRelay(

    private var afterEOSEPerSubscription = mutableMapOf<String, Boolean>()

-    private val authResponse = mutableMapOf<HexKey, Boolean>()
+    private val authResponseWatcher = mutableMapOf<HexKey, Boolean>()
    private val authChallengesSent = mutableSetOf<String>()
+
+    /**
+     * Auth procedures require us to keep track of the outgoing events
+     * to make sure the relay waits for the auth to finish and send them.
+     */
    private val outboxCache = mutableMapOf<HexKey, Event>()

    private var connectingMutex = AtomicBoolean()

-    fun register(listener: Listener) {
-        listeners = listeners.plus(listener)
-    }
+    private val parser = ToClientParser()

-    fun unregister(listener: Listener) {
-        listeners = listeners.minus(listener)
-    }
+    fun isConnectionStarted(): Boolean = socket != null

-    fun isConnected(): Boolean = socket != null
+    fun isConnected(): Boolean = socket != null && isReady

-    fun connect() {
-        connectAndRun {
-            checkNotInMainThread()
+    fun connect() = connectAndRunOverride(::sendEverything)

-            // Sends everything.
-            renewFilters()
-            sendOutbox()
-        }
+    fun sendEverything() {
+        renewSubscriptions()
+        sendOutbox()
    }

    fun sendOutbox() {
@ -90,7 +98,14 @@ class SimpleRelay(
        }
    }

-    fun connectAndRun(onConnected: () -> Unit) {
+    fun connectAndRunAfterSync(onConnected: () -> Unit) {
+        connectAndRunOverride {
+            sendEverything()
+            onConnected()
+        }
+    }
+
+    fun connectAndRunOverride(onConnected: () -> Unit) {
        Log.d("Relay", "Relay.connect $url isAlreadyConnecting: ${connectingMutex.get()}")

        // If there is a connection, don't wait.
@ -99,8 +114,6 @@ class SimpleRelay(
        }

        try {
-            checkNotInMainThread()
-
            if (socket != null) {
                connectingMutex.set(false)
                return
@ -129,7 +142,6 @@ class SimpleRelay(
            pingMillis: Long,
            compression: Boolean,
        ) {
-            checkNotInMainThread()
            Log.d("Relay", "Connect onOpen $url $socket")

            markConnectionAsReady(pingMillis, compression)
@ -137,22 +149,19 @@ class SimpleRelay(
            // Log.w("Relay", "Relay OnOpen, Loading All subscriptions $url")
            onConnected()

-            listeners.forEach { it.onRelayStateChange(this@SimpleRelay, RelayState.CONNECTED) }
+            listener.onRelayStateChange(this@SimpleClientRelay, RelayState.CONNECTED)
        }

        override fun onMessage(text: String) {
-            checkNotInMainThread()
-
            stats.addBytesReceived(text.bytesUsedInMemory())

            try {
                processNewRelayMessage(text)
            } catch (e: Throwable) {
                if (e is CancellationException) throw e
-                e.printStackTrace()
-                text.chunked(2000) { chunked ->
-                    listeners.forEach { it.onError(this@SimpleRelay, "", Error("Problem with $chunked")) }
-                }
+                stats.newError("Error processing: $text")
+                Log.e("Relay", "Error processing: $text")
+                listener.onError(this@SimpleClientRelay, "", Error("Error processing $text"))
            }
        }

@ -160,53 +169,43 @@ class SimpleRelay(
            code: Int,
            reason: String,
        ) {
-            checkNotInMainThread()
-
            Log.w("Relay", "Relay onClosing $url: $reason")

-            listeners.forEach {
-                it.onRelayStateChange(this@SimpleRelay, RelayState.DISCONNECTING)
-            }
+            listener.onRelayStateChange(this@SimpleClientRelay, RelayState.DISCONNECTING)
        }

        override fun onClosed(
            code: Int,
            reason: String,
        ) {
-            checkNotInMainThread()
-
            markConnectionAsClosed()

            Log.w("Relay", "Relay onClosed $url: $reason")

-            listeners.forEach { it.onRelayStateChange(this@SimpleRelay, RelayState.DISCONNECTED) }
+            listener.onRelayStateChange(this@SimpleClientRelay, RelayState.DISCONNECTED)
        }

        override fun onFailure(
            t: Throwable,
-            responseMessage: String?,
+            response: String?,
        ) {
-            checkNotInMainThread()
-
            socket?.cancel() // 1000, "Normal close"

            // checks if this is an actual failure. Closing the socket generates an onFailure as well.
            if (!(socket == null && (t.message == "Socket is closed" || t.message == "Socket closed"))) {
-                stats.newError(responseMessage ?: t.message ?: "onFailure event from server: ${t.javaClass.simpleName}")
+                stats.newError(response ?: t.message ?: "onFailure event from server: ${t.javaClass.simpleName}")
            }

            // Failures disconnect the relay.
            markConnectionAsClosed()

-            Log.w("Relay", "Relay onFailure $url, $responseMessage $responseMessage ${t.message} $socket")
+            Log.w("Relay", "Relay onFailure $url, $response $response ${t.message} $socket")
            t.printStackTrace()
-            listeners.forEach {
-                it.onError(
-                    this@SimpleRelay,
-                    "",
-                    Error("WebSocket Failure. Response: $responseMessage. Exception: ${t.message}", t),
-                )
-            }
+            listener.onError(
+                this@SimpleClientRelay,
+                "",
+                Error("WebSocket Failure. Response: $response. Exception: ${t.message}", t),
+            )
        }
    }

@ -229,115 +228,69 @@ class SimpleRelay(
    }

    fun processNewRelayMessage(newMessage: String) {
-        val msgArray = EventMapper.mapper.readTree(newMessage)
-
-        when (val type = msgArray.get(0).asText()) {
-            "EVENT" -> {
-                val subscriptionId = msgArray.get(1).asText()
-                val event = EventMapper.fromJson(msgArray.get(2))
-
-                // Log.w("Relay", "Relay onEVENT ${event.kind} $url, $subscriptionId ${msgArray.get(2)}")
-
-                // filter results: subs.isActive(subscriptionId) && subs.match(subscriptionId, event)
-                if (true) {
-                    listeners.forEach {
-                        it.onEvent(
-                            this@SimpleRelay,
-                            subscriptionId,
-                            event,
-                            afterEOSEPerSubscription[subscriptionId] == true,
-                        )
-                    }
-                } else {
-                    val filter =
-                        subs.getFilters(subscriptionId).joinToStringLimited(
-                            separator = ",",
-                            limit = 19,
-                            prefix = """["REQ","$subscriptionId",""",
-                            postfix = "]",
-                        ) {
-                            it.toJson()
-                        }
-
-                    Log.w("Relay", "Subscription $filter is not active or the filter does not match the event ${msgArray.get(2)}")
-                }
+        when (val msg = parser.parse(newMessage)) {
+            is EventMessage -> {
+                // Log.w("Relay", "Relay onEVENT $url $newMessage")
+                listener.onEvent(this, msg.subId, msg.event, afterEOSEPerSubscription[msg.subId] == true)
            }
-            "EOSE" ->
-                listeners.forEach {
-                    val subscriptionId = msgArray.get(1).asText()
+            is EoseMessage -> {
+                // Log.w("Relay", "Relay onEOSE $url $newMessage")
+                afterEOSEPerSubscription[msg.subId] = true
+                listener.onEOSE(this@SimpleClientRelay, msg.subId)
+            }
+            is NoticeMessage -> {
+                // Log.w("Relay", "Relay onNotice $url, $newMessage")
+                stats.newNotice(msg.message)
+                listener.onError(this@SimpleClientRelay, msg.message, Error("Relay sent notice: $msg.message"))
+            }
+            is OkMessage -> {
+                Log.w("Relay", "Relay on OK $url, $newMessage")

-                    afterEOSEPerSubscription[subscriptionId] = true
-                    // Log.w("Relay", "Relay onEOSE $url $subscriptionId")
-                    it.onEOSE(this@SimpleRelay, subscriptionId)
-                }
-            "NOTICE" ->
-                listeners.forEach {
-                    val message = msgArray.get(1).asText()
-                    Log.w("Relay", "Relay onNotice $url, $message")
-
-                    stats.newNotice(message)
-
-                    it.onError(this@SimpleRelay, message, Error("Relay sent notice: $message"))
-                }
-            "OK" ->
-                listeners.forEach {
-                    val eventId = msgArray[1].asText()
-                    val success = msgArray[2].asBoolean()
-                    val message = if (msgArray.size() > 2) msgArray[3].asText() else ""
-
-                    Log.w("Relay", "Relay on OK $url, $eventId, $success, $message")
-
-                    if (authResponse.containsKey(eventId)) {
-                        val wasAlreadyAuthenticated = authResponse.get(eventId)
-                        authResponse.put(eventId, success)
-                        if (wasAlreadyAuthenticated != true && success) {
-                            renewFilters()
-                            sendOutbox()
-                        }
+                // if this is the OK of an auth event, renew all subscriptions and resend all outgoing events.
+                if (authResponseWatcher.containsKey(msg.eventId)) {
+                    val wasAlreadyAuthenticated = authResponseWatcher.get(msg.eventId)
+                    authResponseWatcher.put(msg.eventId, msg.success)
+                    if (wasAlreadyAuthenticated != true && msg.success) {
+                        sendEverything()
                    }
+                }

-                    if (outboxCache.contains(eventId) && !message.startsWith("auth-required")) {
-                        synchronized(outboxCache) {
-                            outboxCache.remove(eventId)
-                        }
+                // remove from cache for any error that is not an auth required error.
+                // for auth required, we will do the auth and try to send again.
+                if (outboxCache.contains(msg.eventId) && !msg.message.startsWith("auth-required")) {
+                    synchronized(outboxCache) {
+                        outboxCache.remove(msg.eventId)
                    }
+                }

-                    if (!success) {
-                        stats.newNotice("Failed to receive $eventId: $message")
-                    }
+                if (!msg.success) {
+                    stats.newNotice("Rejected event $msg.eventId: $msg.message")
+                }

-                    it.onSendResponse(this@SimpleRelay, eventId, success, message)
-                }
-            "AUTH" ->
-                listeners.forEach {
-                    Log.w("Relay", "Relay onAuth $url, ${ msgArray[1].asText()}")
-                    it.onAuth(this@SimpleRelay, msgArray[1].asText())
-                }
-            "NOTIFY" ->
-                listeners.forEach {
-                    // Log.w("Relay", "Relay onNotify $url, ${msg[1].asString}")
-                    it.onNotify(this@SimpleRelay, msgArray[1].asText())
-                }
-            "CLOSED" -> listeners.forEach { Log.w("Relay", "Relay Closed Subscription $url, $newMessage") }
+                listener.onSendResponse(this@SimpleClientRelay, msg.eventId, msg.success, msg.message)
+            }
+            is AuthMessage -> {
+                // Log.d("Relay", "Relay onAuth $url, $newMessage")
+                listener.onAuth(this@SimpleClientRelay, msg.challenge)
+            }
+            is NotifyMessage -> {
+                // Log.w("Relay", "Relay onNotify $url, $newMessage")
+                listener.onNotify(this@SimpleClientRelay, msg.message)
+            }
+            is ClosedMessage -> {
+                // Log.w("Relay", "Relay Closed Subscription $url, $newMessage")
+                listener.onClosed(this@SimpleClientRelay, msg.subscriptionId, msg.message)
+            }
            else -> {
                stats.newError("Unsupported message: $newMessage")
-
-                listeners.forEach {
-                    Log.w("Relay", "Unsupported message: $newMessage")
-                    it.onError(
-                        this@SimpleRelay,
-                        "",
-                        Error("Unknown type $type on channel. Msg was $newMessage"),
-                    )
-                }
+                Log.w("Relay", "Unsupported message: $newMessage")
+                listener.onError(this, "", Error("Unsupported message: $newMessage"))
            }
        }
    }

    fun disconnect() {
        Log.d("Relay", "Relay.disconnect $url")
-        checkNotInMainThread()
-
        lastConnectTentative = 0L // this is not an error, so prepare to reconnect as soon as requested.
        socket?.cancel()
        socket = null
@ -349,30 +302,38 @@ class SimpleRelay(
    fun resetEOSEStatuses() {
        afterEOSEPerSubscription = LinkedHashMap(afterEOSEPerSubscription.size)

-        authResponse.clear()
+        authResponseWatcher.clear()
        authChallengesSent.clear()
    }

-    fun sendFilter(
+    fun sendRequest(
        requestId: String,
        filters: List<Filter>,
    ) {
-        checkNotInMainThread()
-
-        if (isConnected()) {
+        if (isConnectionStarted()) {
            if (isReady) {
                if (filters.isNotEmpty()) {
-                    writeToSocket(
-                        filters.joinToStringLimited(
-                            separator = ",",
-                            limit = 19,
-                            prefix = """["REQ","$requestId",""",
-                            postfix = "]",
-                        ) {
-                            it.toJson()
-                        },
-                    )
+                    writeToSocket(ReqCmd.toJson(requestId, filters))
+                    afterEOSEPerSubscription[requestId] = false
+                }
+            }
+        } else {
+            // waits 60 seconds to reconnect after disconnected.
+            if (TimeUtils.now() > lastConnectTentative + RECONNECTING_IN_SECONDS) {
+                // sends all filters after connection is successful.
+                connect()
+            }
+        }
+    }

+    fun sendCount(
+        requestId: String,
+        filters: List<Filter>,
+    ) {
+        if (isConnectionStarted()) {
+            if (isReady) {
+                if (filters.isNotEmpty()) {
+                    writeToSocket(CountCmd.toJson(requestId, filters))
                    afterEOSEPerSubscription[requestId] = false
                }
            }
@ -386,30 +347,23 @@ class SimpleRelay(
    }

    fun connectAndSendFiltersIfDisconnected() {
-        checkNotInMainThread()
-
        if (socket == null) {
            // waits 60 seconds to reconnect after disconnected.
            if (TimeUtils.now() > lastConnectTentative + RECONNECTING_IN_SECONDS) {
-                // println("sendfilter Only if Disconnected ${url} ")
                connect()
            }
        }
    }

-    fun renewFilters() {
+    fun renewSubscriptions() {
        // Force update all filters after AUTH.
        subs.allSubscriptions().forEach {
-            sendFilter(requestId = it.id, it.filters)
+            sendRequest(requestId = it.id, it.filters)
        }
    }

    fun send(signedEvent: Event) {
-        checkNotInMainThread()
-
-        listeners.forEach { listener ->
-            listener.onBeforeSend(this@SimpleRelay, signedEvent)
-        }
+        listener.onBeforeSend(this@SimpleClientRelay, signedEvent)

        if (signedEvent is RelayAuthEvent) {
            sendAuth(signedEvent)
@ -428,9 +382,9 @@ class SimpleRelay(
        // 4. auth is sent
        // ...
        if (!authChallengesSent.contains(challenge)) {
-            authResponse.put(signedEvent.id, false)
+            authResponseWatcher[signedEvent.id] = false
            authChallengesSent.add(challenge)
-            writeToSocket("""["AUTH",${signedEvent.toJson()}]""")
+            writeToSocket(AuthCmd.toJson(signedEvent))
        }
    }

@ -439,36 +393,27 @@ class SimpleRelay(
            outboxCache.put(signedEvent.id, signedEvent)
        }

-        if (isConnected()) {
+        if (isConnectionStarted()) {
            if (isReady) {
-                writeToSocket("""["EVENT",${signedEvent.toJson()}]""")
+                writeToSocket(EventCmd.toJson(signedEvent))
            }
        } else {
-            // sends all filters after connection is successful.
-            connectAndRun {
-                // Sends everything.
-                renewFilters()
-                sendOutbox()
-            }
+            // automatically sends all filters after connection is successful.
+            connect()
        }
    }

    private fun writeToSocket(str: String) {
        if (socket == null) {
-            listeners.forEach { listener ->
-                listener.onError(
-                    this@SimpleRelay,
-                    "",
-                    Error("Failed to send $str. Relay is not connected."),
-                )
-            }
+            listener.onError(
+                this@SimpleClientRelay,
+                "",
+                Error("Failed to send $str. Relay is not connected."),
+            )
        }
        socket?.let {
-            checkNotInMainThread()
            val result = it.send(str)
-            listeners.forEach { listener ->
-                listener.onSend(this@SimpleRelay, str, result)
-            }
+            listener.onSend(this@SimpleClientRelay, str, result)
            stats.addBytesSent(str.bytesUsedInMemory())

            Log.d("Relay", "Relay send $url (${str.length} chars) $str")
@ -476,60 +421,65 @@ class SimpleRelay(
    }

    fun close(subscriptionId: String) {
-        writeToSocket("""["CLOSE","$subscriptionId"]""")
+        writeToSocket(CloseCmd.toJson(subscriptionId))
    }

    interface Listener {
        fun onEvent(
-            relay: SimpleRelay,
+            relay: SimpleClientRelay,
            subscriptionId: String,
            event: Event,
            afterEOSE: Boolean,
        )

        fun onEOSE(
-            relay: SimpleRelay,
+            relay: SimpleClientRelay,
            subscriptionId: String,
        )

        fun onError(
-            relay: SimpleRelay,
+            relay: SimpleClientRelay,
            subscriptionId: String,
            error: Error,
        )

-        fun onSendResponse(
-            relay: SimpleRelay,
-            eventId: String,
-            success: Boolean,
-            message: String,
-        )
-
        fun onAuth(
-            relay: SimpleRelay,
+            relay: SimpleClientRelay,
            challenge: String,
        )

        fun onRelayStateChange(
-            relay: SimpleRelay,
+            relay: SimpleClientRelay,
            type: RelayState,
        )

-        /** Relay sent a notification */
        fun onNotify(
-            relay: SimpleRelay,
+            relay: SimpleClientRelay,
            description: String,
        )

+        fun onClosed(
+            relay: SimpleClientRelay,
+            subscriptionId: String,
+            message: String,
+        )
+
        fun onBeforeSend(
-            relay: SimpleRelay,
+            relay: SimpleClientRelay,
            event: Event,
        )

        fun onSend(
-            relay: SimpleRelay,
+            relay: SimpleClientRelay,
            msg: String,
            success: Boolean,
        )
+
+        fun onSendResponse(
+            relay: SimpleClientRelay,
+            eventId: String,
+            success: Boolean,
+            message: String,
+        )
    }
 }
--- a/ammolite/src/main/java/com/vitorpamplona/ammolite/relays/relays/commands/toClient/AuthMessage.kt
+++ b/ammolite/src/main/java/com/vitorpamplona/ammolite/relays/relays/commands/toClient/AuthMessage.kt
@ -0,0 +1,37 @@
+/**
+ * Copyright (c) 2024 Vitor Pamplona
+ *
+ * Permission is hereby granted, free of charge, to any person obtaining a copy of
+ * this software and associated documentation files (the "Software"), to deal in
+ * the Software without restriction, including without limitation the rights to use,
+ * copy, modify, merge, publish, distribute, sublicense, and/or sell copies of the
+ * Software, and to permit persons to whom the Software is furnished to do so,
+ * subject to the following conditions:
+ *
+ * The above copyright notice and this permission notice shall be included in all
+ * copies or substantial portions of the Software.
+ *
+ * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+ * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS
+ * FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR
+ * COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN
+ * AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
+ * WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
+ */
+package com.vitorpamplona.ammolite.relays.relays.commands.toClient
+
+import com.fasterxml.jackson.databind.JsonNode
+
+class AuthMessage(
+    val challenge: String,
+) : Message {
+    companion object {
+        const val LABEL = "AUTH"
+
+        @JvmStatic
+        fun parse(msgArray: JsonNode): AuthMessage =
+            AuthMessage(
+                msgArray.get(1).asText(),
+            )
+    }
+}
--- a/ammolite/src/main/java/com/vitorpamplona/ammolite/relays/relays/commands/toClient/ClosedMessage.kt
+++ b/ammolite/src/main/java/com/vitorpamplona/ammolite/relays/relays/commands/toClient/ClosedMessage.kt
@ -0,0 +1,39 @@
+/**
+ * Copyright (c) 2024 Vitor Pamplona
+ *
+ * Permission is hereby granted, free of charge, to any person obtaining a copy of
+ * this software and associated documentation files (the "Software"), to deal in
+ * the Software without restriction, including without limitation the rights to use,
+ * copy, modify, merge, publish, distribute, sublicense, and/or sell copies of the
+ * Software, and to permit persons to whom the Software is furnished to do so,
+ * subject to the following conditions:
+ *
+ * The above copyright notice and this permission notice shall be included in all
+ * copies or substantial portions of the Software.
+ *
+ * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+ * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS
+ * FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR
+ * COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN
+ * AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
+ * WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
+ */
+package com.vitorpamplona.ammolite.relays.relays.commands.toClient
+
+import com.fasterxml.jackson.databind.JsonNode
+
+class ClosedMessage(
+    val subscriptionId: String,
+    val message: String,
+) : Message {
+    companion object {
+        const val LABEL = "CLOSED"
+
+        @JvmStatic
+        fun parse(msgArray: JsonNode): ClosedMessage =
+            ClosedMessage(
+                msgArray[1].asText(),
+                msgArray[2].asText(),
+            )
+    }
+}
--- a/ammolite/src/main/java/com/vitorpamplona/ammolite/relays/relays/commands/toClient/EoseMessage.kt
+++ b/ammolite/src/main/java/com/vitorpamplona/ammolite/relays/relays/commands/toClient/EoseMessage.kt
@ -0,0 +1,37 @@
+/**
+ * Copyright (c) 2024 Vitor Pamplona
+ *
+ * Permission is hereby granted, free of charge, to any person obtaining a copy of
+ * this software and associated documentation files (the "Software"), to deal in
+ * the Software without restriction, including without limitation the rights to use,
+ * copy, modify, merge, publish, distribute, sublicense, and/or sell copies of the
+ * Software, and to permit persons to whom the Software is furnished to do so,
+ * subject to the following conditions:
+ *
+ * The above copyright notice and this permission notice shall be included in all
+ * copies or substantial portions of the Software.
+ *
+ * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+ * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS
+ * FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR
+ * COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN
+ * AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
+ * WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
+ */
+package com.vitorpamplona.ammolite.relays.relays.commands.toClient
+
+import com.fasterxml.jackson.databind.JsonNode
+
+class EoseMessage(
+    val subId: String,
+) : Message {
+    companion object {
+        const val LABEL = "EOSE"
+
+        @JvmStatic
+        fun parse(msgArray: JsonNode): EoseMessage =
+            EoseMessage(
+                msgArray.get(1).asText(),
+            )
+    }
+}
--- a/ammolite/src/main/java/com/vitorpamplona/ammolite/relays/relays/commands/toClient/EventMessage.kt
+++ b/ammolite/src/main/java/com/vitorpamplona/ammolite/relays/relays/commands/toClient/EventMessage.kt
@ -0,0 +1,41 @@
+/**
+ * Copyright (c) 2024 Vitor Pamplona
+ *
+ * Permission is hereby granted, free of charge, to any person obtaining a copy of
+ * this software and associated documentation files (the "Software"), to deal in
+ * the Software without restriction, including without limitation the rights to use,
+ * copy, modify, merge, publish, distribute, sublicense, and/or sell copies of the
+ * Software, and to permit persons to whom the Software is furnished to do so,
+ * subject to the following conditions:
+ *
+ * The above copyright notice and this permission notice shall be included in all
+ * copies or substantial portions of the Software.
+ *
+ * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+ * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS
+ * FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR
+ * COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN
+ * AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
+ * WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
+ */
+package com.vitorpamplona.ammolite.relays.relays.commands.toClient
+
+import com.fasterxml.jackson.databind.JsonNode
+import com.vitorpamplona.quartz.nip01Core.core.Event
+import com.vitorpamplona.quartz.nip01Core.jackson.EventMapper
+
+class EventMessage(
+    val subId: String,
+    val event: Event,
+) : Message {
+    companion object {
+        const val LABEL = "EVENT"
+
+        @JvmStatic
+        fun parse(msgArray: JsonNode): EventMessage =
+            EventMessage(
+                msgArray.get(1).asText(),
+                EventMapper.fromJson(msgArray.get(2)),
+            )
+    }
+}
--- a/ammolite/src/main/java/com/vitorpamplona/ammolite/relays/relays/commands/toClient/Message.kt
+++ b/ammolite/src/main/java/com/vitorpamplona/ammolite/relays/relays/commands/toClient/Message.kt
@ -0,0 +1,23 @@
+/**
+ * Copyright (c) 2024 Vitor Pamplona
+ *
+ * Permission is hereby granted, free of charge, to any person obtaining a copy of
+ * this software and associated documentation files (the "Software"), to deal in
+ * the Software without restriction, including without limitation the rights to use,
+ * copy, modify, merge, publish, distribute, sublicense, and/or sell copies of the
+ * Software, and to permit persons to whom the Software is furnished to do so,
+ * subject to the following conditions:
+ *
+ * The above copyright notice and this permission notice shall be included in all
+ * copies or substantial portions of the Software.
+ *
+ * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+ * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS
+ * FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR
+ * COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN
+ * AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
+ * WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
+ */
+package com.vitorpamplona.ammolite.relays.relays.commands.toClient
+
+interface Message
--- a/ammolite/src/main/java/com/vitorpamplona/ammolite/relays/relays/commands/toClient/NoticeMessage.kt
+++ b/ammolite/src/main/java/com/vitorpamplona/ammolite/relays/relays/commands/toClient/NoticeMessage.kt
@ -0,0 +1,37 @@
+/**
+ * Copyright (c) 2024 Vitor Pamplona
+ *
+ * Permission is hereby granted, free of charge, to any person obtaining a copy of
+ * this software and associated documentation files (the "Software"), to deal in
+ * the Software without restriction, including without limitation the rights to use,
+ * copy, modify, merge, publish, distribute, sublicense, and/or sell copies of the
+ * Software, and to permit persons to whom the Software is furnished to do so,
+ * subject to the following conditions:
+ *
+ * The above copyright notice and this permission notice shall be included in all
+ * copies or substantial portions of the Software.
+ *
+ * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+ * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS
+ * FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR
+ * COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN
+ * AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
+ * WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
+ */
+package com.vitorpamplona.ammolite.relays.relays.commands.toClient
+
+import com.fasterxml.jackson.databind.JsonNode
+
+class NoticeMessage(
+    val message: String,
+) : Message {
+    companion object {
+        const val LABEL = "NOTICE"
+
+        @JvmStatic
+        fun parse(msgArray: JsonNode): NoticeMessage =
+            NoticeMessage(
+                msgArray.get(1).asText(),
+            )
+    }
+}
--- a/ammolite/src/main/java/com/vitorpamplona/ammolite/relays/relays/commands/toClient/NotifyMessage.kt
+++ b/ammolite/src/main/java/com/vitorpamplona/ammolite/relays/relays/commands/toClient/NotifyMessage.kt
@ -0,0 +1,37 @@
+/**
+ * Copyright (c) 2024 Vitor Pamplona
+ *
+ * Permission is hereby granted, free of charge, to any person obtaining a copy of
+ * this software and associated documentation files (the "Software"), to deal in
+ * the Software without restriction, including without limitation the rights to use,
+ * copy, modify, merge, publish, distribute, sublicense, and/or sell copies of the
+ * Software, and to permit persons to whom the Software is furnished to do so,
+ * subject to the following conditions:
+ *
+ * The above copyright notice and this permission notice shall be included in all
+ * copies or substantial portions of the Software.
+ *
+ * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+ * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS
+ * FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR
+ * COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN
+ * AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
+ * WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
+ */
+package com.vitorpamplona.ammolite.relays.relays.commands.toClient
+
+import com.fasterxml.jackson.databind.JsonNode
+
+class NotifyMessage(
+    val message: String,
+) : Message {
+    companion object {
+        const val LABEL = "NOTIFY"
+
+        @JvmStatic
+        fun parse(msgArray: JsonNode): NotifyMessage =
+            NotifyMessage(
+                msgArray.get(1).asText(),
+            )
+    }
+}
--- a/ammolite/src/main/java/com/vitorpamplona/ammolite/relays/relays/commands/toClient/OkMessage.kt
+++ b/ammolite/src/main/java/com/vitorpamplona/ammolite/relays/relays/commands/toClient/OkMessage.kt
@ -0,0 +1,42 @@
+/**
+ * Copyright (c) 2024 Vitor Pamplona
+ *
+ * Permission is hereby granted, free of charge, to any person obtaining a copy of
+ * this software and associated documentation files (the "Software"), to deal in
+ * the Software without restriction, including without limitation the rights to use,
+ * copy, modify, merge, publish, distribute, sublicense, and/or sell copies of the
+ * Software, and to permit persons to whom the Software is furnished to do so,
+ * subject to the following conditions:
+ *
+ * The above copyright notice and this permission notice shall be included in all
+ * copies or substantial portions of the Software.
+ *
+ * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+ * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS
+ * FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR
+ * COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN
+ * AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
+ * WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
+ */
+package com.vitorpamplona.ammolite.relays.relays.commands.toClient
+
+import com.fasterxml.jackson.databind.JsonNode
+import com.vitorpamplona.quartz.nip01Core.HexKey
+
+class OkMessage(
+    val eventId: HexKey,
+    val success: Boolean,
+    val message: String,
+) : Message {
+    companion object {
+        const val LABEL = "OK"
+
+        @JvmStatic
+        fun parse(msgArray: JsonNode): OkMessage =
+            OkMessage(
+                msgArray[1].asText(),
+                msgArray[2].asBoolean(),
+                if (msgArray.size() > 2) msgArray[3].asText() else "",
+            )
+    }
+}
--- a/ammolite/src/main/java/com/vitorpamplona/ammolite/relays/relays/commands/toClient/ToClientParser.kt
+++ b/ammolite/src/main/java/com/vitorpamplona/ammolite/relays/relays/commands/toClient/ToClientParser.kt
@ -0,0 +1,40 @@
+/**
+ * Copyright (c) 2024 Vitor Pamplona
+ *
+ * Permission is hereby granted, free of charge, to any person obtaining a copy of
+ * this software and associated documentation files (the "Software"), to deal in
+ * the Software without restriction, including without limitation the rights to use,
+ * copy, modify, merge, publish, distribute, sublicense, and/or sell copies of the
+ * Software, and to permit persons to whom the Software is furnished to do so,
+ * subject to the following conditions:
+ *
+ * The above copyright notice and this permission notice shall be included in all
+ * copies or substantial portions of the Software.
+ *
+ * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+ * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS
+ * FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR
+ * COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN
+ * AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
+ * WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
+ */
+package com.vitorpamplona.ammolite.relays.relays.commands.toClient
+
+import com.vitorpamplona.quartz.nip01Core.jackson.EventMapper
+
+class ToClientParser {
+    fun parse(newMessage: String): Message? {
+        val msgArray = EventMapper.mapper.readTree(newMessage)
+        val type = msgArray.get(0).asText()
+        return when (type) {
+            EventMessage.LABEL -> EventMessage.parse(msgArray)
+            EoseMessage.LABEL -> EoseMessage.parse(msgArray)
+            NoticeMessage.LABEL -> NoticeMessage.parse(msgArray)
+            OkMessage.LABEL -> OkMessage.parse(msgArray)
+            AuthMessage.LABEL -> AuthMessage.parse(msgArray)
+            NotifyMessage.LABEL -> NotifyMessage.parse(msgArray)
+            ClosedMessage.LABEL -> ClosedMessage.parse(msgArray)
+            else -> null
+        }
+    }
+}
--- a/ammolite/src/main/java/com/vitorpamplona/ammolite/relays/relays/commands/toRelay/AuthCmd.kt
+++ b/ammolite/src/main/java/com/vitorpamplona/ammolite/relays/relays/commands/toRelay/AuthCmd.kt
@ -0,0 +1,42 @@
+/**
+ * Copyright (c) 2024 Vitor Pamplona
+ *
+ * Permission is hereby granted, free of charge, to any person obtaining a copy of
+ * this software and associated documentation files (the "Software"), to deal in
+ * the Software without restriction, including without limitation the rights to use,
+ * copy, modify, merge, publish, distribute, sublicense, and/or sell copies of the
+ * Software, and to permit persons to whom the Software is furnished to do so,
+ * subject to the following conditions:
+ *
+ * The above copyright notice and this permission notice shall be included in all
+ * copies or substantial portions of the Software.
+ *
+ * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+ * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS
+ * FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR
+ * COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN
+ * AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
+ * WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
+ */
+package com.vitorpamplona.ammolite.relays.relays.commands.toRelay
+
+import com.fasterxml.jackson.databind.JsonNode
+import com.vitorpamplona.quartz.nip01Core.jackson.EventMapper
+import com.vitorpamplona.quartz.nip42RelayAuth.RelayAuthEvent
+
+class AuthCmd(
+    val event: RelayAuthEvent,
+) : Command {
+    companion object {
+        const val LABEL = "AUTH"
+
+        @JvmStatic
+        fun toJson(authEvent: RelayAuthEvent): String = """["AUTH",${authEvent.toJson()}]"""
+
+        @JvmStatic
+        fun parse(msgArray: JsonNode): AuthCmd =
+            AuthCmd(
+                EventMapper.fromJson(msgArray.get(1)) as RelayAuthEvent,
+            )
+    }
+}
--- a/ammolite/src/main/java/com/vitorpamplona/ammolite/relays/relays/commands/toRelay/CloseCmd.kt
+++ b/ammolite/src/main/java/com/vitorpamplona/ammolite/relays/relays/commands/toRelay/CloseCmd.kt
@ -0,0 +1,40 @@
+/**
+ * Copyright (c) 2024 Vitor Pamplona
+ *
+ * Permission is hereby granted, free of charge, to any person obtaining a copy of
+ * this software and associated documentation files (the "Software"), to deal in
+ * the Software without restriction, including without limitation the rights to use,
+ * copy, modify, merge, publish, distribute, sublicense, and/or sell copies of the
+ * Software, and to permit persons to whom the Software is furnished to do so,
+ * subject to the following conditions:
+ *
+ * The above copyright notice and this permission notice shall be included in all
+ * copies or substantial portions of the Software.
+ *
+ * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+ * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS
+ * FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR
+ * COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN
+ * AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
+ * WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
+ */
+package com.vitorpamplona.ammolite.relays.relays.commands.toRelay
+
+import com.fasterxml.jackson.databind.JsonNode
+
+class CloseCmd(
+    val subscriptionId: String,
+) : Command {
+    companion object {
+        const val LABEL = "CLOSE"
+
+        @JvmStatic
+        fun toJson(subscriptionId: String): String = """["CLOSE","$subscriptionId"]"""
+
+        @JvmStatic
+        fun parse(msgArray: JsonNode): CloseCmd =
+            CloseCmd(
+                msgArray.get(1).asText(),
+            )
+    }
+}
--- a/ammolite/src/main/java/com/vitorpamplona/ammolite/relays/relays/commands/toRelay/Command.kt
+++ b/ammolite/src/main/java/com/vitorpamplona/ammolite/relays/relays/commands/toRelay/Command.kt
@ -0,0 +1,23 @@
+/**
+ * Copyright (c) 2024 Vitor Pamplona
+ *
+ * Permission is hereby granted, free of charge, to any person obtaining a copy of
+ * this software and associated documentation files (the "Software"), to deal in
+ * the Software without restriction, including without limitation the rights to use,
+ * copy, modify, merge, publish, distribute, sublicense, and/or sell copies of the
+ * Software, and to permit persons to whom the Software is furnished to do so,
+ * subject to the following conditions:
+ *
+ * The above copyright notice and this permission notice shall be included in all
+ * copies or substantial portions of the Software.
+ *
+ * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+ * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS
+ * FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR
+ * COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN
+ * AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
+ * WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
+ */
+package com.vitorpamplona.ammolite.relays.relays.commands.toRelay
+
+interface Command
--- a/ammolite/src/main/java/com/vitorpamplona/ammolite/relays/relays/commands/toRelay/CountCmd.kt
+++ b/ammolite/src/main/java/com/vitorpamplona/ammolite/relays/relays/commands/toRelay/CountCmd.kt
@ -0,0 +1,65 @@
+/**
+ * Copyright (c) 2024 Vitor Pamplona
+ *
+ * Permission is hereby granted, free of charge, to any person obtaining a copy of
+ * this software and associated documentation files (the "Software"), to deal in
+ * the Software without restriction, including without limitation the rights to use,
+ * copy, modify, merge, publish, distribute, sublicense, and/or sell copies of the
+ * Software, and to permit persons to whom the Software is furnished to do so,
+ * subject to the following conditions:
+ *
+ * The above copyright notice and this permission notice shall be included in all
+ * copies or substantial portions of the Software.
+ *
+ * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+ * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS
+ * FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR
+ * COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN
+ * AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
+ * WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
+ */
+package com.vitorpamplona.ammolite.relays.relays.commands.toRelay
+
+import com.fasterxml.jackson.databind.JsonNode
+import com.fasterxml.jackson.databind.node.ObjectNode
+import com.vitorpamplona.quartz.nip01Core.jackson.EventMapper
+import com.vitorpamplona.quartz.nip01Core.relays.Filter
+import com.vitorpamplona.quartz.nip01Core.relays.FilterDeserializer
+import com.vitorpamplona.quartz.utils.joinToStringLimited
+
+class CountCmd(
+    val subscriptionId: String,
+    val filters: List<Filter>,
+) : Command {
+    companion object {
+        const val LABEL = "COUNT"
+
+        @JvmStatic
+        fun toJson(
+            requestId: String,
+            filters: List<Filter>,
+        ): String =
+            filters.joinToStringLimited(
+                separator = ",",
+                limit = 19,
+                prefix = """["COUNT","$requestId",""",
+                postfix = "]",
+            ) {
+                it.toJson()
+            }
+
+        @JvmStatic
+        fun parse(msgArray: JsonNode): CountCmd {
+            val filters = mutableListOf<Filter>()
+
+            for (i in 2 until msgArray.size()) {
+                val json = EventMapper.mapper.readTree(msgArray.get(i).asText())
+                if (json is ObjectNode) {
+                    filters.add(FilterDeserializer.fromJson(json))
+                }
+            }
+
+            return CountCmd(msgArray.get(1).asText(), filters)
+        }
+    }
+}
--- a/ammolite/src/main/java/com/vitorpamplona/ammolite/relays/relays/commands/toRelay/EventCmd.kt
+++ b/ammolite/src/main/java/com/vitorpamplona/ammolite/relays/relays/commands/toRelay/EventCmd.kt
@ -0,0 +1,42 @@
+/**
+ * Copyright (c) 2024 Vitor Pamplona
+ *
+ * Permission is hereby granted, free of charge, to any person obtaining a copy of
+ * this software and associated documentation files (the "Software"), to deal in
+ * the Software without restriction, including without limitation the rights to use,
+ * copy, modify, merge, publish, distribute, sublicense, and/or sell copies of the
+ * Software, and to permit persons to whom the Software is furnished to do so,
+ * subject to the following conditions:
+ *
+ * The above copyright notice and this permission notice shall be included in all
+ * copies or substantial portions of the Software.
+ *
+ * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+ * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS
+ * FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR
+ * COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN
+ * AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
+ * WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
+ */
+package com.vitorpamplona.ammolite.relays.relays.commands.toRelay
+
+import com.fasterxml.jackson.databind.JsonNode
+import com.vitorpamplona.quartz.nip01Core.core.Event
+import com.vitorpamplona.quartz.nip01Core.jackson.EventMapper
+
+class EventCmd(
+    val event: Event,
+) : Command {
+    companion object {
+        const val LABEL = "EVENT"
+
+        @JvmStatic
+        fun toJson(event: Event): String = """["EVENT",${event.toJson()}]"""
+
+        @JvmStatic
+        fun parse(msgArray: JsonNode): EventCmd =
+            EventCmd(
+                EventMapper.fromJson(msgArray.get(1)),
+            )
+    }
+}
--- a/ammolite/src/main/java/com/vitorpamplona/ammolite/relays/relays/commands/toRelay/ReqCmd.kt
+++ b/ammolite/src/main/java/com/vitorpamplona/ammolite/relays/relays/commands/toRelay/ReqCmd.kt
@ -0,0 +1,66 @@
+/**
+ * Copyright (c) 2024 Vitor Pamplona
+ *
+ * Permission is hereby granted, free of charge, to any person obtaining a copy of
+ * this software and associated documentation files (the "Software"), to deal in
+ * the Software without restriction, including without limitation the rights to use,
+ * copy, modify, merge, publish, distribute, sublicense, and/or sell copies of the
+ * Software, and to permit persons to whom the Software is furnished to do so,
+ * subject to the following conditions:
+ *
+ * The above copyright notice and this permission notice shall be included in all
+ * copies or substantial portions of the Software.
+ *
+ * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+ * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS
+ * FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR
+ * COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN
+ * AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
+ * WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
+ */
+package com.vitorpamplona.ammolite.relays.relays.commands.toRelay
+
+import com.fasterxml.jackson.databind.JsonNode
+import com.fasterxml.jackson.databind.node.ObjectNode
+import com.vitorpamplona.quartz.nip01Core.jackson.EventMapper
+import com.vitorpamplona.quartz.nip01Core.relays.Filter
+import com.vitorpamplona.quartz.nip01Core.relays.FilterDeserializer
+import com.vitorpamplona.quartz.utils.joinToStringLimited
+
+class ReqCmd(
+    val subscriptionId: String,
+    val filters: List<Filter>,
+) : Command {
+    companion object {
+        const val LABEL = "REQ"
+
+        @JvmStatic
+        fun toJson(
+            requestId: String,
+            filters: List<Filter>,
+            limit: Int = 19,
+        ): String =
+            filters.joinToStringLimited(
+                separator = ",",
+                limit = limit,
+                prefix = """["REQ","$requestId",""",
+                postfix = "]",
+            ) {
+                it.toJson()
+            }
+
+        @JvmStatic
+        fun parse(msgArray: JsonNode): ReqCmd {
+            val filters = mutableListOf<Filter>()
+
+            for (i in 2 until msgArray.size()) {
+                val json = EventMapper.mapper.readTree(msgArray.get(i).asText())
+                if (json is ObjectNode) {
+                    filters.add(FilterDeserializer.fromJson(json))
+                }
+            }
+
+            return ReqCmd(msgArray.get(1).asText(), filters)
+        }
+    }
+}
--- a/ammolite/src/main/java/com/vitorpamplona/ammolite/relays/relays/commands/toRelay/ToRelayParser.kt
+++ b/ammolite/src/main/java/com/vitorpamplona/ammolite/relays/relays/commands/toRelay/ToRelayParser.kt
@ -0,0 +1,38 @@
+/**
+ * Copyright (c) 2024 Vitor Pamplona
+ *
+ * Permission is hereby granted, free of charge, to any person obtaining a copy of
+ * this software and associated documentation files (the "Software"), to deal in
+ * the Software without restriction, including without limitation the rights to use,
+ * copy, modify, merge, publish, distribute, sublicense, and/or sell copies of the
+ * Software, and to permit persons to whom the Software is furnished to do so,
+ * subject to the following conditions:
+ *
+ * The above copyright notice and this permission notice shall be included in all
+ * copies or substantial portions of the Software.
+ *
+ * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+ * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS
+ * FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR
+ * COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN
+ * AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
+ * WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
+ */
+package com.vitorpamplona.ammolite.relays.relays.commands.toRelay
+
+import com.vitorpamplona.quartz.nip01Core.jackson.EventMapper
+
+class ToRelayParser {
+    fun parse(newMessage: String): Command? {
+        val msgArray = EventMapper.mapper.readTree(newMessage)
+        val type = msgArray.get(0).asText()
+        return when (type) {
+            AuthCmd.LABEL -> AuthCmd.parse(msgArray)
+            CloseCmd.LABEL -> CloseCmd.parse(msgArray)
+            CountCmd.LABEL -> CountCmd.parse(msgArray)
+            EventCmd.LABEL -> EventCmd.parse(msgArray)
+            ReqCmd.LABEL -> ReqCmd.parse(msgArray)
+            else -> null
+        }
+    }
+}
--- a/benchmark/src/androidTest/java/com/vitorpamplona/quartz/benchmark/EventCmdHasherBenchmark.kt
+++ b/benchmark/src/androidTest/java/com/vitorpamplona/quartz/benchmark/EventCmdHasherBenchmark.kt
@ -40,7 +40,7 @@ import org.junit.runner.RunWith
 * result. Modify your code to see how it affects performance.
 */
@RunWith(AndroidJUnit4::class)
-class EventHasherBenchmark {
+class EventCmdHasherBenchmark {
    @get:Rule val benchmarkRule = BenchmarkRule()

    @Test
--- a/benchmark/src/androidTest/java/com/vitorpamplona/quartz/benchmark/EventCmdSerializerBenchmark.kt
+++ b/benchmark/src/androidTest/java/com/vitorpamplona/quartz/benchmark/EventCmdSerializerBenchmark.kt
@ -38,7 +38,7 @@ import java.security.MessageDigest
 * result. Modify your code to see how it affects performance.
 */
@RunWith(AndroidJUnit4::class)
-class EventSerializerBenchmark {
+class EventCmdSerializerBenchmark {
    @get:Rule val benchmarkRule = BenchmarkRule()

    @Test
--- a/quartz/src/main/java/com/vitorpamplona/quartz/nip01Core/relays/FilterDeserializer.kt
+++ b/quartz/src/main/java/com/vitorpamplona/quartz/nip01Core/relays/FilterDeserializer.kt
@ -0,0 +1,47 @@
+/**
+ * Copyright (c) 2024 Vitor Pamplona
+ *
+ * Permission is hereby granted, free of charge, to any person obtaining a copy of
+ * this software and associated documentation files (the "Software"), to deal in
+ * the Software without restriction, including without limitation the rights to use,
+ * copy, modify, merge, publish, distribute, sublicense, and/or sell copies of the
+ * Software, and to permit persons to whom the Software is furnished to do so,
+ * subject to the following conditions:
+ *
+ * The above copyright notice and this permission notice shall be included in all
+ * copies or substantial portions of the Software.
+ *
+ * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+ * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS
+ * FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR
+ * COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN
+ * AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
+ * WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
+ */
+package com.vitorpamplona.quartz.nip01Core.relays
+
+import com.fasterxml.jackson.databind.node.ObjectNode
+
+class FilterDeserializer {
+    companion object {
+        fun fromJson(jsonObject: ObjectNode): Filter {
+            val tags = mutableListOf<String>()
+            jsonObject.fieldNames().forEach {
+                if (it.startsWith("#")) {
+                    tags.add(it.substring(1))
+                }
+            }
+
+            return Filter(
+                ids = jsonObject.get("ids").map { it.asText() },
+                authors = jsonObject.get("authors").map { it.asText() },
+                kinds = jsonObject.get("kinds").map { it.asInt() },
+                tags = tags.associateWith { jsonObject.get(it).map { it.asText() } },
+                since = jsonObject.get("since").asLong(),
+                until = jsonObject.get("until").asLong(),
+                limit = jsonObject.get("limit").asInt(),
+                search = jsonObject.get("search").asText(),
+            )
+        }
+    }
+}