1 | // Copyright (c) Microsoft. All rights reserved.
|
---|
2 | // Licensed under the MIT license. See LICENSE file in the project root for full license information.
|
---|
3 |
|
---|
4 | #include <stdlib.h>
|
---|
5 | #include "azure_c_shared_utility/xio.h"
|
---|
6 | #include "azure_c_shared_utility/wsio.h"
|
---|
7 | #include "azure_c_shared_utility/tlsio.h"
|
---|
8 | #include "azure_c_shared_utility/platform.h"
|
---|
9 | #include "azure_c_shared_utility/http_proxy_io.h"
|
---|
10 | #include "iothubtransportmqtt_websockets.h"
|
---|
11 | #include "internal/iothubtransport_mqtt_common.h"
|
---|
12 |
|
---|
13 | static XIO_HANDLE getWebSocketsIOTransport(const char* fully_qualified_name, const MQTT_TRANSPORT_PROXY_OPTIONS* mqtt_transport_proxy_options)
|
---|
14 | {
|
---|
15 | XIO_HANDLE result;
|
---|
16 | /* Codes_SRS_IOTHUB_MQTT_WEBSOCKET_TRANSPORT_01_001: [ `getIoTransportProvider` shall obtain the WebSocket IO interface handle by calling `wsio_get_interface_description`. ]*/
|
---|
17 | const IO_INTERFACE_DESCRIPTION* io_interface_description = wsio_get_interface_description();
|
---|
18 | TLSIO_CONFIG tls_io_config;
|
---|
19 | HTTP_PROXY_IO_CONFIG http_proxy_io_config;
|
---|
20 |
|
---|
21 | if (io_interface_description == NULL)
|
---|
22 | {
|
---|
23 | /* Codes_SRS_IOTHUB_MQTT_WEBSOCKET_TRANSPORT_07_013: [ If `wsio_get_interface_description` returns NULL `getIoTransportProvider` shall return NULL. ] */
|
---|
24 | LogError("Failure constructing the provider interface");
|
---|
25 | result = NULL;
|
---|
26 | }
|
---|
27 | else
|
---|
28 | {
|
---|
29 | WSIO_CONFIG ws_io_config;
|
---|
30 |
|
---|
31 | /* Codes_SRS_IOTHUB_MQTT_WEBSOCKET_TRANSPORT_01_003: [ - `hostname` shall be set to `fully_qualified_name`. ]*/
|
---|
32 | ws_io_config.hostname = fully_qualified_name;
|
---|
33 | /* Codes_SRS_IOTHUB_MQTT_WEBSOCKET_TRANSPORT_01_004: [ - `port` shall be set to 443. ]*/
|
---|
34 | ws_io_config.port = 443;
|
---|
35 | /* Codes_SRS_IOTHUB_MQTT_WEBSOCKET_TRANSPORT_01_005: [ - `protocol` shall be set to `MQTT`. ]*/
|
---|
36 | ws_io_config.protocol = "MQTT";
|
---|
37 | /* Codes_SRS_IOTHUB_MQTT_WEBSOCKET_TRANSPORT_01_006: [ - `resource_name` shall be set to `/$iothub/websocket`. ]*/
|
---|
38 | ws_io_config.resource_name = "/$iothub/websocket";
|
---|
39 | /* Codes_SRS_IOTHUB_MQTT_WEBSOCKET_TRANSPORT_01_007: [ - `underlying_io_interface` shall be set to the TLS IO interface description. ]*/
|
---|
40 | /* Codes_SRS_IOTHUB_MQTT_WEBSOCKET_TRANSPORT_01_009: [ `getIoTransportProvider` shall obtain the TLS IO interface handle by calling `platform_get_default_tlsio`. ]*/
|
---|
41 | ws_io_config.underlying_io_interface = platform_get_default_tlsio();
|
---|
42 |
|
---|
43 | /* Codes_SRS_IOTHUB_MQTT_WEBSOCKET_TRANSPORT_01_029: [ If `platform_get_default_tlsio` returns NULL, NULL shall be set in the WebSocket IO parameters structure for the interface description and parameters. ]*/
|
---|
44 | if (ws_io_config.underlying_io_interface == NULL)
|
---|
45 | {
|
---|
46 | ws_io_config.underlying_io_parameters = NULL;
|
---|
47 | }
|
---|
48 | else
|
---|
49 | {
|
---|
50 | /* Codes_SRS_IOTHUB_MQTT_WEBSOCKET_TRANSPORT_01_008: [ - `underlying_io_parameters` shall be set to the TLS IO arguments. ]*/
|
---|
51 | /* Codes_SRS_IOTHUB_MQTT_WEBSOCKET_TRANSPORT_01_010: [ The TLS IO parameters shall be a TLSIO_CONFIG structure filled as below: ]*/
|
---|
52 | ws_io_config.underlying_io_parameters = &tls_io_config;
|
---|
53 |
|
---|
54 | /* Codes_SRS_IOTHUB_MQTT_WEBSOCKET_TRANSPORT_01_011: [ - `hostname` shall be set to `fully_qualified_name`. ]*/
|
---|
55 | tls_io_config.hostname = fully_qualified_name;
|
---|
56 | /* Codes_SRS_IOTHUB_MQTT_WEBSOCKET_TRANSPORT_01_012: [ - `port` shall be set to 443. ]*/
|
---|
57 | tls_io_config.port = 443;
|
---|
58 |
|
---|
59 | if (mqtt_transport_proxy_options != NULL)
|
---|
60 | {
|
---|
61 | /* Codes_SRS_IOTHUB_MQTT_WEBSOCKET_TRANSPORT_01_015: [ - If `mqtt_transport_proxy_options` is not NULL, `underlying_io_interface` shall be set to the HTTP proxy IO interface description. ]*/
|
---|
62 | /* Codes_SRS_IOTHUB_MQTT_WEBSOCKET_TRANSPORT_01_022: [ `getIoTransportProvider` shall obtain the HTTP proxy IO interface handle by calling `http_proxy_io_get_interface_description`. ]*/
|
---|
63 | tls_io_config.underlying_io_interface = http_proxy_io_get_interface_description();
|
---|
64 |
|
---|
65 | /* Codes_SRS_IOTHUB_MQTT_WEBSOCKET_TRANSPORT_01_028: [ If `http_proxy_io_get_interface_description` returns NULL, NULL shall be set in the TLS IO parameters structure for the interface description and parameters. ]*/
|
---|
66 | if (tls_io_config.underlying_io_interface == NULL)
|
---|
67 | {
|
---|
68 | tls_io_config.underlying_io_parameters = NULL;
|
---|
69 | }
|
---|
70 | else
|
---|
71 | {
|
---|
72 | /* Codes_SRS_IOTHUB_MQTT_WEBSOCKET_TRANSPORT_01_016: [ - If `mqtt_transport_proxy_options` is not NULL `underlying_io_parameters` shall be set to the HTTP proxy IO arguments. ]*/
|
---|
73 | tls_io_config.underlying_io_parameters = &http_proxy_io_config;
|
---|
74 |
|
---|
75 | /* Codes_SRS_IOTHUB_MQTT_WEBSOCKET_TRANSPORT_01_023: [ The HTTP proxy IO arguments shall be an `HTTP_PROXY_IO_CONFIG` structure, filled as below: ]*/
|
---|
76 | /* Codes_SRS_IOTHUB_MQTT_WEBSOCKET_TRANSPORT_01_026: [ - `proxy_hostname`, `proxy_port`, `username` and `password` shall be copied from the `mqtt_transport_proxy_options` argument. ]*/
|
---|
77 | http_proxy_io_config.proxy_hostname = mqtt_transport_proxy_options->host_address;
|
---|
78 | http_proxy_io_config.proxy_port = mqtt_transport_proxy_options->port;
|
---|
79 | http_proxy_io_config.username = mqtt_transport_proxy_options->username;
|
---|
80 | http_proxy_io_config.password = mqtt_transport_proxy_options->password;
|
---|
81 | /* Codes_SRS_IOTHUB_MQTT_WEBSOCKET_TRANSPORT_01_024: [ - `hostname` shall be set to `fully_qualified_name`. ]*/
|
---|
82 | http_proxy_io_config.hostname = fully_qualified_name;
|
---|
83 | /* Codes_SRS_IOTHUB_MQTT_WEBSOCKET_TRANSPORT_01_025: [ - `port` shall be set to 443. ]*/
|
---|
84 | http_proxy_io_config.port = 443;
|
---|
85 | }
|
---|
86 | }
|
---|
87 | else
|
---|
88 | {
|
---|
89 | /* Codes_SRS_IOTHUB_MQTT_WEBSOCKET_TRANSPORT_01_013: [ - If `mqtt_transport_proxy_options` is NULL, `underlying_io_interface` shall be set to NULL ]*/
|
---|
90 | tls_io_config.underlying_io_interface = NULL;
|
---|
91 | /* Codes_SRS_IOTHUB_MQTT_WEBSOCKET_TRANSPORT_01_014: [ - If `mqtt_transport_proxy_options` is NULL `underlying_io_parameters` shall be set to NULL. ]*/
|
---|
92 | tls_io_config.underlying_io_parameters = NULL;
|
---|
93 | }
|
---|
94 | }
|
---|
95 |
|
---|
96 | /* Codes_SRS_IOTHUB_MQTT_WEBSOCKET_TRANSPORT_07_012: [ `getIoTransportProvider` shall return the `XIO_HANDLE` returned by `xio_create`. ] */
|
---|
97 | /* Codes_SRS_IOTHUB_MQTT_WEBSOCKET_TRANSPORT_01_002: [ `getIoTransportProvider` shall call `xio_create` while passing the WebSocket IO interface description to it and the WebSocket configuration as a WSIO_CONFIG structure, filled as below ]*/
|
---|
98 | result = xio_create(io_interface_description, &ws_io_config);
|
---|
99 | }
|
---|
100 | return result;
|
---|
101 | }
|
---|
102 |
|
---|
103 | /* Codes_SRS_IOTHUB_MQTT_WEBSOCKET_TRANSPORT_07_001: [ IoTHubTransportMqtt_WS_Create shall create a TRANSPORT_LL_HANDLE by calling into the IoTHubMqttAbstract_Create function. ] */
|
---|
104 | static TRANSPORT_LL_HANDLE IoTHubTransportMqtt_WS_Create(const IOTHUBTRANSPORT_CONFIG* config, TRANSPORT_CALLBACKS_INFO* cb_info, void* ctx)
|
---|
105 | {
|
---|
106 | return IoTHubTransport_MQTT_Common_Create(config, getWebSocketsIOTransport, cb_info, ctx);
|
---|
107 | }
|
---|
108 |
|
---|
109 | /* Codes_SRS_IOTHUB_MQTT_WEBSOCKET_TRANSPORT_07_002: [ IoTHubTransportMqtt_WS_Destroy shall destroy the TRANSPORT_LL_HANDLE by calling into the IoTHubMqttAbstract_Destroy function. ] */
|
---|
110 | static void IoTHubTransportMqtt_WS_Destroy(TRANSPORT_LL_HANDLE handle)
|
---|
111 | {
|
---|
112 | IoTHubTransport_MQTT_Common_Destroy(handle);
|
---|
113 | }
|
---|
114 |
|
---|
115 | /* Codes_SRS_IOTHUB_MQTT_WEBSOCKET_TRANSPORT_07_005: [ IoTHubTransportMqtt_WS_Subscribe shall subscribe the TRANSPORT_LL_HANDLE by calling into the IoTHubMqttAbstract_Subscribe function. ] */
|
---|
116 | static int IoTHubTransportMqtt_WS_Subscribe(IOTHUB_DEVICE_HANDLE handle)
|
---|
117 | {
|
---|
118 | return IoTHubTransport_MQTT_Common_Subscribe(handle);
|
---|
119 | }
|
---|
120 |
|
---|
121 | /* Codes_SRS_IOTHUB_MQTT_WEBSOCKET_TRANSPORT_07_006: [ IoTHubTransportMqtt_WS_Unsubscribe shall unsubscribe the TRANSPORT_LL_HANDLE by calling into the IoTHubMqttAbstract_Unsubscribe function. ] */
|
---|
122 | static void IoTHubTransportMqtt_WS_Unsubscribe(IOTHUB_DEVICE_HANDLE handle)
|
---|
123 | {
|
---|
124 | IoTHubTransport_MQTT_Common_Unsubscribe(handle);
|
---|
125 | }
|
---|
126 |
|
---|
127 | /* Codes_SRS_IOTHUB_MQTT_WEBSOCKET_TRANSPORT_07_015: [ IoTHubTransportMqtt_WS_Subscribe_DeviceMethod shall call into the IoTHubTransport_MQTT_Common_Subscribe_DeviceMethod function ] */
|
---|
128 | static int IoTHubTransportMqtt_WS_Subscribe_DeviceMethod(IOTHUB_DEVICE_HANDLE handle)
|
---|
129 | {
|
---|
130 | return IoTHubTransport_MQTT_Common_Subscribe_DeviceMethod(handle);
|
---|
131 | }
|
---|
132 |
|
---|
133 | /* Codes_SRS_IOTHUB_MQTT_WEBSOCKET_TRANSPORT_07_016: [ IoTHubTransportMqtt_WS_Unsubscribe_DeviceMethod shall call into the IoTHubTransport_MQTT_Common_Unsubscribe_DeviceMethod ] */
|
---|
134 | static void IoTHubTransportMqtt_WS_Unsubscribe_DeviceMethod(IOTHUB_DEVICE_HANDLE handle)
|
---|
135 | {
|
---|
136 | IoTHubTransport_MQTT_Common_Unsubscribe_DeviceMethod(handle);
|
---|
137 | }
|
---|
138 |
|
---|
139 | static int IoTHubTransportMqtt_WS_DeviceMethod_Response(IOTHUB_DEVICE_HANDLE handle, METHOD_HANDLE methodId, const unsigned char* response, size_t response_size, int status_response)
|
---|
140 | {
|
---|
141 | return IoTHubTransport_MQTT_Common_DeviceMethod_Response(handle, methodId, response, response_size, status_response);
|
---|
142 | }
|
---|
143 |
|
---|
144 | /* Codes_SRS_IOTHUB_MQTT_WEBSOCKET_TRANSPORT_07_017: [ IoTHubTransportMqtt_WS_Subscribe_DeviceTwin shall call into the IoTHubTransport_MQTT_Common_Subscribe_DeviceTwin ] */
|
---|
145 | static int IoTHubTransportMqtt_WS_Subscribe_DeviceTwin(IOTHUB_DEVICE_HANDLE handle)
|
---|
146 | {
|
---|
147 | return IoTHubTransport_MQTT_Common_Subscribe_DeviceTwin(handle);
|
---|
148 | }
|
---|
149 |
|
---|
150 | /* Codes_SRS_IOTHUB_MQTT_WEBSOCKET_TRANSPORT_07_018: [ IoTHubTransportMqtt_WS_Unsubscribe_DeviceTwin shall call into the IoTHubTransport_MQTT_Common_Unsubscribe_DeviceTwin ] */
|
---|
151 | static void IoTHubTransportMqtt_WS_Unsubscribe_DeviceTwin(IOTHUB_DEVICE_HANDLE handle)
|
---|
152 | {
|
---|
153 | IoTHubTransport_MQTT_Common_Unsubscribe_DeviceTwin(handle);
|
---|
154 | }
|
---|
155 |
|
---|
156 | // Codes_SRS_IOTHUB_MQTT_WEBSOCKET_TRANSPORT_09_001: [ IoTHubTransportMqtt_WS_GetTwinAsync shall call into the IoTHubTransport_MQTT_Common_GetTwinAsync ]
|
---|
157 | static IOTHUB_CLIENT_RESULT IoTHubTransportMqtt_WS_GetTwinAsync(IOTHUB_DEVICE_HANDLE handle, IOTHUB_CLIENT_DEVICE_TWIN_CALLBACK completionCallback, void* callbackContext)
|
---|
158 | {
|
---|
159 | return IoTHubTransport_MQTT_Common_GetTwinAsync(handle, completionCallback, callbackContext);
|
---|
160 | }
|
---|
161 |
|
---|
162 | /* Codes_SRS_IOTHUB_MQTT_WEBSOCKET_TRANSPORT_07_014: [ IoTHubTransportMqtt_WS_ProcessItem shall call into the IoTHubTransport_MQTT_Common_DoWork function ] */
|
---|
163 | static IOTHUB_PROCESS_ITEM_RESULT IoTHubTransportMqtt_WS_ProcessItem(TRANSPORT_LL_HANDLE handle, IOTHUB_IDENTITY_TYPE item_type, IOTHUB_IDENTITY_INFO* iothub_item)
|
---|
164 | {
|
---|
165 | return IoTHubTransport_MQTT_Common_ProcessItem(handle, item_type, iothub_item);
|
---|
166 | }
|
---|
167 |
|
---|
168 | /* Codes_SRS_IOTHUB_MQTT_WEBSOCKET_TRANSPORT_07_007: [ IoTHubTransportMqtt_WS_DoWork shall call into the IoTHubMqttAbstract_DoWork function. ] */
|
---|
169 | static void IoTHubTransportMqtt_WS_DoWork(TRANSPORT_LL_HANDLE handle)
|
---|
170 | {
|
---|
171 | IoTHubTransport_MQTT_Common_DoWork(handle);
|
---|
172 | }
|
---|
173 |
|
---|
174 | /* Codes_SRS_IOTHUB_MQTT_WEBSOCKET_TRANSPORT_07_008: [ IoTHubTransportMqtt_WS_GetSendStatus shall get the send status by calling into the IoTHubMqttAbstract_GetSendStatus function. ] */
|
---|
175 | static IOTHUB_CLIENT_RESULT IoTHubTransportMqtt_WS_GetSendStatus(IOTHUB_DEVICE_HANDLE handle, IOTHUB_CLIENT_STATUS *iotHubClientStatus)
|
---|
176 | {
|
---|
177 | return IoTHubTransport_MQTT_Common_GetSendStatus(handle, iotHubClientStatus);
|
---|
178 | }
|
---|
179 |
|
---|
180 | /* Codes_SRS_IOTHUB_MQTT_WEBSOCKET_TRANSPORT_07_009: [ IoTHubTransportMqtt_WS_SetOption shall set the options by calling into the IoTHubMqttAbstract_SetOption function. ] */
|
---|
181 | static IOTHUB_CLIENT_RESULT IoTHubTransportMqtt_WS_SetOption(TRANSPORT_LL_HANDLE handle, const char* option, const void* value)
|
---|
182 | {
|
---|
183 | return IoTHubTransport_MQTT_Common_SetOption(handle, option, value);
|
---|
184 | }
|
---|
185 |
|
---|
186 | /* Codes_SRS_IOTHUB_MQTT_WEBSOCKET_TRANSPORT_07_003: [ IoTHubTransportMqtt_WS_Register shall register the TRANSPORT_LL_HANDLE by calling into the IoTHubMqttAbstract_Register function. ]*/
|
---|
187 | static IOTHUB_DEVICE_HANDLE IoTHubTransportMqtt_WS_Register(TRANSPORT_LL_HANDLE handle, const IOTHUB_DEVICE_CONFIG* device, PDLIST_ENTRY waitingToSend)
|
---|
188 | {
|
---|
189 | return IoTHubTransport_MQTT_Common_Register(handle, device, waitingToSend);
|
---|
190 | }
|
---|
191 |
|
---|
192 | /* Codes_SRS_IOTHUB_MQTT_WEBSOCKET_TRANSPORT_07_004: [ IoTHubTransportMqtt_WS_Unregister shall register the TRANSPORT_LL_HANDLE by calling into the IoTHubMqttAbstract_Unregister function. ] */
|
---|
193 | static void IoTHubTransportMqtt_WS_Unregister(IOTHUB_DEVICE_HANDLE deviceHandle)
|
---|
194 | {
|
---|
195 | IoTHubTransport_MQTT_Common_Unregister(deviceHandle);
|
---|
196 | }
|
---|
197 |
|
---|
198 | /* Codes_SRS_IOTHUB_MQTT_WEBSOCKET_TRANSPORT_07_010: [ IoTHubTransportMqtt_WS_GetHostname shall get the hostname by calling into the IoTHubMqttAbstract_GetHostname function. ] */
|
---|
199 | static STRING_HANDLE IoTHubTransportMqtt_WS_GetHostname(TRANSPORT_LL_HANDLE handle)
|
---|
200 | {
|
---|
201 | return IoTHubTransport_MQTT_Common_GetHostname(handle);
|
---|
202 | }
|
---|
203 |
|
---|
204 | static int IoTHubTransportMqtt_WS_SetRetryPolicy(TRANSPORT_LL_HANDLE handle, IOTHUB_CLIENT_RETRY_POLICY retryPolicy, size_t retryTimeoutLimitinSeconds)
|
---|
205 | {
|
---|
206 | /* Codes_SRS_IOTHUB_MQTT_WEBSOCKET_TRANSPORT_25_012: [** IoTHubTransportMqtt_WS_SetRetryPolicy shall call into the IoTHubMqttAbstract_SetRetryPolicy function.]*/
|
---|
207 | return IoTHubTransport_MQTT_Common_SetRetryPolicy(handle, retryPolicy, retryTimeoutLimitinSeconds);
|
---|
208 | }
|
---|
209 |
|
---|
210 | static IOTHUB_CLIENT_RESULT IoTHubTransportMqtt_WS_SendMessageDisposition(MESSAGE_CALLBACK_INFO* message_data, IOTHUBMESSAGE_DISPOSITION_RESULT disposition)
|
---|
211 | {
|
---|
212 | /* Codes_SRS_IOTHUB_MQTT_WEBSOCKET_TRANSPORT_10_001: [IoTHubTransportMqtt_WS_SendMessageDisposition shall send the message disposition by calling into the IoTHubTransport_MQTT_Common_SendMessageDisposition()]*/
|
---|
213 | return IoTHubTransport_MQTT_Common_SendMessageDisposition(message_data, disposition);
|
---|
214 | }
|
---|
215 |
|
---|
216 | static int IoTHubTransportMqtt_WS_Subscribe_InputQueue(IOTHUB_DEVICE_HANDLE handle)
|
---|
217 | {
|
---|
218 | (void)handle;
|
---|
219 | LogError("IoTHubTransportMqtt_WS_Subscribe_InputQueue not implemented\n");
|
---|
220 | return MU_FAILURE;
|
---|
221 | }
|
---|
222 |
|
---|
223 | static void IoTHubTransportMqtt_WS_Unsubscribe_InputQueue(IOTHUB_DEVICE_HANDLE handle)
|
---|
224 | {
|
---|
225 | LogError("IoTHubTransportMqtt_WS_Unsubscribe_InputQueue not implemented\n");
|
---|
226 | (void)handle;
|
---|
227 | }
|
---|
228 |
|
---|
229 | static int IotHubTransportMqtt_WS_SetCallbackContext(TRANSPORT_LL_HANDLE handle, void* ctx)
|
---|
230 | {
|
---|
231 | return IoTHubTransport_MQTT_SetCallbackContext(handle, ctx);
|
---|
232 | }
|
---|
233 |
|
---|
234 | /* Codes_SRS_IOTHUB_MQTT_WEBSOCKET_TRANSPORT_07_011: [ This function shall return a pointer to a structure of type TRANSPORT_PROVIDER having the following values for its fields:
|
---|
235 | IoTHubTransport_SendMessageDisposition = IoTHubTransport_WS_SendMessageDisposition
|
---|
236 | IoTHubTransport_Subscribe_DeviceMethod = IoTHubTransport_WS_Subscribe_DeviceMethod
|
---|
237 | IoTHubTransport_Unsubscribe_DeviceMethod IoTHubTransport_WS_Unsubscribe_DeviceMethod
|
---|
238 | IoTHubTransport_Subscribe_DeviceTwin IoTHubTransport_WS_Subscribe_DeviceTwin
|
---|
239 | IoTHubTransport_Unsubscribe_DeviceTwin IoTHubTransport_WS_Unsubscribe_DeviceTwin
|
---|
240 | IoTHubTransport_GetHostname = IoTHubTransportMqtt_WS_GetHostname
|
---|
241 | IoTHubTransport_Create = IoTHubTransportMqtt_WS_Create
|
---|
242 | IoTHubTransport_Destroy = IoTHubTransportMqtt_WS_Destroy
|
---|
243 | IoTHubTransport_Subscribe = IoTHubTransportMqtt_WS_Subscribe
|
---|
244 | IoTHubTransport_Unsubscribe = IoTHubTransportMqtt_WS_Unsubscribe
|
---|
245 | IoTHubTransport_DoWork = IoTHubTransportMqtt_WS_DoWork
|
---|
246 | IoTHubTransport_SetOption = IoTHubTransportMqtt_WS_SetOption ] */
|
---|
247 | static TRANSPORT_PROVIDER thisTransportProvider_WebSocketsOverTls = {
|
---|
248 | IoTHubTransportMqtt_WS_SendMessageDisposition,
|
---|
249 | IoTHubTransportMqtt_WS_Subscribe_DeviceMethod,
|
---|
250 | IoTHubTransportMqtt_WS_Unsubscribe_DeviceMethod,
|
---|
251 | IoTHubTransportMqtt_WS_DeviceMethod_Response,
|
---|
252 | IoTHubTransportMqtt_WS_Subscribe_DeviceTwin,
|
---|
253 | IoTHubTransportMqtt_WS_Unsubscribe_DeviceTwin,
|
---|
254 | IoTHubTransportMqtt_WS_ProcessItem,
|
---|
255 | IoTHubTransportMqtt_WS_GetHostname,
|
---|
256 | IoTHubTransportMqtt_WS_SetOption,
|
---|
257 | IoTHubTransportMqtt_WS_Create,
|
---|
258 | IoTHubTransportMqtt_WS_Destroy,
|
---|
259 | IoTHubTransportMqtt_WS_Register,
|
---|
260 | IoTHubTransportMqtt_WS_Unregister,
|
---|
261 | IoTHubTransportMqtt_WS_Subscribe,
|
---|
262 | IoTHubTransportMqtt_WS_Unsubscribe,
|
---|
263 | IoTHubTransportMqtt_WS_DoWork,
|
---|
264 | IoTHubTransportMqtt_WS_SetRetryPolicy,
|
---|
265 | IoTHubTransportMqtt_WS_GetSendStatus,
|
---|
266 | IoTHubTransportMqtt_WS_Subscribe_InputQueue,
|
---|
267 | IoTHubTransportMqtt_WS_Unsubscribe_InputQueue,
|
---|
268 | IotHubTransportMqtt_WS_SetCallbackContext,
|
---|
269 | IoTHubTransportMqtt_WS_GetTwinAsync
|
---|
270 | };
|
---|
271 |
|
---|
272 | const TRANSPORT_PROVIDER* MQTT_WebSocket_Protocol(void)
|
---|
273 | {
|
---|
274 | return &thisTransportProvider_WebSocketsOverTls;
|
---|
275 | }
|
---|