2021-11-30 14:51:24 +01:00

822 lines
34 KiB
C

/*
* AWS IoT Device Defender Client v1.2.0
* Copyright (C) 2020 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.
*/
/**
* @file defender_utest.c
* @brief Unit tests for the Device Defender library.
*/
/* Standard includes. */
#include <string.h>
/* Test framework include. */
#include "unity.h"
/* Defender API include. */
#include "defender.h"
/* Thing name used in the tests. */
#define TEST_THING_NAME "TestThing"
#define TEST_THING_NAME_LENGTH STRING_LITERAL_LENGTH( TEST_THING_NAME )
/* Topics used in the tests. */
#define TEST_JSON_PUBLISH_TOPIC "$aws/things/" TEST_THING_NAME "/defender/metrics/json"
#define TEST_JSON_PUBLISH_TOPIC_LENGTH STRING_LITERAL_LENGTH( TEST_JSON_PUBLISH_TOPIC )
#define TEST_JSON_ACCEPTED_TOPIC "$aws/things/" TEST_THING_NAME "/defender/metrics/json/accepted"
#define TEST_JSON_ACCEPTED_TOPIC_LENGTH STRING_LITERAL_LENGTH( TEST_JSON_ACCEPTED_TOPIC )
#define TEST_JSON_REJECTED_TOPIC "$aws/things/" TEST_THING_NAME "/defender/metrics/json/rejected"
#define TEST_JSON_REJECTED_TOPIC_LENGTH STRING_LITERAL_LENGTH( TEST_JSON_REJECTED_TOPIC )
#define TEST_CBOR_PUBLISH_TOPIC "$aws/things/" TEST_THING_NAME "/defender/metrics/cbor"
#define TEST_CBOR_PUBLISH_TOPIC_LENGTH STRING_LITERAL_LENGTH( TEST_CBOR_PUBLISH_TOPIC )
#define TEST_CBOR_ACCEPTED_TOPIC "$aws/things/" TEST_THING_NAME "/defender/metrics/cbor/accepted"
#define TEST_CBOR_ACCEPTED_TOPIC_LENGTH STRING_LITERAL_LENGTH( TEST_CBOR_ACCEPTED_TOPIC )
#define TEST_CBOR_REJECTED_TOPIC "$aws/things/" TEST_THING_NAME "/defender/metrics/cbor/rejected"
#define TEST_CBOR_REJECTED_TOPIC_LENGTH STRING_LITERAL_LENGTH( TEST_CBOR_REJECTED_TOPIC )
/* Length of the topic buffer used in tests. Guard buffers are placed before and
* after the topic buffer to verify that defender APIs do not write out of
* bounds. The memory layout is:
*
* +--------------+-------------------------------+------------+
* | Guard | Writable Topic Buffer | Guard |
* +--------------+-------------------------------+------------+
*
* Both guard buffers are filled with a known pattern before each test and are
* verified to remain unchanged after each test.
*/
#define TEST_TOPIC_BUFFER_PREFIX_GUARD_LENGTH 32
#define TEST_TOPIC_BUFFER_WRITABLE_LENGTH 256
#define TEST_TOPIC_BUFFER_SUFFIX_GUARD_LENGTH 32
#define TEST_TOPIC_BUFFER_TOTAL_LENGTH \
( TEST_TOPIC_BUFFER_PREFIX_GUARD_LENGTH + \
TEST_TOPIC_BUFFER_WRITABLE_LENGTH + \
TEST_TOPIC_BUFFER_SUFFIX_GUARD_LENGTH )
/*-----------------------------------------------------------*/
/**
* @brief Topic buffer used in tests.
*/
static char testTopicBuffer[ TEST_TOPIC_BUFFER_TOTAL_LENGTH ];
/*-----------------------------------------------------------*/
/* ============================ UNITY FIXTURES ============================ */
/* Called before each test method. */
void setUp()
{
/* Initialize the topic buffer with 0xA5. */
memset( &( testTopicBuffer[ 0 ] ), 0xA5, TEST_TOPIC_BUFFER_TOTAL_LENGTH );
}
/* Called after each test method. */
void tearDown()
{
/* Prefix and Suffix guard buffers must never change. */
TEST_ASSERT_EACH_EQUAL_HEX8( 0xA5,
&( testTopicBuffer[ 0 ] ),
TEST_TOPIC_BUFFER_PREFIX_GUARD_LENGTH );
TEST_ASSERT_EACH_EQUAL_HEX8( 0xA5,
&( testTopicBuffer[ TEST_TOPIC_BUFFER_PREFIX_GUARD_LENGTH +
TEST_TOPIC_BUFFER_WRITABLE_LENGTH ] ),
TEST_TOPIC_BUFFER_SUFFIX_GUARD_LENGTH );
}
/* Called at the beginning of the whole suite. */
void suiteSetUp()
{
}
/* Called at the end of the whole suite. */
int suiteTearDown( int numFailures )
{
return numFailures;
}
/*-----------------------------------------------------------*/
/**
* @brief Test that macros generates expected strings.
*/
void test_Defender_MacrosString( void )
{
TEST_ASSERT_EQUAL_STRING_LEN( TEST_JSON_PUBLISH_TOPIC,
DEFENDER_API_JSON_PUBLISH( TEST_THING_NAME ),
TEST_JSON_PUBLISH_TOPIC_LENGTH );
TEST_ASSERT_EQUAL_STRING_LEN( TEST_JSON_ACCEPTED_TOPIC,
DEFENDER_API_JSON_ACCEPTED( TEST_THING_NAME ),
TEST_JSON_ACCEPTED_TOPIC_LENGTH );
TEST_ASSERT_EQUAL_STRING_LEN( TEST_JSON_REJECTED_TOPIC,
DEFENDER_API_JSON_REJECTED( TEST_THING_NAME ),
TEST_JSON_REJECTED_TOPIC_LENGTH );
TEST_ASSERT_EQUAL_STRING_LEN( TEST_CBOR_PUBLISH_TOPIC,
DEFENDER_API_CBOR_PUBLISH( TEST_THING_NAME ),
TEST_CBOR_PUBLISH_TOPIC_LENGTH );
TEST_ASSERT_EQUAL_STRING_LEN( TEST_CBOR_ACCEPTED_TOPIC,
DEFENDER_API_CBOR_ACCEPTED( TEST_THING_NAME ),
TEST_CBOR_ACCEPTED_TOPIC_LENGTH );
TEST_ASSERT_EQUAL_STRING_LEN( TEST_CBOR_REJECTED_TOPIC,
DEFENDER_API_CBOR_REJECTED( TEST_THING_NAME ),
TEST_CBOR_REJECTED_TOPIC_LENGTH );
}
/*-----------------------------------------------------------*/
/**
* @brief Test that macros generates expected string lengths.
*/
void test_Defender_MacrosLength( void )
{
TEST_ASSERT_EQUAL( TEST_JSON_PUBLISH_TOPIC_LENGTH,
DEFENDER_API_LENGTH_JSON_PUBLISH( TEST_THING_NAME_LENGTH ) );
TEST_ASSERT_EQUAL( TEST_JSON_ACCEPTED_TOPIC_LENGTH,
DEFENDER_API_LENGTH_JSON_ACCEPTED( TEST_THING_NAME_LENGTH ) );
TEST_ASSERT_EQUAL( TEST_JSON_REJECTED_TOPIC_LENGTH,
DEFENDER_API_LENGTH_JSON_REJECTED( TEST_THING_NAME_LENGTH ) );
TEST_ASSERT_EQUAL( TEST_CBOR_PUBLISH_TOPIC_LENGTH,
DEFENDER_API_LENGTH_CBOR_PUBLISH( TEST_THING_NAME_LENGTH ) );
TEST_ASSERT_EQUAL( TEST_CBOR_ACCEPTED_TOPIC_LENGTH,
DEFENDER_API_LENGTH_CBOR_ACCEPTED( TEST_THING_NAME_LENGTH ) );
TEST_ASSERT_EQUAL( TEST_CBOR_REJECTED_TOPIC_LENGTH,
DEFENDER_API_LENGTH_CBOR_REJECTED( TEST_THING_NAME_LENGTH ) );
}
/*-----------------------------------------------------------*/
void test_Defender_GetTopic_BadParams( void )
{
DefenderStatus_t ret;
uint16_t topicLength;
/* Null buffer. */
ret = Defender_GetTopic( NULL,
TEST_TOPIC_BUFFER_WRITABLE_LENGTH,
TEST_THING_NAME,
TEST_THING_NAME_LENGTH,
DefenderJsonReportPublish,
&( topicLength ) );
TEST_ASSERT_EQUAL( DefenderBadParameter, ret );
TEST_ASSERT_EACH_EQUAL_HEX8( 0xA5,
&( testTopicBuffer[ TEST_TOPIC_BUFFER_PREFIX_GUARD_LENGTH ] ),
TEST_TOPIC_BUFFER_WRITABLE_LENGTH );
/* NULL thing name. */
ret = Defender_GetTopic( &( testTopicBuffer[ TEST_TOPIC_BUFFER_PREFIX_GUARD_LENGTH ] ),
TEST_TOPIC_BUFFER_WRITABLE_LENGTH,
NULL,
TEST_THING_NAME_LENGTH,
DefenderJsonReportPublish,
&( topicLength ) );
TEST_ASSERT_EQUAL( DefenderBadParameter, ret );
TEST_ASSERT_EACH_EQUAL_HEX8( 0xA5,
&( testTopicBuffer[ TEST_TOPIC_BUFFER_PREFIX_GUARD_LENGTH ] ),
TEST_TOPIC_BUFFER_WRITABLE_LENGTH );
/* Zero length thing name. */
ret = Defender_GetTopic( &( testTopicBuffer[ TEST_TOPIC_BUFFER_PREFIX_GUARD_LENGTH ] ),
TEST_TOPIC_BUFFER_WRITABLE_LENGTH,
TEST_THING_NAME,
0,
DefenderJsonReportPublish,
&( topicLength ) );
TEST_ASSERT_EQUAL( DefenderBadParameter, ret );
TEST_ASSERT_EACH_EQUAL_HEX8( 0xA5,
&( testTopicBuffer[ TEST_TOPIC_BUFFER_PREFIX_GUARD_LENGTH ] ),
TEST_TOPIC_BUFFER_WRITABLE_LENGTH );
/* Thing name length more than the maximum allowed. */
ret = Defender_GetTopic( &( testTopicBuffer[ TEST_TOPIC_BUFFER_PREFIX_GUARD_LENGTH ] ),
TEST_TOPIC_BUFFER_WRITABLE_LENGTH,
TEST_THING_NAME,
DEFENDER_THINGNAME_MAX_LENGTH + 1,
DefenderJsonReportPublish,
&( topicLength ) );
TEST_ASSERT_EQUAL( DefenderBadParameter, ret );
TEST_ASSERT_EACH_EQUAL_HEX8( 0xA5,
&( testTopicBuffer[ TEST_TOPIC_BUFFER_PREFIX_GUARD_LENGTH ] ),
TEST_TOPIC_BUFFER_WRITABLE_LENGTH );
/* Invalid api. */
ret = Defender_GetTopic( &( testTopicBuffer[ TEST_TOPIC_BUFFER_PREFIX_GUARD_LENGTH ] ),
TEST_TOPIC_BUFFER_WRITABLE_LENGTH,
TEST_THING_NAME,
TEST_THING_NAME_LENGTH,
DefenderInvalidTopic,
&( topicLength ) );
TEST_ASSERT_EQUAL( DefenderBadParameter, ret );
TEST_ASSERT_EACH_EQUAL_HEX8( 0xA5,
&( testTopicBuffer[ TEST_TOPIC_BUFFER_PREFIX_GUARD_LENGTH ] ),
TEST_TOPIC_BUFFER_WRITABLE_LENGTH );
/* Invalid api. */
ret = Defender_GetTopic( &( testTopicBuffer[ TEST_TOPIC_BUFFER_PREFIX_GUARD_LENGTH ] ),
TEST_TOPIC_BUFFER_WRITABLE_LENGTH,
TEST_THING_NAME,
TEST_THING_NAME_LENGTH,
DefenderMaxTopic,
&( topicLength ) );
TEST_ASSERT_EQUAL( DefenderBadParameter, ret );
TEST_ASSERT_EACH_EQUAL_HEX8( 0xA5,
&( testTopicBuffer[ TEST_TOPIC_BUFFER_PREFIX_GUARD_LENGTH ] ),
TEST_TOPIC_BUFFER_WRITABLE_LENGTH );
/* NULL output parameter. */
ret = Defender_GetTopic( &( testTopicBuffer[ TEST_TOPIC_BUFFER_PREFIX_GUARD_LENGTH ] ),
TEST_TOPIC_BUFFER_WRITABLE_LENGTH,
TEST_THING_NAME,
TEST_THING_NAME_LENGTH,
DefenderJsonReportPublish,
NULL );
TEST_ASSERT_EQUAL( DefenderBadParameter, ret );
TEST_ASSERT_EACH_EQUAL_HEX8( 0xA5,
&( testTopicBuffer[ TEST_TOPIC_BUFFER_PREFIX_GUARD_LENGTH ] ),
TEST_TOPIC_BUFFER_WRITABLE_LENGTH );
}
/*-----------------------------------------------------------*/
void test_Defender_GetTopic_BufferTooSmall( void )
{
DefenderStatus_t ret;
uint16_t topicLength;
ret = Defender_GetTopic( &( testTopicBuffer[ TEST_TOPIC_BUFFER_PREFIX_GUARD_LENGTH ] ),
5, /* Length too small to fit the entire topic. */
TEST_THING_NAME,
TEST_THING_NAME_LENGTH,
DefenderJsonReportPublish,
&( topicLength ) );
TEST_ASSERT_EQUAL( DefenderBufferTooSmall, ret );
TEST_ASSERT_EACH_EQUAL_HEX8( 0xA5,
&( testTopicBuffer[ TEST_TOPIC_BUFFER_PREFIX_GUARD_LENGTH ] ),
TEST_TOPIC_BUFFER_WRITABLE_LENGTH );
}
/*-----------------------------------------------------------*/
void test_Defender_GetTopic_JsonPublishHappyPath( void )
{
DefenderStatus_t ret;
uint16_t topicLength;
ret = Defender_GetTopic( &( testTopicBuffer[ TEST_TOPIC_BUFFER_PREFIX_GUARD_LENGTH ] ),
TEST_TOPIC_BUFFER_WRITABLE_LENGTH,
TEST_THING_NAME,
TEST_THING_NAME_LENGTH,
DefenderJsonReportPublish,
&( topicLength ) );
TEST_ASSERT_EQUAL( DefenderSuccess, ret );
TEST_ASSERT_EQUAL( TEST_JSON_PUBLISH_TOPIC_LENGTH, topicLength );
TEST_ASSERT_EQUAL_STRING_LEN( TEST_JSON_PUBLISH_TOPIC,
&( testTopicBuffer[ TEST_TOPIC_BUFFER_PREFIX_GUARD_LENGTH ] ),
topicLength );
TEST_ASSERT_EACH_EQUAL_HEX8( 0xA5,
&( testTopicBuffer[ TEST_TOPIC_BUFFER_PREFIX_GUARD_LENGTH + topicLength ] ),
TEST_TOPIC_BUFFER_WRITABLE_LENGTH - topicLength );
}
/*-----------------------------------------------------------*/
void test_Defender_GetTopic_JsonAcceptedHappyPath( void )
{
DefenderStatus_t ret;
uint16_t topicLength;
ret = Defender_GetTopic( &( testTopicBuffer[ TEST_TOPIC_BUFFER_PREFIX_GUARD_LENGTH ] ),
TEST_TOPIC_BUFFER_WRITABLE_LENGTH,
TEST_THING_NAME,
TEST_THING_NAME_LENGTH,
DefenderJsonReportAccepted,
&( topicLength ) );
TEST_ASSERT_EQUAL( DefenderSuccess, ret );
TEST_ASSERT_EQUAL( TEST_JSON_ACCEPTED_TOPIC_LENGTH, topicLength );
TEST_ASSERT_EQUAL_STRING_LEN( TEST_JSON_ACCEPTED_TOPIC,
&( testTopicBuffer[ TEST_TOPIC_BUFFER_PREFIX_GUARD_LENGTH ] ),
topicLength );
TEST_ASSERT_EACH_EQUAL_HEX8( 0xA5,
&( testTopicBuffer[ TEST_TOPIC_BUFFER_PREFIX_GUARD_LENGTH + topicLength ] ),
TEST_TOPIC_BUFFER_WRITABLE_LENGTH - topicLength );
}
/*-----------------------------------------------------------*/
void test_Defender_GetTopic_JsonRejectedHappyPath( void )
{
DefenderStatus_t ret;
uint16_t topicLength;
ret = Defender_GetTopic( &( testTopicBuffer[ TEST_TOPIC_BUFFER_PREFIX_GUARD_LENGTH ] ),
TEST_TOPIC_BUFFER_WRITABLE_LENGTH,
TEST_THING_NAME,
TEST_THING_NAME_LENGTH,
DefenderJsonReportRejected,
&( topicLength ) );
TEST_ASSERT_EQUAL( DefenderSuccess, ret );
TEST_ASSERT_EQUAL( TEST_JSON_REJECTED_TOPIC_LENGTH, topicLength );
TEST_ASSERT_EQUAL_STRING_LEN( TEST_JSON_REJECTED_TOPIC,
&( testTopicBuffer[ TEST_TOPIC_BUFFER_PREFIX_GUARD_LENGTH ] ),
topicLength );
TEST_ASSERT_EACH_EQUAL_HEX8( 0xA5,
&( testTopicBuffer[ TEST_TOPIC_BUFFER_PREFIX_GUARD_LENGTH + topicLength ] ),
TEST_TOPIC_BUFFER_WRITABLE_LENGTH - topicLength );
}
/*-----------------------------------------------------------*/
void test_Defender_GetTopic_CborPublishHappyPath( void )
{
DefenderStatus_t ret;
uint16_t topicLength;
ret = Defender_GetTopic( &( testTopicBuffer[ TEST_TOPIC_BUFFER_PREFIX_GUARD_LENGTH ] ),
TEST_TOPIC_BUFFER_WRITABLE_LENGTH,
TEST_THING_NAME,
TEST_THING_NAME_LENGTH,
DefenderCborReportPublish,
&( topicLength ) );
TEST_ASSERT_EQUAL( DefenderSuccess, ret );
TEST_ASSERT_EQUAL( TEST_CBOR_PUBLISH_TOPIC_LENGTH, topicLength );
TEST_ASSERT_EQUAL_STRING_LEN( TEST_CBOR_PUBLISH_TOPIC,
&( testTopicBuffer[ TEST_TOPIC_BUFFER_PREFIX_GUARD_LENGTH ] ),
topicLength );
TEST_ASSERT_EACH_EQUAL_HEX8( 0xA5,
&( testTopicBuffer[ TEST_TOPIC_BUFFER_PREFIX_GUARD_LENGTH + topicLength ] ),
TEST_TOPIC_BUFFER_WRITABLE_LENGTH - topicLength );
}
/*-----------------------------------------------------------*/
void test_Defender_GetTopic_CborAcceptedHappyPath( void )
{
DefenderStatus_t ret;
uint16_t topicLength;
ret = Defender_GetTopic( &( testTopicBuffer[ TEST_TOPIC_BUFFER_PREFIX_GUARD_LENGTH ] ),
TEST_TOPIC_BUFFER_WRITABLE_LENGTH,
TEST_THING_NAME,
TEST_THING_NAME_LENGTH,
DefenderCborReportAccepted,
&( topicLength ) );
TEST_ASSERT_EQUAL( DefenderSuccess, ret );
TEST_ASSERT_EQUAL( TEST_CBOR_ACCEPTED_TOPIC_LENGTH, topicLength );
TEST_ASSERT_EQUAL_STRING_LEN( TEST_CBOR_ACCEPTED_TOPIC,
&( testTopicBuffer[ TEST_TOPIC_BUFFER_PREFIX_GUARD_LENGTH ] ),
topicLength );
TEST_ASSERT_EACH_EQUAL_HEX8( 0xA5,
&( testTopicBuffer[ TEST_TOPIC_BUFFER_PREFIX_GUARD_LENGTH + topicLength ] ),
TEST_TOPIC_BUFFER_WRITABLE_LENGTH - topicLength );
}
/*-----------------------------------------------------------*/
void test_Defender_GetTopic_CborRejectedHappyPath( void )
{
DefenderStatus_t ret;
uint16_t topicLength;
ret = Defender_GetTopic( &( testTopicBuffer[ TEST_TOPIC_BUFFER_PREFIX_GUARD_LENGTH ] ),
TEST_TOPIC_BUFFER_WRITABLE_LENGTH,
TEST_THING_NAME,
TEST_THING_NAME_LENGTH,
DefenderCborReportRejected,
&( topicLength ) );
TEST_ASSERT_EQUAL( DefenderSuccess, ret );
TEST_ASSERT_EQUAL( TEST_CBOR_REJECTED_TOPIC_LENGTH, topicLength );
TEST_ASSERT_EQUAL_STRING_LEN( TEST_CBOR_REJECTED_TOPIC,
&( testTopicBuffer[ TEST_TOPIC_BUFFER_PREFIX_GUARD_LENGTH ] ),
topicLength );
TEST_ASSERT_EACH_EQUAL_HEX8( 0xA5,
&( testTopicBuffer[ TEST_TOPIC_BUFFER_PREFIX_GUARD_LENGTH + topicLength ] ),
TEST_TOPIC_BUFFER_WRITABLE_LENGTH - topicLength );
}
/*-----------------------------------------------------------*/
void test_Defender_MatchTopic_BadParams( void )
{
DefenderStatus_t ret;
const char * pThingName;
uint16_t thingNameLength;
DefenderTopic_t api;
/* NULL topic. */
ret = Defender_MatchTopic( NULL,
TEST_JSON_PUBLISH_TOPIC_LENGTH,
&( api ),
&( pThingName ),
&( thingNameLength ) );
TEST_ASSERT_EQUAL( DefenderBadParameter, ret );
/* NULL output parameter. */
ret = Defender_MatchTopic( TEST_JSON_PUBLISH_TOPIC,
TEST_JSON_PUBLISH_TOPIC_LENGTH,
NULL,
&( pThingName ),
&( thingNameLength ) );
TEST_ASSERT_EQUAL( DefenderBadParameter, ret );
}
/*-----------------------------------------------------------*/
void test_Defender_MatchTopic_IncompletePrefix( void )
{
DefenderStatus_t ret;
const char * pThingName;
uint16_t thingNameLength;
DefenderTopic_t api;
ret = Defender_MatchTopic( "$aws/things",
STRING_LITERAL_LENGTH( "$aws/things" ),
&( api ),
&( pThingName ),
&( thingNameLength ) );
TEST_ASSERT_EQUAL( DefenderNoMatch, ret );
TEST_ASSERT_EQUAL( DefenderInvalidTopic, api );
}
/*-----------------------------------------------------------*/
void test_Defender_MatchTopic_InvalidPrefix( void )
{
DefenderStatus_t ret;
const char * pThingName;
uint16_t thingNameLength;
DefenderTopic_t api;
ret = Defender_MatchTopic( "$aws/jobs/things/TestThing/defender/metrics/json",
STRING_LITERAL_LENGTH( "$aws/jobs/things/TestThing/defender/metrics/json" ),
&( api ),
&( pThingName ),
&( thingNameLength ) );
TEST_ASSERT_EQUAL( DefenderNoMatch, ret );
TEST_ASSERT_EQUAL( DefenderInvalidTopic, api );
ret = Defender_MatchTopic( "$aws/things/jobs/TestThing/defender/metrics/json",
STRING_LITERAL_LENGTH( "$aws/jobs/TestThing/defender/metrics/json" ),
&( api ),
&( pThingName ),
&( thingNameLength ) );
TEST_ASSERT_EQUAL( DefenderNoMatch, ret );
TEST_ASSERT_EQUAL( DefenderInvalidTopic, api );
}
/*-----------------------------------------------------------*/
void test_Defender_MatchTopic_MissingThingName( void )
{
DefenderStatus_t ret;
const char * pThingName;
uint16_t thingNameLength;
DefenderTopic_t api;
ret = Defender_MatchTopic( "$aws/things/",
STRING_LITERAL_LENGTH( "$aws/things/" ),
&( api ),
&( pThingName ),
&( thingNameLength ) );
TEST_ASSERT_EQUAL( DefenderNoMatch, ret );
TEST_ASSERT_EQUAL( DefenderInvalidTopic, api );
}
/*-----------------------------------------------------------*/
void test_Defender_MatchTopic_IncompleteBridge( void )
{
DefenderStatus_t ret;
const char * pThingName;
uint16_t thingNameLength;
DefenderTopic_t api;
ret = Defender_MatchTopic( "$aws/things/TestThing",
STRING_LITERAL_LENGTH( "$aws/things/TestThing" ),
&( api ),
&( pThingName ),
&( thingNameLength ) );
TEST_ASSERT_EQUAL( DefenderNoMatch, ret );
TEST_ASSERT_EQUAL( DefenderInvalidTopic, api );
ret = Defender_MatchTopic( "$aws/things/TestThing/",
STRING_LITERAL_LENGTH( "$aws/things/TestThing/" ),
&( api ),
&( pThingName ),
&( thingNameLength ) );
TEST_ASSERT_EQUAL( DefenderNoMatch, ret );
TEST_ASSERT_EQUAL( DefenderInvalidTopic, api );
ret = Defender_MatchTopic( "$aws/things/TestThing/defender",
STRING_LITERAL_LENGTH( "$aws/things/TestThing/defender" ),
&( api ),
&( pThingName ),
&( thingNameLength ) );
TEST_ASSERT_EQUAL( DefenderNoMatch, ret );
TEST_ASSERT_EQUAL( DefenderInvalidTopic, api );
}
/*-----------------------------------------------------------*/
void test_Defender_MatchTopic_InvalidBridge( void )
{
DefenderStatus_t ret;
const char * pThingName;
uint16_t thingNameLength;
DefenderTopic_t api;
ret = Defender_MatchTopic( "$aws/things/TestThing/shadow/metrics/json",
STRING_LITERAL_LENGTH( "$aws/things/TestThing/shadow/metrics/json" ),
&( api ),
&( pThingName ),
&( thingNameLength ) );
TEST_ASSERT_EQUAL( DefenderNoMatch, ret );
TEST_ASSERT_EQUAL( DefenderInvalidTopic, api );
ret = Defender_MatchTopic( "$aws/things/TestThing/defender/defender/metrics/json",
STRING_LITERAL_LENGTH( "$aws/things/TestThing/defender/defender/metrics/json" ),
&( api ),
&( pThingName ),
&( thingNameLength ) );
TEST_ASSERT_EQUAL( DefenderNoMatch, ret );
TEST_ASSERT_EQUAL( DefenderInvalidTopic, api );
}
/*-----------------------------------------------------------*/
void test_Defender_MatchTopic_IncompleteFormat( void )
{
DefenderStatus_t ret;
const char * pThingName;
uint16_t thingNameLength;
DefenderTopic_t api;
ret = Defender_MatchTopic( "$aws/things/TestThing/defender/metrics",
STRING_LITERAL_LENGTH( "$aws/things/TestThing/defender/metrics" ),
&( api ),
&( pThingName ),
&( thingNameLength ) );
TEST_ASSERT_EQUAL( DefenderNoMatch, ret );
TEST_ASSERT_EQUAL( DefenderInvalidTopic, api );
ret = Defender_MatchTopic( "$aws/things/TestThing/defender/metrics/",
STRING_LITERAL_LENGTH( "$aws/things/TestThing/defender/metrics/" ),
&( api ),
&( pThingName ),
&( thingNameLength ) );
TEST_ASSERT_EQUAL( DefenderNoMatch, ret );
TEST_ASSERT_EQUAL( DefenderInvalidTopic, api );
}
/*-----------------------------------------------------------*/
void test_Defender_MatchTopic_InvalidFormat( void )
{
DefenderStatus_t ret;
const char * pThingName;
uint16_t thingNameLength;
DefenderTopic_t api;
ret = Defender_MatchTopic( "$aws/things/TestThing/defender/metrics/xml",
STRING_LITERAL_LENGTH( "$aws/things/TestThing/defender/metrics/xml" ),
&( api ),
&( pThingName ),
&( thingNameLength ) );
TEST_ASSERT_EQUAL( DefenderNoMatch, ret );
TEST_ASSERT_EQUAL( DefenderInvalidTopic, api );
}
/*-----------------------------------------------------------*/
void test_Defender_MatchTopic_InvalidSuffix( void )
{
DefenderStatus_t ret;
const char * pThingName;
uint16_t thingNameLength;
DefenderTopic_t api;
ret = Defender_MatchTopic( "$aws/things/TestThing/defender/metrics/json/delta",
STRING_LITERAL_LENGTH( "$aws/things/TestThing/defender/metrics/json/delta" ),
&( api ),
&( pThingName ),
&( thingNameLength ) );
TEST_ASSERT_EQUAL( DefenderNoMatch, ret );
TEST_ASSERT_EQUAL( DefenderInvalidTopic, api );
}
/*-----------------------------------------------------------*/
void test_Defender_MatchTopic_ExtraData( void )
{
DefenderStatus_t ret;
const char * pThingName;
uint16_t thingNameLength;
DefenderTopic_t api;
ret = Defender_MatchTopic( "$aws/things/TestThing/defender/metrics/json/gibberish",
STRING_LITERAL_LENGTH( "$aws/things/TestThing/defender/metrics/json/gibberish" ),
&( api ),
&( pThingName ),
&( thingNameLength ) );
TEST_ASSERT_EQUAL( DefenderNoMatch, ret );
TEST_ASSERT_EQUAL( DefenderInvalidTopic, api );
ret = Defender_MatchTopic( "$aws/things/TestThing/defender/metrics/json/accepted/gibberish",
STRING_LITERAL_LENGTH( "$aws/things/TestThing/defender/metrics/json/accepted/gibberish" ),
&( api ),
&( pThingName ),
&( thingNameLength ) );
TEST_ASSERT_EQUAL( DefenderNoMatch, ret );
TEST_ASSERT_EQUAL( DefenderInvalidTopic, api );
}
/*-----------------------------------------------------------*/
void test_Defender_MatchTopic_JsonPublishHappyPath( void )
{
DefenderStatus_t ret;
const char * pThingName;
uint16_t thingNameLength;
DefenderTopic_t api;
ret = Defender_MatchTopic( TEST_JSON_PUBLISH_TOPIC,
TEST_JSON_PUBLISH_TOPIC_LENGTH,
&( api ),
&( pThingName ),
&( thingNameLength ) );
TEST_ASSERT_EQUAL( DefenderSuccess, ret );
TEST_ASSERT_EQUAL( DefenderJsonReportPublish, api );
TEST_ASSERT_EQUAL_PTR( TEST_JSON_PUBLISH_TOPIC + DEFENDER_API_LENGTH_PREFIX, pThingName );
TEST_ASSERT_EQUAL( TEST_THING_NAME_LENGTH, thingNameLength );
}
/*-----------------------------------------------------------*/
void test_Defender_MatchTopic_JsonAcceptedHappyPath( void )
{
DefenderStatus_t ret;
const char * pThingName;
uint16_t thingNameLength;
DefenderTopic_t api;
ret = Defender_MatchTopic( TEST_JSON_ACCEPTED_TOPIC,
TEST_JSON_ACCEPTED_TOPIC_LENGTH,
&( api ),
&( pThingName ),
&( thingNameLength ) );
TEST_ASSERT_EQUAL( DefenderSuccess, ret );
TEST_ASSERT_EQUAL( DefenderJsonReportAccepted, api );
TEST_ASSERT_EQUAL_PTR( TEST_JSON_ACCEPTED_TOPIC + DEFENDER_API_LENGTH_PREFIX, pThingName );
TEST_ASSERT_EQUAL( TEST_THING_NAME_LENGTH, thingNameLength );
}
/*-----------------------------------------------------------*/
void test_Defender_MatchTopic_JsonRejectedHappyPath( void )
{
DefenderStatus_t ret;
const char * pThingName;
uint16_t thingNameLength;
DefenderTopic_t api;
ret = Defender_MatchTopic( TEST_JSON_REJECTED_TOPIC,
TEST_JSON_REJECTED_TOPIC_LENGTH,
&( api ),
&( pThingName ),
&( thingNameLength ) );
TEST_ASSERT_EQUAL( DefenderSuccess, ret );
TEST_ASSERT_EQUAL( DefenderJsonReportRejected, api );
TEST_ASSERT_EQUAL_PTR( TEST_JSON_REJECTED_TOPIC + DEFENDER_API_LENGTH_PREFIX, pThingName );
TEST_ASSERT_EQUAL( TEST_THING_NAME_LENGTH, thingNameLength );
}
/*-----------------------------------------------------------*/
void test_Defender_MatchTopic_CborPublishHappyPath( void )
{
DefenderStatus_t ret;
const char * pThingName;
uint16_t thingNameLength;
DefenderTopic_t api;
ret = Defender_MatchTopic( TEST_CBOR_PUBLISH_TOPIC,
TEST_CBOR_PUBLISH_TOPIC_LENGTH,
&( api ),
&( pThingName ),
&( thingNameLength ) );
TEST_ASSERT_EQUAL( DefenderSuccess, ret );
TEST_ASSERT_EQUAL( DefenderCborReportPublish, api );
TEST_ASSERT_EQUAL_PTR( TEST_CBOR_PUBLISH_TOPIC + DEFENDER_API_LENGTH_PREFIX, pThingName );
TEST_ASSERT_EQUAL( TEST_THING_NAME_LENGTH, thingNameLength );
}
/*-----------------------------------------------------------*/
void test_Defender_MatchTopic_CborAcceptedHappyPath( void )
{
DefenderStatus_t ret;
const char * pThingName;
uint16_t thingNameLength;
DefenderTopic_t api;
ret = Defender_MatchTopic( TEST_CBOR_ACCEPTED_TOPIC,
TEST_CBOR_ACCEPTED_TOPIC_LENGTH,
&( api ),
&( pThingName ),
&( thingNameLength ) );
TEST_ASSERT_EQUAL( DefenderSuccess, ret );
TEST_ASSERT_EQUAL( DefenderCborReportAccepted, api );
TEST_ASSERT_EQUAL_PTR( TEST_CBOR_ACCEPTED_TOPIC + DEFENDER_API_LENGTH_PREFIX, pThingName );
TEST_ASSERT_EQUAL( TEST_THING_NAME_LENGTH, thingNameLength );
}
/*-----------------------------------------------------------*/
void test_Defender_MatchTopic_CborRejectedHappyPath( void )
{
DefenderStatus_t ret;
const char * pThingName;
uint16_t thingNameLength;
DefenderTopic_t api;
ret = Defender_MatchTopic( TEST_CBOR_REJECTED_TOPIC,
TEST_CBOR_REJECTED_TOPIC_LENGTH,
&( api ),
&( pThingName ),
&( thingNameLength ) );
TEST_ASSERT_EQUAL( DefenderSuccess, ret );
TEST_ASSERT_EQUAL( DefenderCborReportRejected, api );
TEST_ASSERT_EQUAL_PTR( TEST_CBOR_REJECTED_TOPIC + DEFENDER_API_LENGTH_PREFIX, pThingName );
TEST_ASSERT_EQUAL( TEST_THING_NAME_LENGTH, thingNameLength );
}
/*-----------------------------------------------------------*/
void test_Defender_MatchTopic_MissingOptionalParams( void )
{
DefenderStatus_t ret;
const char * pThingName;
uint16_t thingNameLength;
DefenderTopic_t api;
/* Missing output param for returning thing name. */
ret = Defender_MatchTopic( TEST_JSON_PUBLISH_TOPIC,
TEST_JSON_PUBLISH_TOPIC_LENGTH,
&( api ),
NULL,
&( thingNameLength ) );
TEST_ASSERT_EQUAL( DefenderSuccess, ret );
TEST_ASSERT_EQUAL( DefenderJsonReportPublish, api );
TEST_ASSERT_EQUAL( TEST_THING_NAME_LENGTH, thingNameLength );
/* Missing output param for returning thing name length. */
ret = Defender_MatchTopic( TEST_JSON_PUBLISH_TOPIC,
TEST_JSON_PUBLISH_TOPIC_LENGTH,
&( api ),
&( pThingName ),
NULL );
TEST_ASSERT_EQUAL( DefenderSuccess, ret );
TEST_ASSERT_EQUAL( DefenderJsonReportPublish, api );
TEST_ASSERT_EQUAL_PTR( TEST_JSON_PUBLISH_TOPIC + DEFENDER_API_LENGTH_PREFIX, pThingName );
/* Missing output param for returning both thing name and thing name
* length. */
ret = Defender_MatchTopic( TEST_JSON_PUBLISH_TOPIC,
TEST_JSON_PUBLISH_TOPIC_LENGTH,
&( api ),
NULL,
NULL );
TEST_ASSERT_EQUAL( DefenderSuccess, ret );
TEST_ASSERT_EQUAL( DefenderJsonReportPublish, api );
}
/*-----------------------------------------------------------*/