[Refactor] Enhance error reporting in KurrentDB usecases and error handling

Update withRethrowingError to include full type name in usage context
Improve internalClientError messages by including original error details

Author: gradyzhuo

Sources/KurrentDB/Core/Additions/Usecase/StreamStream.swift

@@ -32,7 +32,7 @@ extension StreamStream where Transport == HTTP2ClientTransport.Posix {
             try await client.runConnections()
         }
 
-        return try await withRethrowingError(usage: #function) {
+        return try await withRethrowingError(usage: "\(Self.self)\(#function)") {
             try await send(connection: client, metadata: metadata, callOptions: callOptions)
         }
     }

Sources/KurrentDB/Core/Additions/Usecase/StreamUnary.swift

@@ -32,7 +32,7 @@ extension StreamUnary where Transport == HTTP2ClientTransport.Posix {
     }
 
     package func perform(client: GRPCClient<HTTP2ClientTransport.Posix>, metadata: Metadata, callOptions: CallOptions) async throws(KurrentError) -> Response {
-        try await withRethrowingError(usage: #function) {
+        try await withRethrowingError(usage: "\(Self.self)\(#function)") {
             try await withThrowingTaskGroup(of: Void.self) { group in
                 group.addTask {
                     try await client.runConnections()

Sources/KurrentDB/Core/Additions/Usecase/UnaryStream.swift

@@ -16,7 +16,7 @@ extension UnaryStream where Transport == HTTP2ClientTransport.Posix, Responses =
             try await client.runConnections()
         }
 
-        return try await withRethrowingError(usage: #function) {
+        return try await withRethrowingError(usage: "\(Self.self)\(#function)") {
             let metadata = Metadata(from: node.settings)
             let request = try request(metadata: metadata)
             return try await send(connection: client, request: request, callOptions: callOptions)
@@ -52,7 +52,7 @@ extension UnaryStream where Transport == HTTP2ClientTransport.Posix {
             try await client.runConnections()
         }
 
-        return try await withRethrowingError(usage: #function) {
+        return try await withRethrowingError(usage: "\(Self.self)\(#function)") {
             let request = try request(metadata: metadata)
             return try await send(connection: client, request: request, callOptions: callOptions)
         }

Sources/KurrentDB/Core/Additions/Usecase/UnaryUnary.swift

@@ -37,7 +37,7 @@ extension UnaryUnary where Transport == HTTP2ClientTransport.Posix {
     }
 
     package func perform(client: GRPCClient<HTTP2ClientTransport.Posix>, metadata: Metadata, callOptions: CallOptions) async throws(KurrentError) -> Response {
-        try await withRethrowingError(usage: #function) {
+        try await withRethrowingError(usage: "\(Self.self)\(#function)") {
             try await withThrowingTaskGroup(of: Void.self) { group in
                 group.addTask {
                     try await client.runConnections()

Sources/KurrentDB/Core/Error/KurrentError.swift

@@ -154,7 +154,7 @@ func withRethrowingError<T>(usage: String, action: @Sendable () async throws ->
     } catch let error as RPCError {
         try error.rethrow(usage: usage, origin: error)
     } catch {
-        throw .internalClientError(reason: "\(usage) failed.")
+        throw .internalClientError(reason: "\(usage) failed. error: \(error)")
     }
     throw .internalClientError(reason: "\(usage) failed.")
 }
@@ -167,7 +167,7 @@ func withRethrowingError<T>(usage: String, action: @Sendable () throws -> T) thr
     } catch let error as RPCError {
         try error.rethrow(usage: usage, origin: error)
     } catch {
-        throw .internalClientError(reason: "\(usage) failed.")
+        throw .internalClientError(reason: "\(usage) failed. error: \(error)")
     }
     throw .internalClientError(reason: "\(usage) failed.")
 }