1 /*
2 * Copyright (C) 2018 The Android Open Source Project
3 *
4 * Licensed under the Apache License, Version 2.0 (the "License");
5 * you may not use this file except in compliance with the License.
6 * You may obtain a copy of the License at
7 *
8 * http://www.apache.org/licenses/LICENSE-2.0
9 *
10 * Unless required by applicable law or agreed to in writing, software
11 * distributed under the License is distributed on an "AS IS" BASIS,
12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13 * See the License for the specific language governing permissions and
14 * limitations under the License.
15 */
16
17 #include <android/hardware/automotive/vehicle/2.0/IVehicle.h>
18 #include <gtest/gtest.h>
19
20 #include "VehicleHalTestUtils.h"
21 #include "vhal_v2_0/VmsUtils.h"
22
23 namespace android {
24 namespace hardware {
25 namespace automotive {
26 namespace vehicle {
27 namespace V2_0 {
28 namespace vms {
29
30 namespace {
31
TEST(VmsUtilsTest,subscribeMessage)32 TEST(VmsUtilsTest, subscribeMessage) {
33 VmsLayer layer(1, 0, 2);
34 auto message = createSubscribeMessage(layer);
35 ASSERT_NE(message, nullptr);
36 EXPECT_TRUE(isValidVmsMessage(*message));
37 EXPECT_EQ(message->prop, toInt(VehicleProperty::VEHICLE_MAP_SERVICE));
38 EXPECT_EQ(message->value.int32Values.size(), 0x4ul);
39 EXPECT_EQ(parseMessageType(*message), VmsMessageType::SUBSCRIBE);
40
41 // Layer
42 EXPECT_EQ(message->value.int32Values[1], 1);
43 EXPECT_EQ(message->value.int32Values[2], 0);
44 EXPECT_EQ(message->value.int32Values[3], 2);
45 }
46
TEST(VmsUtilsTest,unsubscribeMessage)47 TEST(VmsUtilsTest, unsubscribeMessage) {
48 VmsLayer layer(1, 0, 2);
49 auto message = createUnsubscribeMessage(layer);
50 ASSERT_NE(message, nullptr);
51 EXPECT_TRUE(isValidVmsMessage(*message));
52 EXPECT_EQ(message->prop, toInt(VehicleProperty::VEHICLE_MAP_SERVICE));
53 EXPECT_EQ(message->value.int32Values.size(), 0x4ul);
54 EXPECT_EQ(parseMessageType(*message), VmsMessageType::UNSUBSCRIBE);
55
56 // Layer
57 EXPECT_EQ(message->value.int32Values[1], 1);
58 EXPECT_EQ(message->value.int32Values[2], 0);
59 EXPECT_EQ(message->value.int32Values[3], 2);
60 }
61
TEST(VmsUtilsTest,singleOfferingMessage)62 TEST(VmsUtilsTest, singleOfferingMessage) {
63 VmsOffers offers = {123, {VmsLayerOffering(VmsLayer(1, 0, 2))}};
64 auto message = createOfferingMessage(offers);
65 ASSERT_NE(message, nullptr);
66 EXPECT_TRUE(isValidVmsMessage(*message));
67 EXPECT_EQ(message->prop, toInt(VehicleProperty::VEHICLE_MAP_SERVICE));
68 EXPECT_EQ(message->value.int32Values.size(), 0x7ul);
69 EXPECT_EQ(parseMessageType(*message), VmsMessageType::OFFERING);
70
71 // Publisher ID
72 EXPECT_EQ(message->value.int32Values[1], 123);
73
74 // Number of layer offerings
75 EXPECT_EQ(message->value.int32Values[2], 1);
76
77 // Layer
78 EXPECT_EQ(message->value.int32Values[3], 1);
79 EXPECT_EQ(message->value.int32Values[4], 0);
80 EXPECT_EQ(message->value.int32Values[5], 2);
81
82 // Number of dependencies
83 EXPECT_EQ(message->value.int32Values[6], 0);
84 }
85
TEST(VmsUtilsTest,offeringWithDependencies)86 TEST(VmsUtilsTest, offeringWithDependencies) {
87 VmsLayer layer(1, 0, 2);
88 std::vector<VmsLayer> dependencies = {VmsLayer(2, 0, 2), VmsLayer(3, 0, 3)};
89 std::vector<VmsLayerOffering> offering = {VmsLayerOffering(layer, dependencies)};
90 VmsOffers offers = {123, offering};
91 auto message = createOfferingMessage(offers);
92 ASSERT_NE(message, nullptr);
93 EXPECT_TRUE(isValidVmsMessage(*message));
94 EXPECT_EQ(message->prop, toInt(VehicleProperty::VEHICLE_MAP_SERVICE));
95 EXPECT_EQ(message->value.int32Values.size(), 0xdul);
96 EXPECT_EQ(parseMessageType(*message), VmsMessageType::OFFERING);
97
98 // Publisher ID
99 EXPECT_EQ(message->value.int32Values[1], 123);
100
101 // Number of layer offerings
102 EXPECT_EQ(message->value.int32Values[2], 1);
103
104 // Layer
105 EXPECT_EQ(message->value.int32Values[3], 1);
106 EXPECT_EQ(message->value.int32Values[4], 0);
107 EXPECT_EQ(message->value.int32Values[5], 2);
108
109 // Number of dependencies
110 EXPECT_EQ(message->value.int32Values[6], 2);
111
112 // Dependency 1
113 EXPECT_EQ(message->value.int32Values[7], 2);
114 EXPECT_EQ(message->value.int32Values[8], 0);
115 EXPECT_EQ(message->value.int32Values[9], 2);
116
117 // Dependency 2
118 EXPECT_EQ(message->value.int32Values[10], 3);
119 EXPECT_EQ(message->value.int32Values[11], 0);
120 EXPECT_EQ(message->value.int32Values[12], 3);
121 }
122
TEST(VmsUtilsTest,availabilityMessage)123 TEST(VmsUtilsTest, availabilityMessage) {
124 auto message = createAvailabilityRequest();
125 ASSERT_NE(message, nullptr);
126 EXPECT_TRUE(isValidVmsMessage(*message));
127 EXPECT_EQ(message->prop, toInt(VehicleProperty::VEHICLE_MAP_SERVICE));
128 EXPECT_EQ(message->value.int32Values.size(), 0x1ul);
129 EXPECT_EQ(parseMessageType(*message), VmsMessageType::AVAILABILITY_REQUEST);
130 }
131
TEST(VmsUtilsTest,subscriptionsMessage)132 TEST(VmsUtilsTest, subscriptionsMessage) {
133 auto message = createSubscriptionsRequest();
134 ASSERT_NE(message, nullptr);
135 EXPECT_TRUE(isValidVmsMessage(*message));
136 EXPECT_EQ(message->prop, toInt(VehicleProperty::VEHICLE_MAP_SERVICE));
137 EXPECT_EQ(message->value.int32Values.size(), 0x1ul);
138 EXPECT_EQ(parseMessageType(*message), VmsMessageType::SUBSCRIPTIONS_REQUEST);
139 }
140
TEST(VmsUtilsTest,dataMessage)141 TEST(VmsUtilsTest, dataMessage) {
142 const std::string bytes = "aaa";
143 const VmsLayerAndPublisher layer_and_publisher(VmsLayer(2, 0, 1), 123);
144 auto message = createDataMessageWithLayerPublisherInfo(layer_and_publisher, bytes);
145 ASSERT_NE(message, nullptr);
146 EXPECT_TRUE(isValidVmsMessage(*message));
147 EXPECT_EQ(message->prop, toInt(VehicleProperty::VEHICLE_MAP_SERVICE));
148 EXPECT_EQ(message->value.int32Values.size(), 0x5ul);
149 EXPECT_EQ(message->value.int32Values[0], toInt(VmsMessageType::DATA));
150
151 // Layer
152 EXPECT_EQ(message->value.int32Values[1], 2);
153 EXPECT_EQ(message->value.int32Values[2], 0);
154 EXPECT_EQ(message->value.int32Values[3], 1);
155
156 // Publisher ID
157 EXPECT_EQ(message->value.int32Values[4], 123);
158
159 EXPECT_EQ(parseMessageType(*message), VmsMessageType::DATA);
160 EXPECT_EQ(message->value.bytes.size(), bytes.size());
161 EXPECT_EQ(memcmp(message->value.bytes.data(), bytes.data(), bytes.size()), 0);
162 }
163
TEST(VmsUtilsTest,emptyMessageInvalid)164 TEST(VmsUtilsTest, emptyMessageInvalid) {
165 VehiclePropValue empty_prop;
166 EXPECT_FALSE(isValidVmsMessage(empty_prop));
167 }
168
TEST(VmsUtilsTest,invalidMessageType)169 TEST(VmsUtilsTest, invalidMessageType) {
170 VmsLayer layer(1, 0, 2);
171 auto message = createSubscribeMessage(layer);
172 message->value.int32Values[0] = -1;
173
174 EXPECT_FALSE(isValidVmsMessage(*message));
175 }
176
TEST(VmsUtilsTest,parseDataMessage)177 TEST(VmsUtilsTest, parseDataMessage) {
178 const std::string bytes = "aaa";
179 const VmsLayerAndPublisher layer_and_publisher(VmsLayer(1, 0, 1), 123);
180 auto message = createDataMessageWithLayerPublisherInfo(layer_and_publisher, bytes);
181 auto data_str = parseData(*message);
182 ASSERT_FALSE(data_str.empty());
183 EXPECT_EQ(data_str, bytes);
184 }
185
TEST(VmsUtilsTest,parseInvalidDataMessage)186 TEST(VmsUtilsTest, parseInvalidDataMessage) {
187 VmsLayer layer(1, 0, 2);
188 auto message = createSubscribeMessage(layer);
189 auto data_str = parseData(*message);
190 EXPECT_TRUE(data_str.empty());
191 }
192
TEST(VmsUtilsTest,publisherIdRequest)193 TEST(VmsUtilsTest, publisherIdRequest) {
194 std::string bytes = "pub_id";
195 auto message = createPublisherIdRequest(bytes);
196 ASSERT_NE(message, nullptr);
197 EXPECT_TRUE(isValidVmsMessage(*message));
198 EXPECT_EQ(message->prop, toInt(VehicleProperty::VEHICLE_MAP_SERVICE));
199 EXPECT_EQ(message->value.int32Values.size(), 0x1ul);
200 EXPECT_EQ(parseMessageType(*message), VmsMessageType::PUBLISHER_ID_REQUEST);
201 EXPECT_EQ(message->value.bytes.size(), bytes.size());
202 EXPECT_EQ(memcmp(message->value.bytes.data(), bytes.data(), bytes.size()), 0);
203 }
204
TEST(VmsUtilsTest,validPublisherIdResponse)205 TEST(VmsUtilsTest, validPublisherIdResponse) {
206 auto message = createBaseVmsMessage(2);
207 message->value.int32Values =
208 hidl_vec<int32_t>{toInt(VmsMessageType::PUBLISHER_ID_RESPONSE), 1234};
209 EXPECT_EQ(parsePublisherIdResponse(*message), 1234);
210 }
211
TEST(VmsUtilsTest,invalidPublisherIdResponse)212 TEST(VmsUtilsTest, invalidPublisherIdResponse) {
213 auto message = createBaseVmsMessage(1);
214 EXPECT_EQ(parsePublisherIdResponse(*message), -1);
215 }
216
TEST(VmsUtilsTest,validSequenceNumberForSubscriptionsState)217 TEST(VmsUtilsTest, validSequenceNumberForSubscriptionsState) {
218 auto message = createBaseVmsMessage(2);
219 message->value.int32Values =
220 hidl_vec<int32_t>{toInt(VmsMessageType::SUBSCRIPTIONS_CHANGE), 1234};
221 EXPECT_EQ(getSequenceNumberForSubscriptionsState(*message), 1234);
222 }
223
TEST(VmsUtilsTest,invalidSubscriptionsState)224 TEST(VmsUtilsTest, invalidSubscriptionsState) {
225 auto message = createBaseVmsMessage(1);
226 EXPECT_EQ(getSequenceNumberForSubscriptionsState(*message), -1);
227 }
228
TEST(VmsUtilsTest,newSequenceNumberForExistingSmallerNumber)229 TEST(VmsUtilsTest, newSequenceNumberForExistingSmallerNumber) {
230 auto message = createBaseVmsMessage(2);
231 message->value.int32Values =
232 hidl_vec<int32_t>{toInt(VmsMessageType::SUBSCRIPTIONS_CHANGE), 1234};
233 EXPECT_TRUE(isSequenceNumberNewer(*message, 1233));
234 }
235
TEST(VmsUtilsTest,newSequenceNumberForExistingGreaterNumber)236 TEST(VmsUtilsTest, newSequenceNumberForExistingGreaterNumber) {
237 auto message = createBaseVmsMessage(2);
238 message->value.int32Values =
239 hidl_vec<int32_t>{toInt(VmsMessageType::SUBSCRIPTIONS_CHANGE), 1234};
240 EXPECT_FALSE(isSequenceNumberNewer(*message, 1235));
241 }
242
TEST(VmsUtilsTest,newSequenceNumberForSameNumber)243 TEST(VmsUtilsTest, newSequenceNumberForSameNumber) {
244 auto message = createBaseVmsMessage(2);
245 message->value.int32Values =
246 hidl_vec<int32_t>{toInt(VmsMessageType::SUBSCRIPTIONS_CHANGE), 1234};
247 EXPECT_FALSE(isSequenceNumberNewer(*message, 1234));
248 }
249
TEST(VmsUtilsTest,subscribedLayers)250 TEST(VmsUtilsTest, subscribedLayers) {
251 VmsOffers offers = {123,
252 {VmsLayerOffering(VmsLayer(1, 0, 1), {VmsLayer(4, 1, 1)}),
253 VmsLayerOffering(VmsLayer(2, 0, 1))}};
254 auto message = createBaseVmsMessage(2);
255 message->value.int32Values = hidl_vec<int32_t>{toInt(VmsMessageType::SUBSCRIPTIONS_CHANGE),
256 1234, // sequence number
257 2, // number of layers
258 1, // number of associated layers
259 1, // layer 1
260 0,
261 1,
262 4, // layer 2
263 1,
264 1,
265 2, // associated layer
266 0,
267 1,
268 2, // number of publisher IDs
269 111, // publisher IDs
270 123};
271 EXPECT_TRUE(isValidVmsMessage(*message));
272 auto result = getSubscribedLayers(*message, offers);
273 EXPECT_EQ(static_cast<int>(result.size()), 2);
274 EXPECT_EQ(result.at(0), VmsLayer(1, 0, 1));
275 EXPECT_EQ(result.at(1), VmsLayer(2, 0, 1));
276 }
277
TEST(VmsUtilsTest,subscribedLayersWithDifferentSubtype)278 TEST(VmsUtilsTest, subscribedLayersWithDifferentSubtype) {
279 VmsOffers offers = {123, {VmsLayerOffering(VmsLayer(1, 0, 1))}};
280 auto message = createBaseVmsMessage(2);
281 message->value.int32Values = hidl_vec<int32_t>{toInt(VmsMessageType::SUBSCRIPTIONS_CHANGE),
282 1234, // sequence number
283 1, // number of layers
284 0, // number of associated layers
285 1, // layer 1
286 1, // different subtype
287 1};
288 EXPECT_TRUE(isValidVmsMessage(*message));
289 EXPECT_TRUE(getSubscribedLayers(*message, offers).empty());
290 }
291
TEST(VmsUtilsTest,subscribedLayersWithDifferentVersion)292 TEST(VmsUtilsTest, subscribedLayersWithDifferentVersion) {
293 VmsOffers offers = {123, {VmsLayerOffering(VmsLayer(1, 0, 1))}};
294 auto message = createBaseVmsMessage(2);
295 message->value.int32Values = hidl_vec<int32_t>{toInt(VmsMessageType::SUBSCRIPTIONS_CHANGE),
296 1234, // sequence number
297 1, // number of layers
298 0, // number of associated layers
299 1, // layer 1
300 0,
301 2}; // different version
302 EXPECT_TRUE(isValidVmsMessage(*message));
303 EXPECT_TRUE(getSubscribedLayers(*message, offers).empty());
304 }
305
TEST(VmsUtilsTest,subscribedLayersWithDifferentPublisherId)306 TEST(VmsUtilsTest, subscribedLayersWithDifferentPublisherId) {
307 VmsOffers offers = {123, {VmsLayerOffering(VmsLayer(1, 0, 1))}};
308 auto message = createBaseVmsMessage(2);
309 message->value.int32Values = hidl_vec<int32_t>{toInt(VmsMessageType::SUBSCRIPTIONS_CHANGE),
310 1234, // sequence number
311 0, // number of layers
312 1, // number of associated layers
313 1, // associated layer 1
314 0,
315 1,
316 1, // number of publisher IDs
317 234}; // publisher ID 1
318 EXPECT_TRUE(isValidVmsMessage(*message));
319 EXPECT_TRUE(getSubscribedLayers(*message, offers).empty());
320 }
321
TEST(VmsUtilsTest,serviceNewlyStarted)322 TEST(VmsUtilsTest, serviceNewlyStarted) {
323 auto message = createBaseVmsMessage(2);
324 message->value.int32Values = hidl_vec<int32_t>{toInt(VmsMessageType::AVAILABILITY_CHANGE), 0};
325 EXPECT_TRUE(hasServiceNewlyStarted(*message));
326 }
327
TEST(VmsUtilsTest,serviceNotNewlyStarted)328 TEST(VmsUtilsTest, serviceNotNewlyStarted) {
329 auto message = createBaseVmsMessage(2);
330 message->value.int32Values =
331 hidl_vec<int32_t>{toInt(VmsMessageType::AVAILABILITY_CHANGE), 1234};
332 EXPECT_FALSE(hasServiceNewlyStarted(*message));
333 }
334
TEST(VmsUtilsTest,invalidAvailabilityChange)335 TEST(VmsUtilsTest, invalidAvailabilityChange) {
336 auto message = createBaseVmsMessage(1);
337 EXPECT_FALSE(hasServiceNewlyStarted(*message));
338 }
339
TEST(VmsUtilsTest,startSessionRequest)340 TEST(VmsUtilsTest, startSessionRequest) {
341 auto message = createStartSessionMessage(123, 456);
342 ASSERT_NE(message, nullptr);
343 EXPECT_TRUE(isValidVmsMessage(*message));
344 EXPECT_EQ(message->prop, toInt(VehicleProperty::VEHICLE_MAP_SERVICE));
345 EXPECT_EQ(message->value.int32Values.size(), 0x3ul);
346 EXPECT_EQ(parseMessageType(*message), VmsMessageType::START_SESSION);
347 EXPECT_EQ(message->value.int32Values[1], 123);
348 EXPECT_EQ(message->value.int32Values[2], 456);
349 }
350
TEST(VmsUtilsTest,startSessionServiceNewlyStarted)351 TEST(VmsUtilsTest, startSessionServiceNewlyStarted) {
352 auto message = createBaseVmsMessage(3);
353 int new_service_id;
354 message->value.int32Values = hidl_vec<int32_t>{toInt(VmsMessageType::START_SESSION), 123, -1};
355 EXPECT_EQ(parseStartSessionMessage(*message, 122, 456, &new_service_id),
356 VmsSessionStatus::kNewServerSession);
357 EXPECT_EQ(new_service_id, 123);
358 }
359
TEST(VmsUtilsTest,startSessionServiceNewlyStartedEdgeCase)360 TEST(VmsUtilsTest, startSessionServiceNewlyStartedEdgeCase) {
361 auto message = createBaseVmsMessage(3);
362 int new_service_id;
363 message->value.int32Values = hidl_vec<int32_t>{toInt(VmsMessageType::START_SESSION), 0, -1};
364 EXPECT_EQ(parseStartSessionMessage(*message, -1, 0, &new_service_id),
365 VmsSessionStatus::kNewServerSession);
366 EXPECT_EQ(new_service_id, 0);
367 }
368
TEST(VmsUtilsTest,startSessionClientNewlyStarted)369 TEST(VmsUtilsTest, startSessionClientNewlyStarted) {
370 auto message = createBaseVmsMessage(3);
371 int new_service_id;
372 message->value.int32Values = hidl_vec<int32_t>{toInt(VmsMessageType::START_SESSION), 123, 456};
373 EXPECT_EQ(parseStartSessionMessage(*message, -1, 456, &new_service_id),
374 VmsSessionStatus::kAckToCurrentSession);
375 EXPECT_EQ(new_service_id, 123);
376 }
377
TEST(VmsUtilsTest,startSessionClientNewlyStartedWithSameServerAndClientId)378 TEST(VmsUtilsTest, startSessionClientNewlyStartedWithSameServerAndClientId) {
379 auto message = createBaseVmsMessage(3);
380 int new_service_id;
381 message->value.int32Values = hidl_vec<int32_t>{toInt(VmsMessageType::START_SESSION), 123, 456};
382 EXPECT_EQ(parseStartSessionMessage(*message, 123, 456, &new_service_id),
383 VmsSessionStatus::kAckToCurrentSession);
384 EXPECT_EQ(new_service_id, 123);
385 }
386
TEST(VmsUtilsTest,startSessionWithZeroAsIds)387 TEST(VmsUtilsTest, startSessionWithZeroAsIds) {
388 auto message = createBaseVmsMessage(3);
389 int new_service_id;
390 message->value.int32Values = hidl_vec<int32_t>{toInt(VmsMessageType::START_SESSION), 0, 0};
391 EXPECT_EQ(parseStartSessionMessage(*message, 0, 0, &new_service_id),
392 VmsSessionStatus::kAckToCurrentSession);
393 EXPECT_EQ(new_service_id, 0);
394 }
395
TEST(VmsUtilsTest,startSessionOldServiceId)396 TEST(VmsUtilsTest, startSessionOldServiceId) {
397 auto message = createBaseVmsMessage(3);
398 int new_service_id;
399 message->value.int32Values = hidl_vec<int32_t>{toInt(VmsMessageType::START_SESSION), 120, 456};
400 EXPECT_EQ(parseStartSessionMessage(*message, 123, 456, &new_service_id),
401 VmsSessionStatus::kAckToCurrentSession);
402 EXPECT_EQ(new_service_id, 120);
403 }
404
TEST(VmsUtilsTest,startSessionNegativeServerId)405 TEST(VmsUtilsTest, startSessionNegativeServerId) {
406 auto message = createBaseVmsMessage(3);
407 int new_service_id;
408 message->value.int32Values = hidl_vec<int32_t>{toInt(VmsMessageType::START_SESSION), -1, 456};
409 EXPECT_EQ(parseStartSessionMessage(*message, -1, 456, &new_service_id),
410 VmsSessionStatus::kAckToCurrentSession);
411 EXPECT_EQ(new_service_id, -1);
412 }
413
TEST(VmsUtilsTest,startSessionInvalidMessageFormat)414 TEST(VmsUtilsTest, startSessionInvalidMessageFormat) {
415 auto message = createBaseVmsMessage(2);
416 int new_service_id;
417 message->value.int32Values = hidl_vec<int32_t>{toInt(VmsMessageType::START_SESSION), 123};
418 EXPECT_EQ(parseStartSessionMessage(*message, 123, 456, &new_service_id),
419 VmsSessionStatus::kInvalidMessage);
420 EXPECT_EQ(new_service_id, 123);
421 }
422
423 } // namespace
424
425 } // namespace vms
426 } // namespace V2_0
427 } // namespace vehicle
428 } // namespace automotive
429 } // namespace hardware
430 } // namespace android
431