1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
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);
}
}
|
