From 7ab4d181e1fa783de132309dc2a4edbe67d1b912 Mon Sep 17 00:00:00 2001
From: Anton Tananaev <anton.tananaev@gmail.com>
Date: Sun, 27 Oct 2013 13:18:42 +1300
Subject: Add atrack ack response

---
 src/org/traccar/protocol/AtrackProtocolDecoder.java | 20 ++++++++++++++++++--
 1 file changed, 18 insertions(+), 2 deletions(-)

(limited to 'src/org/traccar/protocol/AtrackProtocolDecoder.java')

diff --git a/src/org/traccar/protocol/AtrackProtocolDecoder.java b/src/org/traccar/protocol/AtrackProtocolDecoder.java
index 66ef0b322..8af89ff75 100644
--- a/src/org/traccar/protocol/AtrackProtocolDecoder.java
+++ b/src/org/traccar/protocol/AtrackProtocolDecoder.java
@@ -18,10 +18,12 @@ package org.traccar.protocol;
 import java.nio.charset.Charset;
 import java.util.Date;
 import org.jboss.netty.buffer.ChannelBuffer;
+import org.jboss.netty.buffer.ChannelBuffers;
 import org.jboss.netty.channel.Channel;
 import org.jboss.netty.channel.ChannelHandlerContext;
 import org.traccar.BaseProtocolDecoder;
 import org.traccar.ServerManager;
+import org.traccar.helper.Crc;
 import org.traccar.helper.Log;
 import org.traccar.model.ExtendedInfoFormatter;
 import org.traccar.model.Position;
@@ -47,6 +49,16 @@ public class AtrackProtocolDecoder extends BaseProtocolDecoder {
     private static final int MSG_HEARTBEAT = 0x1A;
     private static final int MSG_DATA = 0x10;
 
+    private static void sendResponse(Channel channel, long rawId, int index) {
+        if (channel != null) {
+            ChannelBuffer response = ChannelBuffers.directBuffer(12);
+            response.writeShort(0xfe02);
+            response.writeLong(rawId);
+            response.writeShort(index);
+            channel.write(response);
+        }
+    }
+    
     @Override
     protected Object decode(
             ChannelHandlerContext ctx, Channel channel, Object msg)
@@ -57,20 +69,24 @@ public class AtrackProtocolDecoder extends BaseProtocolDecoder {
         buf.skipBytes(2); // prefix
         buf.readUnsignedShort(); // checksum
         buf.readUnsignedShort(); // length
-        buf.readUnsignedShort(); // sequence
+        int index = buf.readUnsignedShort();
 
         // Create new position
         Position position = new Position();
         ExtendedInfoFormatter extendedInfo = new ExtendedInfoFormatter("atrack");
 
         // Get device id
-        String id = String.valueOf(buf.readLong());
+        long rawId = buf.readLong();
+        String id = String.valueOf(rawId);
         try {
             position.setDeviceId(getDataManager().getDeviceByImei(id).getId());
         } catch(Exception error) {
             Log.warning("Unknown device - " + id);
             return null;
         }
+        
+        // Send acknowledgement
+        sendResponse(channel, rawId, index);
 
         // Date and time
         position.setTime(new Date(buf.readUnsignedInt() * 1000)); // gps time
-- 
cgit v1.2.3