/* This Source Code Form is subject to the terms of the Mozilla Public * License, v. 2.0. If a copy of the MPL was not distributed with this * file, You can obtain one at http://mozilla.org/MPL/2.0/. * * Copyright (c) 2018 Fraunhofer IOSB (Author: Lukas Meling) */ #include "ua_types.h" #include "ua_client.h" #include "ua_util.h" #include "ua_pubsub_networkmessage.h" #include "check.h" START_TEST(UA_PubSub_EncodeAllOptionalFields) { UA_NetworkMessage m; memset(&m, 0, sizeof(UA_NetworkMessage)); m.version = 1; m.networkMessageType = UA_NETWORKMESSAGE_DATASET; m.payloadHeaderEnabled = true; m.payloadHeader.dataSetPayloadHeader.count = 1; UA_UInt16 dsWriter1 = 12345; m.payloadHeader.dataSetPayloadHeader.dataSetWriterIds = (UA_UInt16 *)UA_Array_new(m.payloadHeader.dataSetPayloadHeader.count, &UA_TYPES[UA_TYPES_UINT16]); m.payloadHeader.dataSetPayloadHeader.dataSetWriterIds[0] = dsWriter1; size_t memsize = m.payloadHeader.dataSetPayloadHeader.count * sizeof(UA_DataSetMessage); m.payload.dataSetPayload.dataSetMessages = (UA_DataSetMessage*)UA_malloc(memsize); memset(m.payload.dataSetPayload.dataSetMessages, 0, memsize); /* enable messageId */ m.messageIdEnabled = true; m.messageId = UA_STRING_ALLOC("ABCDEFGH"); /* enable publisherId */ m.publisherIdEnabled = true; m.publisherIdType = UA_PUBLISHERDATATYPE_UINT16; m.publisherId.publisherIdUInt16 = 65535; /* enable dataSetClassId */ m.dataSetClassIdEnabled = true; m.dataSetClassId.data1 = 1; m.dataSetClassId.data2 = 2; m.dataSetClassId.data3 = 3; /* DatasetMessage */ m.payload.dataSetPayload.dataSetMessages[0].header.dataSetMessageValid = true; m.payload.dataSetPayload.dataSetMessages[0].header.fieldEncoding = UA_FIELDENCODING_VARIANT; m.payload.dataSetPayload.dataSetMessages[0].header.dataSetMessageType = UA_DATASETMESSAGE_DATAKEYFRAME; UA_UInt16 fieldCountDS1 = 1; m.payload.dataSetPayload.dataSetMessages[0].data.keyFrameData.fieldCount = fieldCountDS1; m.payload.dataSetPayload.dataSetMessages[0].data.keyFrameData.dataSetFields = (UA_DataValue*)UA_Array_new(m.payload.dataSetPayload.dataSetMessages[0].data.keyFrameData.fieldCount, &UA_TYPES[UA_TYPES_DATAVALUE]); UA_DataValue_init(&m.payload.dataSetPayload.dataSetMessages[0].data.keyFrameData.dataSetFields[0]); /* enable DataSetMessageSequenceNr */ m.payload.dataSetPayload.dataSetMessages[0].header.dataSetMessageSequenceNrEnabled = true; m.payload.dataSetPayload.dataSetMessages[0].header.dataSetMessageSequenceNr = 4711; /* enable metaDataVersion */ m.payload.dataSetPayload.dataSetMessages[0].header.configVersionMajorVersionEnabled = true; m.payload.dataSetPayload.dataSetMessages[0].header.configVersionMinorVersionEnabled = true; m.payload.dataSetPayload.dataSetMessages[0].header.configVersionMajorVersion = 42; m.payload.dataSetPayload.dataSetMessages[0].header.configVersionMinorVersion = 7; /* enable timestamp */ m.payload.dataSetPayload.dataSetMessages[0].header.timestampEnabled = true; m.payload.dataSetPayload.dataSetMessages[0].header.timestamp = 11111111111111; /* enable status */ m.payload.dataSetPayload.dataSetMessages[0].header.statusEnabled = true; m.payload.dataSetPayload.dataSetMessages[0].header.status = 12345; /* Set fieldnames */ m.payload.dataSetPayload.dataSetMessages[0].data.keyFrameData.fieldNames = (UA_String*)UA_Array_new(m.payload.dataSetPayload.dataSetMessages[0].data.keyFrameData.fieldCount, &UA_TYPES[UA_TYPES_STRING]); m.payload.dataSetPayload.dataSetMessages[0].data.keyFrameData.fieldNames[0] = UA_STRING_ALLOC("Field1"); UA_UInt32 iv = 27; UA_Variant_setScalarCopy(&m.payload.dataSetPayload.dataSetMessages[0].data.keyFrameData.dataSetFields[0].value, &iv, &UA_TYPES[UA_TYPES_UINT32]); m.payload.dataSetPayload.dataSetMessages[0].data.keyFrameData.dataSetFields[0].hasValue = true; size_t size = UA_NetworkMessage_calcSizeJson(&m, NULL, 0, NULL, 0, true); ck_assert(size == 338); UA_ByteString buffer; UA_StatusCode rv = UA_ByteString_allocBuffer(&buffer, size+1); ck_assert_int_eq(rv, UA_STATUSCODE_GOOD); UA_Byte *bufPos = buffer.data; memset(bufPos, 0, size+1); const UA_Byte *bufEnd = &(buffer.data[buffer.length]); rv = UA_NetworkMessage_encodeJson(&m, &bufPos, &bufEnd, NULL, 0, NULL, 0, true); *bufPos = 0; // then ck_assert_int_eq(rv, UA_STATUSCODE_GOOD); char* result = "{\"MessageId\":\"ABCDEFGH\",\"MessageType\":\"ua-data\",\"PublisherId\":65535,\"DataSetClassId\":\"00000001-0002-0003-0000-000000000000\",\"Messages\":[{\"DataSetWriterId\":12345,\"SequenceNumber\":4711,\"MetaDataVersion\":{\"MajorVersion\":42,\"MinorVersion\":7},\"Timestamp\":\"1601-01-13T20:38:32.111Z\",\"Status\":2764857,\"Payload\":{\"Field1\":{\"Type\":7,\"Body\":27}}}]}"; ck_assert_str_eq(result, (char*)buffer.data); UA_ByteString_deleteMembers(&buffer); UA_NetworkMessage_deleteMembers(&m); } END_TEST START_TEST(UA_PubSub_EnDecode) { UA_NetworkMessage m; memset(&m, 0, sizeof(UA_NetworkMessage)); m.version = 1; m.networkMessageType = UA_NETWORKMESSAGE_DATASET; m.payloadHeaderEnabled = true; m.payloadHeader.dataSetPayloadHeader.count = 2; UA_UInt16 dsWriter1 = 4; UA_UInt16 dsWriter2 = 7; m.payloadHeader.dataSetPayloadHeader.dataSetWriterIds = (UA_UInt16 *)UA_Array_new(m.payloadHeader.dataSetPayloadHeader.count, &UA_TYPES[UA_TYPES_UINT16]); m.payloadHeader.dataSetPayloadHeader.dataSetWriterIds[0] = dsWriter1; m.payloadHeader.dataSetPayloadHeader.dataSetWriterIds[1] = dsWriter2; size_t memsize = m.payloadHeader.dataSetPayloadHeader.count * sizeof(UA_DataSetMessage); m.payload.dataSetPayload.dataSetMessages = (UA_DataSetMessage*)UA_malloc(memsize); memset(m.payload.dataSetPayload.dataSetMessages, 0, memsize); m.payload.dataSetPayload.dataSetMessages[0].header.dataSetMessageValid = true; m.payload.dataSetPayload.dataSetMessages[0].header.fieldEncoding = UA_FIELDENCODING_VARIANT; m.payload.dataSetPayload.dataSetMessages[0].header.dataSetMessageType = UA_DATASETMESSAGE_DATAKEYFRAME; UA_UInt16 fieldCountDS1 = 1; m.payload.dataSetPayload.dataSetMessages[0].data.keyFrameData.fieldCount = fieldCountDS1; m.payload.dataSetPayload.dataSetMessages[0].data.keyFrameData.dataSetFields = (UA_DataValue*)UA_Array_new(m.payload.dataSetPayload.dataSetMessages[0].data.keyFrameData.fieldCount, &UA_TYPES[UA_TYPES_DATAVALUE]); UA_DataValue_init(&m.payload.dataSetPayload.dataSetMessages[0].data.keyFrameData.dataSetFields[0]); /* Set fieldnames */ m.payload.dataSetPayload.dataSetMessages[0].data.keyFrameData.fieldNames = (UA_String*)UA_Array_new(m.payload.dataSetPayload.dataSetMessages[0].data.keyFrameData.fieldCount, &UA_TYPES[UA_TYPES_STRING]); m.payload.dataSetPayload.dataSetMessages[0].data.keyFrameData.fieldNames[0] = UA_STRING_ALLOC("Field1"); UA_UInt32 iv = 27; UA_Variant_setScalarCopy(&m.payload.dataSetPayload.dataSetMessages[0].data.keyFrameData.dataSetFields[0].value, &iv, &UA_TYPES[UA_TYPES_UINT32]); m.payload.dataSetPayload.dataSetMessages[0].data.keyFrameData.dataSetFields[0].hasValue = true; m.payload.dataSetPayload.dataSetMessages[1].header.dataSetMessageValid = true; m.payload.dataSetPayload.dataSetMessages[1].header.fieldEncoding = UA_FIELDENCODING_DATAVALUE; m.payload.dataSetPayload.dataSetMessages[1].header.dataSetMessageType = UA_DATASETMESSAGE_DATAKEYFRAME; UA_UInt16 fieldCountDS2 = 2; m.payload.dataSetPayload.dataSetMessages[1].data.keyFrameData.fieldCount = fieldCountDS2; memsize = sizeof(UA_DataSetMessage_DeltaFrameField) * m.payload.dataSetPayload.dataSetMessages[1].data.deltaFrameData.fieldCount; m.payload.dataSetPayload.dataSetMessages[1].data.deltaFrameData.deltaFrameFields = (UA_DataSetMessage_DeltaFrameField*)UA_malloc(memsize); /* Set fieldnames */ m.payload.dataSetPayload.dataSetMessages[1].data.keyFrameData.fieldNames = (UA_String*)UA_Array_new(m.payload.dataSetPayload.dataSetMessages[1].data.deltaFrameData.fieldCount, &UA_TYPES[UA_TYPES_STRING]); m.payload.dataSetPayload.dataSetMessages[1].data.keyFrameData.fieldNames[0] = UA_STRING_ALLOC("Field2.1"); m.payload.dataSetPayload.dataSetMessages[1].data.keyFrameData.fieldNames[1] = UA_STRING_ALLOC("Field2.2"); UA_Guid gv = UA_Guid_random(); UA_DataValue_init(&m.payload.dataSetPayload.dataSetMessages[1].data.keyFrameData.dataSetFields[0]); UA_Variant_setScalarCopy(&m.payload.dataSetPayload.dataSetMessages[1].data.keyFrameData.dataSetFields[0].value, &gv, &UA_TYPES[UA_TYPES_GUID]); m.payload.dataSetPayload.dataSetMessages[1].data.keyFrameData.dataSetFields[0].hasValue = true; UA_DataValue_init(&m.payload.dataSetPayload.dataSetMessages[1].data.keyFrameData.dataSetFields[1]); UA_Int64 iv64 = 152478978534; UA_Variant_setScalarCopy(&m.payload.dataSetPayload.dataSetMessages[1].data.keyFrameData.dataSetFields[1].value, &iv64, &UA_TYPES[UA_TYPES_INT64]); m.payload.dataSetPayload.dataSetMessages[1].data.keyFrameData.dataSetFields[1].hasValue = true; size_t size = UA_NetworkMessage_calcSizeJson(&m, NULL, 0, NULL, 0, true); UA_ByteString buffer; UA_StatusCode rv = UA_ByteString_allocBuffer(&buffer, size); ck_assert_int_eq(rv, UA_STATUSCODE_GOOD); UA_Byte *bufPos = buffer.data; memset(bufPos, 0, size); const UA_Byte *bufEnd = &(buffer.data[buffer.length]); rv = UA_NetworkMessage_encodeJson(&m, &bufPos, &bufEnd, NULL, 0, NULL, 0, true); //*bufPos = 0; // then ck_assert_int_eq(rv, UA_STATUSCODE_GOOD); UA_NetworkMessage m2; memset(&m2, 0, sizeof(UA_NetworkMessage)); rv = UA_NetworkMessage_decodeJson(&m2, &buffer); ck_assert_int_eq(rv, UA_STATUSCODE_GOOD); ck_assert(m.networkMessageType == m2.networkMessageType); ck_assert(m.timestampEnabled == m2.timestampEnabled); ck_assert(m.dataSetClassIdEnabled == m2.dataSetClassIdEnabled); ck_assert(m.groupHeaderEnabled == m2.groupHeaderEnabled); ck_assert(m.picosecondsEnabled == m2.picosecondsEnabled); ck_assert(m.promotedFieldsEnabled == m2.promotedFieldsEnabled); ck_assert(m.publisherIdEnabled == m2.publisherIdEnabled); ck_assert(m.securityEnabled == m2.securityEnabled); ck_assert(m.chunkMessage == m2.chunkMessage); ck_assert(m.payloadHeaderEnabled == m2.payloadHeaderEnabled); ck_assert_uint_eq(m2.payloadHeader.dataSetPayloadHeader.dataSetWriterIds[0], dsWriter1); ck_assert_uint_eq(m2.payloadHeader.dataSetPayloadHeader.dataSetWriterIds[1], dsWriter2); ck_assert(m.payload.dataSetPayload.dataSetMessages[0].header.dataSetMessageValid == m2.payload.dataSetPayload.dataSetMessages[0].header.dataSetMessageValid); ck_assert(m.payload.dataSetPayload.dataSetMessages[0].header.fieldEncoding == m2.payload.dataSetPayload.dataSetMessages[0].header.fieldEncoding); ck_assert_int_eq(m2.payload.dataSetPayload.dataSetMessages[0].data.keyFrameData.fieldCount, fieldCountDS1); ck_assert(m.payload.dataSetPayload.dataSetMessages[0].data.keyFrameData.dataSetFields[0].hasValue == m2.payload.dataSetPayload.dataSetMessages[0].data.keyFrameData.dataSetFields[0].hasValue); ck_assert_uint_eq((uintptr_t)m2.payload.dataSetPayload.dataSetMessages[0].data.keyFrameData.dataSetFields[0].value.type, (uintptr_t)&UA_TYPES[UA_TYPES_UINT32]); ck_assert_uint_eq(*(UA_UInt32 *)m2.payload.dataSetPayload.dataSetMessages[0].data.keyFrameData.dataSetFields[0].value.data, iv); ck_assert(m.payload.dataSetPayload.dataSetMessages[0].data.keyFrameData.dataSetFields[0].hasSourceTimestamp == m2.payload.dataSetPayload.dataSetMessages[0].data.keyFrameData.dataSetFields[0].hasSourceTimestamp); ck_assert(m.payload.dataSetPayload.dataSetMessages[1].header.dataSetMessageValid == m2.payload.dataSetPayload.dataSetMessages[1].header.dataSetMessageValid); ck_assert(m.payload.dataSetPayload.dataSetMessages[1].data.deltaFrameData.deltaFrameFields[0].fieldValue.hasSourceTimestamp == m2.payload.dataSetPayload.dataSetMessages[1].data.deltaFrameData.deltaFrameFields[0].fieldValue.hasSourceTimestamp); UA_ByteString_deleteMembers(&buffer); UA_NetworkMessage_deleteMembers(&m); UA_NetworkMessage_deleteMembers(&m2); } END_TEST START_TEST(UA_NetworkMessage_oneMessage_twoFields_json_decode) { // given UA_NetworkMessage out; UA_ByteString buf = UA_STRING("{\"MessageId\":\"5ED82C10-50BB-CD07-0120-22521081E8EE\",\"MessageType\":\"ua-data\",\"Messages\":[{\"DataSetWriterId\":62541,\"MetaDataVersion\":{\"MajorVersion\":1478393530,\"MinorVersion\":12345},\"SequenceNumber\":4711,\"Payload\":{\"Test\":{\"Type\":5,\"Body\":42},\"Server localtime\":{\"Type\":13,\"Body\":\"2018-06-05T05:58:36.000Z\"}}}]}"); // when UA_StatusCode retval = UA_NetworkMessage_decodeJson(&out, &buf); // then ck_assert_int_eq(retval, UA_STATUSCODE_GOOD); //NetworkMessage ck_assert_int_eq(out.chunkMessage, false); ck_assert_int_eq(out.dataSetClassIdEnabled, false); ck_assert_int_eq(out.groupHeaderEnabled, false); ck_assert_int_eq(out.networkMessageType, UA_NETWORKMESSAGE_DATASET); ck_assert_int_eq(out.picosecondsEnabled, false); ck_assert_int_eq(out.promotedFieldsEnabled, false); ck_assert_int_eq(out.securityEnabled, false); ck_assert_int_eq(out.timestampEnabled, false); ck_assert_int_eq(out.publisherIdEnabled, false); ck_assert_int_eq(out.payloadHeaderEnabled, true); ck_assert_int_eq(out.payloadHeader.dataSetPayloadHeader.count, 1); ck_assert_int_eq(out.payloadHeader.dataSetPayloadHeader.dataSetWriterIds[0], 62541); //dataSetMessage ck_assert_int_eq(out.payload.dataSetPayload.dataSetMessages[0].header.dataSetMessageSequenceNrEnabled, true); ck_assert_int_eq(out.payload.dataSetPayload.dataSetMessages[0].header.dataSetMessageSequenceNr, 4711); ck_assert_int_eq(out.payload.dataSetPayload.dataSetMessages[0].header.dataSetMessageType, UA_DATASETMESSAGE_DATAKEYFRAME); ck_assert_int_eq(out.payload.dataSetPayload.dataSetMessages[0].header.fieldEncoding, UA_FIELDENCODING_VARIANT); ck_assert_int_eq(out.payload.dataSetPayload.dataSetMessages[0].header.picoSecondsIncluded, false); ck_assert_int_eq(out.payload.dataSetPayload.dataSetMessages[0].header.configVersionMinorVersionEnabled, true); ck_assert_int_eq(out.payload.dataSetPayload.dataSetMessages[0].header.configVersionMajorVersionEnabled, true); ck_assert_int_eq(out.payload.dataSetPayload.dataSetMessages[0].header.configVersionMinorVersion, 12345); ck_assert_int_eq(out.payload.dataSetPayload.dataSetMessages[0].header.configVersionMajorVersion, 1478393530); ck_assert_int_eq(out.payload.dataSetPayload.dataSetMessages[0].header.dataSetMessageSequenceNr, 4711); //ck_assert_int_eq(out.payload.dataSetPayload.dataSetMessages[0].header.dataSetWriterId, 62541); ck_assert_int_eq(out.payload.dataSetPayload.dataSetMessages[0].data.keyFrameData.dataSetFields[0].hasValue, 1); ck_assert_int_eq(*((UA_UInt16*)out.payload.dataSetPayload.dataSetMessages[0].data.keyFrameData.dataSetFields[0].value.data), 42); ck_assert_int_eq(out.payload.dataSetPayload.dataSetMessages[0].data.keyFrameData.dataSetFields[1].hasValue, 1); UA_DateTime *dt = (UA_DateTime*)out.payload.dataSetPayload.dataSetMessages[0].data.keyFrameData.dataSetFields[1].value.data; UA_DateTimeStruct dts = UA_DateTime_toStruct(*dt); ck_assert_int_eq(dts.year, 2018); ck_assert_int_eq(dts.month, 6); ck_assert_int_eq(dts.day, 5); ck_assert_int_eq(dts.hour, 5); ck_assert_int_eq(dts.min, 58); ck_assert_int_eq(dts.sec, 36); ck_assert_int_eq(dts.milliSec, 0); ck_assert_int_eq(dts.microSec, 0); ck_assert_int_eq(dts.nanoSec, 0); UA_NetworkMessage_deleteMembers(&out); } END_TEST START_TEST(UA_NetworkMessage_json_decode) { // given UA_NetworkMessage out; memset(&out,0,sizeof(UA_NetworkMessage)); UA_ByteString buf = UA_STRING("{\"MessageId\":\"5ED82C10-50BB-CD07-0120-22521081E8EE\",\"MessageType\":\"ua-data\",\"Messages\":[{\"MetaDataVersion\":{\"MajorVersion\": 47, \"MinorVersion\": 47},\"DataSetWriterId\":62541,\"Status\":22,\"SequenceNumber\":4711,\"Payload\":{\"Test\":{\"Type\":5,\"Body\":42},\"Server localtime\":{\"Type\":1,\"Body\":true}}}]}"); // when UA_StatusCode retval = UA_NetworkMessage_decodeJson(&out, &buf); // then ck_assert_int_eq(retval, UA_STATUSCODE_GOOD); //NetworkMessage ck_assert_int_eq(out.chunkMessage, false); ck_assert_int_eq(out.dataSetClassIdEnabled, false); ck_assert_int_eq(out.groupHeaderEnabled, false); ck_assert_int_eq(out.networkMessageType, UA_NETWORKMESSAGE_DATASET); ck_assert_int_eq(out.picosecondsEnabled, false); ck_assert_int_eq(out.promotedFieldsEnabled, false); ck_assert_int_eq(out.securityEnabled, false); ck_assert_int_eq(out.timestampEnabled, false); ck_assert_int_eq(out.publisherIdEnabled, false); ck_assert_int_eq(out.payloadHeaderEnabled, true); ck_assert_int_eq(out.payloadHeader.dataSetPayloadHeader.count, 1); ck_assert_int_eq(out.payloadHeader.dataSetPayloadHeader.dataSetWriterIds[0], 62541); //dataSetMessage ck_assert_int_eq(out.payload.dataSetPayload.dataSetMessages[0].header.dataSetMessageSequenceNrEnabled, true); ck_assert_int_eq(out.payload.dataSetPayload.dataSetMessages[0].header.dataSetMessageSequenceNr, 4711); ck_assert_int_eq(out.payload.dataSetPayload.dataSetMessages[0].header.dataSetMessageType, UA_DATASETMESSAGE_DATAKEYFRAME); ck_assert_int_eq(out.payload.dataSetPayload.dataSetMessages[0].header.fieldEncoding, UA_FIELDENCODING_VARIANT); ck_assert_int_eq(out.payload.dataSetPayload.dataSetMessages[0].header.picoSecondsIncluded, false); ck_assert_int_eq(out.payload.dataSetPayload.dataSetMessages[0].header.statusEnabled, true); ck_assert_int_eq(out.payload.dataSetPayload.dataSetMessages[0].header.status, 22); ck_assert_int_eq(out.payload.dataSetPayload.dataSetMessages[0].header.configVersionMinorVersionEnabled, true); ck_assert_int_eq(out.payload.dataSetPayload.dataSetMessages[0].header.configVersionMajorVersionEnabled, true); ck_assert_int_eq(out.payload.dataSetPayload.dataSetMessages[0].header.configVersionMinorVersion, 47); ck_assert_int_eq(out.payload.dataSetPayload.dataSetMessages[0].header.configVersionMajorVersion, 47); //dataSetFields ck_assert_int_eq(out.payload.dataSetPayload.dataSetMessages[0].data.keyFrameData.dataSetFields[0].hasValue, true); ck_assert_int_eq(*((UA_UInt16*)out.payload.dataSetPayload.dataSetMessages[0].data.keyFrameData.dataSetFields[0].value.data), 42); ck_assert_int_eq(out.payload.dataSetPayload.dataSetMessages[0].data.keyFrameData.dataSetFields[1].hasValue, true); ck_assert_int_eq(*((UA_Boolean*)out.payload.dataSetPayload.dataSetMessages[0].data.keyFrameData.dataSetFields[1].value.data), 1); UA_NetworkMessage_deleteMembers(&out); } END_TEST START_TEST(UA_Networkmessage_DataSetFieldsNull_json_decode) { // given UA_NetworkMessage out; memset(&out, 0, sizeof(UA_NetworkMessage)); UA_ByteString buf = UA_STRING("{ \"MessageId\": \"32235546-05d9-4fd7-97df-ea3ff3408574\", " "\"MessageType\": \"ua-data\", \"PublisherId\": \"MQTT-Localhost\", " "\"DataSetClassId\": \"00000005-cab9-4470-8f8a-2c1ead207e0e\", \"Messages\": " "[ { \"DataSetWriterId\": 1, \"SequenceNumber\": 224, \"MetaDataVersion\": " "{ \"MajorVersion\": 1, \"MinorVersion\": 1 },\"Payload\":null}]}"); // when UA_StatusCode retval = UA_NetworkMessage_decodeJson(&out, &buf); // then ck_assert_int_eq(retval, UA_STATUSCODE_GOOD); ck_assert_int_eq(out.dataSetClassId.data1, 5); ck_assert_int_eq(out.payload.dataSetPayload.dataSetMessages->header.dataSetMessageSequenceNr, 224); ck_assert_ptr_eq(out.payload.dataSetPayload.dataSetMessages->data.keyFrameData.dataSetFields, NULL); UA_NetworkMessage_deleteMembers(&out); } END_TEST START_TEST(UA_NetworkMessage_fieldNames_json_decode) { // given UA_NetworkMessage out; UA_ByteString buf = UA_STRING("{\"MessageId\":\"5ED82C10-50BB-CD07-0120-22521081E8EE\"," "\"MessageType\":\"ua-data\",\"Messages\":" "[{\"DataSetWriterId\":62541,\"MetaDataVersion\":" "{\"MajorVersion\":1478393530,\"MinorVersion\":12345}," "\"SequenceNumber\":4711,\"Payload\":{\"Test\":{\"Type\":5,\"Body\":42},\"Test2\":" "{\"Type\":13,\"Body\":\"2018-06-05T05:58:36.000Z\"}}}]}"); // when UA_StatusCode retval = UA_NetworkMessage_decodeJson(&out, &buf); // then ck_assert_int_eq(retval, UA_STATUSCODE_GOOD); //NetworkMessage ck_assert_int_eq(out.payload.dataSetPayload.dataSetMessages[0].data.keyFrameData.fieldNames[0].data[0], 'T'); ck_assert_int_eq(out.payload.dataSetPayload.dataSetMessages[0].data.keyFrameData.fieldNames[0].data[1], 'e'); ck_assert_int_eq(out.payload.dataSetPayload.dataSetMessages[0].data.keyFrameData.fieldNames[0].data[2], 's'); ck_assert_int_eq(out.payload.dataSetPayload.dataSetMessages[0].data.keyFrameData.fieldNames[0].data[3], 't'); ck_assert_int_eq(out.payload.dataSetPayload.dataSetMessages[0].data.keyFrameData.fieldNames[1].data[0], 'T'); ck_assert_int_eq(out.payload.dataSetPayload.dataSetMessages[0].data.keyFrameData.fieldNames[1].data[1], 'e'); ck_assert_int_eq(out.payload.dataSetPayload.dataSetMessages[0].data.keyFrameData.fieldNames[1].data[2], 's'); ck_assert_int_eq(out.payload.dataSetPayload.dataSetMessages[0].data.keyFrameData.fieldNames[1].data[3], 't'); ck_assert_int_eq(out.payload.dataSetPayload.dataSetMessages[0].data.keyFrameData.fieldNames[1].data[4], '2'); UA_NetworkMessage_deleteMembers(&out); } END_TEST static Suite *testSuite_networkmessage(void) { Suite *s = suite_create("Built-in Data Types 62541-6 Json"); TCase *tc_json_networkmessage = tcase_create("networkmessage_json"); tcase_add_test(tc_json_networkmessage, UA_PubSub_EncodeAllOptionalFields); tcase_add_test(tc_json_networkmessage, UA_PubSub_EnDecode); tcase_add_test(tc_json_networkmessage, UA_NetworkMessage_oneMessage_twoFields_json_decode); tcase_add_test(tc_json_networkmessage, UA_NetworkMessage_json_decode); tcase_add_test(tc_json_networkmessage, UA_Networkmessage_DataSetFieldsNull_json_decode); tcase_add_test(tc_json_networkmessage, UA_NetworkMessage_fieldNames_json_decode); suite_add_tcase(s, tc_json_networkmessage); return s; } int main(void) { int number_failed = 0; Suite *s; SRunner *sr; s = testSuite_networkmessage(); sr = srunner_create(s); srunner_set_fork_status(sr, CK_NOFORK); srunner_run_all(sr, CK_NORMAL); number_failed += srunner_ntests_failed(sr); srunner_free(sr); return (number_failed == 0) ? EXIT_SUCCESS : EXIT_FAILURE; }