aws_iot_defender_internal.h

/*
 * AWS IoT Defender V3.0.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 AWS_IOT_DEFENDER_INTERNAL_H_
#define AWS_IOT_DEFENDER_INTERNAL_H_

/* The config header is always included first. */
#include "iot_config.h"

/* Defender include. */
#include "aws_iot_defender.h"

/* Serializer include. */
#include "iot_serializer.h"

/* Platform thread include. */
#include "platform/iot_threads.h"

/* Double linked list include. */
#include "iot_linear_containers.h"

#if AWS_IOT_DEFENDER_ENABLE_ASSERTS == 1
    #ifndef AwsIotDefender_Assert
        #ifdef Iot_DefaultAssert
            #define AwsIotDefender_Assert( expression )    Iot_DefaultAssert( expression )
        #else
            #error "Asserts are enabled for Defender, but AwsIotDefender_Assert is not defined"
        #endif
    #endif
#else /* if AWS_IOT_DEFENDER_ENABLE_ASSERTS == 1 */
    #define AwsIotDefender_Assert( expression )
#endif /* if AWS_IOT_DEFENDER_ENABLE_ASSERTS == 1 */

/* Configure logs for Defender functions. */
#ifdef AWS_IOT_LOG_LEVEL_DEFENDER
    #define LIBRARY_LOG_LEVEL        AWS_IOT_LOG_LEVEL_DEFENDER
#else
    #ifdef AWS_IOT_LOG_LEVEL_GLOBAL
        #define LIBRARY_LOG_LEVEL    IOT_LOG_LEVEL_GLOBAL
    #else
        #define LIBRARY_LOG_LEVEL    IOT_LOG_NONE
    #endif
#endif

#define LIBRARY_LOG_NAME    ( "Defender" )
#include "iot_logging_setup.h"

/*
 * Provide default values for undefined memory allocation functions based on
 * the usage of dynamic memory allocation.
 */
#if IOT_STATIC_MEMORY_ONLY == 1
    #include "iot_static_memory.h"

    #define AwsIotDefender_MallocReport    Iot_MallocMessageBuffer

    #define AwsIotDefender_FreeReport      Iot_FreeMessageBuffer

    #define AwsIotDefender_MallocTopic     Iot_MallocMessageBuffer

    #define AwsIotDefender_FreeTopic       Iot_FreeMessageBuffer
#else /* if IOT_STATIC_MEMORY_ONLY */
    #ifndef AwsIotDefender_MallocReport
        #ifdef Iot_DefaultMalloc
            #define AwsIotDefender_MallocReport    Iot_DefaultMalloc
        #else
            #error "No malloc function defined for AwsIotDefender_MallocReport"
        #endif
    #endif

    #ifndef AwsIotDefender_FreeReport
        #ifdef Iot_DefaultFree
            #define AwsIotDefender_FreeReport    Iot_DefaultFree
        #else
            #error "No free function defined for AwsIotDefender_FreeReport"
        #endif
    #endif

    #ifndef AwsIotDefender_MallocTopic
        #ifdef Iot_DefaultMalloc
            #define AwsIotDefender_MallocTopic    Iot_DefaultMalloc
        #else
            #error "No malloc function defined for AwsIotDefender_MallocTopic"
        #endif
    #endif

    #ifndef AwsIotDefender_FreeTopic
        #ifdef Iot_DefaultFree
            #define AwsIotDefender_FreeTopic    Iot_DefaultFree
        #else
            #error "No free function defined for AwsIotDefender_FreeTopic"
        #endif
    #endif
#endif /* if IOT_STATIC_MEMORY_ONLY */

#ifndef AWS_IOT_DEFENDER_DEFAULT_PERIOD_SECONDS
    #define AWS_IOT_DEFENDER_DEFAULT_PERIOD_SECONDS    ( 300 )
#endif

#ifndef AWS_IOT_DEFENDER_WAIT_SERVER_MAX_SECONDS
    #define AWS_IOT_DEFENDER_WAIT_SERVER_MAX_SECONDS    ( 3 )
#endif

