Revision 0:ceabe0e90767, committed 2019-05-17

Comitter:

Markl

Date:

Fri May 17 16:38:26 2019 +0000

Commit message:

Sample MQTT proxy for cellular

Changed in this revision

--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/MQTT.lib	Fri May 17 16:38:26 2019 +0000
@@ -0,0 +1,1 @@
+https://os.mbed.com/users/Markl/code/MQTT/#150b06e72bf8

--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/main.cpp	Fri May 17 16:38:26 2019 +0000
@@ -0,0 +1,361 @@
+/*
+ * @author  Asavie - Mark Lambe
+ * @version V1.0.0
+ * @date    25 March 2019
+ * @brief   Demonstration of Asavie IoT Connect cloud service connector and proxy
+ * @overview Securely connect MQTT data to IoT cloud services via Asavie proxy, 
+ * further information on setup available at https://developer.asavie.com
+ *
+ ******************************************************************************
+ * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
+ * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
+ * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
+ * DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE
+ * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
+ * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
+ * SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER
+ * CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
+ * OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
+ * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+ *
+ ******************************************************************************
+ */
+
+#include "mbed.h"
+#include "common_functions.h"
+#include "UDPSocket.h"
+#include "CellularLog.h"
+#include "MQTTNetwork.h"
+#include "MQTTmbed.h"
+#include "MQTTClient.h"
+
+
+// MQTT host details
+static const char mqtt_host[] = "mqtt.asavie.network";
+static int mqtt_port = 1883;
+
+// Define MQTT details
+char mqtt_client[] = "Asavie";
+char mqtt_topic[] = "Asavie";
+char mqtt_pub_msg[] = "{\"message\": \"MQTT sent via Asavie IoT Connect\"}";
+
+// Incoming MQTT message
+int arrivedcount = 0;
+
+
+//TCP test
+#define UDP 0
+#define TCP 1
+
+// Number of retries /
+#define RETRY_COUNT 3
+
+NetworkInterface *iface;
+
+// Echo server hostname
+const char *host_name = MBED_CONF_APP_ECHO_SERVER_HOSTNAME;
+
+// Echo server port (same for TCP and UDP)
+const int port = MBED_CONF_APP_ECHO_SERVER_PORT;
+
+static rtos::Mutex trace_mutex;
+
+#if MBED_CONF_MBED_TRACE_ENABLE
+static void trace_wait()
+{
+    trace_mutex.lock();
+}
+
+static void trace_release()
+{
+    trace_mutex.unlock();
+}
+
+static char time_st[50];
+
+static char* trace_time(size_t ss)
+{
+    snprintf(time_st, 49, "[%08llums]", Kernel::get_ms_count());
+    return time_st;
+}
+
+static void trace_open()
+{
+    mbed_trace_init();
+    mbed_trace_prefix_function_set( &trace_time );
+
+    mbed_trace_mutex_wait_function_set(trace_wait);
+    mbed_trace_mutex_release_function_set(trace_release);
+
+    mbed_cellular_trace::mutex_wait_function_set(trace_wait);
+    mbed_cellular_trace::mutex_release_function_set(trace_release);
+}
+
+static void trace_close()
+{
+    mbed_cellular_trace::mutex_wait_function_set(NULL);
+    mbed_cellular_trace::mutex_release_function_set(NULL);
+
+    mbed_trace_free();
+}
+#endif // #if MBED_CONF_MBED_TRACE_ENABLE
+
+Thread dot_thread(osPriorityNormal, 512);
+
+void print_function(const char *format, ...)
+{
+    trace_mutex.lock();
+    va_list arglist;
+    va_start( arglist, format );
+    vprintf(format, arglist);
+    va_end( arglist );
+    trace_mutex.unlock();
+}
+
+void dot_event()
+{
+    while (true) {
+        ThisThread::sleep_for(4000);
+        if (iface && iface->get_connection_status() == NSAPI_STATUS_GLOBAL_UP) {
+            break;
+        } else {
+            trace_mutex.lock();
+            printf(".");
+            fflush(stdout);
+            trace_mutex.unlock();
+        }
+    }
+}
+
+/**
+ * Connects to the Cellular Network
+ */
+nsapi_error_t do_connect()
+{
+    nsapi_error_t retcode = NSAPI_ERROR_OK;
+    uint8_t retry_counter = 0;
+
+    while (iface->get_connection_status() != NSAPI_STATUS_GLOBAL_UP) {
+        retcode = iface->connect();
+        if (retcode == NSAPI_ERROR_AUTH_FAILURE) {
+            print_function("\n\nAuthentication Failure. Exiting application\n");
+        } else if (retcode == NSAPI_ERROR_OK) {
+            print_function("\n\nConnection Established.\n");
+        } else if (retry_counter > RETRY_COUNT) {
+            print_function("\n\nFatal connection failure: %d\n", retcode);
+        } else {
+            print_function("\n\nCouldn't connect: %d, will retry\n", retcode);
+            retry_counter++;
+            continue;
+        }
+        break;
+    }
+    return retcode;
+}
+
+/**
+ * MQTT message receiver
+ */
+
+void messageArrived(MQTT::MessageData& md)
+{
+    MQTT::Message &message = md.message;
+    print_function("Message arrived: qos %d, retained %d, dup %d, packetid %d\r\n", message.qos, message.retained, message.dup, message.id);
+    print_function("Payload %.*s\r\n", message.payloadlen, (char*)message.payload);
+    ++arrivedcount;
+}
+
+
+int mqtt_send_receive() {
+    
+    MQTTNetwork mqttNetwork(iface);
+
+    MQTT::Client<MQTTNetwork, Countdown> client(mqttNetwork);
+
+    print_function("Connecting to %s:%d\r\n", mqtt_host, mqtt_port);
+    int rc = mqttNetwork.connect(mqtt_host, mqtt_port);
+    if (rc != 0)
+        print_function("rc from TCP connect is %d\r\n", rc);
+
+    MQTTPacket_connectData data = MQTTPacket_connectData_initializer;
+    data.MQTTVersion = 3;
+    data.clientID.cstring = mqtt_client;
+
+    if ((rc = client.connect(data)) != 0)
+        print_function("rc from MQTT connect is %d\r\n", rc);
+
+    if ((rc = client.subscribe(mqtt_topic, MQTT::QOS0, messageArrived)) != 0)
+        print_function("rc from MQTT subscribe is %d\r\n", rc);
+
+    MQTT::Message message;
+
+    // QoS 0
+    char buf[100];
+    sprintf(buf, "Hello World!  QoS 0 message from Asavie \r\n");
+    message.qos = MQTT::QOS0;
+    message.retained = false;
+    message.dup = false;
+    message.payload = (void*)buf;
+    message.payloadlen = strlen(buf)+1;
+    rc = client.publish(mqtt_topic, message);
+    while (arrivedcount < 1)
+        client.yield(100);
+
+    // QoS 1
+    sprintf(buf, "Hello World!  QoS 1 message from Asavie \r\n");
+    message.qos = MQTT::QOS1;
+    message.payloadlen = strlen(buf)+1;
+    rc = client.publish(mqtt_topic, message);
+    while (arrivedcount < 2)
+        client.yield(100);
+
+    // QoS 2
+    sprintf(buf, "Hello World!  QoS 2 message from Asavie \r\n");
+    message.qos = MQTT::QOS2;
+    message.payloadlen = strlen(buf)+1;
+    rc = client.publish(mqtt_topic, message);
+    while (arrivedcount < 3)
+        client.yield(100);
+
+    if ((rc = client.unsubscribe(mqtt_topic)) != 0)
+        print_function("rc from unsubscribe was %d\r\n", rc);
+
+    if ((rc = client.disconnect()) != 0)
+        print_function("rc from disconnect was %d\r\n", rc);
+
+    mqttNetwork.disconnect();
+
+    print_function("MQTT finished, received %d msgs\r\n", arrivedcount);
+
+    return 0;
+}
+
+
+
+/**
+ * Opens a UDP or a TCP socket with the given echo server and performs an echo
+ * transaction retrieving current.
+ */
+nsapi_error_t test_send_recv()
+{
+    nsapi_size_or_error_t retcode;
+#if MBED_CONF_APP_SOCK_TYPE == TCP
+    TCPSocket sock;
+#else
+    UDPSocket sock;
+#endif
+
+    retcode = sock.open(iface);
+    if (retcode != NSAPI_ERROR_OK) {
+#if MBED_CONF_APP_SOCK_TYPE == TCP
+        print_function("TCPSocket.open() fails, code: %d\n", retcode);
+#else
+        print_function("UDPSocket.open() fails, code: %d\n", retcode);
+#endif
+        return -1;
+    }
+
+    SocketAddress sock_addr;
+    retcode = iface->gethostbyname(host_name, &sock_addr);
+    if (retcode != NSAPI_ERROR_OK) {
+        print_function("Couldn't resolve remote host: %s, code: %d\n", host_name, retcode);
+        return -1;
+    }
+
+    sock_addr.set_port(port);
+
+    sock.set_timeout(15000);
+    int n = 0;
+    const char *echo_string = "TEST";
+    char recv_buf[4];
+#if MBED_CONF_APP_SOCK_TYPE == TCP
+    retcode = sock.connect(sock_addr);
+    if (retcode < 0) {
+        print_function("TCPSocket.connect() fails, code: %d\n", retcode);
+        return -1;
+    } else {
+        print_function("TCP: connected with %s server\n", host_name);
+    }
+    retcode = sock.send((void*) echo_string, sizeof(echo_string));
+    if (retcode < 0) {
+        print_function("TCPSocket.send() fails, code: %d\n", retcode);
+        return -1;
+    } else {
+        print_function("TCP: Sent %d Bytes to %s\n", retcode, host_name);
+    }
+
+    n = sock.recv((void*) recv_buf, sizeof(recv_buf));
+#else
+
+    retcode = sock.sendto(sock_addr, (void*) echo_string, sizeof(echo_string));
+    if (retcode < 0) {
+        print_function("UDPSocket.sendto() fails, code: %d\n", retcode);
+        return -1;
+    } else {
+        print_function("UDP: Sent %d Bytes to %s\n", retcode, host_name);
+    }
+
+    n = sock.recvfrom(&sock_addr, (void*) recv_buf, sizeof(recv_buf));
+#endif
+
+    sock.close();
+
+    if (n > 0) {
+        print_function("Received from echo server %d Bytes\n", n);
+        return 0;
+    }
+
+    return -1;
+}
+
+int main()
+{
+     
+    print_function("\n\nAsavie IoT Connect cloud service connector example\n");
+    print_function("\n\nBuilt: %s, %s\n", __DATE__, __TIME__);
+#ifdef MBED_CONF_NSAPI_DEFAULT_CELLULAR_PLMN
+    print_function("\n\n[MAIN], plmn: %s\n", MBED_CONF_NSAPI_DEFAULT_CELLULAR_PLMN);
+#endif
+
+    print_function("Establishing connection\n");
+#if MBED_CONF_MBED_TRACE_ENABLE
+    trace_open();
+#else
+    dot_thread.start(dot_event);
+#endif // #if MBED_CONF_MBED_TRACE_ENABLE
+
+    // sim pin, apn, credentials and possible plmn are taken atuomtically from json when using get_default_instance()
+    iface = NetworkInterface::get_default_instance();
+    MBED_ASSERT(iface);
+
+    nsapi_error_t retcode = NSAPI_ERROR_NO_CONNECTION;
+
+    /* Attempt to connect to a cellular network */
+    while (do_connect() == NSAPI_ERROR_OK) {
+        // Validate TCP session rules in Asavie IoT Connect
+        retcode = test_send_recv();
+        // Validate Asavie IoT Connect cloud service connector
+        retcode = mqtt_send_receive();
+        
+    }
+    
+    
+    if (iface->disconnect() != NSAPI_ERROR_OK) {
+        print_function("\n\n disconnect failed.\n\n");
+    }
+
+    if (retcode == NSAPI_ERROR_OK) {
+        print_function("\n\nSuccess. Exiting \n\n");
+    } else {
+        print_function("\n\nFailure. Exiting \n\n");
+    }
+
+    while(do_connect() == NSAPI_ERROR_OK);
+#if MBED_CONF_MBED_TRACE_ENABLE
+    trace_close();
+#else
+    dot_thread.terminate();
+#endif // #if MBED_CONF_MBED_TRACE_ENABLE
+
+    return 0;
+}

