Azure IoT / iothub_client

Microsoft Azure IoTHub client libraries

Dependents:   sht15_remote_monitoring RobotArmDemo iothub_client_sample_amqp f767zi_mqtt ... more

This library implements the Microsoft Azure IoTHub client library. The code is replicated from https://github.com/Azure/azure-iot-sdks

iothub_client_ll_uploadtoblob.c@86:a1352899ea45, 2018-04-16 (annotated)

Committer:
AzureIoTClient
Date:
Mon Apr 16 14:25:56 2018 -0700
Revision:
86:a1352899ea45
Parent:
82:f94e6bed4495
Child:
88:248736be106e
1.2.3

Who changed what in which revision?

UserRevisionLine numberNew contents of line
AzureIoTClient 42:448eecc3676e 1 // Copyright (c) Microsoft. All rights reserved.
AzureIoTClient 42:448eecc3676e 2 // Licensed under the MIT license. See LICENSE file in the project root for full license information.
AzureIoTClient 42:448eecc3676e 3
Azure.IoT Build 45:54c11b1b1407 4 #ifdef DONT_USE_UPLOADTOBLOB
Azure.IoT Build 45:54c11b1b1407 5 #error "trying to compile iothub_client_ll_uploadtoblob.c while the symbol DONT_USE_UPLOADTOBLOB is #define'd"
Azure.IoT Build 45:54c11b1b1407 6 #else
Azure.IoT Build 45:54c11b1b1407 7
AzureIoTClient 42:448eecc3676e 8 #include <stdlib.h>
AzureIoTClient 42:448eecc3676e 9 #include <string.h>
AzureIoTClient 60:41648c4e7036 10 #include "azure_c_shared_utility/optimize_size.h"
AzureIoTClient 42:448eecc3676e 11 #include "azure_c_shared_utility/gballoc.h"
AzureIoTClient 42:448eecc3676e 12 #include "azure_c_shared_utility/string_tokenizer.h"
AzureIoTClient 42:448eecc3676e 13 #include "azure_c_shared_utility/doublylinkedlist.h"
Azure.IoT Build 45:54c11b1b1407 14 #include "azure_c_shared_utility/xlogging.h"
AzureIoTClient 42:448eecc3676e 15 #include "azure_c_shared_utility/tickcounter.h"
AzureIoTClient 42:448eecc3676e 16 #include "azure_c_shared_utility/httpapiexsas.h"
AzureIoTClient 74:ea0021abecf7 17 #include "azure_c_shared_utility/shared_util_options.h"
AzureIoTClient 77:e4e36df9caee 18 #include "azure_c_shared_utility/urlencode.h"
AzureIoTClient 42:448eecc3676e 19
AzureIoTClient 42:448eecc3676e 20 #include "iothub_client_ll.h"
AzureIoTClient 48:cc5d91f2b06d 21 #include "iothub_client_options.h"
AzureIoTClient 42:448eecc3676e 22 #include "iothub_client_private.h"
AzureIoTClient 42:448eecc3676e 23 #include "iothub_client_version.h"
AzureIoTClient 42:448eecc3676e 24 #include "iothub_transport_ll.h"
AzureIoTClient 42:448eecc3676e 25 #include "parson.h"
AzureIoTClient 42:448eecc3676e 26 #include "iothub_client_ll_uploadtoblob.h"
AzureIoTClient 42:448eecc3676e 27 #include "blob.h"
AzureIoTClient 42:448eecc3676e 28
AzureIoTClient 47:aaa262b5f898 29
AzureIoTClient 47:aaa262b5f898 30 #ifdef WINCE
AzureIoTClient 47:aaa262b5f898 31 #include <stdarg.h>
AzureIoTClient 47:aaa262b5f898 32 // Returns number of characters copied.
AzureIoTClient 47:aaa262b5f898 33 int snprintf(char * s, size_t n, const char * format, ...)
AzureIoTClient 47:aaa262b5f898 34 {
AzureIoTClient 48:cc5d91f2b06d 35 int result;
AzureIoTClient 48:cc5d91f2b06d 36 va_list args;
AzureIoTClient 48:cc5d91f2b06d 37 va_start(args, format);
AzureIoTClient 48:cc5d91f2b06d 38 result = vsnprintf(s, n, format, args);
AzureIoTClient 48:cc5d91f2b06d 39 va_end(args);
AzureIoTClient 48:cc5d91f2b06d 40 return result;
AzureIoTClient 47:aaa262b5f898 41 }
AzureIoTClient 47:aaa262b5f898 42 #endif
AzureIoTClient 47:aaa262b5f898 43
AzureIoTClient 47:aaa262b5f898 44
AzureIoTClient 42:448eecc3676e 45 /*Codes_SRS_IOTHUBCLIENT_LL_02_085: [ IoTHubClient_LL_UploadToBlob shall use the same authorization as step 1. to prepare and perform a HTTP request with the following parameters: ]*/
AzureIoTClient 42:448eecc3676e 46 #define FILE_UPLOAD_FAILED_BODY "{ \"isSuccess\":false, \"statusCode\":-1,\"statusDescription\" : \"client not able to connect with the server\" }"
AzureIoTClient 82:f94e6bed4495 47 #define FILE_UPLOAD_ABORTED_BODY "{ \"isSuccess\":false, \"statusCode\":-1,\"statusDescription\" : \"file upload aborted\" }"
AzureIoTClient 42:448eecc3676e 48
AzureIoTClient 42:448eecc3676e 49 #define AUTHORIZATION_SCHEME_VALUES \
AzureIoTClient 42:448eecc3676e 50 DEVICE_KEY, \
AzureIoTClient 46:6a69294b6119 51 X509, \
AzureIoTClient 42:448eecc3676e 52 SAS_TOKEN
AzureIoTClient 42:448eecc3676e 53 DEFINE_ENUM(AUTHORIZATION_SCHEME, AUTHORIZATION_SCHEME_VALUES);
AzureIoTClient 42:448eecc3676e 54
AzureIoTClient 46:6a69294b6119 55 typedef struct UPLOADTOBLOB_X509_CREDENTIALS_TAG
AzureIoTClient 46:6a69294b6119 56 {
AzureIoTClient 46:6a69294b6119 57 const char* x509certificate;
AzureIoTClient 46:6a69294b6119 58 const char* x509privatekey;
AzureIoTClient 46:6a69294b6119 59 }UPLOADTOBLOB_X509_CREDENTIALS;
AzureIoTClient 46:6a69294b6119 60
AzureIoTClient 42:448eecc3676e 61 typedef struct IOTHUB_CLIENT_LL_UPLOADTOBLOB_HANDLE_DATA_TAG
AzureIoTClient 42:448eecc3676e 62 {
AzureIoTClient 42:448eecc3676e 63 STRING_HANDLE deviceId; /*needed for file upload*/
AzureIoTClient 42:448eecc3676e 64 const char* hostname; /*needed for file upload*/
AzureIoTClient 42:448eecc3676e 65 AUTHORIZATION_SCHEME authorizationScheme; /*needed for file upload*/
AzureIoTClient 42:448eecc3676e 66 union {
AzureIoTClient 42:448eecc3676e 67 STRING_HANDLE deviceKey; /*used when authorizationScheme is DEVICE_KEY*/
AzureIoTClient 42:448eecc3676e 68 STRING_HANDLE sas; /*used when authorizationScheme is SAS_TOKEN*/
AzureIoTClient 46:6a69294b6119 69 UPLOADTOBLOB_X509_CREDENTIALS x509credentials; /*assumed to be used when both deviceKey and deviceSasToken are NULL*/
AzureIoTClient 42:448eecc3676e 70 } credentials; /*needed for file upload*/
AzureIoTClient 62:5a4cdacf5090 71 char* certificates; /*if there are any certificates used*/
AzureIoTClient 74:ea0021abecf7 72 HTTP_PROXY_OPTIONS http_proxy_options;
AzureIoTClient 82:f94e6bed4495 73 size_t curl_verbose;
AzureIoTClient 86:a1352899ea45 74 size_t blob_upload_timeout_secs;
AzureIoTClient 42:448eecc3676e 75 }IOTHUB_CLIENT_LL_UPLOADTOBLOB_HANDLE_DATA;
AzureIoTClient 42:448eecc3676e 76
AzureIoTClient 80:db5f5237bc95 77 typedef struct BLOB_UPLOAD_CONTEXT_TAG
AzureIoTClient 80:db5f5237bc95 78 {
AzureIoTClient 80:db5f5237bc95 79 const unsigned char* blobSource; /* source to upload */
AzureIoTClient 80:db5f5237bc95 80 size_t blobSourceSize; /* size of the source */
AzureIoTClient 80:db5f5237bc95 81 size_t remainingSizeToUpload; /* size not yet uploaded */
AzureIoTClient 80:db5f5237bc95 82 }BLOB_UPLOAD_CONTEXT;
AzureIoTClient 80:db5f5237bc95 83
AzureIoTClient 42:448eecc3676e 84 IOTHUB_CLIENT_LL_UPLOADTOBLOB_HANDLE IoTHubClient_LL_UploadToBlob_Create(const IOTHUB_CLIENT_CONFIG* config)
AzureIoTClient 42:448eecc3676e 85 {
AzureIoTClient 42:448eecc3676e 86 IOTHUB_CLIENT_LL_UPLOADTOBLOB_HANDLE_DATA* handleData = malloc(sizeof(IOTHUB_CLIENT_LL_UPLOADTOBLOB_HANDLE_DATA));
AzureIoTClient 42:448eecc3676e 87 if (handleData == NULL)
AzureIoTClient 42:448eecc3676e 88 {
AzureIoTClient 42:448eecc3676e 89 LogError("oom - malloc");
AzureIoTClient 42:448eecc3676e 90 /*return as is*/
AzureIoTClient 42:448eecc3676e 91 }
AzureIoTClient 42:448eecc3676e 92 else
AzureIoTClient 42:448eecc3676e 93 {
AzureIoTClient 42:448eecc3676e 94 size_t iotHubNameLength = strlen(config->iotHubName);
AzureIoTClient 42:448eecc3676e 95 size_t iotHubSuffixLength = strlen(config->iotHubSuffix);
AzureIoTClient 42:448eecc3676e 96 handleData->deviceId = STRING_construct(config->deviceId);
AzureIoTClient 42:448eecc3676e 97 if (handleData->deviceId == NULL)
AzureIoTClient 42:448eecc3676e 98 {
AzureIoTClient 42:448eecc3676e 99 LogError("unable to STRING_construct");
AzureIoTClient 42:448eecc3676e 100 free(handleData);
AzureIoTClient 42:448eecc3676e 101 handleData = NULL;
AzureIoTClient 42:448eecc3676e 102 }
AzureIoTClient 42:448eecc3676e 103 else
AzureIoTClient 42:448eecc3676e 104 {
AzureIoTClient 42:448eecc3676e 105 handleData->hostname = malloc(iotHubNameLength + 1 + iotHubSuffixLength + 1); /*first +1 is because "." the second +1 is because \0*/
AzureIoTClient 42:448eecc3676e 106 if (handleData->hostname == NULL)
AzureIoTClient 42:448eecc3676e 107 {
AzureIoTClient 42:448eecc3676e 108 LogError("malloc failed");
AzureIoTClient 42:448eecc3676e 109 STRING_delete(handleData->deviceId);
AzureIoTClient 42:448eecc3676e 110 free(handleData);
AzureIoTClient 42:448eecc3676e 111 handleData = NULL;
AzureIoTClient 42:448eecc3676e 112 }
AzureIoTClient 42:448eecc3676e 113 else
AzureIoTClient 42:448eecc3676e 114 {
AzureIoTClient 75:86205ca63a59 115 char* insert_pos = (char*)handleData->hostname;
AzureIoTClient 75:86205ca63a59 116 (void)memcpy((char*)insert_pos, config->iotHubName, iotHubNameLength);
AzureIoTClient 75:86205ca63a59 117 insert_pos += iotHubNameLength;
AzureIoTClient 75:86205ca63a59 118 *insert_pos = '.';
AzureIoTClient 75:86205ca63a59 119 insert_pos += 1;
AzureIoTClient 75:86205ca63a59 120 (void)memcpy(insert_pos, config->iotHubSuffix, iotHubSuffixLength); /*+1 will copy the \0 too*/
AzureIoTClient 75:86205ca63a59 121 insert_pos += iotHubSuffixLength;
AzureIoTClient 75:86205ca63a59 122 *insert_pos = '\0';
AzureIoTClient 75:86205ca63a59 123
AzureIoTClient 62:5a4cdacf5090 124 handleData->certificates = NULL;
AzureIoTClient 74:ea0021abecf7 125 memset(&(handleData->http_proxy_options), 0, sizeof(HTTP_PROXY_OPTIONS));
AzureIoTClient 82:f94e6bed4495 126 handleData->curl_verbose = 0;
AzureIoTClient 86:a1352899ea45 127 handleData->blob_upload_timeout_secs = 0;
AzureIoTClient 74:ea0021abecf7 128
AzureIoTClient 46:6a69294b6119 129 if ((config->deviceSasToken != NULL) && (config->deviceKey == NULL))
AzureIoTClient 42:448eecc3676e 130 {
AzureIoTClient 42:448eecc3676e 131 handleData->authorizationScheme = SAS_TOKEN;
AzureIoTClient 42:448eecc3676e 132 handleData->credentials.sas = STRING_construct(config->deviceSasToken);
AzureIoTClient 42:448eecc3676e 133 if (handleData->credentials.sas == NULL)
AzureIoTClient 42:448eecc3676e 134 {
AzureIoTClient 42:448eecc3676e 135 LogError("unable to STRING_construct");
AzureIoTClient 42:448eecc3676e 136 free((void*)handleData->hostname);
AzureIoTClient 42:448eecc3676e 137 STRING_delete(handleData->deviceId);
AzureIoTClient 42:448eecc3676e 138 free(handleData);
AzureIoTClient 42:448eecc3676e 139 handleData = NULL;
AzureIoTClient 42:448eecc3676e 140 }
AzureIoTClient 42:448eecc3676e 141 else
AzureIoTClient 42:448eecc3676e 142 {
AzureIoTClient 42:448eecc3676e 143 /*return as is*/
AzureIoTClient 42:448eecc3676e 144 }
AzureIoTClient 42:448eecc3676e 145 }
AzureIoTClient 46:6a69294b6119 146 else if ((config->deviceSasToken == NULL) && (config->deviceKey != NULL))
AzureIoTClient 42:448eecc3676e 147 {
AzureIoTClient 42:448eecc3676e 148 handleData->authorizationScheme = DEVICE_KEY;
AzureIoTClient 42:448eecc3676e 149 handleData->credentials.deviceKey = STRING_construct(config->deviceKey);
AzureIoTClient 42:448eecc3676e 150 if (handleData->credentials.deviceKey == NULL)
AzureIoTClient 42:448eecc3676e 151 {
AzureIoTClient 42:448eecc3676e 152 LogError("unable to STRING_construct");
AzureIoTClient 42:448eecc3676e 153 free((void*)handleData->hostname);
AzureIoTClient 42:448eecc3676e 154 STRING_delete(handleData->deviceId);
AzureIoTClient 42:448eecc3676e 155 free(handleData);
AzureIoTClient 42:448eecc3676e 156 handleData = NULL;
AzureIoTClient 42:448eecc3676e 157 }
AzureIoTClient 42:448eecc3676e 158 else
AzureIoTClient 42:448eecc3676e 159 {
AzureIoTClient 42:448eecc3676e 160 /*return as is*/
AzureIoTClient 42:448eecc3676e 161 }
AzureIoTClient 42:448eecc3676e 162 }
AzureIoTClient 46:6a69294b6119 163 else if ((config->deviceSasToken == NULL) && (config->deviceKey == NULL))
AzureIoTClient 46:6a69294b6119 164 {
AzureIoTClient 46:6a69294b6119 165 handleData->authorizationScheme = X509;
AzureIoTClient 46:6a69294b6119 166 handleData->credentials.x509credentials.x509certificate = NULL;
AzureIoTClient 46:6a69294b6119 167 handleData->credentials.x509credentials.x509privatekey = NULL;
AzureIoTClient 46:6a69294b6119 168 /*return as is*/
AzureIoTClient 46:6a69294b6119 169 }
AzureIoTClient 42:448eecc3676e 170 }
AzureIoTClient 42:448eecc3676e 171 }
AzureIoTClient 42:448eecc3676e 172 }
AzureIoTClient 42:448eecc3676e 173 return (IOTHUB_CLIENT_LL_UPLOADTOBLOB_HANDLE)handleData;
AzureIoTClient 42:448eecc3676e 174
AzureIoTClient 42:448eecc3676e 175 }
AzureIoTClient 42:448eecc3676e 176
AzureIoTClient 42:448eecc3676e 177 /*returns 0 when correlationId, sasUri contain data*/
AzureIoTClient 42:448eecc3676e 178 static int IoTHubClient_LL_UploadToBlob_step1and2(IOTHUB_CLIENT_LL_UPLOADTOBLOB_HANDLE_DATA* handleData, HTTPAPIEX_HANDLE iotHubHttpApiExHandle, HTTP_HEADERS_HANDLE requestHttpHeaders, const char* destinationFileName,
AzureIoTClient 42:448eecc3676e 179 STRING_HANDLE correlationId, STRING_HANDLE sasUri)
AzureIoTClient 42:448eecc3676e 180 {
AzureIoTClient 42:448eecc3676e 181 int result;
AzureIoTClient 42:448eecc3676e 182
AzureIoTClient 82:f94e6bed4495 183 /*Codes_SRS_IOTHUBCLIENT_LL_02_066: [ IoTHubClient_LL_UploadMultipleBlocksToBlob(Ex) shall create an HTTP relative path formed from "/devices/" + deviceId + "/files/" + "?api-version=API_VERSION". ]*/
AzureIoTClient 42:448eecc3676e 184 STRING_HANDLE relativePath = STRING_construct("/devices/");
AzureIoTClient 42:448eecc3676e 185 if (relativePath == NULL)
AzureIoTClient 42:448eecc3676e 186 {
AzureIoTClient 82:f94e6bed4495 187 /*Codes_SRS_IOTHUBCLIENT_LL_02_067: [ If creating the relativePath fails then IoTHubClient_LL_UploadMultipleBlocksToBlob(Ex) shall fail and return IOTHUB_CLIENT_ERROR. ]*/
AzureIoTClient 42:448eecc3676e 188 LogError("unable to STRING_construct");
AzureIoTClient 60:41648c4e7036 189 result = __FAILURE__;
AzureIoTClient 42:448eecc3676e 190 }
AzureIoTClient 74:ea0021abecf7 191 else
AzureIoTClient 74:ea0021abecf7 192 {
AzureIoTClient 74:ea0021abecf7 193 if (!(
AzureIoTClient 74:ea0021abecf7 194 (STRING_concat_with_STRING(relativePath, handleData->deviceId) == 0) &&
AzureIoTClient 74:ea0021abecf7 195 (STRING_concat(relativePath, "/files") == 0) &&
AzureIoTClient 74:ea0021abecf7 196 (STRING_concat(relativePath, API_VERSION) == 0)
AzureIoTClient 74:ea0021abecf7 197 ))
AzureIoTClient 74:ea0021abecf7 198 {
AzureIoTClient 82:f94e6bed4495 199 /*Codes_SRS_IOTHUBCLIENT_LL_02_067: [ If creating the relativePath fails then IoTHubClient_LL_UploadMultipleBlocksToBlob(Ex) shall fail and return IOTHUB_CLIENT_ERROR. ]*/
AzureIoTClient 74:ea0021abecf7 200 LogError("unable to concatenate STRING");
AzureIoTClient 74:ea0021abecf7 201 result = __FAILURE__;
AzureIoTClient 74:ea0021abecf7 202 }
AzureIoTClient 74:ea0021abecf7 203 else
AzureIoTClient 74:ea0021abecf7 204 {
AzureIoTClient 82:f94e6bed4495 205 /*Codes_SRS_IOTHUBCLIENT_LL_32_001: [ IoTHubClient_LL_UploadMultipleBlocksToBlob(Ex) shall create a JSON string formed from "{ \"blobName\": \" + destinationFileName + "\" }" */
AzureIoTClient 74:ea0021abecf7 206 STRING_HANDLE blobName = STRING_construct("{ \"blobName\": \"");
AzureIoTClient 74:ea0021abecf7 207 if (blobName == NULL)
AzureIoTClient 74:ea0021abecf7 208 {
AzureIoTClient 82:f94e6bed4495 209 /*Codes_SRS_IOTHUBCLIENT_LL_32_002: [ If creating the JSON string fails then IoTHubClient_LL_UploadMultipleBlocksToBlob(Ex) shall fail and return IOTHUB_CLIENT_ERROR. ]*/
AzureIoTClient 74:ea0021abecf7 210 LogError("unable to STRING_construct");
AzureIoTClient 74:ea0021abecf7 211 result = __FAILURE__;
AzureIoTClient 74:ea0021abecf7 212 }
AzureIoTClient 74:ea0021abecf7 213 else
AzureIoTClient 74:ea0021abecf7 214 {
AzureIoTClient 74:ea0021abecf7 215 if (!(
AzureIoTClient 74:ea0021abecf7 216 (STRING_concat(blobName, destinationFileName) == 0) &&
AzureIoTClient 74:ea0021abecf7 217 (STRING_concat(blobName, "\" }") == 0)
AzureIoTClient 74:ea0021abecf7 218 ))
AzureIoTClient 74:ea0021abecf7 219 {
AzureIoTClient 82:f94e6bed4495 220 /*Codes_SRS_IOTHUBCLIENT_LL_32_002: [ If creating the JSON string fails then IoTHubClient_LL_UploadMultipleBlocksToBlob(Ex) shall fail and return IOTHUB_CLIENT_ERROR. ]*/
AzureIoTClient 74:ea0021abecf7 221 LogError("unable to concatenate STRING");
AzureIoTClient 74:ea0021abecf7 222 result = __FAILURE__;
AzureIoTClient 74:ea0021abecf7 223 }
AzureIoTClient 74:ea0021abecf7 224 else
AzureIoTClient 74:ea0021abecf7 225 {
AzureIoTClient 69:b6f532f8c608 226 size_t len = STRING_length(blobName);
AzureIoTClient 74:ea0021abecf7 227 BUFFER_HANDLE blobBuffer = BUFFER_create((const unsigned char *)STRING_c_str(blobName), len);
AzureIoTClient 42:448eecc3676e 228
AzureIoTClient 74:ea0021abecf7 229 if (blobBuffer == NULL)
AzureIoTClient 74:ea0021abecf7 230 {
AzureIoTClient 82:f94e6bed4495 231 /*Codes_SRS_IOTHUBCLIENT_LL_32_002: [ If creating the JSON string fails then IoTHubClient_LL_UploadMultipleBlocksToBlob(Ex) shall fail and return IOTHUB_CLIENT_ERROR. ]*/
AzureIoTClient 69:b6f532f8c608 232 LogError("unable to create BUFFER");
AzureIoTClient 74:ea0021abecf7 233 result = __FAILURE__;
AzureIoTClient 74:ea0021abecf7 234 }
AzureIoTClient 74:ea0021abecf7 235 else
AzureIoTClient 74:ea0021abecf7 236 {
AzureIoTClient 82:f94e6bed4495 237 /*Codes_SRS_IOTHUBCLIENT_LL_02_068: [ IoTHubClient_LL_UploadMultipleBlocksToBlob(Ex) shall create an HTTP responseContent BUFFER_HANDLE. ]*/
AzureIoTClient 74:ea0021abecf7 238 BUFFER_HANDLE responseContent = BUFFER_new();
AzureIoTClient 74:ea0021abecf7 239 if (responseContent == NULL)
AzureIoTClient 74:ea0021abecf7 240 {
AzureIoTClient 82:f94e6bed4495 241 /*Codes_SRS_IOTHUBCLIENT_LL_02_069: [ If creating the HTTP response buffer handle fails then IoTHubClient_LL_UploadMultipleBlocksToBlob(Ex) shall fail and return IOTHUB_CLIENT_ERROR. ]*/
AzureIoTClient 74:ea0021abecf7 242 result = __FAILURE__;
AzureIoTClient 74:ea0021abecf7 243 LogError("unable to BUFFER_new");
AzureIoTClient 74:ea0021abecf7 244 }
AzureIoTClient 74:ea0021abecf7 245 else
AzureIoTClient 74:ea0021abecf7 246 {
AzureIoTClient 82:f94e6bed4495 247 /*Codes_SRS_IOTHUBCLIENT_LL_02_072: [ IoTHubClient_LL_UploadMultipleBlocksToBlob(Ex) shall add the following name:value to request HTTP headers: ] "Content-Type": "application/json" "Accept": "application/json" "User-Agent": "iothubclient/" IOTHUB_SDK_VERSION*/
AzureIoTClient 74:ea0021abecf7 248 /*Codes_SRS_IOTHUBCLIENT_LL_02_107: [ - "Authorization" header shall not be build. ]*/
AzureIoTClient 74:ea0021abecf7 249 if (!(
AzureIoTClient 74:ea0021abecf7 250 (HTTPHeaders_AddHeaderNameValuePair(requestHttpHeaders, "Content-Type", "application/json") == HTTP_HEADERS_OK) &&
AzureIoTClient 74:ea0021abecf7 251 (HTTPHeaders_AddHeaderNameValuePair(requestHttpHeaders, "Accept", "application/json") == HTTP_HEADERS_OK) &&
AzureIoTClient 74:ea0021abecf7 252 (HTTPHeaders_AddHeaderNameValuePair(requestHttpHeaders, "User-Agent", "iothubclient/" IOTHUB_SDK_VERSION) == HTTP_HEADERS_OK) &&
AzureIoTClient 74:ea0021abecf7 253 (handleData->authorizationScheme == X509 || (HTTPHeaders_AddHeaderNameValuePair(requestHttpHeaders, "Authorization", "") == HTTP_HEADERS_OK))
AzureIoTClient 74:ea0021abecf7 254 ))
AzureIoTClient 74:ea0021abecf7 255 {
AzureIoTClient 82:f94e6bed4495 256 /*Codes_SRS_IOTHUBCLIENT_LL_02_071: [ If creating the HTTP headers fails then IoTHubClient_LL_UploadMultipleBlocksToBlob(Ex) shall fail and return IOTHUB_CLIENT_ERROR. ]*/
AzureIoTClient 74:ea0021abecf7 257 LogError("unable to HTTPHeaders_AddHeaderNameValuePair");
AzureIoTClient 74:ea0021abecf7 258 result = __FAILURE__;
AzureIoTClient 74:ea0021abecf7 259 }
AzureIoTClient 74:ea0021abecf7 260 else
AzureIoTClient 74:ea0021abecf7 261 {
AzureIoTClient 74:ea0021abecf7 262 int wasIoTHubRequestSuccess = 0; /*!=0 means responseContent has a buffer that should be parsed by parson after executing the below switch*/
AzureIoTClient 74:ea0021abecf7 263 /* set the result to error by default */
AzureIoTClient 74:ea0021abecf7 264 result = __FAILURE__;
AzureIoTClient 74:ea0021abecf7 265 switch (handleData->authorizationScheme)
AzureIoTClient 74:ea0021abecf7 266 {
AzureIoTClient 74:ea0021abecf7 267 default:
AzureIoTClient 74:ea0021abecf7 268 {
AzureIoTClient 74:ea0021abecf7 269 /*wasIoTHubRequestSuccess takes care of the return value*/
AzureIoTClient 74:ea0021abecf7 270 LogError("Internal Error: unexpected value in handleData->authorizationScheme = %d", handleData->authorizationScheme);
AzureIoTClient 74:ea0021abecf7 271 result = __FAILURE__;
AzureIoTClient 74:ea0021abecf7 272 break;
AzureIoTClient 74:ea0021abecf7 273 }
AzureIoTClient 74:ea0021abecf7 274 case(X509):
AzureIoTClient 74:ea0021abecf7 275 {
AzureIoTClient 74:ea0021abecf7 276 unsigned int statusCode;
AzureIoTClient 82:f94e6bed4495 277 /*Codes_SRS_IOTHUBCLIENT_LL_32_003: [ IoTHubClient_LL_UploadMultipleBlocksToBlob(Ex) shall execute HTTPAPIEX_ExecuteRequest passing the following information for arguments: ]*/
AzureIoTClient 74:ea0021abecf7 278 if (HTTPAPIEX_ExecuteRequest(
AzureIoTClient 82:f94e6bed4495 279 iotHubHttpApiExHandle, /*HTTPAPIEX_HANDLE handle - the handle created at the beginning of `IoTHubClient_LL_UploadMultipleBlocksToBlob(Ex)`*/
AzureIoTClient 74:ea0021abecf7 280 HTTPAPI_REQUEST_POST, /*HTTPAPI_REQUEST_TYPE requestType - HTTPAPI_REQUEST_POST*/
AzureIoTClient 74:ea0021abecf7 281 STRING_c_str(relativePath), /*const char* relativePath - the HTTP relative path*/
AzureIoTClient 74:ea0021abecf7 282 requestHttpHeaders, /*HTTP_HEADERS_HANDLE requestHttpHeadersHandle - request HTTP headers*/
AzureIoTClient 74:ea0021abecf7 283 blobBuffer, /*BUFFER_HANDLE requestContent - address of JSON with optional/directory/tree/filename*/
AzureIoTClient 74:ea0021abecf7 284 &statusCode, /*unsigned int* statusCode - the address of an unsigned int that will contain the HTTP status code*/
AzureIoTClient 74:ea0021abecf7 285 NULL, /*HTTP_HEADERS_HANDLE responseHttpHeadersHandle - NULL*/
AzureIoTClient 74:ea0021abecf7 286 responseContent /*BUFFER_HANDLE responseContent - the HTTP response BUFFER_HANDLE - responseContent*/
AzureIoTClient 74:ea0021abecf7 287 ) != HTTPAPIEX_OK)
AzureIoTClient 74:ea0021abecf7 288 {
AzureIoTClient 82:f94e6bed4495 289 /*Codes_SRS_IOTHUBCLIENT_LL_02_076: [ If HTTPAPIEX_ExecuteRequest call fails then IoTHubClient_LL_UploadMultipleBlocksToBlob(Ex) shall fail and return IOTHUB_CLIENT_ERROR. ]*/
AzureIoTClient 74:ea0021abecf7 290 result = __FAILURE__;
AzureIoTClient 74:ea0021abecf7 291 LogError("unable to HTTPAPIEX_ExecuteRequest");
AzureIoTClient 74:ea0021abecf7 292 }
AzureIoTClient 74:ea0021abecf7 293 else
AzureIoTClient 74:ea0021abecf7 294 {
AzureIoTClient 82:f94e6bed4495 295 /*Codes_SRS_IOTHUBCLIENT_LL_02_077: [ If HTTP statusCode is greater than or equal to 300 then IoTHubClient_LL_UploadMultipleBlocksToBlob(Ex) shall fail and return IOTHUB_CLIENT_ERROR. ]*/
AzureIoTClient 74:ea0021abecf7 296 if (statusCode >= 300)
AzureIoTClient 74:ea0021abecf7 297 {
AzureIoTClient 74:ea0021abecf7 298 result = __FAILURE__;
AzureIoTClient 74:ea0021abecf7 299 LogError("HTTP code was %u", statusCode);
AzureIoTClient 74:ea0021abecf7 300 }
AzureIoTClient 74:ea0021abecf7 301 else
AzureIoTClient 74:ea0021abecf7 302 {
AzureIoTClient 74:ea0021abecf7 303 wasIoTHubRequestSuccess = 1;
AzureIoTClient 74:ea0021abecf7 304 }
AzureIoTClient 74:ea0021abecf7 305 }
AzureIoTClient 74:ea0021abecf7 306 break;
AzureIoTClient 74:ea0021abecf7 307 }
AzureIoTClient 74:ea0021abecf7 308 case (SAS_TOKEN):
AzureIoTClient 74:ea0021abecf7 309 {
AzureIoTClient 74:ea0021abecf7 310 const char* sasToken = STRING_c_str(handleData->credentials.sas);
AzureIoTClient 82:f94e6bed4495 311 /*Codes_SRS_IOTHUBCLIENT_LL_02_073: [ If the credentials used to create handle have "sasToken" then IoTHubClient_LL_UploadMultipleBlocksToBlob(Ex) shall add the following HTTP request headers: ]*/
AzureIoTClient 74:ea0021abecf7 312 if (HTTPHeaders_ReplaceHeaderNameValuePair(requestHttpHeaders, "Authorization", sasToken) != HTTP_HEADERS_OK)
AzureIoTClient 74:ea0021abecf7 313 {
AzureIoTClient 82:f94e6bed4495 314 /*Codes_SRS_IOTHUBCLIENT_LL_02_074: [ If adding "Authorization" fails then IoTHubClient_LL_UploadMultipleBlocksToBlob(Ex) shall fail and return IOTHUB_CLIENT_ERROR ]*/
AzureIoTClient 74:ea0021abecf7 315 result = __FAILURE__;
AzureIoTClient 74:ea0021abecf7 316 LogError("unable to HTTPHeaders_AddHeaderNameValuePair");
AzureIoTClient 74:ea0021abecf7 317 }
AzureIoTClient 74:ea0021abecf7 318 else
AzureIoTClient 74:ea0021abecf7 319 {
AzureIoTClient 74:ea0021abecf7 320 unsigned int statusCode;
AzureIoTClient 82:f94e6bed4495 321 /*Codes_SRS_IOTHUBCLIENT_LL_32_004: [ IoTHubClient_LL_UploadMultipleBlocksToBlob(Ex) shall execute HTTPAPIEX_ExecuteRequest passing the following information for arguments: ]*/
AzureIoTClient 74:ea0021abecf7 322 if (HTTPAPIEX_ExecuteRequest(
AzureIoTClient 82:f94e6bed4495 323 iotHubHttpApiExHandle, /*HTTPAPIEX_HANDLE handle - the handle created at the beginning of `IoTHubClient_LL_UploadMultipleBlocksToBlob(Ex)`*/
AzureIoTClient 74:ea0021abecf7 324 HTTPAPI_REQUEST_POST, /*HTTPAPI_REQUEST_TYPE requestType - HTTPAPI_REQUEST_POST*/
AzureIoTClient 74:ea0021abecf7 325 STRING_c_str(relativePath), /*const char* relativePath - the HTTP relative path*/
AzureIoTClient 74:ea0021abecf7 326 requestHttpHeaders, /*HTTP_HEADERS_HANDLE requestHttpHeadersHandle - request HTTP headers*/
AzureIoTClient 74:ea0021abecf7 327 blobBuffer, /*BUFFER_HANDLE requestContent - address of JSON with optional/directory/tree/filename*/
AzureIoTClient 74:ea0021abecf7 328 &statusCode, /*unsigned int* statusCode - the address of an unsigned int that will contain the HTTP status code*/
AzureIoTClient 74:ea0021abecf7 329 NULL, /*HTTP_HEADERS_HANDLE responseHttpHeadersHandle - NULL*/
AzureIoTClient 74:ea0021abecf7 330 responseContent /*BUFFER_HANDLE responseContent - the HTTP response BUFFER_HANDLE - responseContent*/
AzureIoTClient 74:ea0021abecf7 331 ) != HTTPAPIEX_OK)
AzureIoTClient 74:ea0021abecf7 332 {
AzureIoTClient 82:f94e6bed4495 333 /*Codes_SRS_IOTHUBCLIENT_LL_02_076: [ If HTTPAPIEX_ExecuteRequest call fails then IoTHubClient_LL_UploadMultipleBlocksToBlob(Ex) shall fail and return IOTHUB_CLIENT_ERROR. ]*/
AzureIoTClient 74:ea0021abecf7 334 result = __FAILURE__;
AzureIoTClient 74:ea0021abecf7 335 LogError("unable to HTTPAPIEX_ExecuteRequest");
AzureIoTClient 74:ea0021abecf7 336 }
AzureIoTClient 74:ea0021abecf7 337 else
AzureIoTClient 74:ea0021abecf7 338 {
AzureIoTClient 82:f94e6bed4495 339 /*Codes_SRS_IOTHUBCLIENT_LL_02_077: [ If HTTP statusCode is greater than or equal to 300 then IoTHubClient_LL_UploadMultipleBlocksToBlob(Ex) shall fail and return IOTHUB_CLIENT_ERROR. ]*/
AzureIoTClient 74:ea0021abecf7 340 if (statusCode >= 300)
AzureIoTClient 74:ea0021abecf7 341 {
AzureIoTClient 74:ea0021abecf7 342 result = __FAILURE__;
AzureIoTClient 74:ea0021abecf7 343 LogError("HTTP code was %u", statusCode);
AzureIoTClient 74:ea0021abecf7 344 }
AzureIoTClient 74:ea0021abecf7 345 else
AzureIoTClient 74:ea0021abecf7 346 {
AzureIoTClient 74:ea0021abecf7 347 wasIoTHubRequestSuccess = 1;
AzureIoTClient 74:ea0021abecf7 348 }
AzureIoTClient 74:ea0021abecf7 349 }
AzureIoTClient 74:ea0021abecf7 350 }
AzureIoTClient 74:ea0021abecf7 351 break;
AzureIoTClient 74:ea0021abecf7 352 }
AzureIoTClient 74:ea0021abecf7 353 case(DEVICE_KEY):
AzureIoTClient 74:ea0021abecf7 354 {
AzureIoTClient 82:f94e6bed4495 355 /*Codes_SRS_IOTHUBCLIENT_LL_02_078: [ If the credentials used to create handle have "deviceKey" then IoTHubClient_LL_UploadMultipleBlocksToBlob(Ex) shall create an HTTPAPIEX_SAS_HANDLE passing as arguments: ]*/
AzureIoTClient 74:ea0021abecf7 356 STRING_HANDLE uriResource = STRING_construct(handleData->hostname);
AzureIoTClient 74:ea0021abecf7 357 if (uriResource == NULL)
AzureIoTClient 74:ea0021abecf7 358 {
AzureIoTClient 82:f94e6bed4495 359 /*Codes_SRS_IOTHUBCLIENT_LL_02_089: [ If creating the HTTPAPIEX_SAS_HANDLE fails then IoTHubClient_LL_UploadMultipleBlocksToBlob(Ex) shall fail and return IOTHUB_CLIENT_ERROR. ]*/
AzureIoTClient 74:ea0021abecf7 360 result = __FAILURE__;
AzureIoTClient 74:ea0021abecf7 361 LogError("unable to STRING_construct");
AzureIoTClient 74:ea0021abecf7 362 }
AzureIoTClient 74:ea0021abecf7 363 else
AzureIoTClient 74:ea0021abecf7 364 {
AzureIoTClient 74:ea0021abecf7 365 if (!(
AzureIoTClient 74:ea0021abecf7 366 (STRING_concat(uriResource, "/devices/") == 0) &&
AzureIoTClient 74:ea0021abecf7 367 (STRING_concat_with_STRING(uriResource, handleData->deviceId) == 0)
AzureIoTClient 74:ea0021abecf7 368 ))
AzureIoTClient 74:ea0021abecf7 369 {
AzureIoTClient 82:f94e6bed4495 370 /*Codes_SRS_IOTHUBCLIENT_LL_02_089: [ If creating the HTTPAPIEX_SAS_HANDLE fails then IoTHubClient_LL_UploadMultipleBlocksToBlob(Ex) shall fail and return IOTHUB_CLIENT_ERROR. ]*/
AzureIoTClient 74:ea0021abecf7 371 LogError("unable to STRING_concat_with_STRING");
AzureIoTClient 74:ea0021abecf7 372 result = __FAILURE__;
AzureIoTClient 74:ea0021abecf7 373 }
AzureIoTClient 74:ea0021abecf7 374 else
AzureIoTClient 74:ea0021abecf7 375 {
AzureIoTClient 74:ea0021abecf7 376 STRING_HANDLE empty = STRING_new();
AzureIoTClient 74:ea0021abecf7 377 if (empty == NULL)
AzureIoTClient 74:ea0021abecf7 378 {
AzureIoTClient 74:ea0021abecf7 379 LogError("unable to STRING_new");
AzureIoTClient 74:ea0021abecf7 380 result = __FAILURE__;
AzureIoTClient 74:ea0021abecf7 381 }
AzureIoTClient 74:ea0021abecf7 382 else
AzureIoTClient 74:ea0021abecf7 383 {
AzureIoTClient 82:f94e6bed4495 384 /*Codes_SRS_IOTHUBCLIENT_LL_02_089: [ If creating the HTTPAPIEX_SAS_HANDLE fails then IoTHubClient_LL_UploadMultipleBlocksToBlob(Ex) shall fail and return IOTHUB_CLIENT_ERROR. ]*/
AzureIoTClient 74:ea0021abecf7 385 HTTPAPIEX_SAS_HANDLE sasHandle = HTTPAPIEX_SAS_Create(handleData->credentials.deviceKey, uriResource, empty);
AzureIoTClient 74:ea0021abecf7 386 if (sasHandle == NULL)
AzureIoTClient 74:ea0021abecf7 387 {
AzureIoTClient 74:ea0021abecf7 388 LogError("unable to HTTPAPIEX_SAS_Create");
AzureIoTClient 74:ea0021abecf7 389 result = __FAILURE__;
AzureIoTClient 74:ea0021abecf7 390 }
AzureIoTClient 74:ea0021abecf7 391 else
AzureIoTClient 74:ea0021abecf7 392 {
AzureIoTClient 74:ea0021abecf7 393 unsigned int statusCode;
AzureIoTClient 82:f94e6bed4495 394 /*Codes_SRS_IOTHUBCLIENT_LL_32_005: [ IoTHubClient_LL_UploadMultipleBlocksToBlob(Ex) shall call HTTPAPIEX_SAS_ExecuteRequest passing as arguments: ]*/
AzureIoTClient 74:ea0021abecf7 395 if (HTTPAPIEX_SAS_ExecuteRequest(
AzureIoTClient 74:ea0021abecf7 396 sasHandle, /*HTTPAPIEX_SAS_HANDLE sasHandle - the created HTTPAPIEX_SAS_HANDLE*/
AzureIoTClient 74:ea0021abecf7 397 iotHubHttpApiExHandle, /*HTTPAPIEX_HANDLE handle - the created HTTPAPIEX_HANDLE*/
AzureIoTClient 74:ea0021abecf7 398 HTTPAPI_REQUEST_POST, /*HTTPAPI_REQUEST_TYPE requestType - HTTPAPI_REQUEST_POST*/
AzureIoTClient 74:ea0021abecf7 399 STRING_c_str(relativePath), /*const char* relativePath - the HTTP relative path*/
AzureIoTClient 74:ea0021abecf7 400 requestHttpHeaders, /*HTTP_HEADERS_HANDLE requestHttpHeadersHandle - request HTTP headers*/
AzureIoTClient 74:ea0021abecf7 401 blobBuffer, /*BUFFER_HANDLE requestContent - address of JSON with optional/directory/tree/filename*/
AzureIoTClient 74:ea0021abecf7 402 &statusCode, /*unsigned int* statusCode - the address of an unsigned int that will contain the HTTP status code*/
AzureIoTClient 74:ea0021abecf7 403 NULL, /*HTTP_HEADERS_HANDLE responseHeadersHandle - NULL*/
AzureIoTClient 74:ea0021abecf7 404 responseContent
AzureIoTClient 74:ea0021abecf7 405 ) != HTTPAPIEX_OK)
AzureIoTClient 74:ea0021abecf7 406 {
AzureIoTClient 82:f94e6bed4495 407 /*Codes_SRS_IOTHUBCLIENT_LL_02_079: [ If HTTPAPIEX_SAS_ExecuteRequest fails then IoTHubClient_LL_UploadMultipleBlocksToBlob(Ex) shall fail and return IOTHUB_CLIENT_ERROR. ]*/
AzureIoTClient 74:ea0021abecf7 408 LogError("unable to HTTPAPIEX_SAS_ExecuteRequest");
AzureIoTClient 74:ea0021abecf7 409 result = __FAILURE__;
AzureIoTClient 74:ea0021abecf7 410 }
AzureIoTClient 74:ea0021abecf7 411 else
AzureIoTClient 74:ea0021abecf7 412 {
AzureIoTClient 74:ea0021abecf7 413 if (statusCode >= 300)
AzureIoTClient 74:ea0021abecf7 414 {
AzureIoTClient 82:f94e6bed4495 415 /*Codes_SRS_IOTHUBCLIENT_LL_02_080: [ If status code is greater than or equal to 300 then IoTHubClient_LL_UploadMultipleBlocksToBlob(Ex) shall fail and return IOTHUB_CLIENT_ERROR. ]*/
AzureIoTClient 74:ea0021abecf7 416 result = __FAILURE__;
AzureIoTClient 74:ea0021abecf7 417 LogError("HTTP code was %u", statusCode);
AzureIoTClient 74:ea0021abecf7 418 }
AzureIoTClient 74:ea0021abecf7 419 else
AzureIoTClient 74:ea0021abecf7 420 {
AzureIoTClient 74:ea0021abecf7 421 wasIoTHubRequestSuccess = 1;
AzureIoTClient 74:ea0021abecf7 422 }
AzureIoTClient 74:ea0021abecf7 423 }
AzureIoTClient 74:ea0021abecf7 424 HTTPAPIEX_SAS_Destroy(sasHandle);
AzureIoTClient 74:ea0021abecf7 425 }
AzureIoTClient 74:ea0021abecf7 426 STRING_delete(empty);
AzureIoTClient 74:ea0021abecf7 427 }
AzureIoTClient 74:ea0021abecf7 428 }
AzureIoTClient 74:ea0021abecf7 429 STRING_delete(uriResource);
AzureIoTClient 74:ea0021abecf7 430 }
AzureIoTClient 74:ea0021abecf7 431 }
AzureIoTClient 74:ea0021abecf7 432 } /*switch*/
AzureIoTClient 42:448eecc3676e 433
AzureIoTClient 74:ea0021abecf7 434 if (wasIoTHubRequestSuccess == 0)
AzureIoTClient 74:ea0021abecf7 435 {
AzureIoTClient 74:ea0021abecf7 436 /*do nothing, shall be reported as an error*/
AzureIoTClient 74:ea0021abecf7 437 }
AzureIoTClient 74:ea0021abecf7 438 else
AzureIoTClient 74:ea0021abecf7 439 {
AzureIoTClient 74:ea0021abecf7 440 const unsigned char*responseContent_u_char = BUFFER_u_char(responseContent);
AzureIoTClient 74:ea0021abecf7 441 size_t responseContent_length = BUFFER_length(responseContent);
AzureIoTClient 74:ea0021abecf7 442 STRING_HANDLE responseAsString = STRING_from_byte_array(responseContent_u_char, responseContent_length);
AzureIoTClient 74:ea0021abecf7 443 if (responseAsString == NULL)
AzureIoTClient 74:ea0021abecf7 444 {
AzureIoTClient 74:ea0021abecf7 445 result = __FAILURE__;
AzureIoTClient 74:ea0021abecf7 446 LogError("unable to get the response as string");
AzureIoTClient 74:ea0021abecf7 447 }
AzureIoTClient 74:ea0021abecf7 448 else
AzureIoTClient 74:ea0021abecf7 449 {
AzureIoTClient 82:f94e6bed4495 450 /*Codes_SRS_IOTHUBCLIENT_LL_02_081: [ Otherwise, IoTHubClient_LL_UploadMultipleBlocksToBlob(Ex) shall use parson to extract and save the following information from the response buffer: correlationID and SasUri. ]*/
AzureIoTClient 74:ea0021abecf7 451 JSON_Value* allJson = json_parse_string(STRING_c_str(responseAsString));
AzureIoTClient 74:ea0021abecf7 452 if (allJson == NULL)
AzureIoTClient 74:ea0021abecf7 453 {
AzureIoTClient 82:f94e6bed4495 454 /*Codes_SRS_IOTHUBCLIENT_LL_02_082: [ If extracting and saving the correlationId or SasUri fails then IoTHubClient_LL_UploadMultipleBlocksToBlob(Ex) shall fail and return IOTHUB_CLIENT_ERROR. ]*/
AzureIoTClient 74:ea0021abecf7 455 LogError("unable to json_parse_string");
AzureIoTClient 74:ea0021abecf7 456 result = __FAILURE__;
AzureIoTClient 74:ea0021abecf7 457 }
AzureIoTClient 74:ea0021abecf7 458 else
AzureIoTClient 74:ea0021abecf7 459 {
AzureIoTClient 74:ea0021abecf7 460 JSON_Object* jsonObject = json_value_get_object(allJson);
AzureIoTClient 74:ea0021abecf7 461 if (jsonObject == NULL)
AzureIoTClient 74:ea0021abecf7 462 {
AzureIoTClient 82:f94e6bed4495 463 /*Codes_SRS_IOTHUBCLIENT_LL_02_082: [ If extracting and saving the correlationId or SasUri fails then IoTHubClient_LL_UploadMultipleBlocksToBlob(Ex) shall fail and return IOTHUB_CLIENT_ERROR. ]*/
AzureIoTClient 74:ea0021abecf7 464 LogError("unable to json_value_get_object");
AzureIoTClient 74:ea0021abecf7 465 result = __FAILURE__;
AzureIoTClient 74:ea0021abecf7 466 }
AzureIoTClient 74:ea0021abecf7 467 else
AzureIoTClient 74:ea0021abecf7 468 {
AzureIoTClient 74:ea0021abecf7 469 const char* json_correlationId;
AzureIoTClient 74:ea0021abecf7 470 json_correlationId = json_object_get_string(jsonObject, "correlationId");
AzureIoTClient 74:ea0021abecf7 471 if (json_correlationId == NULL)
AzureIoTClient 74:ea0021abecf7 472 {
AzureIoTClient 82:f94e6bed4495 473 /*Codes_SRS_IOTHUBCLIENT_LL_02_082: [ If extracting and saving the correlationId or SasUri fails then IoTHubClient_LL_UploadMultipleBlocksToBlob(Ex) shall fail and return IOTHUB_CLIENT_ERROR. ]*/
AzureIoTClient 74:ea0021abecf7 474 LogError("unable to json_object_get_string(jsonObject, \"correlationId\")");
AzureIoTClient 74:ea0021abecf7 475 result = __FAILURE__;
AzureIoTClient 74:ea0021abecf7 476 }
AzureIoTClient 74:ea0021abecf7 477 else
AzureIoTClient 74:ea0021abecf7 478 {
AzureIoTClient 74:ea0021abecf7 479 if (STRING_copy(correlationId, json_correlationId) != 0)
AzureIoTClient 74:ea0021abecf7 480 {
AzureIoTClient 82:f94e6bed4495 481 /*Codes_SRS_IOTHUBCLIENT_LL_02_082: [ If extracting and saving the correlationId or SasUri fails then IoTHubClient_LL_UploadMultipleBlocksToBlob(Ex) shall fail and return IOTHUB_CLIENT_ERROR. ]*/
AzureIoTClient 74:ea0021abecf7 482 LogError("unable to copy json_correlationId");
AzureIoTClient 74:ea0021abecf7 483 result = __FAILURE__;
AzureIoTClient 74:ea0021abecf7 484 }
AzureIoTClient 74:ea0021abecf7 485 else
AzureIoTClient 74:ea0021abecf7 486 {
AzureIoTClient 74:ea0021abecf7 487 const char* json_hostName = json_object_get_string(jsonObject, "hostName");
AzureIoTClient 74:ea0021abecf7 488 if (json_hostName == NULL)
AzureIoTClient 74:ea0021abecf7 489 {
AzureIoTClient 82:f94e6bed4495 490 /*Codes_SRS_IOTHUBCLIENT_LL_02_082: [ If extracting and saving the correlationId or SasUri fails then IoTHubClient_LL_UploadMultipleBlocksToBlob(Ex) shall fail and return IOTHUB_CLIENT_ERROR. ]*/
AzureIoTClient 74:ea0021abecf7 491 LogError("unable to json_object_get_string(jsonObject, \"hostName\")");
AzureIoTClient 74:ea0021abecf7 492 result = __FAILURE__;
AzureIoTClient 74:ea0021abecf7 493 }
AzureIoTClient 74:ea0021abecf7 494 else
AzureIoTClient 74:ea0021abecf7 495 {
AzureIoTClient 74:ea0021abecf7 496 const char* json_containerName = json_object_get_string(jsonObject, "containerName");
AzureIoTClient 74:ea0021abecf7 497 if (json_containerName == NULL)
AzureIoTClient 74:ea0021abecf7 498 {
AzureIoTClient 82:f94e6bed4495 499 /*Codes_SRS_IOTHUBCLIENT_LL_02_082: [ If extracting and saving the correlationId or SasUri fails then IoTHubClient_LL_UploadMultipleBlocksToBlob(Ex) shall fail and return IOTHUB_CLIENT_ERROR. ]*/
AzureIoTClient 74:ea0021abecf7 500 LogError("unable to json_object_get_string(jsonObject, \"containerName\")");
AzureIoTClient 74:ea0021abecf7 501 result = __FAILURE__;
AzureIoTClient 74:ea0021abecf7 502 }
AzureIoTClient 74:ea0021abecf7 503 else
AzureIoTClient 74:ea0021abecf7 504 {
AzureIoTClient 74:ea0021abecf7 505 const char* json_blobName = json_object_get_string(jsonObject, "blobName");
AzureIoTClient 74:ea0021abecf7 506 if (json_blobName == NULL)
AzureIoTClient 74:ea0021abecf7 507 {
AzureIoTClient 82:f94e6bed4495 508 /*Codes_SRS_IOTHUBCLIENT_LL_02_082: [ If extracting and saving the correlationId or SasUri fails then IoTHubClient_LL_UploadMultipleBlocksToBlob(Ex) shall fail and return IOTHUB_CLIENT_ERROR. ]*/
AzureIoTClient 74:ea0021abecf7 509 LogError("unable to json_object_get_string(jsonObject, \"blobName\")");
AzureIoTClient 74:ea0021abecf7 510 result = __FAILURE__;
AzureIoTClient 74:ea0021abecf7 511 }
AzureIoTClient 74:ea0021abecf7 512 else
AzureIoTClient 74:ea0021abecf7 513 {
AzureIoTClient 74:ea0021abecf7 514 const char* json_sasToken = json_object_get_string(jsonObject, "sasToken");
AzureIoTClient 74:ea0021abecf7 515 if (json_sasToken == NULL)
AzureIoTClient 74:ea0021abecf7 516 {
AzureIoTClient 82:f94e6bed4495 517 /*Codes_SRS_IOTHUBCLIENT_LL_02_082: [ If extracting and saving the correlationId or SasUri fails then IoTHubClient_LL_UploadMultipleBlocksToBlob(Ex) shall fail and return IOTHUB_CLIENT_ERROR. ]*/
AzureIoTClient 74:ea0021abecf7 518 LogError("unable to json_object_get_string(jsonObject, \"sasToken\")");
AzureIoTClient 74:ea0021abecf7 519 result = __FAILURE__;
AzureIoTClient 74:ea0021abecf7 520 }
AzureIoTClient 74:ea0021abecf7 521 else
AzureIoTClient 74:ea0021abecf7 522 {
AzureIoTClient 74:ea0021abecf7 523 /*good JSON received from the service*/
AzureIoTClient 42:448eecc3676e 524
AzureIoTClient 74:ea0021abecf7 525 if (STRING_copy(sasUri, "https://") != 0)
AzureIoTClient 74:ea0021abecf7 526 {
AzureIoTClient 82:f94e6bed4495 527 /*Codes_SRS_IOTHUBCLIENT_LL_02_082: [ If extracting and saving the correlationId or SasUri fails then IoTHubClient_LL_UploadMultipleBlocksToBlob(Ex) shall fail and return IOTHUB_CLIENT_ERROR. ]*/
AzureIoTClient 74:ea0021abecf7 528 LogError("unable to STRING_copy");
AzureIoTClient 74:ea0021abecf7 529 result = __FAILURE__;
AzureIoTClient 74:ea0021abecf7 530 }
AzureIoTClient 74:ea0021abecf7 531 else
AzureIoTClient 74:ea0021abecf7 532 {
AzureIoTClient 77:e4e36df9caee 533 /*Codes_SRS_IOTHUBCLIENT_LL_32_008: [ The returned file name shall be URL encoded before passing back to the cloud. ]*/
AzureIoTClient 77:e4e36df9caee 534 STRING_HANDLE fileName = URL_EncodeString(json_blobName);
AzureIoTClient 77:e4e36df9caee 535
AzureIoTClient 77:e4e36df9caee 536 if (fileName == NULL)
AzureIoTClient 77:e4e36df9caee 537 {
AzureIoTClient 82:f94e6bed4495 538 /*Codes_SRS_IOTHUBCLIENT_LL_32_009: [ If URL_EncodeString fails then IoTHubClient_LL_UploadMultipleBlocksToBlob(Ex) shall fail and return IOTHUB_CLIENT_ERROR. ]*/
AzureIoTClient 77:e4e36df9caee 539 LogError("unable to URL_EncodeString of filename");
AzureIoTClient 77:e4e36df9caee 540 result = __FAILURE__;
AzureIoTClient 77:e4e36df9caee 541 }
AzureIoTClient 77:e4e36df9caee 542
AzureIoTClient 77:e4e36df9caee 543 else
AzureIoTClient 77:e4e36df9caee 544 {
AzureIoTClient 77:e4e36df9caee 545 if (!(
AzureIoTClient 77:e4e36df9caee 546 (STRING_concat(sasUri, json_hostName) == 0) &&
AzureIoTClient 77:e4e36df9caee 547 (STRING_concat(sasUri, "/") == 0) &&
AzureIoTClient 77:e4e36df9caee 548 (STRING_concat(sasUri, json_containerName) == 0) &&
AzureIoTClient 77:e4e36df9caee 549 (STRING_concat(sasUri, "/") == 0) &&
AzureIoTClient 77:e4e36df9caee 550 (STRING_concat(sasUri, STRING_c_str(fileName)) == 0) &&
AzureIoTClient 77:e4e36df9caee 551 (STRING_concat(sasUri, json_sasToken) == 0)
AzureIoTClient 77:e4e36df9caee 552 ))
AzureIoTClient 77:e4e36df9caee 553 {
AzureIoTClient 82:f94e6bed4495 554 /*Codes_SRS_IOTHUBCLIENT_LL_02_082: [ If extracting and saving the correlationId or SasUri fails then IoTHubClient_LL_UploadMultipleBlocksToBlob(Ex) shall fail and return IOTHUB_CLIENT_ERROR. ]*/
AzureIoTClient 77:e4e36df9caee 555 LogError("unable to STRING_concat");
AzureIoTClient 77:e4e36df9caee 556 result = __FAILURE__;
AzureIoTClient 77:e4e36df9caee 557 }
AzureIoTClient 77:e4e36df9caee 558 else
AzureIoTClient 77:e4e36df9caee 559 {
AzureIoTClient 77:e4e36df9caee 560 result = 0; /*success in step 1*/
AzureIoTClient 77:e4e36df9caee 561 }
AzureIoTClient 77:e4e36df9caee 562
AzureIoTClient 77:e4e36df9caee 563 STRING_delete(fileName);
AzureIoTClient 77:e4e36df9caee 564 }
AzureIoTClient 74:ea0021abecf7 565 }
AzureIoTClient 74:ea0021abecf7 566 }
AzureIoTClient 74:ea0021abecf7 567 }
AzureIoTClient 74:ea0021abecf7 568 }
AzureIoTClient 74:ea0021abecf7 569 }
AzureIoTClient 74:ea0021abecf7 570 }
AzureIoTClient 74:ea0021abecf7 571 }
AzureIoTClient 74:ea0021abecf7 572 }
AzureIoTClient 74:ea0021abecf7 573 json_value_free(allJson);
AzureIoTClient 74:ea0021abecf7 574 }
AzureIoTClient 74:ea0021abecf7 575 STRING_delete(responseAsString);
AzureIoTClient 74:ea0021abecf7 576 }
AzureIoTClient 74:ea0021abecf7 577 }
AzureIoTClient 74:ea0021abecf7 578 }
AzureIoTClient 74:ea0021abecf7 579 BUFFER_delete(responseContent);
AzureIoTClient 74:ea0021abecf7 580 }
AzureIoTClient 69:b6f532f8c608 581 BUFFER_delete(blobBuffer);
AzureIoTClient 74:ea0021abecf7 582 }
AzureIoTClient 74:ea0021abecf7 583 }
AzureIoTClient 74:ea0021abecf7 584 STRING_delete(blobName);
AzureIoTClient 74:ea0021abecf7 585 }
AzureIoTClient 74:ea0021abecf7 586 }
AzureIoTClient 74:ea0021abecf7 587 STRING_delete(relativePath);
AzureIoTClient 74:ea0021abecf7 588 }
AzureIoTClient 42:448eecc3676e 589 return result;
AzureIoTClient 42:448eecc3676e 590 }
AzureIoTClient 42:448eecc3676e 591
AzureIoTClient 42:448eecc3676e 592 /*returns 0 when the IoTHub has been informed about the file upload status*/
AzureIoTClient 42:448eecc3676e 593 static int IoTHubClient_LL_UploadToBlob_step3(IOTHUB_CLIENT_LL_UPLOADTOBLOB_HANDLE_DATA* handleData, STRING_HANDLE correlationId, HTTPAPIEX_HANDLE iotHubHttpApiExHandle, HTTP_HEADERS_HANDLE requestHttpHeaders, BUFFER_HANDLE messageBody)
AzureIoTClient 42:448eecc3676e 594 {
AzureIoTClient 42:448eecc3676e 595 int result;
AzureIoTClient 42:448eecc3676e 596 /*here is step 3. depending on the outcome of step 2 it needs to inform IoTHub about the file upload status*/
AzureIoTClient 42:448eecc3676e 597 /*if step 1 failed, there's nothing that step 3 needs to report.*/
AzureIoTClient 42:448eecc3676e 598 /*this POST "tries" to happen*/
AzureIoTClient 42:448eecc3676e 599
AzureIoTClient 82:f94e6bed4495 600 /*Codes_SRS_IOTHUBCLIENT_LL_02_085: [ IoTHubClient_LL_UploadMultipleBlocksToBlob(Ex) shall use the same authorization as step 1. to prepare and perform a HTTP request with the following parameters: ]*/
AzureIoTClient 42:448eecc3676e 601 STRING_HANDLE uriResource = STRING_construct(handleData->hostname);
AzureIoTClient 42:448eecc3676e 602 if (uriResource == NULL)
AzureIoTClient 42:448eecc3676e 603 {
AzureIoTClient 42:448eecc3676e 604 LogError("unable to construct URI");
AzureIoTClient 60:41648c4e7036 605 result = __FAILURE__;
AzureIoTClient 42:448eecc3676e 606 }
AzureIoTClient 42:448eecc3676e 607 else
AzureIoTClient 42:448eecc3676e 608 {
AzureIoTClient 42:448eecc3676e 609 if (!(
AzureIoTClient 42:448eecc3676e 610 (STRING_concat(uriResource, "/devices/") == 0) &&
AzureIoTClient 42:448eecc3676e 611 (STRING_concat_with_STRING(uriResource, handleData->deviceId) == 0) &&
AzureIoTClient 42:448eecc3676e 612 (STRING_concat(uriResource, "/files/notifications") == 0)
AzureIoTClient 42:448eecc3676e 613 ))
AzureIoTClient 42:448eecc3676e 614 {
AzureIoTClient 42:448eecc3676e 615 LogError("unable to STRING_concat");
AzureIoTClient 60:41648c4e7036 616 result = __FAILURE__;
AzureIoTClient 42:448eecc3676e 617 }
AzureIoTClient 42:448eecc3676e 618 else
AzureIoTClient 42:448eecc3676e 619 {
AzureIoTClient 42:448eecc3676e 620 STRING_HANDLE relativePathNotification = STRING_construct("/devices/");
AzureIoTClient 42:448eecc3676e 621 if (relativePathNotification == NULL)
AzureIoTClient 42:448eecc3676e 622 {
AzureIoTClient 60:41648c4e7036 623 result = __FAILURE__;
AzureIoTClient 42:448eecc3676e 624 LogError("unable to STRING_construct");
AzureIoTClient 42:448eecc3676e 625 }
AzureIoTClient 42:448eecc3676e 626 else
AzureIoTClient 42:448eecc3676e 627 {
AzureIoTClient 42:448eecc3676e 628 if (!(
AzureIoTClient 42:448eecc3676e 629 (STRING_concat_with_STRING(relativePathNotification, handleData->deviceId) == 0) &&
AzureIoTClient 42:448eecc3676e 630 (STRING_concat(relativePathNotification, "/files/notifications/") == 0) &&
AzureIoTClient 42:448eecc3676e 631 (STRING_concat(relativePathNotification, STRING_c_str(correlationId)) == 0) &&
AzureIoTClient 42:448eecc3676e 632 (STRING_concat(relativePathNotification, API_VERSION) == 0)
AzureIoTClient 42:448eecc3676e 633 ))
AzureIoTClient 42:448eecc3676e 634 {
AzureIoTClient 42:448eecc3676e 635 LogError("unable to STRING_concat_with_STRING");
AzureIoTClient 60:41648c4e7036 636 result = __FAILURE__;
AzureIoTClient 42:448eecc3676e 637 }
AzureIoTClient 42:448eecc3676e 638 else
AzureIoTClient 42:448eecc3676e 639 {
AzureIoTClient 82:f94e6bed4495 640 /*Codes_SRS_IOTHUBCLIENT_LL_02_086: [ If performing the HTTP request fails then IoTHubClient_LL_UploadMultipleBlocksToBlob(Ex) shall fail and return IOTHUB_CLIENT_ERROR. ]*/
AzureIoTClient 42:448eecc3676e 641 switch (handleData->authorizationScheme)
AzureIoTClient 42:448eecc3676e 642 {
AzureIoTClient 42:448eecc3676e 643 default:
AzureIoTClient 42:448eecc3676e 644 {
AzureIoTClient 42:448eecc3676e 645 LogError("internal error: unknown authorization Scheme");
AzureIoTClient 60:41648c4e7036 646 result = __FAILURE__;
AzureIoTClient 42:448eecc3676e 647 break;
AzureIoTClient 42:448eecc3676e 648 }
AzureIoTClient 46:6a69294b6119 649 case (X509):
AzureIoTClient 46:6a69294b6119 650 {
AzureIoTClient 46:6a69294b6119 651 unsigned int notificationStatusCode;
AzureIoTClient 46:6a69294b6119 652 if (HTTPAPIEX_ExecuteRequest(
AzureIoTClient 46:6a69294b6119 653 iotHubHttpApiExHandle,
AzureIoTClient 46:6a69294b6119 654 HTTPAPI_REQUEST_POST,
AzureIoTClient 46:6a69294b6119 655 STRING_c_str(relativePathNotification),
AzureIoTClient 46:6a69294b6119 656 requestHttpHeaders,
AzureIoTClient 46:6a69294b6119 657 messageBody,
AzureIoTClient 46:6a69294b6119 658 &notificationStatusCode,
AzureIoTClient 46:6a69294b6119 659 NULL,
AzureIoTClient 46:6a69294b6119 660 NULL) != HTTPAPIEX_OK)
AzureIoTClient 46:6a69294b6119 661 {
AzureIoTClient 46:6a69294b6119 662 LogError("unable to do HTTPAPIEX_ExecuteRequest");
AzureIoTClient 60:41648c4e7036 663 result = __FAILURE__;
AzureIoTClient 46:6a69294b6119 664 }
AzureIoTClient 46:6a69294b6119 665 else
AzureIoTClient 46:6a69294b6119 666 {
AzureIoTClient 46:6a69294b6119 667 if (notificationStatusCode >= 300)
AzureIoTClient 46:6a69294b6119 668 {
AzureIoTClient 82:f94e6bed4495 669 /*Codes_SRS_IOTHUBCLIENT_LL_02_087: [If the statusCode of the HTTP request is greater than or equal to 300 then IoTHubClient_LL_UploadMultipleBlocksToBlob(Ex) shall fail and return IOTHUB_CLIENT_ERROR]*/
AzureIoTClient 46:6a69294b6119 670 LogError("server didn't like the notification request");
AzureIoTClient 60:41648c4e7036 671 result = __FAILURE__;
AzureIoTClient 46:6a69294b6119 672 }
AzureIoTClient 46:6a69294b6119 673 else
AzureIoTClient 46:6a69294b6119 674 {
AzureIoTClient 46:6a69294b6119 675 result = 0;
AzureIoTClient 46:6a69294b6119 676 }
AzureIoTClient 46:6a69294b6119 677 }
AzureIoTClient 46:6a69294b6119 678 break;
AzureIoTClient 46:6a69294b6119 679 }
AzureIoTClient 42:448eecc3676e 680 case (DEVICE_KEY):
AzureIoTClient 42:448eecc3676e 681 {
AzureIoTClient 42:448eecc3676e 682 STRING_HANDLE empty = STRING_new();
AzureIoTClient 42:448eecc3676e 683 if (empty == NULL)
AzureIoTClient 42:448eecc3676e 684 {
AzureIoTClient 42:448eecc3676e 685 LogError("unable to STRING_new");
AzureIoTClient 60:41648c4e7036 686 result = __FAILURE__;
AzureIoTClient 42:448eecc3676e 687 }
AzureIoTClient 42:448eecc3676e 688 else
AzureIoTClient 42:448eecc3676e 689 {
AzureIoTClient 42:448eecc3676e 690 HTTPAPIEX_SAS_HANDLE sasHandle = HTTPAPIEX_SAS_Create(handleData->credentials.deviceKey, uriResource, empty);
AzureIoTClient 42:448eecc3676e 691 if (sasHandle == NULL)
AzureIoTClient 42:448eecc3676e 692 {
AzureIoTClient 42:448eecc3676e 693 LogError("unable to HTTPAPIEX_SAS_Create");
AzureIoTClient 60:41648c4e7036 694 result = __FAILURE__;
AzureIoTClient 42:448eecc3676e 695 }
AzureIoTClient 42:448eecc3676e 696 else
AzureIoTClient 42:448eecc3676e 697 {
AzureIoTClient 42:448eecc3676e 698 unsigned int statusCode;
AzureIoTClient 42:448eecc3676e 699 if (HTTPAPIEX_SAS_ExecuteRequest(
AzureIoTClient 42:448eecc3676e 700 sasHandle, /*HTTPAPIEX_SAS_HANDLE sasHandle - the created HTTPAPIEX_SAS_HANDLE*/
AzureIoTClient 42:448eecc3676e 701 iotHubHttpApiExHandle, /*HTTPAPIEX_HANDLE handle - the created HTTPAPIEX_HANDLE*/
AzureIoTClient 42:448eecc3676e 702 HTTPAPI_REQUEST_POST, /*HTTPAPI_REQUEST_TYPE requestType - HTTPAPI_REQUEST_GET*/
AzureIoTClient 42:448eecc3676e 703 STRING_c_str(relativePathNotification), /*const char* relativePath - the HTTP relative path*/
AzureIoTClient 42:448eecc3676e 704 requestHttpHeaders, /*HTTP_HEADERS_HANDLE requestHttpHeadersHandle - request HTTP headers*/
AzureIoTClient 42:448eecc3676e 705 messageBody, /*BUFFER_HANDLE requestContent*/
AzureIoTClient 42:448eecc3676e 706 &statusCode, /*unsigned int* statusCode - the address of an unsigned int that will contain the HTTP status code*/
AzureIoTClient 42:448eecc3676e 707 NULL, /*HTTP_HEADERS_HANDLE responseHeadersHandle - NULL*/
AzureIoTClient 42:448eecc3676e 708 NULL
AzureIoTClient 42:448eecc3676e 709 ) != HTTPAPIEX_OK)
AzureIoTClient 42:448eecc3676e 710 {
AzureIoTClient 82:f94e6bed4495 711 /*Codes_SRS_IOTHUBCLIENT_LL_02_079: [ If HTTPAPIEX_SAS_ExecuteRequest fails then IoTHubClient_LL_UploadMultipleBlocksToBlob(Ex) shall fail and return IOTHUB_CLIENT_ERROR. ]*/
AzureIoTClient 42:448eecc3676e 712 LogError("unable to HTTPAPIEX_SAS_ExecuteRequest");
AzureIoTClient 60:41648c4e7036 713 result = __FAILURE__;
AzureIoTClient 42:448eecc3676e 714 ;
AzureIoTClient 42:448eecc3676e 715 }
AzureIoTClient 42:448eecc3676e 716 else
AzureIoTClient 42:448eecc3676e 717 {
AzureIoTClient 42:448eecc3676e 718 if (statusCode >= 300)
AzureIoTClient 42:448eecc3676e 719 {
AzureIoTClient 82:f94e6bed4495 720 /*Codes_SRS_IOTHUBCLIENT_LL_02_087: [If the statusCode of the HTTP request is greater than or equal to 300 then IoTHubClient_LL_UploadMultipleBlocksToBlob(Ex) shall fail and return IOTHUB_CLIENT_ERROR]*/
AzureIoTClient 60:41648c4e7036 721 result = __FAILURE__;
AzureIoTClient 42:448eecc3676e 722 LogError("HTTP code was %u", statusCode);
AzureIoTClient 42:448eecc3676e 723 }
AzureIoTClient 42:448eecc3676e 724 else
AzureIoTClient 42:448eecc3676e 725 {
AzureIoTClient 42:448eecc3676e 726 result = 0;
AzureIoTClient 42:448eecc3676e 727 }
AzureIoTClient 42:448eecc3676e 728 }
AzureIoTClient 42:448eecc3676e 729 HTTPAPIEX_SAS_Destroy(sasHandle);
AzureIoTClient 42:448eecc3676e 730 }
AzureIoTClient 42:448eecc3676e 731 STRING_delete(empty);
AzureIoTClient 42:448eecc3676e 732 }
AzureIoTClient 42:448eecc3676e 733 break;
AzureIoTClient 42:448eecc3676e 734 }
AzureIoTClient 42:448eecc3676e 735 case(SAS_TOKEN):
AzureIoTClient 42:448eecc3676e 736 {
AzureIoTClient 42:448eecc3676e 737 unsigned int notificationStatusCode;
AzureIoTClient 42:448eecc3676e 738 if (HTTPAPIEX_ExecuteRequest(
AzureIoTClient 42:448eecc3676e 739 iotHubHttpApiExHandle,
AzureIoTClient 42:448eecc3676e 740 HTTPAPI_REQUEST_POST,
AzureIoTClient 42:448eecc3676e 741 STRING_c_str(relativePathNotification),
AzureIoTClient 42:448eecc3676e 742 requestHttpHeaders,
AzureIoTClient 42:448eecc3676e 743 messageBody,
AzureIoTClient 42:448eecc3676e 744 &notificationStatusCode,
AzureIoTClient 42:448eecc3676e 745 NULL,
AzureIoTClient 42:448eecc3676e 746 NULL) != HTTPAPIEX_OK)
AzureIoTClient 42:448eecc3676e 747 {
AzureIoTClient 42:448eecc3676e 748 LogError("unable to do HTTPAPIEX_ExecuteRequest");
AzureIoTClient 60:41648c4e7036 749 result = __FAILURE__;
AzureIoTClient 42:448eecc3676e 750 }
AzureIoTClient 42:448eecc3676e 751 else
AzureIoTClient 42:448eecc3676e 752 {
AzureIoTClient 42:448eecc3676e 753 if (notificationStatusCode >= 300)
AzureIoTClient 42:448eecc3676e 754 {
AzureIoTClient 82:f94e6bed4495 755 /*Codes_SRS_IOTHUBCLIENT_LL_02_087: [If the statusCode of the HTTP request is greater than or equal to 300 then IoTHubClient_LL_UploadMultipleBlocksToBlob(Ex) shall fail and return IOTHUB_CLIENT_ERROR]*/
AzureIoTClient 42:448eecc3676e 756 LogError("server didn't like the notification request");
AzureIoTClient 60:41648c4e7036 757 result = __FAILURE__;
AzureIoTClient 42:448eecc3676e 758 }
AzureIoTClient 42:448eecc3676e 759 else
AzureIoTClient 42:448eecc3676e 760 {
AzureIoTClient 42:448eecc3676e 761 result = 0;
AzureIoTClient 42:448eecc3676e 762 }
AzureIoTClient 42:448eecc3676e 763 }
AzureIoTClient 42:448eecc3676e 764 break;
AzureIoTClient 42:448eecc3676e 765 }
AzureIoTClient 42:448eecc3676e 766 } /*switch authorizationScheme*/
AzureIoTClient 42:448eecc3676e 767 }
AzureIoTClient 42:448eecc3676e 768 STRING_delete(relativePathNotification);
AzureIoTClient 42:448eecc3676e 769 }
AzureIoTClient 42:448eecc3676e 770 }
AzureIoTClient 42:448eecc3676e 771 STRING_delete(uriResource);
AzureIoTClient 42:448eecc3676e 772 }
AzureIoTClient 42:448eecc3676e 773 return result;
AzureIoTClient 42:448eecc3676e 774 }
AzureIoTClient 42:448eecc3676e 775
AzureIoTClient 82:f94e6bed4495 776 // this callback splits the source data into blocks to be fed to IoTHubClient_LL_UploadMultipleBlocksToBlob(Ex)_Impl
AzureIoTClient 82:f94e6bed4495 777 static IOTHUB_CLIENT_FILE_UPLOAD_GET_DATA_RESULT FileUpload_GetData_Callback(IOTHUB_CLIENT_FILE_UPLOAD_RESULT result, unsigned char const ** data, size_t* size, void* context)
AzureIoTClient 80:db5f5237bc95 778 {
AzureIoTClient 80:db5f5237bc95 779 BLOB_UPLOAD_CONTEXT* uploadContext = (BLOB_UPLOAD_CONTEXT*) context;
AzureIoTClient 80:db5f5237bc95 780
AzureIoTClient 80:db5f5237bc95 781 if (data == NULL || size == NULL)
AzureIoTClient 80:db5f5237bc95 782 {
AzureIoTClient 80:db5f5237bc95 783 // This is the last call, nothing to do
AzureIoTClient 80:db5f5237bc95 784 }
AzureIoTClient 80:db5f5237bc95 785 else if (result != FILE_UPLOAD_OK)
AzureIoTClient 80:db5f5237bc95 786 {
AzureIoTClient 80:db5f5237bc95 787 // Last call failed
AzureIoTClient 80:db5f5237bc95 788 *data = NULL;
AzureIoTClient 80:db5f5237bc95 789 *size = 0;
AzureIoTClient 80:db5f5237bc95 790 }
AzureIoTClient 80:db5f5237bc95 791 else if (uploadContext->remainingSizeToUpload == 0)
AzureIoTClient 80:db5f5237bc95 792 {
AzureIoTClient 80:db5f5237bc95 793 // Everything has been uploaded
AzureIoTClient 80:db5f5237bc95 794 *data = NULL;
AzureIoTClient 80:db5f5237bc95 795 *size = 0;
AzureIoTClient 80:db5f5237bc95 796 }
AzureIoTClient 80:db5f5237bc95 797 else
AzureIoTClient 80:db5f5237bc95 798 {
AzureIoTClient 80:db5f5237bc95 799 // Upload next block
AzureIoTClient 80:db5f5237bc95 800 size_t thisBlockSize = (uploadContext->remainingSizeToUpload > BLOCK_SIZE) ? BLOCK_SIZE : uploadContext->remainingSizeToUpload;
AzureIoTClient 80:db5f5237bc95 801 *data = (unsigned char*)uploadContext->blobSource + (uploadContext->blobSourceSize - uploadContext->remainingSizeToUpload);
AzureIoTClient 80:db5f5237bc95 802 *size = thisBlockSize;
AzureIoTClient 80:db5f5237bc95 803 uploadContext->remainingSizeToUpload -= thisBlockSize;
AzureIoTClient 80:db5f5237bc95 804 }
AzureIoTClient 82:f94e6bed4495 805
AzureIoTClient 82:f94e6bed4495 806 return IOTHUB_CLIENT_FILE_UPLOAD_GET_DATA_OK;
AzureIoTClient 80:db5f5237bc95 807 }
AzureIoTClient 80:db5f5237bc95 808
AzureIoTClient 86:a1352899ea45 809 static HTTPAPIEX_RESULT set_transfer_timeout(IOTHUB_CLIENT_LL_UPLOADTOBLOB_HANDLE_DATA* handleData, HTTPAPIEX_HANDLE iotHubHttpApiExHandle)
AzureIoTClient 86:a1352899ea45 810 {
AzureIoTClient 86:a1352899ea45 811 HTTPAPIEX_RESULT result;
AzureIoTClient 86:a1352899ea45 812 if (handleData->blob_upload_timeout_secs != 0)
AzureIoTClient 86:a1352899ea45 813 {
AzureIoTClient 86:a1352899ea45 814 // Convert the timeout to milliseconds for curl
AzureIoTClient 86:a1352899ea45 815 long http_timeout = (long)handleData->blob_upload_timeout_secs * 1000;
AzureIoTClient 86:a1352899ea45 816 result = HTTPAPIEX_SetOption(iotHubHttpApiExHandle, OPTION_HTTP_TIMEOUT, &http_timeout);
AzureIoTClient 86:a1352899ea45 817 }
AzureIoTClient 86:a1352899ea45 818 else
AzureIoTClient 86:a1352899ea45 819 {
AzureIoTClient 86:a1352899ea45 820 result = HTTPAPIEX_OK;
AzureIoTClient 86:a1352899ea45 821 }
AzureIoTClient 86:a1352899ea45 822 return result;
AzureIoTClient 86:a1352899ea45 823 }
AzureIoTClient 86:a1352899ea45 824
AzureIoTClient 82:f94e6bed4495 825 IOTHUB_CLIENT_RESULT IoTHubClient_LL_UploadMultipleBlocksToBlob_Impl(IOTHUB_CLIENT_LL_UPLOADTOBLOB_HANDLE handle, const char* destinationFileName, IOTHUB_CLIENT_FILE_UPLOAD_GET_DATA_CALLBACK_EX getDataCallbackEx, void* context)
AzureIoTClient 42:448eecc3676e 826 {
AzureIoTClient 42:448eecc3676e 827 IOTHUB_CLIENT_RESULT result;
AzureIoTClient 42:448eecc3676e 828
AzureIoTClient 82:f94e6bed4495 829 /*Codes_SRS_IOTHUBCLIENT_LL_02_061: [ If handle is NULL then IoTHubClient_LL_UploadMultipleBlocksToBlob(Ex) shall fail and return IOTHUB_CLIENT_INVALID_ARG. ]*/
AzureIoTClient 82:f94e6bed4495 830 /*Codes_SRS_IOTHUBCLIENT_LL_02_062: [ If destinationFileName is NULL then IoTHubClient_LL_UploadMultipleBlocksToBlob(Ex) shall fail and return IOTHUB_CLIENT_INVALID_ARG. ]*/
AzureIoTClient 80:db5f5237bc95 831
AzureIoTClient 42:448eecc3676e 832 if (
AzureIoTClient 42:448eecc3676e 833 (handle == NULL) ||
AzureIoTClient 42:448eecc3676e 834 (destinationFileName == NULL) ||
AzureIoTClient 82:f94e6bed4495 835 (getDataCallbackEx == NULL)
AzureIoTClient 42:448eecc3676e 836 )
AzureIoTClient 42:448eecc3676e 837 {
AzureIoTClient 82:f94e6bed4495 838 LogError("invalid argument detected handle=%p destinationFileName=%p getDataCallbackEx=%p", handle, destinationFileName, getDataCallbackEx);
AzureIoTClient 42:448eecc3676e 839 result = IOTHUB_CLIENT_INVALID_ARG;
AzureIoTClient 42:448eecc3676e 840 }
AzureIoTClient 42:448eecc3676e 841 else
AzureIoTClient 42:448eecc3676e 842 {
AzureIoTClient 42:448eecc3676e 843 IOTHUB_CLIENT_LL_UPLOADTOBLOB_HANDLE_DATA* handleData = (IOTHUB_CLIENT_LL_UPLOADTOBLOB_HANDLE_DATA*)handle;
AzureIoTClient 42:448eecc3676e 844
AzureIoTClient 82:f94e6bed4495 845 /*Codes_SRS_IOTHUBCLIENT_LL_02_064: [ IoTHubClient_LL_UploadMultipleBlocksToBlob(Ex) shall create an HTTPAPIEX_HANDLE to the IoTHub hostname. ]*/
AzureIoTClient 42:448eecc3676e 846 HTTPAPIEX_HANDLE iotHubHttpApiExHandle = HTTPAPIEX_Create(handleData->hostname);
AzureIoTClient 42:448eecc3676e 847
AzureIoTClient 82:f94e6bed4495 848 /*Codes_SRS_IOTHUBCLIENT_LL_02_065: [ If creating the HTTPAPIEX_HANDLE fails then IoTHubClient_LL_UploadMultipleBlocksToBlob(Ex) shall fail and return IOTHUB_CLIENT_ERROR. ]*/
AzureIoTClient 42:448eecc3676e 849 if (iotHubHttpApiExHandle == NULL)
AzureIoTClient 42:448eecc3676e 850 {
AzureIoTClient 42:448eecc3676e 851 LogError("unable to HTTPAPIEX_Create");
AzureIoTClient 42:448eecc3676e 852 result = IOTHUB_CLIENT_ERROR;
AzureIoTClient 42:448eecc3676e 853 }
AzureIoTClient 86:a1352899ea45 854 /*Codes_SRS_IOTHUBCLIENT_LL_30_020: [ If the blob_upload_timeout_secs option has been set to non-zero, IoTHubClient_LL_UploadMultipleBlocksToBlob(Ex) shall set the timeout on the underlying transport accordingly. ]*/
AzureIoTClient 86:a1352899ea45 855 else if (set_transfer_timeout(handleData, iotHubHttpApiExHandle) != HTTPAPIEX_OK)
AzureIoTClient 86:a1352899ea45 856 {
AzureIoTClient 86:a1352899ea45 857 LogError("unable to set blob transfer timeout");
AzureIoTClient 86:a1352899ea45 858 result = IOTHUB_CLIENT_ERROR;
AzureIoTClient 86:a1352899ea45 859
AzureIoTClient 86:a1352899ea45 860 }
AzureIoTClient 42:448eecc3676e 861 else
AzureIoTClient 42:448eecc3676e 862 {
AzureIoTClient 82:f94e6bed4495 863 (void)HTTPAPIEX_SetOption(iotHubHttpApiExHandle, OPTION_CURL_VERBOSE, &handleData->curl_verbose);
AzureIoTClient 82:f94e6bed4495 864
AzureIoTClient 46:6a69294b6119 865 if (
AzureIoTClient 46:6a69294b6119 866 (handleData->authorizationScheme == X509) &&
AzureIoTClient 46:6a69294b6119 867
AzureIoTClient 46:6a69294b6119 868 /*transmit the x509certificate and x509privatekey*/
AzureIoTClient 46:6a69294b6119 869 /*Codes_SRS_IOTHUBCLIENT_LL_02_106: [ - x509certificate and x509privatekey saved options shall be passed on the HTTPAPIEX_SetOption ]*/
AzureIoTClient 46:6a69294b6119 870 (!(
AzureIoTClient 48:cc5d91f2b06d 871 (HTTPAPIEX_SetOption(iotHubHttpApiExHandle, OPTION_X509_CERT, handleData->credentials.x509credentials.x509certificate) == HTTPAPIEX_OK) &&
AzureIoTClient 48:cc5d91f2b06d 872 (HTTPAPIEX_SetOption(iotHubHttpApiExHandle, OPTION_X509_PRIVATE_KEY, handleData->credentials.x509credentials.x509privatekey) == HTTPAPIEX_OK)
AzureIoTClient 46:6a69294b6119 873 ))
AzureIoTClient 46:6a69294b6119 874 )
AzureIoTClient 42:448eecc3676e 875 {
AzureIoTClient 46:6a69294b6119 876 LogError("unable to HTTPAPIEX_SetOption for x509");
AzureIoTClient 42:448eecc3676e 877 result = IOTHUB_CLIENT_ERROR;
AzureIoTClient 42:448eecc3676e 878 }
AzureIoTClient 42:448eecc3676e 879 else
AzureIoTClient 42:448eecc3676e 880 {
AzureIoTClient 62:5a4cdacf5090 881 /*Codes_SRS_IOTHUBCLIENT_LL_02_111: [ If certificates is non-NULL then certificates shall be passed to HTTPAPIEX_SetOption with optionName TrustedCerts. ]*/
AzureIoTClient 62:5a4cdacf5090 882 if ((handleData->certificates != NULL) && (HTTPAPIEX_SetOption(iotHubHttpApiExHandle, "TrustedCerts", handleData->certificates) != HTTPAPIEX_OK))
AzureIoTClient 42:448eecc3676e 883 {
AzureIoTClient 62:5a4cdacf5090 884 LogError("unable to set TrustedCerts!");
AzureIoTClient 42:448eecc3676e 885 result = IOTHUB_CLIENT_ERROR;
AzureIoTClient 42:448eecc3676e 886 }
AzureIoTClient 42:448eecc3676e 887 else
AzureIoTClient 42:448eecc3676e 888 {
AzureIoTClient 62:5a4cdacf5090 889
AzureIoTClient 74:ea0021abecf7 890 if (handleData->http_proxy_options.host_address != NULL)
AzureIoTClient 42:448eecc3676e 891 {
AzureIoTClient 74:ea0021abecf7 892 HTTP_PROXY_OPTIONS proxy_options;
AzureIoTClient 74:ea0021abecf7 893 proxy_options = handleData->http_proxy_options;
AzureIoTClient 74:ea0021abecf7 894
AzureIoTClient 74:ea0021abecf7 895 if (HTTPAPIEX_SetOption(iotHubHttpApiExHandle, OPTION_HTTP_PROXY, &proxy_options) != HTTPAPIEX_OK)
AzureIoTClient 74:ea0021abecf7 896 {
AzureIoTClient 74:ea0021abecf7 897 LogError("unable to set http proxy!");
AzureIoTClient 74:ea0021abecf7 898 result = IOTHUB_CLIENT_ERROR;
AzureIoTClient 74:ea0021abecf7 899 }
AzureIoTClient 74:ea0021abecf7 900 else
AzureIoTClient 74:ea0021abecf7 901 {
AzureIoTClient 74:ea0021abecf7 902 result = IOTHUB_CLIENT_OK;
AzureIoTClient 74:ea0021abecf7 903 }
AzureIoTClient 42:448eecc3676e 904 }
AzureIoTClient 42:448eecc3676e 905 else
AzureIoTClient 42:448eecc3676e 906 {
AzureIoTClient 74:ea0021abecf7 907 result = IOTHUB_CLIENT_OK;
AzureIoTClient 74:ea0021abecf7 908 }
AzureIoTClient 80:db5f5237bc95 909
AzureIoTClient 74:ea0021abecf7 910 if (result != IOTHUB_CLIENT_ERROR)
AzureIoTClient 74:ea0021abecf7 911 {
AzureIoTClient 74:ea0021abecf7 912 STRING_HANDLE correlationId = STRING_new();
AzureIoTClient 74:ea0021abecf7 913 if (correlationId == NULL)
AzureIoTClient 42:448eecc3676e 914 {
AzureIoTClient 62:5a4cdacf5090 915 LogError("unable to STRING_new");
AzureIoTClient 42:448eecc3676e 916 result = IOTHUB_CLIENT_ERROR;
AzureIoTClient 42:448eecc3676e 917 }
AzureIoTClient 42:448eecc3676e 918 else
AzureIoTClient 42:448eecc3676e 919 {
AzureIoTClient 74:ea0021abecf7 920 STRING_HANDLE sasUri = STRING_new();
AzureIoTClient 74:ea0021abecf7 921 if (sasUri == NULL)
AzureIoTClient 42:448eecc3676e 922 {
AzureIoTClient 74:ea0021abecf7 923 LogError("unable to STRING_new");
AzureIoTClient 42:448eecc3676e 924 result = IOTHUB_CLIENT_ERROR;
AzureIoTClient 42:448eecc3676e 925 }
AzureIoTClient 42:448eecc3676e 926 else
AzureIoTClient 42:448eecc3676e 927 {
AzureIoTClient 82:f94e6bed4495 928 /*Codes_SRS_IOTHUBCLIENT_LL_02_070: [ IoTHubClient_LL_UploadMultipleBlocksToBlob(Ex) shall create request HTTP headers. ]*/
AzureIoTClient 74:ea0021abecf7 929 HTTP_HEADERS_HANDLE requestHttpHeaders = HTTPHeaders_Alloc(); /*these are build by step 1 and used by step 3 too*/
AzureIoTClient 74:ea0021abecf7 930 if (requestHttpHeaders == NULL)
AzureIoTClient 46:6a69294b6119 931 {
AzureIoTClient 74:ea0021abecf7 932 LogError("unable to HTTPHeaders_Alloc");
AzureIoTClient 42:448eecc3676e 933 result = IOTHUB_CLIENT_ERROR;
AzureIoTClient 42:448eecc3676e 934 }
AzureIoTClient 42:448eecc3676e 935 else
AzureIoTClient 42:448eecc3676e 936 {
AzureIoTClient 74:ea0021abecf7 937 /*do step 1*/
AzureIoTClient 74:ea0021abecf7 938 if (IoTHubClient_LL_UploadToBlob_step1and2(handleData, iotHubHttpApiExHandle, requestHttpHeaders, destinationFileName, correlationId, sasUri) != 0)
AzureIoTClient 62:5a4cdacf5090 939 {
AzureIoTClient 74:ea0021abecf7 940 LogError("error in IoTHubClient_LL_UploadToBlob_step1");
AzureIoTClient 42:448eecc3676e 941 result = IOTHUB_CLIENT_ERROR;
AzureIoTClient 42:448eecc3676e 942 }
AzureIoTClient 42:448eecc3676e 943 else
AzureIoTClient 42:448eecc3676e 944 {
AzureIoTClient 74:ea0021abecf7 945 /*do step 2.*/
AzureIoTClient 46:6a69294b6119 946
AzureIoTClient 74:ea0021abecf7 947 unsigned int httpResponse;
AzureIoTClient 74:ea0021abecf7 948 BUFFER_HANDLE responseToIoTHub = BUFFER_new();
AzureIoTClient 74:ea0021abecf7 949 if (responseToIoTHub == NULL)
AzureIoTClient 74:ea0021abecf7 950 {
AzureIoTClient 42:448eecc3676e 951 result = IOTHUB_CLIENT_ERROR;
AzureIoTClient 74:ea0021abecf7 952 LogError("unable to BUFFER_new");
AzureIoTClient 42:448eecc3676e 953 }
AzureIoTClient 42:448eecc3676e 954 else
AzureIoTClient 42:448eecc3676e 955 {
AzureIoTClient 82:f94e6bed4495 956 /*Codes_SRS_IOTHUBCLIENT_LL_02_083: [ IoTHubClient_LL_UploadMultipleBlocksToBlob(Ex) shall call Blob_UploadFromSasUri and capture the HTTP return code and HTTP body. ]*/
AzureIoTClient 82:f94e6bed4495 957 BLOB_RESULT uploadMultipleBlocksResult = Blob_UploadMultipleBlocksFromSasUri(STRING_c_str(sasUri), getDataCallbackEx, context, &httpResponse, responseToIoTHub, handleData->certificates, &(handleData->http_proxy_options));
AzureIoTClient 82:f94e6bed4495 958 if (uploadMultipleBlocksResult == BLOB_ABORTED)
AzureIoTClient 74:ea0021abecf7 959 {
AzureIoTClient 82:f94e6bed4495 960 /*Codes_SRS_IOTHUBCLIENT_LL_99_008: [ If step 2 is aborted by the client, then the HTTP message body shall look like: ]*/
AzureIoTClient 82:f94e6bed4495 961 LogInfo("Blob_UploadFromSasUri aborted file upload");
AzureIoTClient 82:f94e6bed4495 962
AzureIoTClient 82:f94e6bed4495 963 if (BUFFER_build(responseToIoTHub, (const unsigned char*)FILE_UPLOAD_ABORTED_BODY, sizeof(FILE_UPLOAD_ABORTED_BODY) / sizeof(FILE_UPLOAD_ABORTED_BODY[0])) == 0)
AzureIoTClient 82:f94e6bed4495 964 {
AzureIoTClient 82:f94e6bed4495 965 if (IoTHubClient_LL_UploadToBlob_step3(handleData, correlationId, iotHubHttpApiExHandle, requestHttpHeaders, responseToIoTHub) != 0)
AzureIoTClient 82:f94e6bed4495 966 {
AzureIoTClient 82:f94e6bed4495 967 LogError("IoTHubClient_LL_UploadToBlob_step3 failed");
AzureIoTClient 82:f94e6bed4495 968 result = IOTHUB_CLIENT_ERROR;
AzureIoTClient 82:f94e6bed4495 969 }
AzureIoTClient 82:f94e6bed4495 970 else
AzureIoTClient 82:f94e6bed4495 971 {
AzureIoTClient 82:f94e6bed4495 972 /*Codes_SRS_IOTHUBCLIENT_LL_99_009: [ If step 2 is aborted by the client and if step 3 succeeds, then `IoTHubClient_LL_UploadMultipleBlocksToBlob(Ex)` shall return `IOTHUB_CLIENT_OK`. ] */
AzureIoTClient 82:f94e6bed4495 973 result = IOTHUB_CLIENT_OK;
AzureIoTClient 82:f94e6bed4495 974 }
AzureIoTClient 82:f94e6bed4495 975 }
AzureIoTClient 82:f94e6bed4495 976 else
AzureIoTClient 82:f94e6bed4495 977 {
AzureIoTClient 82:f94e6bed4495 978 LogError("Unable to BUFFER_build, can't perform IoTHubClient_LL_UploadToBlob_step3");
AzureIoTClient 82:f94e6bed4495 979 result = IOTHUB_CLIENT_ERROR;
AzureIoTClient 82:f94e6bed4495 980 }
AzureIoTClient 82:f94e6bed4495 981 }
AzureIoTClient 82:f94e6bed4495 982 else if (uploadMultipleBlocksResult != BLOB_OK)
AzureIoTClient 82:f94e6bed4495 983 {
AzureIoTClient 82:f94e6bed4495 984 /*Codes_SRS_IOTHUBCLIENT_LL_02_084: [ If Blob_UploadFromSasUri fails then IoTHubClient_LL_UploadMultipleBlocksToBlob(Ex) shall fail and return IOTHUB_CLIENT_ERROR. ]*/
AzureIoTClient 74:ea0021abecf7 985 LogError("unable to Blob_UploadFromSasUri");
AzureIoTClient 62:5a4cdacf5090 986
AzureIoTClient 74:ea0021abecf7 987 /*do step 3*/ /*try*/
AzureIoTClient 74:ea0021abecf7 988 /*Codes_SRS_IOTHUBCLIENT_LL_02_091: [ If step 2 fails without establishing an HTTP dialogue, then the HTTP message body shall look like: ]*/
AzureIoTClient 74:ea0021abecf7 989 if (BUFFER_build(responseToIoTHub, (const unsigned char*)FILE_UPLOAD_FAILED_BODY, sizeof(FILE_UPLOAD_FAILED_BODY) / sizeof(FILE_UPLOAD_FAILED_BODY[0])) == 0)
AzureIoTClient 74:ea0021abecf7 990 {
AzureIoTClient 74:ea0021abecf7 991 if (IoTHubClient_LL_UploadToBlob_step3(handleData, correlationId, iotHubHttpApiExHandle, requestHttpHeaders, responseToIoTHub) != 0)
AzureIoTClient 74:ea0021abecf7 992 {
AzureIoTClient 74:ea0021abecf7 993 LogError("IoTHubClient_LL_UploadToBlob_step3 failed");
AzureIoTClient 74:ea0021abecf7 994 }
AzureIoTClient 74:ea0021abecf7 995 }
AzureIoTClient 42:448eecc3676e 996 result = IOTHUB_CLIENT_ERROR;
AzureIoTClient 42:448eecc3676e 997 }
AzureIoTClient 42:448eecc3676e 998 else
AzureIoTClient 42:448eecc3676e 999 {
AzureIoTClient 74:ea0021abecf7 1000 /*must make a json*/
AzureIoTClient 74:ea0021abecf7 1001
AzureIoTClient 80:db5f5237bc95 1002 int requiredStringLength = snprintf(NULL, 0, "{\"isSuccess\":%s, \"statusCode\":%d, \"statusDescription\":\"%s\"}", ((httpResponse < 300) ? "true" : "false"), httpResponse, BUFFER_u_char(responseToIoTHub));
AzureIoTClient 74:ea0021abecf7 1003
AzureIoTClient 80:db5f5237bc95 1004 char * requiredString = malloc(requiredStringLength + 1);
AzureIoTClient 74:ea0021abecf7 1005 if (requiredString == 0)
AzureIoTClient 46:6a69294b6119 1006 {
AzureIoTClient 74:ea0021abecf7 1007 LogError("unable to malloc");
AzureIoTClient 46:6a69294b6119 1008 result = IOTHUB_CLIENT_ERROR;
AzureIoTClient 46:6a69294b6119 1009 }
AzureIoTClient 46:6a69294b6119 1010 else
AzureIoTClient 46:6a69294b6119 1011 {
AzureIoTClient 74:ea0021abecf7 1012 /*do again snprintf*/
AzureIoTClient 80:db5f5237bc95 1013 BUFFER_HANDLE toBeTransmitted = NULL;
AzureIoTClient 74:ea0021abecf7 1014 (void)snprintf(requiredString, requiredStringLength + 1, "{\"isSuccess\":%s, \"statusCode\":%d, \"statusDescription\":\"%s\"}", ((httpResponse < 300) ? "true" : "false"), httpResponse, BUFFER_u_char(responseToIoTHub));
AzureIoTClient 74:ea0021abecf7 1015 toBeTransmitted = BUFFER_create((const unsigned char*)requiredString, requiredStringLength);
AzureIoTClient 74:ea0021abecf7 1016 if (toBeTransmitted == NULL)
AzureIoTClient 62:5a4cdacf5090 1017 {
AzureIoTClient 74:ea0021abecf7 1018 LogError("unable to BUFFER_create");
AzureIoTClient 62:5a4cdacf5090 1019 result = IOTHUB_CLIENT_ERROR;
AzureIoTClient 62:5a4cdacf5090 1020 }
AzureIoTClient 62:5a4cdacf5090 1021 else
AzureIoTClient 62:5a4cdacf5090 1022 {
AzureIoTClient 74:ea0021abecf7 1023 if (IoTHubClient_LL_UploadToBlob_step3(handleData, correlationId, iotHubHttpApiExHandle, requestHttpHeaders, toBeTransmitted) != 0)
AzureIoTClient 74:ea0021abecf7 1024 {
AzureIoTClient 74:ea0021abecf7 1025 LogError("IoTHubClient_LL_UploadToBlob_step3 failed");
AzureIoTClient 74:ea0021abecf7 1026 result = IOTHUB_CLIENT_ERROR;
AzureIoTClient 74:ea0021abecf7 1027 }
AzureIoTClient 74:ea0021abecf7 1028 else
AzureIoTClient 74:ea0021abecf7 1029 {
AzureIoTClient 74:ea0021abecf7 1030 result = (httpResponse < 300) ? IOTHUB_CLIENT_OK : IOTHUB_CLIENT_ERROR;
AzureIoTClient 74:ea0021abecf7 1031 }
AzureIoTClient 74:ea0021abecf7 1032 BUFFER_delete(toBeTransmitted);
AzureIoTClient 62:5a4cdacf5090 1033 }
AzureIoTClient 74:ea0021abecf7 1034 free(requiredString);
AzureIoTClient 46:6a69294b6119 1035 }
AzureIoTClient 42:448eecc3676e 1036 }
AzureIoTClient 74:ea0021abecf7 1037 BUFFER_delete(responseToIoTHub);
AzureIoTClient 42:448eecc3676e 1038 }
AzureIoTClient 42:448eecc3676e 1039 }
AzureIoTClient 74:ea0021abecf7 1040 HTTPHeaders_Free(requestHttpHeaders);
AzureIoTClient 42:448eecc3676e 1041 }
AzureIoTClient 74:ea0021abecf7 1042 STRING_delete(sasUri);
AzureIoTClient 42:448eecc3676e 1043 }
AzureIoTClient 74:ea0021abecf7 1044 STRING_delete(correlationId);
AzureIoTClient 42:448eecc3676e 1045 }
AzureIoTClient 42:448eecc3676e 1046 }
AzureIoTClient 42:448eecc3676e 1047 }
AzureIoTClient 42:448eecc3676e 1048 }
AzureIoTClient 42:448eecc3676e 1049 HTTPAPIEX_Destroy(iotHubHttpApiExHandle);
AzureIoTClient 42:448eecc3676e 1050 }
AzureIoTClient 42:448eecc3676e 1051 }
AzureIoTClient 80:db5f5237bc95 1052
AzureIoTClient 82:f94e6bed4495 1053 /*Codes_SRS_IOTHUBCLIENT_LL_99_003: [ If `IoTHubClient_LL_UploadMultipleBlocksToBlob(Ex)` return `IOTHUB_CLIENT_OK`, it shall call `getDataCallbackEx` with `result` set to `FILE_UPLOAD_OK`, and `data` and `size` set to NULL. ]*/
AzureIoTClient 82:f94e6bed4495 1054 /*Codes_SRS_IOTHUBCLIENT_LL_99_004: [ If `IoTHubClient_LL_UploadMultipleBlocksToBlob(Ex)` does not return `IOTHUB_CLIENT_OK`, it shall call `getDataCallbackEx` with `result` set to `FILE_UPLOAD_ERROR`, and `data` and `size` set to NULL. ]*/
AzureIoTClient 82:f94e6bed4495 1055 (void)getDataCallbackEx(result == IOTHUB_CLIENT_OK ? FILE_UPLOAD_OK : FILE_UPLOAD_ERROR, NULL, NULL, context);
AzureIoTClient 80:db5f5237bc95 1056
AzureIoTClient 80:db5f5237bc95 1057 return result;
AzureIoTClient 80:db5f5237bc95 1058 }
AzureIoTClient 80:db5f5237bc95 1059
AzureIoTClient 80:db5f5237bc95 1060 IOTHUB_CLIENT_RESULT IoTHubClient_LL_UploadToBlob_Impl(IOTHUB_CLIENT_LL_UPLOADTOBLOB_HANDLE handle, const char* destinationFileName, const unsigned char* source, size_t size)
AzureIoTClient 80:db5f5237bc95 1061 {
AzureIoTClient 80:db5f5237bc95 1062 IOTHUB_CLIENT_RESULT result;
AzureIoTClient 80:db5f5237bc95 1063
AzureIoTClient 80:db5f5237bc95 1064 /*Codes_SRS_IOTHUBCLIENT_LL_02_063: [ If source is NULL and size is greater than 0 then IoTHubClient_LL_UploadToBlob shall fail and return IOTHUB_CLIENT_INVALID_ARG. ]*/
AzureIoTClient 80:db5f5237bc95 1065 if (source == NULL && size > 0)
AzureIoTClient 80:db5f5237bc95 1066 {
AzureIoTClient 80:db5f5237bc95 1067 LogError("invalid source and size combination: source=%p size=%zu", source, size);
AzureIoTClient 80:db5f5237bc95 1068 result = IOTHUB_CLIENT_INVALID_ARG;
AzureIoTClient 80:db5f5237bc95 1069 }
AzureIoTClient 80:db5f5237bc95 1070 else
AzureIoTClient 80:db5f5237bc95 1071 {
AzureIoTClient 80:db5f5237bc95 1072 /*Codes_SRS_IOTHUBCLIENT_LL_99_001: [ `IoTHubClient_LL_UploadToBlob` shall create a struct containing the `source`, the `size`, and the remaining size to upload.]*/
AzureIoTClient 80:db5f5237bc95 1073 BLOB_UPLOAD_CONTEXT context;
AzureIoTClient 80:db5f5237bc95 1074 context.blobSource = source;
AzureIoTClient 80:db5f5237bc95 1075 context.blobSourceSize = size;
AzureIoTClient 80:db5f5237bc95 1076 context.remainingSizeToUpload = size;
AzureIoTClient 80:db5f5237bc95 1077
AzureIoTClient 82:f94e6bed4495 1078 /*Codes_SRS_IOTHUBCLIENT_LL_99_002: [ `IoTHubClient_LL_UploadToBlob` shall call `IoTHubClient_LL_UploadMultipleBlocksToBlob_Impl` with `FileUpload_GetData_Callback` as `getDataCallbackEx` and pass the struct created at step SRS_IOTHUBCLIENT_LL_99_001 as `context` ]*/
AzureIoTClient 80:db5f5237bc95 1079 result = IoTHubClient_LL_UploadMultipleBlocksToBlob_Impl(handle, destinationFileName, FileUpload_GetData_Callback, &context);
AzureIoTClient 80:db5f5237bc95 1080 }
AzureIoTClient 42:448eecc3676e 1081 return result;
AzureIoTClient 42:448eecc3676e 1082 }
AzureIoTClient 42:448eecc3676e 1083
AzureIoTClient 42:448eecc3676e 1084 void IoTHubClient_LL_UploadToBlob_Destroy(IOTHUB_CLIENT_LL_UPLOADTOBLOB_HANDLE handle)
AzureIoTClient 42:448eecc3676e 1085 {
AzureIoTClient 42:448eecc3676e 1086 if (handle == NULL)
AzureIoTClient 42:448eecc3676e 1087 {
AzureIoTClient 62:5a4cdacf5090 1088 LogError("unexpected NULL argument");
AzureIoTClient 42:448eecc3676e 1089 }
AzureIoTClient 42:448eecc3676e 1090 else
AzureIoTClient 42:448eecc3676e 1091 {
AzureIoTClient 42:448eecc3676e 1092 IOTHUB_CLIENT_LL_UPLOADTOBLOB_HANDLE_DATA* handleData = (IOTHUB_CLIENT_LL_UPLOADTOBLOB_HANDLE_DATA*)handle;
AzureIoTClient 42:448eecc3676e 1093 switch (handleData->authorizationScheme)
AzureIoTClient 42:448eecc3676e 1094 {
AzureIoTClient 42:448eecc3676e 1095 case(SAS_TOKEN):
AzureIoTClient 42:448eecc3676e 1096 {
AzureIoTClient 42:448eecc3676e 1097 STRING_delete(handleData->credentials.sas);
AzureIoTClient 42:448eecc3676e 1098 break;
AzureIoTClient 42:448eecc3676e 1099 }
AzureIoTClient 42:448eecc3676e 1100 case(DEVICE_KEY):
AzureIoTClient 42:448eecc3676e 1101 {
AzureIoTClient 42:448eecc3676e 1102 STRING_delete(handleData->credentials.deviceKey);
AzureIoTClient 42:448eecc3676e 1103 break;
AzureIoTClient 42:448eecc3676e 1104 }
AzureIoTClient 46:6a69294b6119 1105 case(X509):
AzureIoTClient 46:6a69294b6119 1106 {
AzureIoTClient 46:6a69294b6119 1107 if (handleData->credentials.x509credentials.x509certificate != NULL)
AzureIoTClient 46:6a69294b6119 1108 {
AzureIoTClient 46:6a69294b6119 1109 free((void*)handleData->credentials.x509credentials.x509certificate);
AzureIoTClient 46:6a69294b6119 1110 }
AzureIoTClient 46:6a69294b6119 1111 if (handleData->credentials.x509credentials.x509privatekey != NULL)
AzureIoTClient 46:6a69294b6119 1112 {
AzureIoTClient 46:6a69294b6119 1113 free((void*)handleData->credentials.x509credentials.x509privatekey);
AzureIoTClient 46:6a69294b6119 1114 }
AzureIoTClient 46:6a69294b6119 1115 break;
AzureIoTClient 46:6a69294b6119 1116 }
AzureIoTClient 42:448eecc3676e 1117 default:
AzureIoTClient 42:448eecc3676e 1118 {
AzureIoTClient 42:448eecc3676e 1119 LogError("INTERNAL ERROR");
AzureIoTClient 42:448eecc3676e 1120 break;
AzureIoTClient 42:448eecc3676e 1121 }
AzureIoTClient 42:448eecc3676e 1122 }
AzureIoTClient 42:448eecc3676e 1123 free((void*)handleData->hostname);
AzureIoTClient 42:448eecc3676e 1124 STRING_delete(handleData->deviceId);
AzureIoTClient 62:5a4cdacf5090 1125 if (handleData->certificates != NULL)
AzureIoTClient 62:5a4cdacf5090 1126 {
AzureIoTClient 62:5a4cdacf5090 1127 free(handleData->certificates);
AzureIoTClient 62:5a4cdacf5090 1128 }
AzureIoTClient 74:ea0021abecf7 1129 if (handleData->http_proxy_options.host_address != NULL)
AzureIoTClient 74:ea0021abecf7 1130 {
AzureIoTClient 74:ea0021abecf7 1131 free((char *)handleData->http_proxy_options.host_address);
AzureIoTClient 74:ea0021abecf7 1132 }
AzureIoTClient 74:ea0021abecf7 1133 if (handleData->http_proxy_options.username != NULL)
AzureIoTClient 74:ea0021abecf7 1134 {
AzureIoTClient 74:ea0021abecf7 1135 free((char *)handleData->http_proxy_options.username);
AzureIoTClient 74:ea0021abecf7 1136 }
AzureIoTClient 74:ea0021abecf7 1137 if (handleData->http_proxy_options.password != NULL)
AzureIoTClient 74:ea0021abecf7 1138 {
AzureIoTClient 74:ea0021abecf7 1139 free((char *)handleData->http_proxy_options.password);
AzureIoTClient 74:ea0021abecf7 1140 }
AzureIoTClient 42:448eecc3676e 1141 free(handleData);
AzureIoTClient 42:448eecc3676e 1142 }
AzureIoTClient 42:448eecc3676e 1143 }
AzureIoTClient 46:6a69294b6119 1144
AzureIoTClient 46:6a69294b6119 1145 IOTHUB_CLIENT_RESULT IoTHubClient_LL_UploadToBlob_SetOption(IOTHUB_CLIENT_LL_UPLOADTOBLOB_HANDLE handle, const char* optionName, const void* value)
AzureIoTClient 46:6a69294b6119 1146 {
AzureIoTClient 46:6a69294b6119 1147 IOTHUB_CLIENT_RESULT result;
AzureIoTClient 46:6a69294b6119 1148 /*Codes_SRS_IOTHUBCLIENT_LL_02_110: [ If parameter handle is NULL then IoTHubClient_LL_UploadToBlob_SetOption shall fail and return IOTHUB_CLIENT_ERROR. ]*/
AzureIoTClient 46:6a69294b6119 1149 if (handle == NULL)
AzureIoTClient 46:6a69294b6119 1150 {
AzureIoTClient 46:6a69294b6119 1151 LogError("invalid argument detected: IOTHUB_CLIENT_LL_UPLOADTOBLOB_HANDLE handle=%p, const char* optionName=%s, const void* value=%p", handle, optionName, value);
AzureIoTClient 46:6a69294b6119 1152 result = IOTHUB_CLIENT_ERROR;
AzureIoTClient 46:6a69294b6119 1153 }
AzureIoTClient 46:6a69294b6119 1154 else
AzureIoTClient 46:6a69294b6119 1155 {
AzureIoTClient 46:6a69294b6119 1156 IOTHUB_CLIENT_LL_UPLOADTOBLOB_HANDLE_DATA* handleData = (IOTHUB_CLIENT_LL_UPLOADTOBLOB_HANDLE_DATA*)handle;
AzureIoTClient 46:6a69294b6119 1157
AzureIoTClient 46:6a69294b6119 1158 /*Codes_SRS_IOTHUBCLIENT_LL_02_100: [ x509certificate - then value then is a null terminated string that contains the x509 certificate. ]*/
AzureIoTClient 48:cc5d91f2b06d 1159 if (strcmp(optionName, OPTION_X509_CERT) == 0)
AzureIoTClient 46:6a69294b6119 1160 {
AzureIoTClient 46:6a69294b6119 1161 /*Codes_SRS_IOTHUBCLIENT_LL_02_109: [ If the authentication scheme is NOT x509 then IoTHubClient_LL_UploadToBlob_SetOption shall return IOTHUB_CLIENT_INVALID_ARG. ]*/
AzureIoTClient 46:6a69294b6119 1162 if (handleData->authorizationScheme != X509)
AzureIoTClient 46:6a69294b6119 1163 {
AzureIoTClient 46:6a69294b6119 1164 LogError("trying to set a x509 certificate while the authentication scheme is not x509");
AzureIoTClient 46:6a69294b6119 1165 result = IOTHUB_CLIENT_INVALID_ARG;
AzureIoTClient 46:6a69294b6119 1166 }
AzureIoTClient 46:6a69294b6119 1167 else
AzureIoTClient 46:6a69294b6119 1168 {
AzureIoTClient 46:6a69294b6119 1169 /*Codes_SRS_IOTHUBCLIENT_LL_02_103: [ The options shall be saved. ]*/
AzureIoTClient 46:6a69294b6119 1170 /*try to make a copy of the certificate*/
AzureIoTClient 46:6a69294b6119 1171 char* temp;
AzureIoTClient 46:6a69294b6119 1172 if (mallocAndStrcpy_s(&temp, value) != 0)
AzureIoTClient 46:6a69294b6119 1173 {
AzureIoTClient 46:6a69294b6119 1174 /*Codes_SRS_IOTHUBCLIENT_LL_02_104: [ If saving fails, then IoTHubClient_LL_UploadToBlob_SetOption shall fail and return IOTHUB_CLIENT_ERROR. ]*/
AzureIoTClient 46:6a69294b6119 1175 LogError("unable to mallocAndStrcpy_s");
AzureIoTClient 46:6a69294b6119 1176 result = IOTHUB_CLIENT_ERROR;
AzureIoTClient 46:6a69294b6119 1177 }
AzureIoTClient 46:6a69294b6119 1178 else
AzureIoTClient 46:6a69294b6119 1179 {
AzureIoTClient 46:6a69294b6119 1180 /*Codes_SRS_IOTHUBCLIENT_LL_02_105: [ Otherwise IoTHubClient_LL_UploadToBlob_SetOption shall succeed and return IOTHUB_CLIENT_OK. ]*/
AzureIoTClient 46:6a69294b6119 1181 if (handleData->credentials.x509credentials.x509certificate != NULL) /*free any previous values, if any*/
AzureIoTClient 46:6a69294b6119 1182 {
AzureIoTClient 46:6a69294b6119 1183 free((void*)handleData->credentials.x509credentials.x509certificate);
AzureIoTClient 46:6a69294b6119 1184 }
AzureIoTClient 46:6a69294b6119 1185 handleData->credentials.x509credentials.x509certificate = temp;
AzureIoTClient 46:6a69294b6119 1186 result = IOTHUB_CLIENT_OK;
AzureIoTClient 46:6a69294b6119 1187 }
AzureIoTClient 46:6a69294b6119 1188 }
AzureIoTClient 46:6a69294b6119 1189 }
AzureIoTClient 46:6a69294b6119 1190 /*Codes_SRS_IOTHUBCLIENT_LL_02_101: [ x509privatekey - then value is a null terminated string that contains the x509 privatekey. ]*/
AzureIoTClient 48:cc5d91f2b06d 1191 else if (strcmp(optionName, OPTION_X509_PRIVATE_KEY) == 0)
AzureIoTClient 46:6a69294b6119 1192 {
AzureIoTClient 46:6a69294b6119 1193 /*Codes_SRS_IOTHUBCLIENT_LL_02_109: [ If the authentication scheme is NOT x509 then IoTHubClient_LL_UploadToBlob_SetOption shall return IOTHUB_CLIENT_INVALID_ARG. ]*/
AzureIoTClient 46:6a69294b6119 1194 if (handleData->authorizationScheme != X509)
AzureIoTClient 46:6a69294b6119 1195 {
AzureIoTClient 46:6a69294b6119 1196 LogError("trying to set a x509 privatekey while the authentication scheme is not x509");
AzureIoTClient 46:6a69294b6119 1197 result = IOTHUB_CLIENT_INVALID_ARG;
AzureIoTClient 46:6a69294b6119 1198 }
AzureIoTClient 46:6a69294b6119 1199 else
AzureIoTClient 46:6a69294b6119 1200 {
AzureIoTClient 46:6a69294b6119 1201 /*Codes_SRS_IOTHUBCLIENT_LL_02_103: [ The options shall be saved. ]*/
AzureIoTClient 46:6a69294b6119 1202 /*try to make a copy of the privatekey*/
AzureIoTClient 46:6a69294b6119 1203 char* temp;
AzureIoTClient 46:6a69294b6119 1204 if (mallocAndStrcpy_s(&temp, value) != 0)
AzureIoTClient 46:6a69294b6119 1205 {
AzureIoTClient 46:6a69294b6119 1206 /*Codes_SRS_IOTHUBCLIENT_LL_02_104: [ If saving fails, then IoTHubClient_LL_UploadToBlob_SetOption shall fail and return IOTHUB_CLIENT_ERROR. ]*/
AzureIoTClient 46:6a69294b6119 1207 LogError("unable to mallocAndStrcpy_s");
AzureIoTClient 46:6a69294b6119 1208 result = IOTHUB_CLIENT_ERROR;
AzureIoTClient 46:6a69294b6119 1209 }
AzureIoTClient 46:6a69294b6119 1210 else
AzureIoTClient 46:6a69294b6119 1211 {
AzureIoTClient 46:6a69294b6119 1212 /*Codes_SRS_IOTHUBCLIENT_LL_02_105: [ Otherwise IoTHubClient_LL_UploadToBlob_SetOption shall succeed and return IOTHUB_CLIENT_OK. ]*/
AzureIoTClient 46:6a69294b6119 1213 if (handleData->credentials.x509credentials.x509privatekey != NULL) /*free any previous values, if any*/
AzureIoTClient 46:6a69294b6119 1214 {
AzureIoTClient 46:6a69294b6119 1215 free((void*)handleData->credentials.x509credentials.x509privatekey);
AzureIoTClient 46:6a69294b6119 1216 }
AzureIoTClient 46:6a69294b6119 1217 handleData->credentials.x509credentials.x509privatekey = temp;
AzureIoTClient 46:6a69294b6119 1218 result = IOTHUB_CLIENT_OK;
AzureIoTClient 46:6a69294b6119 1219 }
AzureIoTClient 46:6a69294b6119 1220 }
AzureIoTClient 46:6a69294b6119 1221 }
AzureIoTClient 86:a1352899ea45 1222 else if (strcmp(OPTION_TRUSTED_CERT, optionName) == 0)
AzureIoTClient 62:5a4cdacf5090 1223 {
AzureIoTClient 62:5a4cdacf5090 1224 if (value == NULL)
AzureIoTClient 62:5a4cdacf5090 1225 {
AzureIoTClient 62:5a4cdacf5090 1226 LogError("NULL is a not a valid value for TrustedCerts");
AzureIoTClient 62:5a4cdacf5090 1227 result = IOTHUB_CLIENT_INVALID_ARG;
AzureIoTClient 62:5a4cdacf5090 1228 }
AzureIoTClient 62:5a4cdacf5090 1229 else
AzureIoTClient 62:5a4cdacf5090 1230 {
AzureIoTClient 62:5a4cdacf5090 1231 char* tempCopy;
AzureIoTClient 62:5a4cdacf5090 1232 if (mallocAndStrcpy_s(&tempCopy, value) != 0)
AzureIoTClient 62:5a4cdacf5090 1233 {
AzureIoTClient 62:5a4cdacf5090 1234 LogError("failure in mallocAndStrcpy_s");
AzureIoTClient 62:5a4cdacf5090 1235 result = IOTHUB_CLIENT_ERROR;
AzureIoTClient 62:5a4cdacf5090 1236 }
AzureIoTClient 62:5a4cdacf5090 1237 else
AzureIoTClient 62:5a4cdacf5090 1238 {
AzureIoTClient 62:5a4cdacf5090 1239 if (handleData->certificates != NULL)
AzureIoTClient 62:5a4cdacf5090 1240 {
AzureIoTClient 62:5a4cdacf5090 1241 free(handleData->certificates);
AzureIoTClient 62:5a4cdacf5090 1242 }
AzureIoTClient 62:5a4cdacf5090 1243 handleData->certificates = tempCopy;
AzureIoTClient 62:5a4cdacf5090 1244 result = IOTHUB_CLIENT_OK;
AzureIoTClient 62:5a4cdacf5090 1245 }
AzureIoTClient 62:5a4cdacf5090 1246 }
AzureIoTClient 62:5a4cdacf5090 1247 }
AzureIoTClient 74:ea0021abecf7 1248 /*Codes_SRS_IOTHUBCLIENT_LL_32_008: [ OPTION_HTTP_PROXY - then the value will be a pointer to HTTP_PROXY_OPTIONS structure. ]*/
AzureIoTClient 74:ea0021abecf7 1249 else if (strcmp(optionName, OPTION_HTTP_PROXY) == 0)
AzureIoTClient 74:ea0021abecf7 1250 {
AzureIoTClient 74:ea0021abecf7 1251 HTTP_PROXY_OPTIONS* proxy_options = (HTTP_PROXY_OPTIONS *)value;
AzureIoTClient 74:ea0021abecf7 1252
AzureIoTClient 74:ea0021abecf7 1253 if (proxy_options->host_address == NULL)
AzureIoTClient 74:ea0021abecf7 1254 {
AzureIoTClient 74:ea0021abecf7 1255 /* Codes_SRS_IOTHUBCLIENT_LL_32_006: [ If `host_address` is NULL, `IoTHubClient_LL_UploadToBlob_SetOption` shall fail and return `IOTHUB_CLIENT_INVALID_ARG`. ]*/
AzureIoTClient 74:ea0021abecf7 1256 LogError("NULL host_address in proxy options");
AzureIoTClient 74:ea0021abecf7 1257 result = IOTHUB_CLIENT_INVALID_ARG;
AzureIoTClient 74:ea0021abecf7 1258 }
AzureIoTClient 74:ea0021abecf7 1259 /* Codes_SRS_IOTHUBCLIENT_LL_32_007: [ If only one of `username` and `password` is NULL, `IoTHubClient_LL_UploadToBlob_SetOption` shall fail and return `IOTHUB_CLIENT_INVALID_ARG`. ]*/
AzureIoTClient 74:ea0021abecf7 1260 else if (((proxy_options->username == NULL) || (proxy_options->password == NULL)) &&
AzureIoTClient 74:ea0021abecf7 1261 (proxy_options->username != proxy_options->password))
AzureIoTClient 74:ea0021abecf7 1262 {
AzureIoTClient 74:ea0021abecf7 1263 LogError("Only one of username and password for proxy settings was NULL");
AzureIoTClient 74:ea0021abecf7 1264 result = IOTHUB_CLIENT_INVALID_ARG;
AzureIoTClient 74:ea0021abecf7 1265 }
AzureIoTClient 74:ea0021abecf7 1266 else
AzureIoTClient 74:ea0021abecf7 1267 {
AzureIoTClient 74:ea0021abecf7 1268 if (handleData->http_proxy_options.host_address != NULL)
AzureIoTClient 74:ea0021abecf7 1269 {
AzureIoTClient 74:ea0021abecf7 1270 free((char *)handleData->http_proxy_options.host_address);
AzureIoTClient 74:ea0021abecf7 1271 handleData->http_proxy_options.host_address = NULL;
AzureIoTClient 74:ea0021abecf7 1272 }
AzureIoTClient 74:ea0021abecf7 1273 if (handleData->http_proxy_options.username != NULL)
AzureIoTClient 74:ea0021abecf7 1274 {
AzureIoTClient 74:ea0021abecf7 1275 free((char *)handleData->http_proxy_options.username);
AzureIoTClient 74:ea0021abecf7 1276 handleData->http_proxy_options.username = NULL;
AzureIoTClient 74:ea0021abecf7 1277 }
AzureIoTClient 74:ea0021abecf7 1278 if (handleData->http_proxy_options.password != NULL)
AzureIoTClient 74:ea0021abecf7 1279 {
AzureIoTClient 74:ea0021abecf7 1280 free((char *)handleData->http_proxy_options.password);
AzureIoTClient 74:ea0021abecf7 1281 handleData->http_proxy_options.password = NULL;
AzureIoTClient 74:ea0021abecf7 1282 }
AzureIoTClient 74:ea0021abecf7 1283
AzureIoTClient 74:ea0021abecf7 1284 handleData->http_proxy_options.port = proxy_options->port;
AzureIoTClient 74:ea0021abecf7 1285
AzureIoTClient 74:ea0021abecf7 1286 if (mallocAndStrcpy_s((char **)(&handleData->http_proxy_options.host_address), proxy_options->host_address) != 0)
AzureIoTClient 74:ea0021abecf7 1287 {
AzureIoTClient 74:ea0021abecf7 1288 LogError("failure in mallocAndStrcpy_s - handleData->http_proxy_options.host_address");
AzureIoTClient 74:ea0021abecf7 1289 result = IOTHUB_CLIENT_ERROR;
AzureIoTClient 74:ea0021abecf7 1290 }
AzureIoTClient 74:ea0021abecf7 1291 else if (proxy_options->username != NULL && mallocAndStrcpy_s((char **)(&handleData->http_proxy_options.username), proxy_options->username) != 0)
AzureIoTClient 74:ea0021abecf7 1292 {
AzureIoTClient 74:ea0021abecf7 1293 LogError("failure in mallocAndStrcpy_s - handleData->http_proxy_options.username");
AzureIoTClient 74:ea0021abecf7 1294 result = IOTHUB_CLIENT_ERROR;
AzureIoTClient 74:ea0021abecf7 1295 }
AzureIoTClient 74:ea0021abecf7 1296 else if (proxy_options->password != NULL && mallocAndStrcpy_s((char **)(&handleData->http_proxy_options.password), proxy_options->password) != 0)
AzureIoTClient 74:ea0021abecf7 1297 {
AzureIoTClient 74:ea0021abecf7 1298 LogError("failure in mallocAndStrcpy_s - handleData->http_proxy_options.password");
AzureIoTClient 74:ea0021abecf7 1299 result = IOTHUB_CLIENT_ERROR;
AzureIoTClient 74:ea0021abecf7 1300 }
AzureIoTClient 74:ea0021abecf7 1301 else
AzureIoTClient 74:ea0021abecf7 1302 {
AzureIoTClient 74:ea0021abecf7 1303 result = IOTHUB_CLIENT_OK;
AzureIoTClient 74:ea0021abecf7 1304 }
AzureIoTClient 74:ea0021abecf7 1305 }
AzureIoTClient 74:ea0021abecf7 1306 }
AzureIoTClient 82:f94e6bed4495 1307 else if (strcmp(optionName, OPTION_CURL_VERBOSE) == 0)
AzureIoTClient 82:f94e6bed4495 1308 {
AzureIoTClient 82:f94e6bed4495 1309 handleData->curl_verbose = *(size_t*)value;
AzureIoTClient 82:f94e6bed4495 1310 result = IOTHUB_CLIENT_OK;
AzureIoTClient 82:f94e6bed4495 1311 }
AzureIoTClient 86:a1352899ea45 1312 else if (strcmp(optionName, OPTION_BLOB_UPLOAD_TIMEOUT_SECS) == 0)
AzureIoTClient 86:a1352899ea45 1313 {
AzureIoTClient 86:a1352899ea45 1314 handleData->blob_upload_timeout_secs = *(size_t*)value;
AzureIoTClient 86:a1352899ea45 1315 result = IOTHUB_CLIENT_OK;
AzureIoTClient 86:a1352899ea45 1316 }
AzureIoTClient 46:6a69294b6119 1317 else
AzureIoTClient 46:6a69294b6119 1318 {
AzureIoTClient 46:6a69294b6119 1319 /*Codes_SRS_IOTHUBCLIENT_LL_02_102: [ If an unknown option is presented then IoTHubClient_LL_UploadToBlob_SetOption shall return IOTHUB_CLIENT_INVALID_ARG. ]*/
AzureIoTClient 46:6a69294b6119 1320 result = IOTHUB_CLIENT_INVALID_ARG;
AzureIoTClient 46:6a69294b6119 1321 }
AzureIoTClient 46:6a69294b6119 1322 }
AzureIoTClient 46:6a69294b6119 1323 return result;
AzureIoTClient 46:6a69294b6119 1324 }
AzureIoTClient 46:6a69294b6119 1325
Azure.IoT Build 45:54c11b1b1407 1326 #endif /*DONT_USE_UPLOADTOBLOB*/
AzureIoTClient 46:6a69294b6119 1327
AzureIoTClient 46:6a69294b6119 1328