connect to vernemq

Author: Alberto Iannaccone

examples/utility/Provisioning/Provisioning.ino

@@ -55,7 +55,8 @@ void setup() {
     while (1);
   }
 
-  ECCX08Cert.setSubjectCommonName(ECCX08.serialNumber());
+  String thingId = promptAndReadLine("Please enter the thing id: ");
+  ECCX08Cert.setSubjectCommonName(thingId);
 
   String csr = ECCX08Cert.endCSR();
 
@@ -68,7 +69,6 @@ void setup() {
   Serial.println();
   Serial.println(csr);
 
-  String thingId                = promptAndReadLine("Please enter the thing id: ");
   String issueYear              = promptAndReadLine("Please enter the issue year of the certificate (2000 - 2031): ");
   String issueMonth             = promptAndReadLine("Please enter the issue month of the certificate (1 - 12): ");
   String issueDay               = promptAndReadLine("Please enter the issue day of the certificate (1 - 31): ");

src/ArduinoCloud.cpp

@@ -4,7 +4,7 @@
 #include <utility/ECCX08Cert.h>
 #include "CloudSerial.h"
 
-const static char server[] = "a19g5nbe27wn47.iot.us-east-1.amazonaws.com"; //"xxxxxxxxxxxxxx.iot.xx-xxxx-x.amazonaws.com";
+const static char server[] = "mqtts-sa.iot.oniudra.cc";
 
 const static int keySlot                                   = 0;
 const static int compressedCertSlot                        = 10;
@@ -42,7 +42,7 @@ int ArduinoCloudClass::begin(Client& net)
     return 0;
   }
 
-  ECCX08Cert.setSubjectCommonName(ECCX08.serialNumber());
+  ECCX08Cert.setSubjectCommonName(_id);
   ECCX08Cert.setIssuerCountryName("US");
   ECCX08Cert.setIssuerOrganizationName("Arduino LLC US");
   ECCX08Cert.setIssuerOrganizationalUnitName("IT");
@@ -52,6 +52,21 @@ int ArduinoCloudClass::begin(Client& net)
     return 0;
   }
 
+  Serial.println("Compressed cert = ");
+
+  const byte* certData = ECCX08Cert.bytes();
+  int certLength = ECCX08Cert.length();
+
+  for (int i = 0; i < certLength; i++) {
+    byte b = certData[i];
+
+    if (b < 16) {
+      Serial.print('0');
+    }
+    Serial.print(b, HEX);
+  }
+  Serial.println();
+
   if (_bearSslClient) {
     delete _bearSslClient;
   }
@@ -70,19 +85,19 @@ int ArduinoCloudClass::begin(Client& net)
 void ArduinoCloudClass::mqttClientBegin(Client& net)
 {
   // MQTT topics definition
-  _stdoutTopic = "$aws/things/" + _id + "/stdout";
-  _stdinTopic = "$aws/things/" + _id + "/stdin";
-  _dataTopicIn = "$aws/things/" + _id + "/datain";
-  _dataTopicOut = "$aws/things/" + _id + "/dataout";
+  _stdoutTopic = "/a/d/" + _id + "/s/o";
+  _stdinTopic = "/a/d/" + _id + "/s/i";
+  _dataTopicIn = "/a/d/" + _id + "/e/i";
+  _dataTopicOut = "/a/d/" + _id + "/e/o";
 
   // use onMessage as callback for received mqtt messages
   _mqttClient.onMessageAdvanced(ArduinoCloudClass::onMessage);
   _mqttClient.begin(server, 8883, net);
   // Set will for MQTT client: {topic, qos, retain message}
-  // const char lastMessage[] = "abcb";
-  // _mqttClient.setWill(_dataTopicOut.c_str(), lastMessage, false, 1);
-  // // Set MQTT connection options
-  // _mqttClient.setOptions(mqttOpt.keepAlive, mqttOpt.cleanSession, mqttOpt.timeout);
+  const char lastMessage[] = "abcb";
+  _mqttClient.setWill(_dataTopicOut.c_str(), lastMessage, false, 1);
+  // Set MQTT connection options
+  _mqttClient.setOptions(mqttOpt.keepAlive, mqttOpt.cleanSession, mqttOpt.timeout);
 }
 
 int ArduinoCloudClass::connect()