iot_test_access_mqtt.h

Go to the documentation of this file.

/*
 * IoT MQTT V2.1.0
 * Copyright (C) 2018 Amazon.com, Inc. or its affiliates.  All Rights Reserved.
 *
 * Permission is hereby granted, free of charge, to any person obtaining a copy of
 * this software and associated documentation files (the "Software"), to deal in
 * the Software without restriction, including without limitation the rights to
 * use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of
 * the Software, and to permit persons to whom the Software is furnished to do so,
 * subject to the following conditions:
 *
 * The above copyright notice and this permission notice shall be included in all
 * copies or substantial portions of the Software.
 *
 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS
 * FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR
 * COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER
 * IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
 * CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
 */

#ifndef IOT_TEST_ACCESS_MQTT_H_
#define IOT_TEST_ACCESS_MQTT_H_

/*--------------------------- iot_mqtt_api.c ---------------------------*/

_mqttConnection_t * IotTestMqtt_createMqttConnection( bool awsIotMqttMode,
                                                      const IotMqttNetworkInfo_t * pNetworkInfo,
                                                      uint16_t keepAliveSeconds );

IotMqttError_t IotTestMqtt_scheduleKeepAlive( IotMqttConnection_t pMqttConnection );

/*-------------------------- iot_mqtt_network.c -------------------------*/

void IotTestMqtt_sendPuback( _mqttConnection_t * pMqttConnection,
                             uint16_t packetIdentifier );

/*------------------------- iot_mqtt_serialize.c ------------------------*/

/*
 * Macros for reading the high and low byte of a 2-byte unsigned int.
 */
#define UINT16_HIGH_BYTE( x )    ( ( uint8_t ) ( x >> 8 ) )            
#define UINT16_LOW_BYTE( x )     ( ( uint8_t ) ( x & 0x00ff ) )        
#define UINT16_DECODE( ptr )                                \
    ( uint16_t ) ( ( ( ( uint16_t ) ( *( ptr ) ) ) << 8 ) | \
                   ( ( uint16_t ) ( *( ptr + 1 ) ) ) )

/*----------------------- iot_mqtt_subscription.c -----------------------*/

/* Internal data structures of iot_mqtt_subscription.c, redefined for the tests. */
typedef struct _topicMatchParams
{
    const char * pTopicName;
    uint16_t topicNameLength;
    bool exactMatchOnly;
} _topicMatchParams_t;
typedef struct _packetMatchParams
{
    uint16_t packetIdentifier;
    int32_t order;
} _packetMatchParams_t;

bool IotTestMqtt_topicMatch( const IotLink_t * pSubscriptionLink,
                             void * pMatch );

bool IotTestMqtt_packetMatch( const IotLink_t * pSubscriptionLink,
                              void * pMatch );

#endif /* ifndef IOT_TEST_ACCESS_MQTT_H_ */