@@ -28,6 +28,7 @@ import io.vertx.core.json.JsonObject
2828import io.vertx.core.net.NetSocket
2929import io.vertx.ext.bridge.BridgeEventType
3030import io.vertx.ext.eventbus.bridge.tcp.impl.protocol.FrameHelper
31+ import org.slf4j.LoggerFactory
3132import spp.protocol.auth.RolePermission
3233import spp.protocol.error.JWTVerificationException
3334import spp.protocol.error.MissingRemoteException
@@ -38,17 +39,17 @@ import spp.protocol.service.error.PermissionAccessDenied
3839
3940class TCPServiceFrameParser (val vertx : Vertx , val socket : NetSocket ) : Handler<AsyncResult<JsonObject>> {
4041
41- // companion object {
42- // private val log = LoggerFactory.getLogger(TCPServiceFrameParser::class.java)
43- // }
42+ companion object {
43+ private val log = LoggerFactory .getLogger(TCPServiceFrameParser ::class .java)
44+ }
4445
4546 override fun handle (event : AsyncResult <JsonObject >) {
4647 if (event.failed()) {
47- // log.error("Failed to receive frame", event.cause())
48+ log.error(" Failed to receive frame" , event.cause())
4849 return
4950 }
5051 val frame = event.result()
51- // log.trace("Received frame: {}", frame)
52+ log.trace(" Received frame: {}" , frame)
5253
5354 // todo: revisit this || after fixing below todo
5455 if (" message" == frame.getString(" type" ) || " send" == frame.getString(" type" )) {
@@ -65,36 +66,36 @@ class TCPServiceFrameParser(val vertx: Vertx, val socket: NetSocket) : Handler<A
6566 if (it.succeeded()) {
6667 if (it.result().body() is JsonObject ) {
6768 FrameHelper .sendFrame(
68- BridgeEventType .SEND .name.toLowerCase (),
69+ BridgeEventType .SEND .name.lowercase (),
6970 frame.getString(" replyAddress" ),
7071 it.result().body(),
7172 socket
7273 )
7374 } else if (it.result().body() is JsonArray ) {
7475 FrameHelper .sendFrame(
75- BridgeEventType .SEND .name.toLowerCase (),
76+ BridgeEventType .SEND .name.lowercase (),
7677 frame.getString(" replyAddress" ),
7778 it.result().body(),
7879 socket
7980 )
8081 } else if (it.result().body() is Boolean ) {
8182 FrameHelper .sendFrame(
82- BridgeEventType .SEND .name.toLowerCase (),
83+ BridgeEventType .SEND .name.lowercase (),
8384 frame.getString(" replyAddress" ),
8485 it.result().body(),
8586 socket
8687 )
8788 } else {
8889 FrameHelper .sendFrame(
89- BridgeEventType .SEND .name.toLowerCase (),
90+ BridgeEventType .SEND .name.lowercase (),
9091 frame.getString(" replyAddress" ),
9192 JsonObject .mapFrom(it.result().body()),
9293 socket
9394 )
9495 }
9596 } else {
9697 FrameHelper .sendFrame(
97- BridgeEventType .SEND .name.toLowerCase (),
98+ BridgeEventType .SEND .name.lowercase (),
9899 frame.getString(" replyAddress" ),
99100 JsonObject .mapFrom(it.cause()),
100101 socket
0 commit comments