aboutsummaryrefslogtreecommitdiff
path: root/src/main/java/org
diff options
context:
space:
mode:
authorJesse Hills <jesserockz@gmail.com>2019-08-01 09:19:22 +1200
committerJesse Hills <jesserockz@gmail.com>2019-08-01 09:19:22 +1200
commitc5bfaf57bb0423c8e5af757c15abd3b3e729dce6 (patch)
tree4b83a6ea131a91c352242e7f60122d6814e6192f /src/main/java/org
parentc4f588bfb161a1e7fe9d927ad28572553ec5c692 (diff)
downloadtraccar-server-c5bfaf57bb0423c8e5af757c15abd3b3e729dce6.tar.gz
traccar-server-c5bfaf57bb0423c8e5af757c15abd3b3e729dce6.tar.bz2
traccar-server-c5bfaf57bb0423c8e5af757c15abd3b3e729dce6.zip
Add simple unit test
Diffstat (limited to 'src/main/java/org')
-rw-r--r--src/main/java/org/traccar/protocol/LeafSpyProtocolDecoder.java20
1 files changed, 11 insertions, 9 deletions
diff --git a/src/main/java/org/traccar/protocol/LeafSpyProtocolDecoder.java b/src/main/java/org/traccar/protocol/LeafSpyProtocolDecoder.java
index 17824177c..47c37a68b 100644
--- a/src/main/java/org/traccar/protocol/LeafSpyProtocolDecoder.java
+++ b/src/main/java/org/traccar/protocol/LeafSpyProtocolDecoder.java
@@ -80,17 +80,17 @@ public class LeafSpyProtocolDecoder extends BaseHttpProtocolDecoder {
case "Elv":
position.setAltitude(Double.parseDouble(value));
break;
- case "DevBat":
+ case "SOC":
position.set(Position.KEY_BATTERY_LEVEL, Double.parseDouble(value));
break;
case "user":
position.set(Position.KEY_DRIVER_UNIQUE_ID, value);
break;
- case "SOC":
- position.set(Position.KEY_CHARGE, Double.parseDouble(value));
+ case "ChrgMode":
+ position.set(Position.KEY_CHARGE, Integer.parseInt(value) != 0);
break;
case "Odo":
- position.set(Position.KEY_OBD_ODOMETER, Integer.parseInt(value));
+ position.set(Position.KEY_OBD_ODOMETER, Integer.parseInt(value) * 1000);
break;
default:
try {
@@ -122,11 +122,13 @@ public class LeafSpyProtocolDecoder extends BaseHttpProtocolDecoder {
}
if (position.getDeviceId() != 0) {
- HttpResponse response = new DefaultFullHttpResponse(
- HttpVersion.HTTP_1_1,
- HttpResponseStatus.OK,
- Unpooled.copiedBuffer("\"status\":\"0\"", StandardCharsets.US_ASCII));
- channel.writeAndFlush(new NetworkMessage(response, channel.remoteAddress()));
+ if(channel != null) {
+ HttpResponse response = new DefaultFullHttpResponse(
+ HttpVersion.HTTP_1_1,
+ HttpResponseStatus.OK,
+ Unpooled.copiedBuffer("\"status\":\"0\"", StandardCharsets.US_ASCII));
+ channel.writeAndFlush(new NetworkMessage(response, channel.remoteAddress()));
+ }
return position;
} else {
sendResponse(channel, HttpResponseStatus.BAD_REQUEST);