Xin Zhang / azure-iot-c-sdk-f767zi

Important changes to repositories hosted on mbed.com

Mbed hosted mercurial repositories are deprecated and are due to be permanently deleted in July 2026.

To keep a copy of this software download the repository Zip archive or clone locally using Mercurial.

It is also possible to export all your personal repositories from the account settings page.

Dependents:   samplemqtt

serializer/src/datamarshaller.c@0:f7f1f0d76dd6, 2018-08-23 (annotated)

Committer:
XinZhangMS
Date:
Thu Aug 23 06:52:14 2018 +0000
Revision:
0:f7f1f0d76dd6
azure-c-sdk for mbed os supporting NUCLEO_F767ZI

Who changed what in which revision?

UserRevisionLine numberNew contents of line
XinZhangMS 0:f7f1f0d76dd6 1 // Copyright (c) Microsoft. All rights reserved.
XinZhangMS 0:f7f1f0d76dd6 2 // Licensed under the MIT license. See LICENSE file in the project root for full license information.
XinZhangMS 0:f7f1f0d76dd6 3
XinZhangMS 0:f7f1f0d76dd6 4 #include <stdlib.h> /*for free*/
XinZhangMS 0:f7f1f0d76dd6 5 #include "azure_c_shared_utility/gballoc.h"
XinZhangMS 0:f7f1f0d76dd6 6
XinZhangMS 0:f7f1f0d76dd6 7 #include <stdbool.h>
XinZhangMS 0:f7f1f0d76dd6 8 #include "datamarshaller.h"
XinZhangMS 0:f7f1f0d76dd6 9 #include "azure_c_shared_utility/crt_abstractions.h"
XinZhangMS 0:f7f1f0d76dd6 10 #include "schema.h"
XinZhangMS 0:f7f1f0d76dd6 11 #include "jsonencoder.h"
XinZhangMS 0:f7f1f0d76dd6 12 #include "agenttypesystem.h"
XinZhangMS 0:f7f1f0d76dd6 13 #include "azure_c_shared_utility/xlogging.h"
XinZhangMS 0:f7f1f0d76dd6 14 #include "parson.h"
XinZhangMS 0:f7f1f0d76dd6 15 #include "azure_c_shared_utility/vector.h"
XinZhangMS 0:f7f1f0d76dd6 16
XinZhangMS 0:f7f1f0d76dd6 17 DEFINE_ENUM_STRINGS(DATA_MARSHALLER_RESULT, DATA_MARSHALLER_RESULT_VALUES);
XinZhangMS 0:f7f1f0d76dd6 18
XinZhangMS 0:f7f1f0d76dd6 19 #define LOG_DATA_MARSHALLER_ERROR \
XinZhangMS 0:f7f1f0d76dd6 20 LogError("(result = %s)", ENUM_TO_STRING(DATA_MARSHALLER_RESULT, result));
XinZhangMS 0:f7f1f0d76dd6 21
XinZhangMS 0:f7f1f0d76dd6 22 typedef struct DATA_MARSHALLER_HANDLE_DATA_TAG
XinZhangMS 0:f7f1f0d76dd6 23 {
XinZhangMS 0:f7f1f0d76dd6 24 SCHEMA_MODEL_TYPE_HANDLE ModelHandle;
XinZhangMS 0:f7f1f0d76dd6 25 bool IncludePropertyPath;
XinZhangMS 0:f7f1f0d76dd6 26 } DATA_MARSHALLER_HANDLE_DATA;
XinZhangMS 0:f7f1f0d76dd6 27
XinZhangMS 0:f7f1f0d76dd6 28 static int NoCloneFunction(void** destination, const void* source)
XinZhangMS 0:f7f1f0d76dd6 29 {
XinZhangMS 0:f7f1f0d76dd6 30 *destination = (void*)source;
XinZhangMS 0:f7f1f0d76dd6 31 return 0;
XinZhangMS 0:f7f1f0d76dd6 32 }
XinZhangMS 0:f7f1f0d76dd6 33
XinZhangMS 0:f7f1f0d76dd6 34 static void NoFreeFunction(void* value)
XinZhangMS 0:f7f1f0d76dd6 35 {
XinZhangMS 0:f7f1f0d76dd6 36 (void)value;
XinZhangMS 0:f7f1f0d76dd6 37 }
XinZhangMS 0:f7f1f0d76dd6 38
XinZhangMS 0:f7f1f0d76dd6 39 DATA_MARSHALLER_HANDLE DataMarshaller_Create(SCHEMA_MODEL_TYPE_HANDLE modelHandle, bool includePropertyPath)
XinZhangMS 0:f7f1f0d76dd6 40 {
XinZhangMS 0:f7f1f0d76dd6 41 DATA_MARSHALLER_HANDLE_DATA* result;
XinZhangMS 0:f7f1f0d76dd6 42
XinZhangMS 0:f7f1f0d76dd6 43 /*Codes_SRS_DATA_MARSHALLER_99_019:[ DataMarshaller_Create shall return NULL if any argument is NULL.]*/
XinZhangMS 0:f7f1f0d76dd6 44 if (modelHandle == NULL)
XinZhangMS 0:f7f1f0d76dd6 45 {
XinZhangMS 0:f7f1f0d76dd6 46 result = NULL;
XinZhangMS 0:f7f1f0d76dd6 47 LogError("(result = %s)", ENUM_TO_STRING(DATA_MARSHALLER_RESULT, DATA_MARSHALLER_INVALID_ARG));
XinZhangMS 0:f7f1f0d76dd6 48 }
XinZhangMS 0:f7f1f0d76dd6 49 else if ((result = (DATA_MARSHALLER_HANDLE_DATA*)malloc(sizeof(DATA_MARSHALLER_HANDLE_DATA))) == NULL)
XinZhangMS 0:f7f1f0d76dd6 50 {
XinZhangMS 0:f7f1f0d76dd6 51 /* Codes_SRS_DATA_MARSHALLER_99_048:[On any other errors not explicitly specified, DataMarshaller_Create shall return NULL.] */
XinZhangMS 0:f7f1f0d76dd6 52 result = NULL;
XinZhangMS 0:f7f1f0d76dd6 53 LogError("(result = %s)", ENUM_TO_STRING(DATA_MARSHALLER_RESULT, DATA_MARSHALLER_ERROR));
XinZhangMS 0:f7f1f0d76dd6 54 }
XinZhangMS 0:f7f1f0d76dd6 55 else
XinZhangMS 0:f7f1f0d76dd6 56 {
XinZhangMS 0:f7f1f0d76dd6 57 /*everything ok*/
XinZhangMS 0:f7f1f0d76dd6 58 /*Codes_SRS_DATA_MARSHALLER_99_018:[ DataMarshaller_Create shall create a new DataMarshaller instance and on success it shall return a non NULL handle.]*/
XinZhangMS 0:f7f1f0d76dd6 59 result->ModelHandle = modelHandle;
XinZhangMS 0:f7f1f0d76dd6 60 result->IncludePropertyPath = includePropertyPath;
XinZhangMS 0:f7f1f0d76dd6 61 }
XinZhangMS 0:f7f1f0d76dd6 62 return result;
XinZhangMS 0:f7f1f0d76dd6 63 }
XinZhangMS 0:f7f1f0d76dd6 64
XinZhangMS 0:f7f1f0d76dd6 65 void DataMarshaller_Destroy(DATA_MARSHALLER_HANDLE dataMarshallerHandle)
XinZhangMS 0:f7f1f0d76dd6 66 {
XinZhangMS 0:f7f1f0d76dd6 67 /* Codes_SRS_DATA_MARSHALLER_99_024:[ When called with a NULL handle, DataMarshaller_Destroy shall do nothing.] */
XinZhangMS 0:f7f1f0d76dd6 68 if (dataMarshallerHandle != NULL)
XinZhangMS 0:f7f1f0d76dd6 69 {
XinZhangMS 0:f7f1f0d76dd6 70 /* Codes_SRS_DATA_MARSHALLER_99_022:[ DataMarshaller_Destroy shall free all resources associated with the dataMarshallerHandle argument.] */
XinZhangMS 0:f7f1f0d76dd6 71 DATA_MARSHALLER_HANDLE_DATA* dataMarshallerInstance = (DATA_MARSHALLER_HANDLE_DATA*)dataMarshallerHandle;
XinZhangMS 0:f7f1f0d76dd6 72 free(dataMarshallerInstance);
XinZhangMS 0:f7f1f0d76dd6 73 }
XinZhangMS 0:f7f1f0d76dd6 74 }
XinZhangMS 0:f7f1f0d76dd6 75
XinZhangMS 0:f7f1f0d76dd6 76 DATA_MARSHALLER_RESULT DataMarshaller_SendData(DATA_MARSHALLER_HANDLE dataMarshallerHandle, size_t valueCount, const DATA_MARSHALLER_VALUE* values, unsigned char** destination, size_t* destinationSize)
XinZhangMS 0:f7f1f0d76dd6 77 {
XinZhangMS 0:f7f1f0d76dd6 78 DATA_MARSHALLER_HANDLE_DATA* dataMarshallerInstance = (DATA_MARSHALLER_HANDLE_DATA*)dataMarshallerHandle;
XinZhangMS 0:f7f1f0d76dd6 79 DATA_MARSHALLER_RESULT result;
XinZhangMS 0:f7f1f0d76dd6 80 MULTITREE_HANDLE treeHandle;
XinZhangMS 0:f7f1f0d76dd6 81
XinZhangMS 0:f7f1f0d76dd6 82 /* Codes_SRS_DATA_MARSHALLER_99_034:[All argument checks shall be performed before calling any other modules.] */
XinZhangMS 0:f7f1f0d76dd6 83 /* Codes_SRS_DATA_MARSHALLER_99_004:[ DATA_MARSHALLER_INVALID_ARG shall be returned when the function has detected an invalid parameter (NULL) being passed to the function.] */
XinZhangMS 0:f7f1f0d76dd6 84 if ((values == NULL) ||
XinZhangMS 0:f7f1f0d76dd6 85 (dataMarshallerHandle == NULL) ||
XinZhangMS 0:f7f1f0d76dd6 86 (destination == NULL) ||
XinZhangMS 0:f7f1f0d76dd6 87 (destinationSize == NULL) ||
XinZhangMS 0:f7f1f0d76dd6 88 /* Codes_SRS_DATA_MARSHALLER_99_033:[ DATA_MARSHALLER_INVALID_ARG shall be returned if the valueCount is zero.] */
XinZhangMS 0:f7f1f0d76dd6 89 (valueCount == 0))
XinZhangMS 0:f7f1f0d76dd6 90 {
XinZhangMS 0:f7f1f0d76dd6 91 result = DATA_MARSHALLER_INVALID_ARG;
XinZhangMS 0:f7f1f0d76dd6 92 LOG_DATA_MARSHALLER_ERROR
XinZhangMS 0:f7f1f0d76dd6 93 }
XinZhangMS 0:f7f1f0d76dd6 94 else
XinZhangMS 0:f7f1f0d76dd6 95 {
XinZhangMS 0:f7f1f0d76dd6 96 size_t i;
XinZhangMS 0:f7f1f0d76dd6 97 bool includePropertyPath = dataMarshallerInstance->IncludePropertyPath;
XinZhangMS 0:f7f1f0d76dd6 98 /* VS complains wrongly that result is not initialized */
XinZhangMS 0:f7f1f0d76dd6 99 result = DATA_MARSHALLER_ERROR;
XinZhangMS 0:f7f1f0d76dd6 100
XinZhangMS 0:f7f1f0d76dd6 101 for (i = 0; i < valueCount; i++)
XinZhangMS 0:f7f1f0d76dd6 102 {
XinZhangMS 0:f7f1f0d76dd6 103 if ((values[i].PropertyPath == NULL) ||
XinZhangMS 0:f7f1f0d76dd6 104 (values[i].Value == NULL))
XinZhangMS 0:f7f1f0d76dd6 105 {
XinZhangMS 0:f7f1f0d76dd6 106 /*Codes_SRS_DATA_MARSHALLER_99_007:[ DATA_MARSHALLER_INVALID_MODEL_PROPERTY shall be returned when any of the items in values contain invalid data]*/
XinZhangMS 0:f7f1f0d76dd6 107 result = DATA_MARSHALLER_INVALID_MODEL_PROPERTY;
XinZhangMS 0:f7f1f0d76dd6 108 LOG_DATA_MARSHALLER_ERROR
XinZhangMS 0:f7f1f0d76dd6 109 break;
XinZhangMS 0:f7f1f0d76dd6 110 }
XinZhangMS 0:f7f1f0d76dd6 111
XinZhangMS 0:f7f1f0d76dd6 112 if ((!dataMarshallerInstance->IncludePropertyPath) &&
XinZhangMS 0:f7f1f0d76dd6 113 (values[i].Value->type == EDM_COMPLEX_TYPE_TYPE) &&
XinZhangMS 0:f7f1f0d76dd6 114 (valueCount > 1))
XinZhangMS 0:f7f1f0d76dd6 115 {
XinZhangMS 0:f7f1f0d76dd6 116 /* Codes_SRS_DATAMARSHALLER_01_002: [If the includePropertyPath argument passed to DataMarshaller_Create was false and the number of values passed to SendData is greater than 1 and at least one of them is a struct, DataMarshaller_SendData shall fallback to including the complete property path in the output JSON.] */
XinZhangMS 0:f7f1f0d76dd6 117 includePropertyPath = true;
XinZhangMS 0:f7f1f0d76dd6 118 }
XinZhangMS 0:f7f1f0d76dd6 119 }
XinZhangMS 0:f7f1f0d76dd6 120
XinZhangMS 0:f7f1f0d76dd6 121 if (i == valueCount)
XinZhangMS 0:f7f1f0d76dd6 122 {
XinZhangMS 0:f7f1f0d76dd6 123 /* Codes_SRS_DATA_MARSHALLER_99_037:[DataMarshaller shall store as MultiTree the data to be encoded by the JSONEncoder module.] */
XinZhangMS 0:f7f1f0d76dd6 124 if ((treeHandle = MultiTree_Create(NoCloneFunction, NoFreeFunction)) == NULL)
XinZhangMS 0:f7f1f0d76dd6 125 {
XinZhangMS 0:f7f1f0d76dd6 126 /* Codes_SRS_DATA_MARSHALLER_99_035:[DATA_MARSHALLER_MULTITREE_ERROR shall be returned in case any MultiTree API call fails.] */
XinZhangMS 0:f7f1f0d76dd6 127 result = DATA_MARSHALLER_MULTITREE_ERROR;
XinZhangMS 0:f7f1f0d76dd6 128 LOG_DATA_MARSHALLER_ERROR
XinZhangMS 0:f7f1f0d76dd6 129 }
XinZhangMS 0:f7f1f0d76dd6 130 else
XinZhangMS 0:f7f1f0d76dd6 131 {
XinZhangMS 0:f7f1f0d76dd6 132 size_t j;
XinZhangMS 0:f7f1f0d76dd6 133 result = DATA_MARSHALLER_OK; /* addressing warning in VS compiler */
XinZhangMS 0:f7f1f0d76dd6 134 /* Codes_SRS_DATA_MARSHALLER_99_038:[For each pair in the values argument, a string : value pair shall exist in the JSON object in the form of propertyName : value.] */
XinZhangMS 0:f7f1f0d76dd6 135 for (j = 0; j < valueCount; j++)
XinZhangMS 0:f7f1f0d76dd6 136 {
XinZhangMS 0:f7f1f0d76dd6 137 if ((includePropertyPath == false) && (values[j].Value->type == EDM_COMPLEX_TYPE_TYPE))
XinZhangMS 0:f7f1f0d76dd6 138 {
XinZhangMS 0:f7f1f0d76dd6 139 size_t k;
XinZhangMS 0:f7f1f0d76dd6 140
XinZhangMS 0:f7f1f0d76dd6 141 /* Codes_SRS_DATAMARSHALLER_01_001: [If the includePropertyPath argument passed to DataMarshaller_Create was false and only one struct is being sent, the relative path of the value passed to DataMarshaller_SendData - including property name - shall be ignored and the value shall be placed at JSON root.] */
XinZhangMS 0:f7f1f0d76dd6 142 for (k = 0; k < values[j].Value->value.edmComplexType.nMembers; k++)
XinZhangMS 0:f7f1f0d76dd6 143 {
XinZhangMS 0:f7f1f0d76dd6 144 /* Codes_SRS_DATAMARSHALLER_01_004: [In this case the members of the struct shall be added as leafs into the MultiTree, each leaf having the name of the struct member.] */
XinZhangMS 0:f7f1f0d76dd6 145 if (MultiTree_AddLeaf(treeHandle, values[j].Value->value.edmComplexType.fields[k].fieldName, (void*)values[j].Value->value.edmComplexType.fields[k].value) != MULTITREE_OK)
XinZhangMS 0:f7f1f0d76dd6 146 {
XinZhangMS 0:f7f1f0d76dd6 147 break;
XinZhangMS 0:f7f1f0d76dd6 148 }
XinZhangMS 0:f7f1f0d76dd6 149 }
XinZhangMS 0:f7f1f0d76dd6 150
XinZhangMS 0:f7f1f0d76dd6 151 if (k < values[j].Value->value.edmComplexType.nMembers)
XinZhangMS 0:f7f1f0d76dd6 152 {
XinZhangMS 0:f7f1f0d76dd6 153 /* Codes_SRS_DATA_MARSHALLER_99_035:[DATA_MARSHALLER_MULTITREE_ERROR shall be returned in case any MultiTree API call fails.] */
XinZhangMS 0:f7f1f0d76dd6 154 result = DATA_MARSHALLER_MULTITREE_ERROR;
XinZhangMS 0:f7f1f0d76dd6 155 LOG_DATA_MARSHALLER_ERROR
XinZhangMS 0:f7f1f0d76dd6 156 break;
XinZhangMS 0:f7f1f0d76dd6 157 }
XinZhangMS 0:f7f1f0d76dd6 158 }
XinZhangMS 0:f7f1f0d76dd6 159 else
XinZhangMS 0:f7f1f0d76dd6 160 {
XinZhangMS 0:f7f1f0d76dd6 161 /* Codes_SRS_DATA_MARSHALLER_99_039:[ If the includePropertyPath argument passed to DataMarshaller_Create was true each property shall be placed in the appropriate position in the JSON according to its path in the model.] */
XinZhangMS 0:f7f1f0d76dd6 162 if (MultiTree_AddLeaf(treeHandle, values[j].PropertyPath, (void*)values[j].Value) != MULTITREE_OK)
XinZhangMS 0:f7f1f0d76dd6 163 {
XinZhangMS 0:f7f1f0d76dd6 164 /* Codes_SRS_DATA_MARSHALLER_99_035:[DATA_MARSHALLER_MULTITREE_ERROR shall be returned in case any MultiTree API call fails.] */
XinZhangMS 0:f7f1f0d76dd6 165 result = DATA_MARSHALLER_MULTITREE_ERROR;
XinZhangMS 0:f7f1f0d76dd6 166 LOG_DATA_MARSHALLER_ERROR
XinZhangMS 0:f7f1f0d76dd6 167 break;
XinZhangMS 0:f7f1f0d76dd6 168 }
XinZhangMS 0:f7f1f0d76dd6 169 }
XinZhangMS 0:f7f1f0d76dd6 170
XinZhangMS 0:f7f1f0d76dd6 171 }
XinZhangMS 0:f7f1f0d76dd6 172
XinZhangMS 0:f7f1f0d76dd6 173 if (j == valueCount)
XinZhangMS 0:f7f1f0d76dd6 174 {
XinZhangMS 0:f7f1f0d76dd6 175 STRING_HANDLE payload = STRING_new();
XinZhangMS 0:f7f1f0d76dd6 176 if (payload == NULL)
XinZhangMS 0:f7f1f0d76dd6 177 {
XinZhangMS 0:f7f1f0d76dd6 178 result = DATA_MARSHALLER_ERROR;
XinZhangMS 0:f7f1f0d76dd6 179 LOG_DATA_MARSHALLER_ERROR
XinZhangMS 0:f7f1f0d76dd6 180 }
XinZhangMS 0:f7f1f0d76dd6 181 else
XinZhangMS 0:f7f1f0d76dd6 182 {
XinZhangMS 0:f7f1f0d76dd6 183 if (JSONEncoder_EncodeTree(treeHandle, payload, (JSON_ENCODER_TOSTRING_FUNC)AgentDataTypes_ToString) != JSON_ENCODER_OK)
XinZhangMS 0:f7f1f0d76dd6 184 {
XinZhangMS 0:f7f1f0d76dd6 185 /* Codes_SRS_DATA_MARSHALLER_99_027:[ DATA_MARSHALLER_JSON_ENCODER_ERROR shall be returned when JSONEncoder returns an error code.] */
XinZhangMS 0:f7f1f0d76dd6 186 result = DATA_MARSHALLER_JSON_ENCODER_ERROR;
XinZhangMS 0:f7f1f0d76dd6 187 LOG_DATA_MARSHALLER_ERROR
XinZhangMS 0:f7f1f0d76dd6 188 }
XinZhangMS 0:f7f1f0d76dd6 189 else
XinZhangMS 0:f7f1f0d76dd6 190 {
XinZhangMS 0:f7f1f0d76dd6 191 /*Codes_SRS_DATAMARSHALLER_02_007: [DataMarshaller_SendData shall copy in the output parameters *destination, *destinationSize the content and the content length of the encoded JSON tree.] */
XinZhangMS 0:f7f1f0d76dd6 192 size_t resultSize = STRING_length(payload);
XinZhangMS 0:f7f1f0d76dd6 193 unsigned char* temp = malloc(resultSize);
XinZhangMS 0:f7f1f0d76dd6 194 if (temp == NULL)
XinZhangMS 0:f7f1f0d76dd6 195 {
XinZhangMS 0:f7f1f0d76dd6 196 /*Codes_SRS_DATA_MARSHALLER_99_015:[ DATA_MARSHALLER_ERROR shall be returned in all the other error cases not explicitly defined here.]*/
XinZhangMS 0:f7f1f0d76dd6 197 result = DATA_MARSHALLER_ERROR;
XinZhangMS 0:f7f1f0d76dd6 198 LOG_DATA_MARSHALLER_ERROR;
XinZhangMS 0:f7f1f0d76dd6 199 }
XinZhangMS 0:f7f1f0d76dd6 200 else
XinZhangMS 0:f7f1f0d76dd6 201 {
XinZhangMS 0:f7f1f0d76dd6 202 (void)memcpy(temp, STRING_c_str(payload), resultSize);
XinZhangMS 0:f7f1f0d76dd6 203 *destination = temp;
XinZhangMS 0:f7f1f0d76dd6 204 *destinationSize = resultSize;
XinZhangMS 0:f7f1f0d76dd6 205 result = DATA_MARSHALLER_OK;
XinZhangMS 0:f7f1f0d76dd6 206 }
XinZhangMS 0:f7f1f0d76dd6 207 }
XinZhangMS 0:f7f1f0d76dd6 208 STRING_delete(payload);
XinZhangMS 0:f7f1f0d76dd6 209 }
XinZhangMS 0:f7f1f0d76dd6 210 } /* if (j==valueCount)*/
XinZhangMS 0:f7f1f0d76dd6 211 MultiTree_Destroy(treeHandle);
XinZhangMS 0:f7f1f0d76dd6 212 } /* MultiTree_Create */
XinZhangMS 0:f7f1f0d76dd6 213 }
XinZhangMS 0:f7f1f0d76dd6 214 }
XinZhangMS 0:f7f1f0d76dd6 215
XinZhangMS 0:f7f1f0d76dd6 216 return result;
XinZhangMS 0:f7f1f0d76dd6 217 }
XinZhangMS 0:f7f1f0d76dd6 218
XinZhangMS 0:f7f1f0d76dd6 219
XinZhangMS 0:f7f1f0d76dd6 220 DATA_MARSHALLER_RESULT DataMarshaller_SendData_ReportedProperties(DATA_MARSHALLER_HANDLE dataMarshallerHandle, VECTOR_HANDLE values, unsigned char** destination, size_t* destinationSize)
XinZhangMS 0:f7f1f0d76dd6 221 {
XinZhangMS 0:f7f1f0d76dd6 222 DATA_MARSHALLER_RESULT result;
XinZhangMS 0:f7f1f0d76dd6 223 /*Codes_SRS_DATA_MARSHALLER_02_021: [ If argument dataMarshallerHandle is NULL then DataMarshaller_SendData_ReportedProperties shall fail and return DATA_MARSHALLER_INVALID_ARG. ]*/
XinZhangMS 0:f7f1f0d76dd6 224 /*Codes_SRS_DATA_MARSHALLER_02_008: [ If argument values is NULL then DataMarshaller_SendData_ReportedProperties shall fail and return DATA_MARSHALLER_INVALID_ARG. ]*/
XinZhangMS 0:f7f1f0d76dd6 225 /*Codes_SRS_DATA_MARSHALLER_02_009: [ If argument destination NULL then DataMarshaller_SendData_ReportedProperties shall fail and return DATA_MARSHALLER_INVALID_ARG. ]*/
XinZhangMS 0:f7f1f0d76dd6 226 /*Codes_SRS_DATA_MARSHALLER_02_010: [ If argument destinationSize NULL then DataMarshaller_SendData_ReportedProperties shall fail and return DATA_MARSHALLER_INVALID_ARG. ]*/
XinZhangMS 0:f7f1f0d76dd6 227 if (
XinZhangMS 0:f7f1f0d76dd6 228 (dataMarshallerHandle == NULL) ||
XinZhangMS 0:f7f1f0d76dd6 229 (values == NULL) ||
XinZhangMS 0:f7f1f0d76dd6 230 (destination == NULL) ||
XinZhangMS 0:f7f1f0d76dd6 231 (destinationSize == NULL)
XinZhangMS 0:f7f1f0d76dd6 232 )
XinZhangMS 0:f7f1f0d76dd6 233 {
XinZhangMS 0:f7f1f0d76dd6 234 LogError("invalid argument DATA_MARSHALLER_HANDLE dataMarshallerHandle=%p, VECTOR_HANDLE values=%p, unsigned char** destination=%p, size_t* destinationSize=%p",
XinZhangMS 0:f7f1f0d76dd6 235 dataMarshallerHandle,
XinZhangMS 0:f7f1f0d76dd6 236 values,
XinZhangMS 0:f7f1f0d76dd6 237 destination,
XinZhangMS 0:f7f1f0d76dd6 238 destinationSize);
XinZhangMS 0:f7f1f0d76dd6 239 result = DATA_MARSHALLER_INVALID_ARG;
XinZhangMS 0:f7f1f0d76dd6 240 }
XinZhangMS 0:f7f1f0d76dd6 241 else
XinZhangMS 0:f7f1f0d76dd6 242 {
XinZhangMS 0:f7f1f0d76dd6 243 /*Codes_SRS_DATA_MARSHALLER_02_012: [ DataMarshaller_SendData_ReportedProperties shall create an empty JSON_Value. ]*/
XinZhangMS 0:f7f1f0d76dd6 244 JSON_Value* json = json_value_init_object();
XinZhangMS 0:f7f1f0d76dd6 245 if (json == NULL)
XinZhangMS 0:f7f1f0d76dd6 246 {
XinZhangMS 0:f7f1f0d76dd6 247 /*Codes_SRS_DATA_MARSHALLER_02_019: [ If any failure occurs, DataMarshaller_SendData_ReportedProperties shall fail and return DATA_MARSHALLER_ERROR. ]*/
XinZhangMS 0:f7f1f0d76dd6 248 LogError("failure calling json_value_init_object");
XinZhangMS 0:f7f1f0d76dd6 249 result = DATA_MARSHALLER_ERROR;
XinZhangMS 0:f7f1f0d76dd6 250 }
XinZhangMS 0:f7f1f0d76dd6 251 else
XinZhangMS 0:f7f1f0d76dd6 252 {
XinZhangMS 0:f7f1f0d76dd6 253 /*Codes_SRS_DATA_MARSHALLER_02_013: [ DataMarshaller_SendData_ReportedProperties shall get the object behind the JSON_Value by calling json_object. ]*/
XinZhangMS 0:f7f1f0d76dd6 254 JSON_Object* jsonObject = json_object(json);
XinZhangMS 0:f7f1f0d76dd6 255 if (jsonObject == NULL)
XinZhangMS 0:f7f1f0d76dd6 256 {
XinZhangMS 0:f7f1f0d76dd6 257 /*Codes_SRS_DATA_MARSHALLER_02_019: [ If any failure occurs, DataMarshaller_SendData_ReportedProperties shall fail and return DATA_MARSHALLER_ERROR. ]*/
XinZhangMS 0:f7f1f0d76dd6 258 LogError("failure calling json_object");
XinZhangMS 0:f7f1f0d76dd6 259 result = DATA_MARSHALLER_ERROR;
XinZhangMS 0:f7f1f0d76dd6 260 }
XinZhangMS 0:f7f1f0d76dd6 261 else
XinZhangMS 0:f7f1f0d76dd6 262 {
XinZhangMS 0:f7f1f0d76dd6 263 size_t nReportedProperties = VECTOR_size(values), nProcessedProperties = 0;
XinZhangMS 0:f7f1f0d76dd6 264
XinZhangMS 0:f7f1f0d76dd6 265 for (size_t i = 0;i < nReportedProperties; i++)
XinZhangMS 0:f7f1f0d76dd6 266 {
XinZhangMS 0:f7f1f0d76dd6 267 DATA_MARSHALLER_VALUE* v = *(DATA_MARSHALLER_VALUE**)VECTOR_element(values, i);
XinZhangMS 0:f7f1f0d76dd6 268 STRING_HANDLE s = STRING_new();
XinZhangMS 0:f7f1f0d76dd6 269 if (s == NULL)
XinZhangMS 0:f7f1f0d76dd6 270 {
XinZhangMS 0:f7f1f0d76dd6 271 /*Codes_SRS_DATA_MARSHALLER_02_019: [ If any failure occurs, DataMarshaller_SendData_ReportedProperties shall fail and return DATA_MARSHALLER_ERROR. ]*/
XinZhangMS 0:f7f1f0d76dd6 272 LogError("failure calling STRING_new");
XinZhangMS 0:f7f1f0d76dd6 273 i = nReportedProperties;/*forces loop to break, result is set in the "if" following this for*/
XinZhangMS 0:f7f1f0d76dd6 274 }
XinZhangMS 0:f7f1f0d76dd6 275 else
XinZhangMS 0:f7f1f0d76dd6 276 {
XinZhangMS 0:f7f1f0d76dd6 277 /*Codes_SRS_DATA_MARSHALLER_02_014: [ For every reported property, DataMarshaller_SendData_ReportedProperties shall get the reported property's JSON value (as string) by calling AgentDataTypes_ToString. ]*/
XinZhangMS 0:f7f1f0d76dd6 278 if (AgentDataTypes_ToString(s, v->Value) != AGENT_DATA_TYPES_OK)
XinZhangMS 0:f7f1f0d76dd6 279 {
XinZhangMS 0:f7f1f0d76dd6 280 /*Codes_SRS_DATA_MARSHALLER_02_019: [ If any failure occurs, DataMarshaller_SendData_ReportedProperties shall fail and return DATA_MARSHALLER_ERROR. ]*/
XinZhangMS 0:f7f1f0d76dd6 281 LogError("failure calling AgentDataTypes_ToString");
XinZhangMS 0:f7f1f0d76dd6 282 i = nReportedProperties;/*forces loop to break, result is set in the "if" following this for*/
XinZhangMS 0:f7f1f0d76dd6 283 }
XinZhangMS 0:f7f1f0d76dd6 284 else
XinZhangMS 0:f7f1f0d76dd6 285 {
XinZhangMS 0:f7f1f0d76dd6 286 /*Codes_SRS_DATA_MARSHALLER_02_015: [ DataMarshaller_SendData_ReportedProperties shall import the JSON value (as string) by calling json_parse_string. ]*/
XinZhangMS 0:f7f1f0d76dd6 287 JSON_Value * rightSide = json_parse_string(STRING_c_str(s));
XinZhangMS 0:f7f1f0d76dd6 288 if (rightSide == NULL)
XinZhangMS 0:f7f1f0d76dd6 289 {
XinZhangMS 0:f7f1f0d76dd6 290 /*Codes_SRS_DATA_MARSHALLER_02_019: [ If any failure occurs, DataMarshaller_SendData_ReportedProperties shall fail and return DATA_MARSHALLER_ERROR. ]*/
XinZhangMS 0:f7f1f0d76dd6 291 LogError("failure calling json_parse_string");
XinZhangMS 0:f7f1f0d76dd6 292 i = nReportedProperties;/*forces loop to break, result is set in the "if" following this for*/
XinZhangMS 0:f7f1f0d76dd6 293 }
XinZhangMS 0:f7f1f0d76dd6 294 else
XinZhangMS 0:f7f1f0d76dd6 295 {
XinZhangMS 0:f7f1f0d76dd6 296 char* leftSide;
XinZhangMS 0:f7f1f0d76dd6 297 if (mallocAndStrcpy_s(&leftSide, v->PropertyPath) != 0)
XinZhangMS 0:f7f1f0d76dd6 298 {
XinZhangMS 0:f7f1f0d76dd6 299 /*Codes_SRS_DATA_MARSHALLER_02_019: [ If any failure occurs, DataMarshaller_SendData_ReportedProperties shall fail and return DATA_MARSHALLER_ERROR. ]*/
XinZhangMS 0:f7f1f0d76dd6 300 LogError("failure calling mallocAndStrcpy_s");
XinZhangMS 0:f7f1f0d76dd6 301 json_value_free(rightSide);
XinZhangMS 0:f7f1f0d76dd6 302 i = nReportedProperties;/*forces loop to break, result is set in the "if" following this for*/
XinZhangMS 0:f7f1f0d76dd6 303 }
XinZhangMS 0:f7f1f0d76dd6 304 else
XinZhangMS 0:f7f1f0d76dd6 305 {
XinZhangMS 0:f7f1f0d76dd6 306 /*Codes_SRS_DATA_MARSHALLER_02_016: [ DataMarshaller_SendData_ReportedProperties shall replace all the occurences of / with . in the reported property paths. ]*/
XinZhangMS 0:f7f1f0d76dd6 307 char *whereIsSlash;
XinZhangMS 0:f7f1f0d76dd6 308 while ((whereIsSlash = strchr(leftSide, '/')) != NULL)
XinZhangMS 0:f7f1f0d76dd6 309 {
XinZhangMS 0:f7f1f0d76dd6 310 *whereIsSlash = '.';
XinZhangMS 0:f7f1f0d76dd6 311 }
XinZhangMS 0:f7f1f0d76dd6 312
XinZhangMS 0:f7f1f0d76dd6 313 /*Codes_SRS_DATA_MARSHALLER_02_017: [ DataMarshaller_SendData_ReportedProperties shall use json_object_dotset_value passing the reported property path and the imported json value. ]*/
XinZhangMS 0:f7f1f0d76dd6 314 /*Codes_SRS_DATA_MARSHALLER_02_011: [ DataMarshaller_SendData_ReportedProperties shall ignore the value of includePropertyPath and shall consider it to be true. ]*/
XinZhangMS 0:f7f1f0d76dd6 315 if (json_object_dotset_value(jsonObject, leftSide, rightSide) != JSONSuccess)
XinZhangMS 0:f7f1f0d76dd6 316 {
XinZhangMS 0:f7f1f0d76dd6 317 /*Codes_SRS_DATA_MARSHALLER_02_019: [ If any failure occurs, DataMarshaller_SendData_ReportedProperties shall fail and return DATA_MARSHALLER_ERROR. ]*/
XinZhangMS 0:f7f1f0d76dd6 318 LogError("failure calling json_object_dotset_value");
XinZhangMS 0:f7f1f0d76dd6 319 json_value_free(rightSide);
XinZhangMS 0:f7f1f0d76dd6 320 i = nReportedProperties;/*forces loop to break, result is set in the "if" following this for*/
XinZhangMS 0:f7f1f0d76dd6 321 }
XinZhangMS 0:f7f1f0d76dd6 322 else
XinZhangMS 0:f7f1f0d76dd6 323 {
XinZhangMS 0:f7f1f0d76dd6 324 /*all is fine with this property... */
XinZhangMS 0:f7f1f0d76dd6 325 nProcessedProperties++;
XinZhangMS 0:f7f1f0d76dd6 326 }
XinZhangMS 0:f7f1f0d76dd6 327 free(leftSide);
XinZhangMS 0:f7f1f0d76dd6 328 }
XinZhangMS 0:f7f1f0d76dd6 329 }
XinZhangMS 0:f7f1f0d76dd6 330 }
XinZhangMS 0:f7f1f0d76dd6 331 STRING_delete(s);
XinZhangMS 0:f7f1f0d76dd6 332 }
XinZhangMS 0:f7f1f0d76dd6 333 }
XinZhangMS 0:f7f1f0d76dd6 334
XinZhangMS 0:f7f1f0d76dd6 335 if (nProcessedProperties != nReportedProperties)
XinZhangMS 0:f7f1f0d76dd6 336 {
XinZhangMS 0:f7f1f0d76dd6 337 result = DATA_MARSHALLER_ERROR;
XinZhangMS 0:f7f1f0d76dd6 338 /*all properties have NOT been processed*/
XinZhangMS 0:f7f1f0d76dd6 339 /*return result as is*/
XinZhangMS 0:f7f1f0d76dd6 340 }
XinZhangMS 0:f7f1f0d76dd6 341 else
XinZhangMS 0:f7f1f0d76dd6 342 {
XinZhangMS 0:f7f1f0d76dd6 343 /*Codes_SRS_DATA_MARSHALLER_02_018: [ DataMarshaller_SendData_ReportedProperties shall use json_serialize_to_string_pretty to produce the output JSON string that fills out parameters destination and destionationSize. ]*/
XinZhangMS 0:f7f1f0d76dd6 344 char* temp = json_serialize_to_string_pretty(json);
XinZhangMS 0:f7f1f0d76dd6 345 if (temp == NULL)
XinZhangMS 0:f7f1f0d76dd6 346 {
XinZhangMS 0:f7f1f0d76dd6 347 /*Codes_SRS_DATA_MARSHALLER_02_019: [ If any failure occurs, DataMarshaller_SendData_ReportedProperties shall fail and return DATA_MARSHALLER_ERROR. ]*/
XinZhangMS 0:f7f1f0d76dd6 348 LogError("failure calling json_serialize_to_string_pretty ");
XinZhangMS 0:f7f1f0d76dd6 349 result = DATA_MARSHALLER_ERROR;
XinZhangMS 0:f7f1f0d76dd6 350 }
XinZhangMS 0:f7f1f0d76dd6 351 else
XinZhangMS 0:f7f1f0d76dd6 352 {
XinZhangMS 0:f7f1f0d76dd6 353 /*Codes_SRS_DATA_MARSHALLER_02_020: [ Otherwise DataMarshaller_SendData_ReportedProperties shall succeed and return DATA_MARSHALLER_OK. ]*/
XinZhangMS 0:f7f1f0d76dd6 354 *destination = (unsigned char*)temp;
XinZhangMS 0:f7f1f0d76dd6 355 *destinationSize = strlen(temp);
XinZhangMS 0:f7f1f0d76dd6 356 result = DATA_MARSHALLER_OK;
XinZhangMS 0:f7f1f0d76dd6 357 /*all is fine... */
XinZhangMS 0:f7f1f0d76dd6 358 }
XinZhangMS 0:f7f1f0d76dd6 359 }
XinZhangMS 0:f7f1f0d76dd6 360 }
XinZhangMS 0:f7f1f0d76dd6 361 json_value_free(json);
XinZhangMS 0:f7f1f0d76dd6 362 }
XinZhangMS 0:f7f1f0d76dd6 363 }
XinZhangMS 0:f7f1f0d76dd6 364 return result;
XinZhangMS 0:f7f1f0d76dd6 365 }