highperfocused/amethyst
1
0
Fork 0
mirror of https://github.com/vitorpamplona/amethyst.git synced 2025-10-09 20:22:41 +02:00
Code Issues Packages Projects Releases Wiki Activity

Better logs on BasicRelayClient

Browse Source
This commit is contained in:
Vitor Pamplona
2025-09-24 19:24:01 -04:00
parent 8466020137
commit d04cf97418
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
quartz/src/commonMain/kotlin/com/vitorpamplona/quartz/nip01Core/relay/client/single/basic/BasicRelayClient.kt
View File

@@ -174,6 +174,8 @@ open class BasicRelayClient(
} }
override fun onMessage(text: String) { override fun onMessage(text: String) {
// Log.d(logTag, "Receiving: $text")
if (text.startsWith(EVENT_MESSAGE_PREFIX)) { if (text.startsWith(EVENT_MESSAGE_PREFIX)) {
// defers the parsing of ["EVENTS" to avoid blocking the HTTP thread // defers the parsing of ["EVENTS" to avoid blocking the HTTP thread
scope.launch(Dispatchers.Default) { scope.launch(Dispatchers.Default) {
@@ -239,7 +241,7 @@ open class BasicRelayClient(
text: String, text: String,
onConnected: () -> Unit, onConnected: () -> Unit,
) { ) {
// Log.d(logTag, "Receiving: $text") // Log.d(logTag, "Processing: $text")
stats.addBytesReceived(text.bytesUsedInMemory()) stats.addBytesReceived(text.bytesUsedInMemory())
try { try {
@@ -465,7 +467,7 @@ open class BasicRelayClient(
) )
} }
socket?.let { socket?.let {
Log.d(logTag, "Sending: $str") // Log.d(logTag, "Sending (${str.length} chars): $str")
val result = it.send(str) val result = it.send(str)
listener.onSend(this@BasicRelayClient, str, result) listener.onSend(this@BasicRelayClient, str, result)
stats.addBytesSent(str.bytesUsedInMemory()) stats.addBytesSent(str.bytesUsedInMemory())