113498266Sopenharmony_ci#ifndef HEADER_CURL_MQTT_H 213498266Sopenharmony_ci#define HEADER_CURL_MQTT_H 313498266Sopenharmony_ci/*************************************************************************** 413498266Sopenharmony_ci * _ _ ____ _ 513498266Sopenharmony_ci * Project ___| | | | _ \| | 613498266Sopenharmony_ci * / __| | | | |_) | | 713498266Sopenharmony_ci * | (__| |_| | _ <| |___ 813498266Sopenharmony_ci * \___|\___/|_| \_\_____| 913498266Sopenharmony_ci * 1013498266Sopenharmony_ci * Copyright (C) Björn Stenberg, <bjorn@haxx.se> 1113498266Sopenharmony_ci * 1213498266Sopenharmony_ci * This software is licensed as described in the file COPYING, which 1313498266Sopenharmony_ci * you should have received as part of this distribution. The terms 1413498266Sopenharmony_ci * are also available at https://curl.se/docs/copyright.html. 1513498266Sopenharmony_ci * 1613498266Sopenharmony_ci * You may opt to use, copy, modify, merge, publish, distribute and/or sell 1713498266Sopenharmony_ci * copies of the Software, and permit persons to whom the Software is 1813498266Sopenharmony_ci * furnished to do so, under the terms of the COPYING file. 1913498266Sopenharmony_ci * 2013498266Sopenharmony_ci * This software is distributed on an "AS IS" basis, WITHOUT WARRANTY OF ANY 2113498266Sopenharmony_ci * KIND, either express or implied. 2213498266Sopenharmony_ci * 2313498266Sopenharmony_ci * SPDX-License-Identifier: curl 2413498266Sopenharmony_ci * 2513498266Sopenharmony_ci ***************************************************************************/ 2613498266Sopenharmony_ci 2713498266Sopenharmony_ci#ifndef CURL_DISABLE_MQTT 2813498266Sopenharmony_ciextern const struct Curl_handler Curl_handler_mqtt; 2913498266Sopenharmony_ci#endif 3013498266Sopenharmony_ci 3113498266Sopenharmony_cienum mqttstate { 3213498266Sopenharmony_ci MQTT_FIRST, /* 0 */ 3313498266Sopenharmony_ci MQTT_REMAINING_LENGTH, /* 1 */ 3413498266Sopenharmony_ci MQTT_CONNACK, /* 2 */ 3513498266Sopenharmony_ci MQTT_SUBACK, /* 3 */ 3613498266Sopenharmony_ci MQTT_SUBACK_COMING, /* 4 - the SUBACK remainder */ 3713498266Sopenharmony_ci MQTT_PUBWAIT, /* 5 - wait for publish */ 3813498266Sopenharmony_ci MQTT_PUB_REMAIN, /* 6 - wait for the remainder of the publish */ 3913498266Sopenharmony_ci 4013498266Sopenharmony_ci MQTT_NOSTATE /* 7 - never used an actual state */ 4113498266Sopenharmony_ci}; 4213498266Sopenharmony_ci 4313498266Sopenharmony_cistruct mqtt_conn { 4413498266Sopenharmony_ci enum mqttstate state; 4513498266Sopenharmony_ci enum mqttstate nextstate; /* switch to this after remaining length is 4613498266Sopenharmony_ci done */ 4713498266Sopenharmony_ci unsigned int packetid; 4813498266Sopenharmony_ci}; 4913498266Sopenharmony_ci 5013498266Sopenharmony_ci/* protocol-specific transfer-related data */ 5113498266Sopenharmony_cistruct MQTT { 5213498266Sopenharmony_ci char *sendleftovers; 5313498266Sopenharmony_ci size_t nsend; /* size of sendleftovers */ 5413498266Sopenharmony_ci 5513498266Sopenharmony_ci /* when receiving */ 5613498266Sopenharmony_ci size_t npacket; /* byte counter */ 5713498266Sopenharmony_ci unsigned char firstbyte; 5813498266Sopenharmony_ci size_t remaining_length; 5913498266Sopenharmony_ci struct dynbuf recvbuf; 6013498266Sopenharmony_ci unsigned char pkt_hd[4]; /* for decoding the arriving packet length */ 6113498266Sopenharmony_ci}; 6213498266Sopenharmony_ci 6313498266Sopenharmony_ci#endif /* HEADER_CURL_MQTT_H */ 64