aboutsummaryrefslogtreecommitdiff
path: root/test/org/traccar/ProtocolDecoderTest.java
diff options
context:
space:
mode:
authorAnton Tananaev <anton.tananaev@gmail.com>2015-10-22 15:26:17 +1300
committerAnton Tananaev <anton.tananaev@gmail.com>2015-10-22 15:26:17 +1300
commit1ca95d099df96d576a0eaddc6e42b5b41aed3e06 (patch)
tree65ae84eb5e301317263fd72c31cc54922c71eb96 /test/org/traccar/ProtocolDecoderTest.java
parent122a26d2822f35b27b9cb0b217916d6b821d9654 (diff)
downloadtrackermap-server-1ca95d099df96d576a0eaddc6e42b5b41aed3e06.tar.gz
trackermap-server-1ca95d099df96d576a0eaddc6e42b5b41aed3e06.tar.bz2
trackermap-server-1ca95d099df96d576a0eaddc6e42b5b41aed3e06.zip
Refactor protocol unit testing
Diffstat (limited to 'test/org/traccar/ProtocolDecoderTest.java')
-rw-r--r--test/org/traccar/ProtocolDecoderTest.java169
1 files changed, 169 insertions, 0 deletions
diff --git a/test/org/traccar/ProtocolDecoderTest.java b/test/org/traccar/ProtocolDecoderTest.java
new file mode 100644
index 000000000..96f268c50
--- /dev/null
+++ b/test/org/traccar/ProtocolDecoderTest.java
@@ -0,0 +1,169 @@
+package org.traccar;
+
+import org.jboss.netty.buffer.ChannelBuffer;
+import org.jboss.netty.buffer.ChannelBuffers;
+import org.jboss.netty.handler.codec.http.DefaultHttpRequest;
+import org.jboss.netty.handler.codec.http.HttpMethod;
+import org.jboss.netty.handler.codec.http.HttpVersion;
+import org.junit.Assert;
+import org.traccar.database.IdentityManager;
+import org.traccar.helper.ChannelBufferTools;
+import org.traccar.model.Device;
+import org.traccar.model.Position;
+
+import java.nio.ByteOrder;
+import java.nio.charset.Charset;
+import java.util.Date;
+import java.util.List;
+
+public class ProtocolDecoderTest {
+
+ static {
+ Context.init(new IdentityManager() {
+
+ private Device createDevice() {
+ Device device = new Device();
+ device.setId(1);
+ device.setUniqueId("123456789012345");
+ return device;
+ }
+
+ @Override
+ public Device getDeviceById(long id) {
+ return createDevice();
+ }
+
+ @Override
+ public Device getDeviceByUniqueId(String imei) {
+ return createDevice();
+ }
+
+ });
+ }
+
+ protected void verifyNothing(BaseProtocolDecoder decoder, Object object) throws Exception {
+ Assert.assertNull(decoder.decode(null, null, object));
+ }
+
+ protected void verifyAttributes(BaseProtocolDecoder decoder, Object object) throws Exception {
+ Object decodedObject = decoder.decode(null, null, object);
+ Assert.assertNotNull(decodedObject);
+ Assert.assertTrue(decodedObject instanceof Position);
+ Position position = (Position) decodedObject;
+ Assert.assertFalse(position.getAttributes().isEmpty());
+ }
+
+ protected void verifyPosition(BaseProtocolDecoder decoder, Object object) throws Exception {
+ verifyDecodedPosition(decoder.decode(null, null, object));
+ }
+
+ protected void verifyPosition(BaseProtocolDecoder decoder, Object object, Position position) throws Exception {
+ verifyDecodedPosition(decoder.decode(null, null, object), position);
+ }
+
+ protected void verifyPositions(BaseProtocolDecoder decoder, Object object) throws Exception {
+ Object decodedObject = decoder.decode(null, null, object);
+ Assert.assertNotNull(decodedObject);
+ Assert.assertTrue(decodedObject instanceof List);
+ for (Object item : (List) decodedObject) {
+ verifyDecodedPosition(item);
+ }
+ }
+
+ protected Position position(
+ Date time, boolean valid, double lat, double lon, double altitude, double speed, double course) {
+
+ Position position = new Position();
+
+ position.setDeviceTime(time);
+ position.setFixTime(time);
+ position.setValid(valid);
+ position.setLatitude(lat);
+ position.setLongitude(lon);
+ position.setAltitude(altitude);
+ position.setSpeed(speed);
+ position.setCourse(course);
+
+ return position;
+ }
+
+ protected ChannelBuffer binary(String... data) {
+ return binary(ByteOrder.BIG_ENDIAN, data);
+ }
+
+ protected ChannelBuffer binary(ByteOrder endianness, String... data) {
+ return ChannelBuffers.wrappedBuffer(
+ endianness, ChannelBufferTools.convertHexString(String.join("", data)));
+ }
+
+ protected String text(String... data) {
+ return String.join("", data);
+ }
+
+ protected ChannelBuffer buffer(String... data) {
+ return ChannelBuffers.copiedBuffer(String.join("", data), Charset.defaultCharset());
+ }
+
+ protected DefaultHttpRequest request(String url) {
+ return request(HttpMethod.GET, url);
+ }
+
+ protected DefaultHttpRequest request(HttpMethod method, String url) {
+ return new DefaultHttpRequest(HttpVersion.HTTP_1_1, method, url);
+ }
+
+ protected DefaultHttpRequest request(HttpMethod method, String url, ChannelBuffer data) {
+ DefaultHttpRequest request = new DefaultHttpRequest(HttpVersion.HTTP_1_1, method, url);
+ request.setContent(data);
+ return request;
+ }
+
+ private void verifyDecodedPosition(Object decodedObject, Position expected) {
+
+ Assert.assertNotNull(decodedObject);
+ Assert.assertTrue(decodedObject instanceof Position);
+
+ Position position = (Position) decodedObject;
+
+ Assert.assertEquals(position.getDeviceTime(), expected.getDeviceTime());
+ Assert.assertEquals(position.getFixTime(), expected.getFixTime());
+ Assert.assertEquals(position.getValid(), expected.getValid());
+ Assert.assertEquals(position.getLatitude(), expected.getLatitude(), 0.00001);
+ Assert.assertEquals(position.getLongitude(), expected.getLongitude(), 0.00001);
+ Assert.assertEquals(position.getAltitude(), expected.getAltitude(), 0.01);
+ Assert.assertEquals(position.getSpeed(), expected.getSpeed(), 0.01);
+ Assert.assertEquals(position.getCourse(), expected.getCourse(), 0.01);
+
+ verifyDecodedPosition(decodedObject);
+
+ }
+
+ private void verifyDecodedPosition(Object decodedObject) {
+
+ Assert.assertNotNull(decodedObject);
+ Assert.assertTrue(decodedObject instanceof Position);
+
+ Position position = (Position) decodedObject;
+
+ Assert.assertNotNull(position.getFixTime());
+ Assert.assertTrue(position.getFixTime().after(new Date(946684800000L))); // 2000 year
+ Assert.assertTrue(position.getFixTime().getTime() < System.currentTimeMillis() + 25 * 3600000); // 25 hours
+
+ Assert.assertTrue(position.getLatitude() >= -90);
+ Assert.assertTrue(position.getLatitude() <= 90);
+
+ Assert.assertTrue(position.getLongitude() >= -180);
+ Assert.assertTrue(position.getLongitude() <= 180);
+
+ Assert.assertTrue(position.getAltitude() >= -12262);
+ Assert.assertTrue(position.getAltitude() <= 18000);
+
+ Assert.assertTrue(position.getSpeed() >= 0);
+ Assert.assertTrue(position.getSpeed() <= 869);
+
+ Assert.assertTrue(position.getCourse() >= 0);
+ Assert.assertTrue(position.getCourse() <= 360);
+
+ }
+
+}