diff --git a/ammolite/src/main/java/com/vitorpamplona/ammolite/relays/Relay.kt b/ammolite/src/main/java/com/vitorpamplona/ammolite/relays/Relay.kt
index 58263f48c..dfd611544 100644
--- 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) }
 
diff --git a/ammolite/src/main/java/com/vitorpamplona/ammolite/relays/RelayPool.kt b/ammolite/src/main/java/com/vitorpamplona/ammolite/relays/RelayPool.kt
index 23e36e222..5d000672b 100644
--- 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) {
diff --git a/ammolite/src/main/java/com/vitorpamplona/ammolite/relays/relays/SimpleRelay.kt b/ammolite/src/main/java/com/vitorpamplona/ammolite/relays/relays/SimpleClientRelay.kt
similarity index 53%
rename from ammolite/src/main/java/com/vitorpamplona/ammolite/relays/relays/SimpleRelay.kt
rename to ammolite/src/main/java/com/vitorpamplona/ammolite/relays/relays/SimpleClientRelay.kt
index e43e55aa3..170b612c0 100644
--- a/ammolite/src/main/java/com/vitorpamplona/ammolite/relays/relays/SimpleRelay.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,
+        )
     }
 }
diff --git 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
new file mode 100644
index 000000000..f7c8b7631
--- /dev/null
+++ 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(),
+            )
+    }
+}
diff --git 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
new file mode 100644
index 000000000..2bf006463
--- /dev/null
+++ 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(),
+            )
+    }
+}
diff --git 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
new file mode 100644
index 000000000..26bfdd01f
--- /dev/null
+++ 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(),
+            )
+    }
+}
diff --git 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
new file mode 100644
index 000000000..5445f7ede
--- /dev/null
+++ 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)),
+            )
+    }
+}
diff --git 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
new file mode 100644
index 000000000..3cacc747e
--- /dev/null
+++ 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
diff --git 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
new file mode 100644
index 000000000..c362b3d4d
--- /dev/null
+++ 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(),
+            )
+    }
+}
diff --git 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
new file mode 100644
index 000000000..1442bb767
--- /dev/null
+++ 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(),
+            )
+    }
+}
diff --git 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
new file mode 100644
index 000000000..e823007ba
--- /dev/null
+++ 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 "",
+            )
+    }
+}
diff --git 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
new file mode 100644
index 000000000..0d074617f
--- /dev/null
+++ 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
+        }
+    }
+}
diff --git 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
new file mode 100644
index 000000000..e83339182
--- /dev/null
+++ 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,
+            )
+    }
+}
diff --git 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
new file mode 100644
index 000000000..431c26d31
--- /dev/null
+++ 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(),
+            )
+    }
+}
diff --git 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
new file mode 100644
index 000000000..cef2cf29e
--- /dev/null
+++ 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
diff --git 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
new file mode 100644
index 000000000..662e8772a
--- /dev/null
+++ 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)
+        }
+    }
+}
diff --git 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
new file mode 100644
index 000000000..70a91e7fc
--- /dev/null
+++ 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)),
+            )
+    }
+}
diff --git 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
new file mode 100644
index 000000000..ee9f71cc4
--- /dev/null
+++ 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)
+        }
+    }
+}
diff --git 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
new file mode 100644
index 000000000..9e0692f95
--- /dev/null
+++ 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
+        }
+    }
+}
diff --git a/benchmark/src/androidTest/java/com/vitorpamplona/quartz/benchmark/EventHasherBenchmark.kt b/benchmark/src/androidTest/java/com/vitorpamplona/quartz/benchmark/EventCmdHasherBenchmark.kt
similarity index 98%
rename from benchmark/src/androidTest/java/com/vitorpamplona/quartz/benchmark/EventHasherBenchmark.kt
rename to benchmark/src/androidTest/java/com/vitorpamplona/quartz/benchmark/EventCmdHasherBenchmark.kt
index 866bcc55c..9911848b4 100644
--- a/benchmark/src/androidTest/java/com/vitorpamplona/quartz/benchmark/EventHasherBenchmark.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
diff --git a/benchmark/src/androidTest/java/com/vitorpamplona/quartz/benchmark/EventSerializerBenchmark.kt b/benchmark/src/androidTest/java/com/vitorpamplona/quartz/benchmark/EventCmdSerializerBenchmark.kt
similarity index 98%
rename from benchmark/src/androidTest/java/com/vitorpamplona/quartz/benchmark/EventSerializerBenchmark.kt
rename to benchmark/src/androidTest/java/com/vitorpamplona/quartz/benchmark/EventCmdSerializerBenchmark.kt
index f02909288..c368eb390 100644
--- a/benchmark/src/androidTest/java/com/vitorpamplona/quartz/benchmark/EventSerializerBenchmark.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
diff --git a/quartz/src/main/java/com/vitorpamplona/quartz/nip01Core/relays/FilterDeserializer.kt b/quartz/src/main/java/com/vitorpamplona/quartz/nip01Core/relays/FilterDeserializer.kt
new file mode 100644
index 000000000..72713181f
--- /dev/null
+++ 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(),
+            )
+        }
+    }
+}