Diff: AWS_openssl/aws_iot_src/shadow/aws_iot_shadow.cpp

Revision:

15:6f2798e45099

--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/AWS_openssl/aws_iot_src/shadow/aws_iot_shadow.cpp	Thu Dec 01 18:05:38 2016 +0000
@@ -0,0 +1,177 @@
+/*
+ * Copyright 2010-2015 Amazon.com, Inc. or its affiliates. All Rights Reserved.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License").
+ * You may not use this file except in compliance with the License.
+ * A copy of the License is located at
+ *
+ *  http://aws.amazon.com/apache2.0
+ *
+ * or in the "license" file accompanying this file. This file is distributed
+ * on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either
+ * express or implied. See the License for the specific language governing
+ * permissions and limitations under the License.
+ */
+
+#include "aws_iot_error.h"
+#include "aws_iot_log.h"
+#include "aws_iot_shadow_actions.h"
+#include "aws_iot_shadow_json.h"
+#include "aws_iot_shadow_key.h"
+#include "aws_iot_shadow_records.h"
+
+const ShadowParameters_t ShadowParametersDefault = {
+		.pMyThingName = AWS_IOT_MY_THING_NAME,
+		.pMqttClientId = AWS_IOT_MQTT_CLIENT_ID,
+		.pHost = AWS_IOT_MQTT_HOST,
+		.port = AWS_IOT_MQTT_PORT,
+		.pRootCA = NULL,
+		.pClientCRT = NULL,
+		.pClientKey = NULL
+};
+
+void aws_iot_shadow_reset_last_received_version(void) {
+	shadowJsonVersionNum = 0;
+}
+
+uint32_t aws_iot_shadow_get_last_received_version(void) {
+	return shadowJsonVersionNum;
+}
+
+void aws_iot_shadow_enable_discard_old_delta_msgs(void) {
+	shadowDiscardOldDeltaFlag = true;
+}
+
+void aws_iot_shadow_disable_discard_old_delta_msgs(void) {
+	shadowDiscardOldDeltaFlag = false;
+}
+
+IoT_Error_t aws_iot_shadow_init(MQTTClient_t *pClient) {
+
+	IoT_Error_t rc = NONE_ERROR;
+
+	if (pClient == NULL) {
+		return NULL_VALUE_ERROR;
+	}
+
+	resetClientTokenSequenceNum();
+	aws_iot_shadow_reset_last_received_version();
+	initDeltaTokens();
+	return NONE_ERROR;
+}
+
+IoT_Error_t aws_iot_shadow_connect(MQTTClient_t *pClient, ShadowParameters_t *pParams) {
+	IoT_Error_t rc = NONE_ERROR;
+	
+	MQTTConnectParams ConnectParams = MQTTConnectParamsDefault;
+	if (pClient == NULL) {
+		return NULL_VALUE_ERROR;
+	}
+
+	if (pClient->connect == NULL) {
+		return NULL_VALUE_ERROR;
+	}
+    
+	snprintf(myThingName, MAX_SIZE_OF_THING_NAME, "%s", pParams->pMyThingName );
+	snprintf(mqttClientID, MAX_SIZE_OF_UNIQUE_CLIENT_ID_BYTES, "%s", pParams->pMqttClientId );
+
+	INFO("...Thing Name %s", myThingName);
+	INFO("...MQTT Client ID %s", mqttClientID);
+    
+	ConnectParams.KeepAliveInterval_sec = 10;
+	ConnectParams.MQTTVersion = MQTT_3_1_1;
+	ConnectParams.mqttCommandTimeout_ms = 10000;//2000;
+	ConnectParams.tlsHandshakeTimeout_ms = 10000;
+	ConnectParams.isCleansession = true;
+	ConnectParams.isSSLHostnameVerify = true;
+	ConnectParams.isWillMsgPresent = false;
+	ConnectParams.pClientID = pParams->pMqttClientId;
+	ConnectParams.pDeviceCertLocation = pParams->pClientCRT;
+	ConnectParams.pDevicePrivateKeyLocation = pParams->pClientKey;
+	ConnectParams.pRootCALocation = pParams->pRootCA;
+	ConnectParams.pPassword = NULL;
+	ConnectParams.pUserName = NULL;
+	ConnectParams.pHostURL = pParams->pHost;
+	ConnectParams.port = pParams->port;
+	ConnectParams.disconnectHandler = NULL;
+
+	rc = pClient->connect(&ConnectParams);
+
+	if(rc == NONE_ERROR){
+		initializeRecords(pClient);
+	}
+
+	return rc;
+}
+
+IoT_Error_t aws_iot_shadow_register_delta(MQTTClient_t *pClient, jsonStruct_t *pStruct) {
+	IoT_Error_t rc = NONE_ERROR;
+
+	if (!(pClient->isConnected())) {
+		return CONNECTION_ERROR;
+	}
+
+	rc = registerJsonTokenOnDelta(pStruct);
+
+	return rc;
+}
+
+IoT_Error_t aws_iot_shadow_yield(MQTTClient_t *pClient, int timeout) {
+	HandleExpiredResponseCallbacks();
+	return pClient->yield(timeout);
+}
+
+IoT_Error_t aws_iot_shadow_disconnect(MQTTClient_t *pClient) {
+	return pClient->disconnect();
+}
+
+IoT_Error_t aws_iot_shadow_update(MQTTClient_t *pClient, const char *pThingName, char *pJsonString,
+		fpActionCallback_t callback, void *pContextData, uint8_t timeout_seconds, bool isPersistentSubscribe) {
+
+	IoT_Error_t ret_val = NONE_ERROR;
+
+	if (!(pClient->isConnected())) {
+		return CONNECTION_ERROR;
+	}
+
+	ret_val = iot_shadow_action(pClient, pThingName, SHADOW_UPDATE, pJsonString, callback, pContextData,
+			timeout_seconds, isPersistentSubscribe);
+
+	return ret_val;
+}
+
+IoT_Error_t aws_iot_shadow_delete(MQTTClient_t *pClient, const char *pThingName, fpActionCallback_t callback,
+		void *pContextData, uint8_t timeout_seconds, bool isPersistentSubscribe) {
+	IoT_Error_t ret_val = NONE_ERROR;
+
+	if (!(pClient->isConnected())) {
+		return CONNECTION_ERROR;
+	}
+
+	char deleteRequestJsonBuf[MAX_SIZE_CLIENT_TOKEN_CLIENT_SEQUENCE];
+	iot_shadow_delete_request_json(deleteRequestJsonBuf);
+	ret_val = iot_shadow_action(pClient, pThingName, SHADOW_DELETE, deleteRequestJsonBuf, callback, pContextData,
+			timeout_seconds, isPersistentSubscribe);
+
+	return ret_val;
+}
+
+IoT_Error_t aws_iot_shadow_get(MQTTClient_t *pClient, const char *pThingName, fpActionCallback_t callback,
+		void *pContextData, uint8_t timeout_seconds, bool isPersistentSubscribe) {
+
+	IoT_Error_t ret_val = NONE_ERROR;
+
+	if (!(pClient->isConnected())) {
+		return CONNECTION_ERROR;
+	}
+
+	char getRequestJsonBuf[MAX_SIZE_CLIENT_TOKEN_CLIENT_SEQUENCE];
+
+	iot_shadow_get_request_json(getRequestJsonBuf);
+
+	ret_val = iot_shadow_action(pClient, pThingName, SHADOW_GET, getRequestJsonBuf, callback, pContextData,
+			timeout_seconds, isPersistentSubscribe);
+
+	return ret_val;
+}
+