--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/mbed-os.lib	Fri May 17 16:38:26 2019 +0000
@@ -0,0 +1,1 @@
+https://github.com/ARMmbed/mbed-os/#51d55508e8400b60af467005646c4e2164738d48

--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/mbed_app.json	Fri May 17 16:38:26 2019 +0000
@@ -0,0 +1,38 @@
+{
+    "config": {
+        "sock-type": "TCP",
+        "echo-server-hostname": {
+            "help": "Echo server host name.",
+            "value": "\"echo.mbedcloudtesting.com\""
+        },
+        "echo-server-port": {
+            "help": "Echo server port number.",
+            "value": 7
+        },
+        "trace-level": {
+            "help": "Options are TRACE_LEVEL_ERROR,TRACE_LEVEL_WARN,TRACE_LEVEL_INFO,TRACE_LEVEL_DEBUG",
+            "macro_name": "MBED_TRACE_MAX_LEVEL",
+            "value": "TRACE_LEVEL_DEBUG"
+        }
+  },
+    "target_overrides": {
+        "*": {
+            "target.network-default-interface-type": "CELLULAR",
+            "mbed-trace.enable": true,
+            "lwip.ipv4-enabled": true,
+            "lwip.ethernet-enabled": false,
+            "lwip.ppp-enabled": true,
+            "lwip.tcp-enabled": true,
+            "platform.stdio-convert-newlines": true,
+            "platform.stdio-baud-rate": 115200,
+            "platform.default-serial-baud-rate": 115200,
+            "platform.stdio-buffered-serial": true,
+            "cellular.debug-at": false,
+            "nsapi.default-cellular-plmn": 0,
+            "nsapi.default-cellular-sim-pin": "\"1234\"",
+            "nsapi.default-cellular-apn": "\"m2mexpress.gdsp\"",
+            "nsapi.default-cellular-username": "\"Data\"",
+            "nsapi.default-cellular-password": "\"Data\""
+        }
+    }
+}