From c801d33f44ae346d01e19e47a3b97c8405f4d5b4 Mon Sep 17 00:00:00 2001
From: Anton Tananaev <anton@traccar.org>
Date: Wed, 12 Oct 2022 17:47:35 -0700
Subject: Fix G1RUS decoding

---
 src/main/java/org/traccar/protocol/G1rusProtocolDecoder.java | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

(limited to 'src/main/java')

diff --git a/src/main/java/org/traccar/protocol/G1rusProtocolDecoder.java b/src/main/java/org/traccar/protocol/G1rusProtocolDecoder.java
index e974e446d..17cfbc1eb 100644
--- a/src/main/java/org/traccar/protocol/G1rusProtocolDecoder.java
+++ b/src/main/java/org/traccar/protocol/G1rusProtocolDecoder.java
@@ -124,8 +124,12 @@ public class G1rusProtocolDecoder extends BaseProtocolDecoder {
 
         ByteBuf buf = (ByteBuf) msg;
 
+        buf.readUnsignedByte(); // header
+        buf.readUnsignedByte(); // version
+
         int type = buf.readUnsignedByte();
         String imei = String.valueOf(buf.readLong());
+        buf.readerIndex(buf.readerIndex() - 1);
         DeviceSession deviceSession = getDeviceSession(channel, remoteAddress, imei);
         if (deviceSession == null) {
             return null;
@@ -144,14 +148,14 @@ public class G1rusProtocolDecoder extends BaseProtocolDecoder {
                 if (BitUtil.to(subtype, 6) == MSG_REGULAR) {
                     positions.add(decodeRegular(deviceSession, buf, subtype));
                 } else {
-                    buf.skipBytes(length);
+                    buf.skipBytes(length - 1);
                 }
             }
             return positions.isEmpty() ? null : positions;
 
         }
 
-        buf.skipBytes(2);
+        buf.readUnsignedShort(); // checksum
         buf.readUnsignedByte(); // tail
 
         return null;
-- 
cgit v1.2.3