From 143670869a3e3fe36ff8a6f7075cfb42cd0259d1 Mon Sep 17 00:00:00 2001 From: Anton Tananaev Date: Tue, 2 Mar 2021 22:49:37 -0800 Subject: Fix response --- .../org/traccar/protocol/DolphinProtocolDecoder.java | 20 +++++++++++++++----- 1 file changed, 15 insertions(+), 5 deletions(-) diff --git a/src/main/java/org/traccar/protocol/DolphinProtocolDecoder.java b/src/main/java/org/traccar/protocol/DolphinProtocolDecoder.java index 8e57b18b5..e882c2378 100644 --- a/src/main/java/org/traccar/protocol/DolphinProtocolDecoder.java +++ b/src/main/java/org/traccar/protocol/DolphinProtocolDecoder.java @@ -45,7 +45,7 @@ public class DolphinProtocolDecoder extends BaseProtocolDecoder { ByteBuf buf = (ByteBuf) msg; buf.readUnsignedShort(); // header - buf.readUnsignedIntLE(); // index + int index = (int) buf.readUnsignedIntLE(); buf.readUnsignedShort(); // version buf.readUnsignedShort(); // flags int type = buf.readUnsignedShortLE(); @@ -64,11 +64,21 @@ public class DolphinProtocolDecoder extends BaseProtocolDecoder { ByteBufUtil.getBytes(buf, buf.readerIndex(), length, false)); if (channel != null) { - DolphinMessages.DataPackResponse response = DolphinMessages.DataPackResponse.newBuilder() + byte[] responseData = DolphinMessages.DataPackResponse.newBuilder() .setResponse(DolphinMessages.DataPackResponseCode.DataPack_OK) - .build(); - channel.writeAndFlush(new NetworkMessage( - Unpooled.wrappedBuffer(response.toByteArray()), remoteAddress)); + .build() + .toByteArray(); + + ByteBuf response = Unpooled.buffer(); + response.writeShort(0xABAB); // header + response.writeIntLE(index); + response.writeShort(0); // flags + response.writeShortLE(DolphinMessages.MessageType.DataPack_Response.getNumber()); + response.writeIntLE(responseData.length); + response.writeIntLE(0); // reserved + response.writeBytes(responseData); + + channel.writeAndFlush(new NetworkMessage(response, remoteAddress)); } List positions = new LinkedList<>(); -- cgit v1.2.3