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?
User | Revision | Line number | New 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>© 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 |