|
|
|
@ -36,22 +36,22 @@ public class SocketHandler extends SimpleChannelInboundHandler<SocketPayload> {
|
|
|
|
|
|
|
|
|
|
try { |
|
|
|
|
logger.debug("==================== [SocketHandler channelRead0 ] ==================== "); |
|
|
|
|
logger.debug("AUTH KEY ===> {}", payload.getAuthKey()); |
|
|
|
|
// logger.debug("AUTH KEY ===> {}", payload.getAuthKey());
|
|
|
|
|
|
|
|
|
|
if(payload.getAuthKey().isEmpty()) { |
|
|
|
|
logger.info("====== auth key is empty ======"); |
|
|
|
|
// logger.info("====== auth key is empty ======");
|
|
|
|
|
|
|
|
|
|
res.setRspCode("-2000"); |
|
|
|
|
res.setRspMessage("auth key is empty !"); |
|
|
|
|
|
|
|
|
|
} else if(!auth.checkAuthkey(payload.getAuthKey().trim())) { |
|
|
|
|
logger.info("===== auth key is invalid ====="); |
|
|
|
|
// logger.info("===== auth key is invalid =====");
|
|
|
|
|
|
|
|
|
|
res.setRspCode("-2000"); |
|
|
|
|
res.setRspMessage("Invalid auth key !"); |
|
|
|
|
|
|
|
|
|
} else { |
|
|
|
|
logger.info("====> SOCKET BODY : {}", JsonUtils.toJson(payload)); |
|
|
|
|
// logger.info("====> SOCKET BODY : {}", JsonUtils.toJson(payload));
|
|
|
|
|
|
|
|
|
|
switch (payload.getCommand().trim()) { |
|
|
|
|
case "OPENSKY" : |
|
|
|
@ -76,7 +76,7 @@ public class SocketHandler extends SimpleChannelInboundHandler<SocketPayload> {
|
|
|
|
|
|
|
|
|
|
e.printStackTrace(); |
|
|
|
|
} finally { |
|
|
|
|
logger.debug("res >>>" + JsonUtils.toJson(res)); |
|
|
|
|
// logger.debug("res >>>" + JsonUtils.toJson(res));
|
|
|
|
|
ctx.writeAndFlush(res); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|