Release 1.0.1: Fixed timeout interrupt handler function signature. Improved background thread termination in Python script. Updated examples with error detection.

Author: ZENG

AWS-IoT-Arduino-Yun-Library/aws_iot_version.h

@@ -18,7 +18,7 @@
 
 #define VERSION_MAJOR 1
 #define VERSION_MINOR 0
-#define VERSION_PATCH 0
+#define VERSION_PATCH 1
 #define VERSION_TAG ""
 
 #endif

AWS-IoT-Arduino-Yun-Library/examples/BasicPubSub/BasicPubSub.ino

@@ -21,6 +21,7 @@ aws_iot_mqtt_client myClient; // init iot_mqtt_client
 char msg[32]; // read-write buffer
 int cnt = 0; // loop counts
 int rc = -100; // return value placeholder
+bool success_connect = false; // whether it is connected
 
 // Basic callback function that prints out the message
 void msg_callback(char* src, int len) {
@@ -41,46 +42,55 @@ void setup() {
   sprintf(curr_version, "AWS IoT SDK Version(dev) %d.%d.%d-%s\n", VERSION_MAJOR, VERSION_MINOR, VERSION_PATCH, VERSION_TAG);
   Serial.println(curr_version);
   // Set up the client
-  if((rc = myClient.setup(AWS_IOT_CLIENT_ID)) != 0) {
-    Serial.println("Setup failed!");
-    Serial.println(rc);
-  }
-  // Load user configuration
-  if((rc = myClient.config(AWS_IOT_MQTT_HOST, AWS_IOT_MQTT_PORT, AWS_IOT_ROOT_CA_PATH, AWS_IOT_PRIVATE_KEY_PATH, AWS_IOT_CERTIFICATE_PATH)) != 0) {
-    Serial.println("Config failed!");
-    Serial.println(rc);
-  }
-  // Use default connect: 60 sec for keepalive
-  if((rc = myClient.connect()) != 0) {
-    Serial.println("Connect failed!");
-    Serial.println(rc);
+  if((rc = myClient.setup(AWS_IOT_CLIENT_ID)) == 0) {
+    // Load user configuration
+    if((rc = myClient.config(AWS_IOT_MQTT_HOST, AWS_IOT_MQTT_PORT, AWS_IOT_ROOT_CA_PATH, AWS_IOT_PRIVATE_KEY_PATH, AWS_IOT_CERTIFICATE_PATH)) == 0) {
+      // Use default connect: 60 sec for keepalive
+      if((rc = myClient.connect()) == 0) {
+        success_connect = true;
+        // Subscribe to "topic1"
+        if((rc = myClient.subscribe("topic1", 1, msg_callback)) != 0) {
+          Serial.println("Subscribe failed!");
+          Serial.println(rc);
+        }
+      }
+      else {
+        Serial.println("Connect failed!");
+        Serial.println(rc);
+      }
+    }
+    else {
+      Serial.println("Config failed!");
+      Serial.println(rc);
+    }
   }
-  // Subscribe to "topic1"
-  if((rc = myClient.subscribe("topic1", 1, msg_callback)) != 0) {
-    Serial.println("Subscribe failed!");
+  else {
+    Serial.println("Setup failed!");
     Serial.println(rc);
   }
   // Delay to make sure SUBACK is received, delay time could vary according to the server
   delay(2000);
 }
 
 void loop() {
-  // Generate a new message in each loop and publish to "topic1"
-  sprintf(msg, "new message %d", cnt);
-  if((rc = myClient.publish("topic1", msg, strlen(msg), 1, false)) != 0) {
-    Serial.println("Publish failed!");
-    Serial.println(rc);
-  }
+  if(success_connect) {
+    // Generate a new message in each loop and publish to "topic1"
+    sprintf(msg, "new message %d", cnt);
+    if((rc = myClient.publish("topic1", msg, strlen(msg), 1, false)) != 0) {
+      Serial.println("Publish failed!");
+      Serial.println(rc);
+    }
 
-  // Get a chance to run a callback
-  if((rc = myClient.yield()) != 0) {
-    Serial.println("Yield failed!");
-    Serial.println(rc);
-  }
+    // Get a chance to run a callback
+    if((rc = myClient.yield()) != 0) {
+      Serial.println("Yield failed!");
+      Serial.println(rc);
+    }
 
-  // Done with the current loop
-  sprintf(msg, "loop %d done", cnt++);
-  Serial.println(msg);
+    // Done with the current loop
+    sprintf(msg, "loop %d done", cnt++);
+    Serial.println(msg);
 
-  delay(1000);
+    delay(1000);
+  }
 }

AWS-IoT-Arduino-Yun-Library/examples/ThingShadowEcho/ThingShadowEcho.ino

@@ -21,19 +21,24 @@ aws_iot_mqtt_client myClient;
 char JSON_buf[100];
 int cnt = 0;
 int rc = 1;
+bool success_connect = false;
 
-void print_log(char* src, int code) {
+bool print_log(char* src, int code) {
+  bool ret = true;
   if(code == 0) {
     Serial.print("[LOG] command: ");
     Serial.print(src);
     Serial.println(" completed.");
+    ret = true;
   }
   else {
     Serial.print("[ERR] command: ");
     Serial.print(src);
     Serial.print(" code: ");
     Serial.println(code);
+    ret = false;
   }
+  return ret;
 }
 
 void msg_callback_delta(char* src, int len) {
@@ -56,17 +61,22 @@ void setup() {
   sprintf(curr_version, "AWS IoT SDK Version(dev) %d.%d.%d-%s\n", VERSION_MAJOR, VERSION_MINOR, VERSION_PATCH, VERSION_TAG);
   Serial.println(curr_version);
 
-  print_log("setup", myClient.setup(AWS_IOT_CLIENT_ID));
-  print_log("config", myClient.config(AWS_IOT_MQTT_HOST, AWS_IOT_MQTT_PORT, AWS_IOT_ROOT_CA_PATH, AWS_IOT_PRIVATE_KEY_PATH, AWS_IOT_CERTIFICATE_PATH));
-  print_log("connect", myClient.connect());
-  print_log("shadow init", myClient.shadow_init(AWS_IOT_MY_THING_NAME));
-  print_log("register thing shadow delta function", myClient.shadow_register_delta_func(AWS_IOT_MY_THING_NAME, msg_callback_delta));
-
+  if(print_log("setup", myClient.setup(AWS_IOT_CLIENT_ID))) {
+    if(print_log("config", myClient.config(AWS_IOT_MQTT_HOST, AWS_IOT_MQTT_PORT, AWS_IOT_ROOT_CA_PATH, AWS_IOT_PRIVATE_KEY_PATH, AWS_IOT_CERTIFICATE_PATH))) {
+      if(print_log("connect", myClient.connect())) {
+        success_connect = true;
+        print_log("shadow init", myClient.shadow_init(AWS_IOT_MY_THING_NAME));
+        print_log("register thing shadow delta function", myClient.shadow_register_delta_func(AWS_IOT_MY_THING_NAME, msg_callback_delta));
+      }
+    }
+  }
 }
 
 void loop() {
-  if(myClient.yield()) {
-    Serial.println("Yield failed.");
+  if(success_connect) {
+    if(myClient.yield()) {
+      Serial.println("Yield failed.");
+    }
+    delay(1000); // check for incoming delta per 100 ms
   }
-  delay(1000); // check for incoming delta per 100 ms
 }

AWS-IoT-Arduino-Yun-Library/keywords.txt

@@ -7,7 +7,7 @@ config	KEYWORD2
 connect	KEYWORD2
 publish	KEYWORD2
 subscribe	KEYWORD2
-unsubscirbe	KEYWORD2
+unsubscribe	KEYWORD2
 disconnect	KEYWORD2
 yield	KEYWORD2
 shadow_init	KEYWORD2

CHANGELOG.md

@@ -1,3 +1,15 @@
+# 1.0.1 (November 3, 2015)
+Features:
+
+N/A
+
+Bugfixes/Improvements:
+
+* Updated README.md
+* Updated examples with error detection
+* Fixed timeout interrupt handler function signature
+* Improved background thread termination in Python script
+
 # 1.0.0 (October 8, 2015)
 Features:
 
@@ -17,4 +29,4 @@ Features:
 
 Bugfixes/Improvements:
 
-* N/A
+* N/A