#ifndef AWS_IOT_DEFENDER_MQTT_CONNECT_TIMEOUT_SECONDS
    #define AWS_IOT_DEFENDER_MQTT_CONNECT_TIMEOUT_SECONDS    ( 10U )
#endif

#ifndef AWS_IOT_DEFENDER_MQTT_SUBSCRIBE_TIMEOUT_SECONDS
    #define AWS_IOT_DEFENDER_MQTT_SUBSCRIBE_TIMEOUT_SECONDS    ( 10U )
#endif

#ifndef AWS_IOT_DEFENDER_MQTT_PUBLISH_TIMEOUT_SECONDS
    #define AWS_IOT_DEFENDER_MQTT_PUBLISH_TIMEOUT_SECONDS    ( 10U )
#endif

#ifndef AWS_IOT_DEFENDER_FORMAT
    #define AWS_IOT_DEFENDER_FORMAT    AWS_IOT_DEFENDER_FORMAT_CBOR
#endif

/* In current release, JSON format is not supported. */
#if AWS_IOT_DEFENDER_FORMAT == AWS_IOT_DEFENDER_FORMAT_JSON
    #error "AWS_IOT_DEFENDER_FORMAT_JSON is not supported."
#endif

/* Default to short tag to save memory and network. */
#ifndef AWS_IOT_DEFENDER_USE_LONG_TAG
    #define AWS_IOT_DEFENDER_USE_LONG_TAG    ( 0 )
#endif

/*----------------- Below this line is INTERNAL used only --------------------*/

/* This MUST be consistent with enum AwsIotDefenderMetricsGroup_t. */
#define DEFENDER_METRICS_GROUP_COUNT    1

#if AWS_IOT_DEFENDER_FORMAT == AWS_IOT_DEFENDER_FORMAT_CBOR
    #define DEFENDER_FORMAT    "cbor"
#else /* if AWS_IOT_DEFENDER_FORMAT == AWS_IOT_DEFENDER_FORMAT_CBOR */
    #error "AWS_IOT_DEFENDER_FORMAT must be AWS_IOT_DEFENDER_FORMAT_CBOR."
#endif /* if AWS_IOT_DEFENDER_FORMAT == AWS_IOT_DEFENDER_FORMAT_CBOR */

#if  AWS_IOT_DEFENDER_USE_LONG_TAG == 1
    #define AwsIotDefenderInternal_SelectTag( long_tag, short_tag )    ( long_tag )
#else
    #define AwsIotDefenderInternal_SelectTag( long_tag, short_tag )    ( short_tag )
#endif

#define _defenderToMilliseconds( secondValue )    ( secondValue ) * 1000
#define _defenderToSeconds( millisecondValue ) \
    ( millisecondValue ) / 1000                \


typedef struct _defenderMetrics
{
    uint32_t metricsFlag[ DEFENDER_METRICS_GROUP_COUNT ];

    IotMutex_t mutex;
} _defenderMetrics_t;

bool AwsIotDefenderInternal_CreateReport( void );

uint8_t * AwsIotDefenderInternal_GetReportBuffer( void );

size_t AwsIotDefenderInternal_GetReportBufferSize( void );

void AwsIotDefenderInternal_DeleteReport( void );

AwsIotDefenderError_t AwsIotDefenderInternal_BuildTopicsNames( void );

void AwsIotDefenderInternal_DeleteTopicsNames( void );

IotMqttError_t AwsIotDefenderInternal_MqttSubscribe( void );

IotMqttError_t AwsIotDefenderInternal_MqttPublish( uint8_t * pData,
                                                   size_t dataLength );

IotMqttError_t AwsIotDefenderInternal_MqttUnSubscribe( void );

void AwsIotDefenderInternal_MqttDisconnect( void );

/*----------------- Below this line are INTERNAL global variables --------------------*/

extern _defenderMetrics_t _AwsIotDefenderMetrics;

extern const IotSerializerEncodeInterface_t * _pAwsIotDefenderEncoder;
extern const IotSerializerDecodeInterface_t * _pAwsIotDefenderDecoder;

#endif /* ifndef AWS_IOT_DEFENDER_INTERNAL_H_ */