james kang / MQTT_JS

Provides Javascript wrappers for MQTT.

Dependencies:   mbed-http DEVI2C_JS MQTTPacket FP

MQTT_JS.h@1:a8ffffd1beab, 2020-02-03 (annotated)

Committer:
kajasu
Date:
Mon Feb 03 09:36:20 2020 +0000
Revision:
1:a8ffffd1beab
Parent:
0:f4dbe435e64c 
TT

Who changed what in which revision?

UserRevisionLine numberNew contents of line
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 1 /*
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 2 * @file MQTT_JS.h
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 3 * @author ST
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 4 * @version V1.0.0
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 5 * @date 9 October 2017
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 6 * @brief Implementation of MQTT for Javascript.
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 7 ******************************************************************************
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 8 * @attention
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 9 *
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 10 * <h2><center>&copy; COPYRIGHT(c) 2017 STMicroelectronics</center></h2>
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 11 *
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 12 * Redistribution and use in source and binary forms, with or without modification,
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 13 * are permitted provided that the following conditions are met:
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 14 * 1. Redistributions of source code must retain the above copyright notice,
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 15 * this list of conditions and the following disclaimer.
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 16 * 2. Redistributions in binary form must reproduce the above copyright notice,
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 17 * this list of conditions and the following disclaimer in the documentation
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 18 * and/or other materials provided with the distribution.
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 19 * 3. Neither the name of STMicroelectronics nor the names of its contributors
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 20 * may be used to endorse or promote products derived from this software
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 21 * without specific prior written permission.
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 22 *
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 23 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 24 * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 25 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 26 * DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 27 * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 28 * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 29 * SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 30 * CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 31 * OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 32 * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 33 *
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 34 ******************************************************************************
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 35 */
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 36
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 37 /* Prevent recursive inclusion -----------------------------------------------*/
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 38
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 39 #ifndef _MQTT_JS_H_
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 40 #define _MQTT_JS_H_
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 41
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 42 /* Includes ------------------------------------------------------------------*/
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 43
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 44 #include "mbed.h"
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 45 #include "TCPSocket.h"
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 46 #include "MQTTClient.h"
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 47 #include "MQTTNetwork.h"
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 48 #include "MQTTmbed.h"
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 49
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 50 #include "NetworkInterface_JS.h"
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 51
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 52 #include "jerryscript-mbed-library-registry/wrap_tools.h"
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 53
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 54 #include <ctype.h>
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 55
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 56 /* Constants -----------------------------------------------------------------*/
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 57
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 58 #define MQTT_MAX_PACKET_SIZE 250
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 59 #define MQTT_MAX_PAYLOAD_SIZE 300
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 60
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 61 #define MAX_SSID_LEN 80
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 62 #define MAX_PASSW_LEN 80
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 63
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 64 #define HTTP_BROKER_URL "http://customer.cloudmqtt.com/login"
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 65
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 66 typedef void (* subscribeCallbackType)(MQTT::MessageData & msgMQTT);
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 67
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 68 /* Class Declaration ---------------------------------------------------------*/
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 69
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 70 /**
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 71 * Abstract class of MQTT for Javascript.
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 72 */
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 73 class MQTT_JS{
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 74 private:
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 75 char ssid[MAX_SSID_LEN];
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 76 char seckey[MAX_PASSW_LEN];
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 77
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 78 char id[32];
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 79 char topic[32];
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 80 char auth_token[32];
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 81 char hostname[128];
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 82 char port[16];
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 83
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 84 int connack_rc; // MQTT connack return code
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 85 char* ip_addr;
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 86 char type[30];
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 87 bool netConnecting;
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 88 int connectTimeout;
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 89 bool mqttConnecting;
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 90 bool netConnected;
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 91 bool connected;
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 92 int retryAttempt;
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 93 char subscription_url[300];
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 94 MQTT::Client<MQTTNetwork, Countdown, MQTT_MAX_PACKET_SIZE>* client;
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 95 MQTTNetwork* mqttNetwork;
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 96
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 97 static jerry_value_t onSubscribeCallback;
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 98
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 99 public:
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 100
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 101 /* Constructors */
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 102 MQTT_JS();
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 103
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 104 /* Destructors */
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 105 ~MQTT_JS();
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 106
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 107 /* Functions */
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 108
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 109 NetworkInterface* getNetworkInterface();
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 110
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 111 int onSubscribe(jerry_value_t cb);
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 112 int onDisconnect(jerry_value_t cb, subscribeCallbackType fn);
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 113
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 114 static void subscribe_cb(MQTT::MessageData & msgMQTT);
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 115
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 116 int init(NetworkInterface* network, char* _id, char* _token, char* _url, char* _port);
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 117
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 118 int connect();
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 119
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 120 int subscribe(char *pubTopic);
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 121
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 122 int unsubscribe(char *pubTopic);
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 123
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 124 int connect(NetworkInterface* network);
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 125
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 126 int getConnTimeout(int attemptNumber);
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 127
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 128 void attemptConnect(NetworkInterface* network) ;
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 129
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 130 int publish(char* buf, int n = 0);
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 131
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 132 int yield(int time);
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 133
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 134 int start_mqtt(NetworkInterface* network);
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 135 };
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 136
akhtar.syedzeeshan@gmail.com 0:f4dbe435e64c 137 #endif