Google Git
Sign in
coral / a71ch-crypto-support / 8dc1f1434da50a4b7361d651239c1f3f4f8cc25b / . / ext / open62541 / tests / pubsub / check_pubsub_encoding_json.c
blob: 90484aba7b485e443347a4f6ffad0da830b9c658 [file] [log] [blame]
/* 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 <open62541/client.h>
#include <open62541/types.h>
#include <open62541/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_int_eq(size, 342);
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.1111111Z\",\"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;
}