From 80a8996e0c11637253e3a6b2b5fb3ee58b2f36d0 Mon Sep 17 00:00:00 2001
From: a10zn8 <a1.cyb3r@gmail.com>
Date: Mon, 21 Aug 2023 14:48:53 +0400
Subject: [PATCH] move constant for cancelled

---
 src/main/kotlin/io/emeraldpay/dshackle/commons/constatnts.kt   | 1 +
 src/main/kotlin/io/emeraldpay/dshackle/reader/SpannedReader.kt | 3 ++-
 src/main/kotlin/io/emeraldpay/dshackle/rpc/NativeCall.kt       | 3 ++-
 3 files changed, 5 insertions(+), 2 deletions(-)

diff --git a/src/main/kotlin/io/emeraldpay/dshackle/commons/constatnts.kt b/src/main/kotlin/io/emeraldpay/dshackle/commons/constatnts.kt
index 271d7be4..066ca9c5 100644
--- a/src/main/kotlin/io/emeraldpay/dshackle/commons/constatnts.kt
+++ b/src/main/kotlin/io/emeraldpay/dshackle/commons/constatnts.kt
@@ -9,6 +9,7 @@ const val SPAN_REQUEST_API_TYPE = "request.api.type"
 const val SPAN_REQUEST_UPSTREAM_ID = "request.upstreamId"
 const val SPAN_REQUEST_ID = "request.id"
 const val SPAN_NO_RESPONSE_MESSAGE = "no-response.message"
+const val SPAN_REQUEST_CANCELLED = "cancelled"
 
 const val LOCAL_READER = "localReader"
 const val RPC_READER = "rpcReader"
diff --git a/src/main/kotlin/io/emeraldpay/dshackle/reader/SpannedReader.kt b/src/main/kotlin/io/emeraldpay/dshackle/reader/SpannedReader.kt
index 922c78c1..47c0486a 100644
--- a/src/main/kotlin/io/emeraldpay/dshackle/reader/SpannedReader.kt
+++ b/src/main/kotlin/io/emeraldpay/dshackle/reader/SpannedReader.kt
@@ -3,6 +3,7 @@ package io.emeraldpay.dshackle.reader
 import io.emeraldpay.dshackle.commons.SPAN_ERROR
 import io.emeraldpay.dshackle.commons.SPAN_READER_NAME
 import io.emeraldpay.dshackle.commons.SPAN_READER_RESULT
+import io.emeraldpay.dshackle.commons.SPAN_REQUEST_CANCELLED
 import io.emeraldpay.dshackle.commons.SPAN_REQUEST_INFO
 import io.emeraldpay.dshackle.commons.SPAN_STATUS_MESSAGE
 import io.emeraldpay.dshackle.data.HashId
@@ -39,7 +40,7 @@ class SpannedReader<K, D>(
             }
             .doOnNext { newSpan.end() }
             .doOnCancel {
-                newSpan.tag(SPAN_STATUS_MESSAGE, "cancelled").end()
+                newSpan.tag(SPAN_STATUS_MESSAGE, SPAN_REQUEST_CANCELLED).end()
             }
             .switchIfEmpty {
                 newSpan.tag(SPAN_READER_RESULT, "empty result").end()
diff --git a/src/main/kotlin/io/emeraldpay/dshackle/rpc/NativeCall.kt b/src/main/kotlin/io/emeraldpay/dshackle/rpc/NativeCall.kt
index dcc32d87..d7a46c51 100644
--- a/src/main/kotlin/io/emeraldpay/dshackle/rpc/NativeCall.kt
+++ b/src/main/kotlin/io/emeraldpay/dshackle/rpc/NativeCall.kt
@@ -27,6 +27,7 @@ import io.emeraldpay.dshackle.SilentException
 import io.emeraldpay.dshackle.commons.LOCAL_READER
 import io.emeraldpay.dshackle.commons.RPC_READER
 import io.emeraldpay.dshackle.commons.SPAN_ERROR
+import io.emeraldpay.dshackle.commons.SPAN_REQUEST_CANCELLED
 import io.emeraldpay.dshackle.commons.SPAN_REQUEST_ID
 import io.emeraldpay.dshackle.commons.SPAN_STATUS_MESSAGE
 import io.emeraldpay.dshackle.config.MainConfig
@@ -125,7 +126,7 @@ open class NativeCall(
                     }
                     .doOnNext { callRes -> completeSpan(callRes, requestCount) }
                     .doOnCancel {
-                        tracer.currentSpan()?.tag(SPAN_STATUS_MESSAGE, "cancel")?.end()
+                        tracer.currentSpan()?.tag(SPAN_STATUS_MESSAGE, SPAN_REQUEST_CANCELLED)?.end()
                     }
                     .contextWrite { ctx -> createTracingReactorContext(ctx, requestCount, requestId, requestSpan) }
             }