#include <CUnit/CUnit.h>
|
#include <CUnit/Basic.h>
|
|
#include "mqtt_protocol.h"
|
#include "property_mosq.h"
|
#include "packet_mosq.h"
|
|
/* ========================================================================
|
* BAD IDENTIFIER
|
* ======================================================================== */
|
|
static void bad_add_byte_helper(int identifier)
|
{
|
mosquitto_property *proplist = NULL;
|
int rc;
|
|
rc = mosquitto_property_add_byte(&proplist, identifier, 1);
|
CU_ASSERT_EQUAL(rc, MOSQ_ERR_INVAL);
|
CU_ASSERT_PTR_NULL(proplist);
|
}
|
|
static void bad_add_int16_helper(int identifier)
|
{
|
mosquitto_property *proplist = NULL;
|
int rc;
|
|
rc = mosquitto_property_add_int16(&proplist, identifier, 1);
|
CU_ASSERT_EQUAL(rc, MOSQ_ERR_INVAL);
|
CU_ASSERT_PTR_NULL(proplist);
|
}
|
|
static void bad_add_int32_helper(int identifier)
|
{
|
mosquitto_property *proplist = NULL;
|
int rc;
|
|
rc = mosquitto_property_add_int32(&proplist, identifier, 1);
|
CU_ASSERT_EQUAL(rc, MOSQ_ERR_INVAL);
|
CU_ASSERT_PTR_NULL(proplist);
|
}
|
|
static void bad_add_varint_helper(int identifier)
|
{
|
mosquitto_property *proplist = NULL;
|
int rc;
|
|
rc = mosquitto_property_add_varint(&proplist, identifier, 1);
|
CU_ASSERT_EQUAL(rc, MOSQ_ERR_INVAL);
|
CU_ASSERT_PTR_NULL(proplist);
|
}
|
|
static void bad_add_binary_helper(int identifier)
|
{
|
mosquitto_property *proplist = NULL;
|
int rc;
|
|
rc = mosquitto_property_add_binary(&proplist, identifier, "test", 4);
|
CU_ASSERT_EQUAL(rc, MOSQ_ERR_INVAL);
|
CU_ASSERT_PTR_NULL(proplist);
|
}
|
|
static void bad_add_string_helper(int identifier)
|
{
|
mosquitto_property *proplist = NULL;
|
int rc;
|
|
rc = mosquitto_property_add_string(&proplist, identifier, "test");
|
CU_ASSERT_EQUAL(rc, MOSQ_ERR_INVAL);
|
CU_ASSERT_PTR_NULL(proplist);
|
}
|
|
static void bad_add_string_pair_helper(int identifier)
|
{
|
mosquitto_property *proplist = NULL;
|
int rc;
|
|
rc = mosquitto_property_add_string_pair(&proplist, identifier, "key", "value");
|
CU_ASSERT_EQUAL(rc, MOSQ_ERR_INVAL);
|
CU_ASSERT_PTR_NULL(proplist);
|
}
|
|
static void TEST_add_bad_byte(void)
|
{
|
bad_add_byte_helper(MQTT_PROP_MESSAGE_EXPIRY_INTERVAL);
|
bad_add_byte_helper(MQTT_PROP_CONTENT_TYPE);
|
bad_add_byte_helper(MQTT_PROP_RESPONSE_TOPIC);
|
bad_add_byte_helper(MQTT_PROP_CORRELATION_DATA);
|
bad_add_byte_helper(MQTT_PROP_SUBSCRIPTION_IDENTIFIER);
|
bad_add_byte_helper(MQTT_PROP_SESSION_EXPIRY_INTERVAL);
|
bad_add_byte_helper(MQTT_PROP_ASSIGNED_CLIENT_IDENTIFIER);
|
bad_add_byte_helper(MQTT_PROP_SERVER_KEEP_ALIVE);
|
bad_add_byte_helper(MQTT_PROP_AUTHENTICATION_METHOD);
|
bad_add_byte_helper(MQTT_PROP_AUTHENTICATION_DATA);
|
bad_add_byte_helper(MQTT_PROP_WILL_DELAY_INTERVAL);
|
bad_add_byte_helper(MQTT_PROP_RESPONSE_INFORMATION);
|
bad_add_byte_helper(MQTT_PROP_SERVER_REFERENCE);
|
bad_add_byte_helper(MQTT_PROP_REASON_STRING);
|
bad_add_byte_helper(MQTT_PROP_RECEIVE_MAXIMUM);
|
bad_add_byte_helper(MQTT_PROP_TOPIC_ALIAS_MAXIMUM);
|
bad_add_byte_helper(MQTT_PROP_TOPIC_ALIAS);
|
bad_add_byte_helper(MQTT_PROP_USER_PROPERTY);
|
bad_add_byte_helper(MQTT_PROP_MAXIMUM_PACKET_SIZE);
|
}
|
|
static void TEST_add_bad_int16(void)
|
{
|
bad_add_int16_helper(MQTT_PROP_PAYLOAD_FORMAT_INDICATOR);
|
bad_add_int16_helper(MQTT_PROP_MESSAGE_EXPIRY_INTERVAL);
|
bad_add_int16_helper(MQTT_PROP_CONTENT_TYPE);
|
bad_add_int16_helper(MQTT_PROP_RESPONSE_TOPIC);
|
bad_add_int16_helper(MQTT_PROP_CORRELATION_DATA);
|
bad_add_int16_helper(MQTT_PROP_SUBSCRIPTION_IDENTIFIER);
|
bad_add_int16_helper(MQTT_PROP_SESSION_EXPIRY_INTERVAL);
|
bad_add_int16_helper(MQTT_PROP_ASSIGNED_CLIENT_IDENTIFIER);
|
bad_add_int16_helper(MQTT_PROP_AUTHENTICATION_METHOD);
|
bad_add_int16_helper(MQTT_PROP_AUTHENTICATION_DATA);
|
bad_add_int16_helper(MQTT_PROP_REQUEST_PROBLEM_INFORMATION);
|
bad_add_int16_helper(MQTT_PROP_WILL_DELAY_INTERVAL);
|
bad_add_int16_helper(MQTT_PROP_REQUEST_RESPONSE_INFORMATION);
|
bad_add_int16_helper(MQTT_PROP_RESPONSE_INFORMATION);
|
bad_add_int16_helper(MQTT_PROP_SERVER_REFERENCE);
|
bad_add_int16_helper(MQTT_PROP_REASON_STRING);
|
bad_add_int16_helper(MQTT_PROP_MAXIMUM_QOS);
|
bad_add_int16_helper(MQTT_PROP_RETAIN_AVAILABLE);
|
bad_add_int16_helper(MQTT_PROP_USER_PROPERTY);
|
bad_add_int16_helper(MQTT_PROP_MAXIMUM_PACKET_SIZE);
|
bad_add_int16_helper(MQTT_PROP_WILDCARD_SUB_AVAILABLE);
|
bad_add_int16_helper(MQTT_PROP_SUBSCRIPTION_ID_AVAILABLE);
|
bad_add_int16_helper(MQTT_PROP_SHARED_SUB_AVAILABLE);
|
}
|
|
static void TEST_add_bad_int32(void)
|
{
|
bad_add_int32_helper(MQTT_PROP_PAYLOAD_FORMAT_INDICATOR);
|
bad_add_int32_helper(MQTT_PROP_CONTENT_TYPE);
|
bad_add_int32_helper(MQTT_PROP_RESPONSE_TOPIC);
|
bad_add_int32_helper(MQTT_PROP_CORRELATION_DATA);
|
bad_add_int32_helper(MQTT_PROP_SUBSCRIPTION_IDENTIFIER);
|
bad_add_int32_helper(MQTT_PROP_ASSIGNED_CLIENT_IDENTIFIER);
|
bad_add_int32_helper(MQTT_PROP_SERVER_KEEP_ALIVE);
|
bad_add_int32_helper(MQTT_PROP_AUTHENTICATION_METHOD);
|
bad_add_int32_helper(MQTT_PROP_AUTHENTICATION_DATA);
|
bad_add_int32_helper(MQTT_PROP_REQUEST_PROBLEM_INFORMATION);
|
bad_add_int32_helper(MQTT_PROP_REQUEST_RESPONSE_INFORMATION);
|
bad_add_int32_helper(MQTT_PROP_RESPONSE_INFORMATION);
|
bad_add_int32_helper(MQTT_PROP_SERVER_REFERENCE);
|
bad_add_int32_helper(MQTT_PROP_REASON_STRING);
|
bad_add_int32_helper(MQTT_PROP_RECEIVE_MAXIMUM);
|
bad_add_int32_helper(MQTT_PROP_TOPIC_ALIAS_MAXIMUM);
|
bad_add_int32_helper(MQTT_PROP_TOPIC_ALIAS);
|
bad_add_int32_helper(MQTT_PROP_MAXIMUM_QOS);
|
bad_add_int32_helper(MQTT_PROP_RETAIN_AVAILABLE);
|
bad_add_int32_helper(MQTT_PROP_USER_PROPERTY);
|
bad_add_int32_helper(MQTT_PROP_WILDCARD_SUB_AVAILABLE);
|
bad_add_int32_helper(MQTT_PROP_SUBSCRIPTION_ID_AVAILABLE);
|
bad_add_int32_helper(MQTT_PROP_SHARED_SUB_AVAILABLE);
|
}
|
|
static void TEST_add_bad_varint(void)
|
{
|
bad_add_varint_helper(MQTT_PROP_PAYLOAD_FORMAT_INDICATOR);
|
bad_add_varint_helper(MQTT_PROP_MESSAGE_EXPIRY_INTERVAL);
|
bad_add_varint_helper(MQTT_PROP_CONTENT_TYPE);
|
bad_add_varint_helper(MQTT_PROP_RESPONSE_TOPIC);
|
bad_add_varint_helper(MQTT_PROP_CORRELATION_DATA);
|
bad_add_varint_helper(MQTT_PROP_SESSION_EXPIRY_INTERVAL);
|
bad_add_varint_helper(MQTT_PROP_ASSIGNED_CLIENT_IDENTIFIER);
|
bad_add_varint_helper(MQTT_PROP_SERVER_KEEP_ALIVE);
|
bad_add_varint_helper(MQTT_PROP_AUTHENTICATION_METHOD);
|
bad_add_varint_helper(MQTT_PROP_AUTHENTICATION_DATA);
|
bad_add_varint_helper(MQTT_PROP_REQUEST_PROBLEM_INFORMATION);
|
bad_add_varint_helper(MQTT_PROP_WILL_DELAY_INTERVAL);
|
bad_add_varint_helper(MQTT_PROP_REQUEST_RESPONSE_INFORMATION);
|
bad_add_varint_helper(MQTT_PROP_RESPONSE_INFORMATION);
|
bad_add_varint_helper(MQTT_PROP_SERVER_REFERENCE);
|
bad_add_varint_helper(MQTT_PROP_REASON_STRING);
|
bad_add_varint_helper(MQTT_PROP_RECEIVE_MAXIMUM);
|
bad_add_varint_helper(MQTT_PROP_TOPIC_ALIAS_MAXIMUM);
|
bad_add_varint_helper(MQTT_PROP_TOPIC_ALIAS);
|
bad_add_varint_helper(MQTT_PROP_MAXIMUM_QOS);
|
bad_add_varint_helper(MQTT_PROP_RETAIN_AVAILABLE);
|
bad_add_varint_helper(MQTT_PROP_USER_PROPERTY);
|
bad_add_varint_helper(MQTT_PROP_MAXIMUM_PACKET_SIZE);
|
bad_add_varint_helper(MQTT_PROP_WILDCARD_SUB_AVAILABLE);
|
bad_add_varint_helper(MQTT_PROP_SUBSCRIPTION_ID_AVAILABLE);
|
bad_add_varint_helper(MQTT_PROP_SHARED_SUB_AVAILABLE);
|
}
|
|
static void TEST_add_bad_binary(void)
|
{
|
bad_add_binary_helper(MQTT_PROP_PAYLOAD_FORMAT_INDICATOR);
|
bad_add_binary_helper(MQTT_PROP_MESSAGE_EXPIRY_INTERVAL);
|
bad_add_binary_helper(MQTT_PROP_CONTENT_TYPE);
|
bad_add_binary_helper(MQTT_PROP_RESPONSE_TOPIC);
|
bad_add_binary_helper(MQTT_PROP_SUBSCRIPTION_IDENTIFIER);
|
bad_add_binary_helper(MQTT_PROP_SESSION_EXPIRY_INTERVAL);
|
bad_add_binary_helper(MQTT_PROP_ASSIGNED_CLIENT_IDENTIFIER);
|
bad_add_binary_helper(MQTT_PROP_SERVER_KEEP_ALIVE);
|
bad_add_binary_helper(MQTT_PROP_AUTHENTICATION_METHOD);
|
bad_add_binary_helper(MQTT_PROP_REQUEST_PROBLEM_INFORMATION);
|
bad_add_binary_helper(MQTT_PROP_WILL_DELAY_INTERVAL);
|
bad_add_binary_helper(MQTT_PROP_REQUEST_RESPONSE_INFORMATION);
|
bad_add_binary_helper(MQTT_PROP_RESPONSE_INFORMATION);
|
bad_add_binary_helper(MQTT_PROP_SERVER_REFERENCE);
|
bad_add_binary_helper(MQTT_PROP_REASON_STRING);
|
bad_add_binary_helper(MQTT_PROP_RECEIVE_MAXIMUM);
|
bad_add_binary_helper(MQTT_PROP_TOPIC_ALIAS_MAXIMUM);
|
bad_add_binary_helper(MQTT_PROP_TOPIC_ALIAS);
|
bad_add_binary_helper(MQTT_PROP_MAXIMUM_QOS);
|
bad_add_binary_helper(MQTT_PROP_RETAIN_AVAILABLE);
|
bad_add_binary_helper(MQTT_PROP_USER_PROPERTY);
|
bad_add_binary_helper(MQTT_PROP_MAXIMUM_PACKET_SIZE);
|
bad_add_binary_helper(MQTT_PROP_WILDCARD_SUB_AVAILABLE);
|
bad_add_binary_helper(MQTT_PROP_SUBSCRIPTION_ID_AVAILABLE);
|
bad_add_binary_helper(MQTT_PROP_SHARED_SUB_AVAILABLE);
|
}
|
|
static void TEST_add_bad_string(void)
|
{
|
bad_add_string_helper(MQTT_PROP_PAYLOAD_FORMAT_INDICATOR);
|
bad_add_string_helper(MQTT_PROP_MESSAGE_EXPIRY_INTERVAL);
|
bad_add_string_helper(MQTT_PROP_CORRELATION_DATA);
|
bad_add_string_helper(MQTT_PROP_SUBSCRIPTION_IDENTIFIER);
|
bad_add_string_helper(MQTT_PROP_SESSION_EXPIRY_INTERVAL);
|
bad_add_string_helper(MQTT_PROP_SERVER_KEEP_ALIVE);
|
bad_add_string_helper(MQTT_PROP_AUTHENTICATION_DATA);
|
bad_add_string_helper(MQTT_PROP_REQUEST_PROBLEM_INFORMATION);
|
bad_add_string_helper(MQTT_PROP_WILL_DELAY_INTERVAL);
|
bad_add_string_helper(MQTT_PROP_REQUEST_RESPONSE_INFORMATION);
|
bad_add_string_helper(MQTT_PROP_RECEIVE_MAXIMUM);
|
bad_add_string_helper(MQTT_PROP_TOPIC_ALIAS_MAXIMUM);
|
bad_add_string_helper(MQTT_PROP_TOPIC_ALIAS);
|
bad_add_string_helper(MQTT_PROP_MAXIMUM_QOS);
|
bad_add_string_helper(MQTT_PROP_RETAIN_AVAILABLE);
|
bad_add_string_helper(MQTT_PROP_USER_PROPERTY);
|
bad_add_string_helper(MQTT_PROP_MAXIMUM_PACKET_SIZE);
|
bad_add_string_helper(MQTT_PROP_WILDCARD_SUB_AVAILABLE);
|
bad_add_string_helper(MQTT_PROP_SUBSCRIPTION_ID_AVAILABLE);
|
bad_add_string_helper(MQTT_PROP_SHARED_SUB_AVAILABLE);
|
}
|
|
static void TEST_add_bad_string_pair(void)
|
{
|
bad_add_string_pair_helper(MQTT_PROP_PAYLOAD_FORMAT_INDICATOR);
|
bad_add_string_pair_helper(MQTT_PROP_MESSAGE_EXPIRY_INTERVAL);
|
bad_add_string_pair_helper(MQTT_PROP_CONTENT_TYPE);
|
bad_add_string_pair_helper(MQTT_PROP_RESPONSE_TOPIC);
|
bad_add_string_pair_helper(MQTT_PROP_CORRELATION_DATA);
|
bad_add_string_pair_helper(MQTT_PROP_SUBSCRIPTION_IDENTIFIER);
|
bad_add_string_pair_helper(MQTT_PROP_SESSION_EXPIRY_INTERVAL);
|
bad_add_string_pair_helper(MQTT_PROP_ASSIGNED_CLIENT_IDENTIFIER);
|
bad_add_string_pair_helper(MQTT_PROP_SERVER_KEEP_ALIVE);
|
bad_add_string_pair_helper(MQTT_PROP_AUTHENTICATION_METHOD);
|
bad_add_string_pair_helper(MQTT_PROP_AUTHENTICATION_DATA);
|
bad_add_string_pair_helper(MQTT_PROP_REQUEST_PROBLEM_INFORMATION);
|
bad_add_string_pair_helper(MQTT_PROP_WILL_DELAY_INTERVAL);
|
bad_add_string_pair_helper(MQTT_PROP_REQUEST_RESPONSE_INFORMATION);
|
bad_add_string_pair_helper(MQTT_PROP_RESPONSE_INFORMATION);
|
bad_add_string_pair_helper(MQTT_PROP_SERVER_REFERENCE);
|
bad_add_string_pair_helper(MQTT_PROP_REASON_STRING);
|
bad_add_string_pair_helper(MQTT_PROP_RECEIVE_MAXIMUM);
|
bad_add_string_pair_helper(MQTT_PROP_TOPIC_ALIAS_MAXIMUM);
|
bad_add_string_pair_helper(MQTT_PROP_TOPIC_ALIAS);
|
bad_add_string_pair_helper(MQTT_PROP_MAXIMUM_QOS);
|
bad_add_string_pair_helper(MQTT_PROP_RETAIN_AVAILABLE);
|
bad_add_string_pair_helper(MQTT_PROP_MAXIMUM_PACKET_SIZE);
|
bad_add_string_pair_helper(MQTT_PROP_WILDCARD_SUB_AVAILABLE);
|
bad_add_string_pair_helper(MQTT_PROP_SUBSCRIPTION_ID_AVAILABLE);
|
bad_add_string_pair_helper(MQTT_PROP_SHARED_SUB_AVAILABLE);
|
}
|
|
/* ========================================================================
|
* SINGLE ADD
|
* ======================================================================== */
|
|
static void single_add_byte_helper(int identifier)
|
{
|
mosquitto_property *proplist = NULL;
|
int rc;
|
|
rc = mosquitto_property_add_byte(&proplist, identifier, 1);
|
CU_ASSERT_EQUAL(rc, MOSQ_ERR_SUCCESS);
|
CU_ASSERT_PTR_NOT_NULL(proplist);
|
if(proplist){
|
CU_ASSERT_EQUAL(proplist->identifier, identifier);
|
CU_ASSERT_EQUAL(proplist->value.i8, 1);
|
CU_ASSERT_PTR_NULL(proplist->next);
|
|
mosquitto_property_free_all(&proplist);
|
}
|
}
|
|
static void single_add_int16_helper(int identifier)
|
{
|
mosquitto_property *proplist = NULL;
|
int rc;
|
|
rc = mosquitto_property_add_int16(&proplist, identifier, 11234);
|
CU_ASSERT_EQUAL(rc, MOSQ_ERR_SUCCESS);
|
CU_ASSERT_PTR_NOT_NULL(proplist);
|
if(proplist){
|
CU_ASSERT_EQUAL(proplist->identifier, identifier);
|
CU_ASSERT_EQUAL(proplist->value.i16, 11234);
|
CU_ASSERT_PTR_NULL(proplist->next);
|
|
mosquitto_property_free_all(&proplist);
|
}
|
}
|
|
static void single_add_int32_helper(int identifier)
|
{
|
mosquitto_property *proplist = NULL;
|
int rc;
|
|
rc = mosquitto_property_add_int32(&proplist, identifier, 765432);
|
CU_ASSERT_EQUAL(rc, MOSQ_ERR_SUCCESS);
|
CU_ASSERT_PTR_NOT_NULL(proplist);
|
if(proplist){
|
CU_ASSERT_EQUAL(proplist->identifier, identifier);
|
CU_ASSERT_EQUAL(proplist->value.i32, 765432);
|
CU_ASSERT_PTR_NULL(proplist->next);
|
|
mosquitto_property_free_all(&proplist);
|
}
|
}
|
|
static void single_add_varint_helper(int identifier)
|
{
|
mosquitto_property *proplist = NULL;
|
int rc;
|
|
rc = mosquitto_property_add_varint(&proplist, identifier, 139123999);
|
CU_ASSERT_EQUAL(rc, MOSQ_ERR_SUCCESS);
|
CU_ASSERT_PTR_NOT_NULL(proplist);
|
if(proplist){
|
CU_ASSERT_EQUAL(proplist->identifier, identifier);
|
CU_ASSERT_EQUAL(proplist->value.varint, 139123999);
|
CU_ASSERT_PTR_NULL(proplist->next);
|
|
mosquitto_property_free_all(&proplist);
|
}
|
}
|
|
static void single_add_binary_helper(int identifier)
|
{
|
mosquitto_property *proplist = NULL;
|
int rc;
|
|
rc = mosquitto_property_add_binary(&proplist, identifier, "test", 4);
|
CU_ASSERT_EQUAL(rc, MOSQ_ERR_SUCCESS);
|
CU_ASSERT_PTR_NOT_NULL(proplist);
|
if(proplist){
|
CU_ASSERT_EQUAL(proplist->identifier, identifier);
|
CU_ASSERT_EQUAL(proplist->value.bin.len, 4);
|
CU_ASSERT_NSTRING_EQUAL(proplist->value.bin.v, "test", 4);
|
CU_ASSERT_PTR_NULL(proplist->next);
|
|
mosquitto_property_free_all(&proplist);
|
}
|
}
|
|
static void single_add_string_helper(int identifier)
|
{
|
mosquitto_property *proplist = NULL;
|
int rc;
|
|
rc = mosquitto_property_add_string(&proplist, identifier, "string");
|
CU_ASSERT_EQUAL(rc, MOSQ_ERR_SUCCESS);
|
CU_ASSERT_PTR_NOT_NULL(proplist);
|
if(proplist){
|
CU_ASSERT_EQUAL(proplist->identifier, identifier);
|
CU_ASSERT_STRING_EQUAL(proplist->value.s.v, "string");
|
CU_ASSERT_EQUAL(proplist->value.s.len, strlen("string"));
|
CU_ASSERT_PTR_NULL(proplist->next);
|
|
mosquitto_property_free_all(&proplist);
|
}
|
}
|
|
static void single_add_string_pair_helper(int identifier)
|
{
|
mosquitto_property *proplist = NULL;
|
int rc;
|
|
rc = mosquitto_property_add_string_pair(&proplist, identifier, "key", "value");
|
CU_ASSERT_EQUAL(rc, MOSQ_ERR_SUCCESS);
|
CU_ASSERT_PTR_NOT_NULL(proplist);
|
if(proplist){
|
CU_ASSERT_EQUAL(proplist->identifier, identifier);
|
CU_ASSERT_STRING_EQUAL(proplist->name.v, "key");
|
CU_ASSERT_EQUAL(proplist->name.len, strlen("key"));
|
CU_ASSERT_STRING_EQUAL(proplist->value.s.v, "value");
|
CU_ASSERT_EQUAL(proplist->value.s.len, strlen("value"));
|
CU_ASSERT_PTR_NULL(proplist->next);
|
|
mosquitto_property_free_all(&proplist);
|
}
|
}
|
|
static void TEST_add_single_byte(void)
|
{
|
single_add_byte_helper(MQTT_PROP_PAYLOAD_FORMAT_INDICATOR);
|
single_add_byte_helper(MQTT_PROP_REQUEST_PROBLEM_INFORMATION);
|
single_add_byte_helper(MQTT_PROP_REQUEST_RESPONSE_INFORMATION);
|
single_add_byte_helper(MQTT_PROP_MAXIMUM_QOS);
|
single_add_byte_helper(MQTT_PROP_RETAIN_AVAILABLE);
|
single_add_byte_helper(MQTT_PROP_WILDCARD_SUB_AVAILABLE);
|
single_add_byte_helper(MQTT_PROP_SUBSCRIPTION_ID_AVAILABLE);
|
single_add_byte_helper(MQTT_PROP_SHARED_SUB_AVAILABLE);
|
}
|
|
static void TEST_add_single_int16(void)
|
{
|
single_add_int16_helper(MQTT_PROP_SERVER_KEEP_ALIVE);
|
single_add_int16_helper(MQTT_PROP_RECEIVE_MAXIMUM);
|
single_add_int16_helper(MQTT_PROP_TOPIC_ALIAS_MAXIMUM);
|
single_add_int16_helper(MQTT_PROP_TOPIC_ALIAS);
|
}
|
|
static void TEST_add_single_int32(void)
|
{
|
single_add_int32_helper(MQTT_PROP_MESSAGE_EXPIRY_INTERVAL);
|
single_add_int32_helper(MQTT_PROP_SESSION_EXPIRY_INTERVAL);
|
single_add_int32_helper(MQTT_PROP_WILL_DELAY_INTERVAL);
|
single_add_int32_helper(MQTT_PROP_MAXIMUM_PACKET_SIZE);
|
}
|
|
static void TEST_add_single_varint(void)
|
{
|
single_add_varint_helper(MQTT_PROP_SUBSCRIPTION_IDENTIFIER);
|
}
|
|
static void TEST_add_single_binary(void)
|
{
|
single_add_binary_helper(MQTT_PROP_CORRELATION_DATA);
|
single_add_binary_helper(MQTT_PROP_AUTHENTICATION_DATA);
|
}
|
|
static void TEST_add_single_string(void)
|
{
|
single_add_string_helper(MQTT_PROP_CONTENT_TYPE);
|
single_add_string_helper(MQTT_PROP_RESPONSE_TOPIC);
|
single_add_string_helper(MQTT_PROP_ASSIGNED_CLIENT_IDENTIFIER);
|
single_add_string_helper(MQTT_PROP_AUTHENTICATION_METHOD);
|
single_add_string_helper(MQTT_PROP_RESPONSE_INFORMATION);
|
single_add_string_helper(MQTT_PROP_SERVER_REFERENCE);
|
single_add_string_helper(MQTT_PROP_REASON_STRING);
|
}
|
|
static void TEST_add_single_string_pair(void)
|
{
|
single_add_string_pair_helper(MQTT_PROP_USER_PROPERTY);
|
}
|
|
/* ========================================================================
|
* ADD ALL PROPERTIES FOR A COMMAND
|
* ======================================================================== */
|
|
static void TEST_add_all_connect(void)
|
{
|
mosquitto_property *proplist = NULL;
|
mosquitto_property *p;
|
int count;
|
int rc;
|
|
rc = mosquitto_property_add_int32(&proplist, MQTT_PROP_SESSION_EXPIRY_INTERVAL, 86400);
|
CU_ASSERT_EQUAL(rc, MOSQ_ERR_SUCCESS);
|
CU_ASSERT_PTR_NOT_NULL(proplist);
|
rc = mosquitto_property_add_string(&proplist, MQTT_PROP_AUTHENTICATION_METHOD, "basic");
|
CU_ASSERT_EQUAL(rc, MOSQ_ERR_SUCCESS);
|
CU_ASSERT_PTR_NOT_NULL(proplist);
|
rc = mosquitto_property_add_binary(&proplist, MQTT_PROP_AUTHENTICATION_DATA, "password", strlen("password"));
|
CU_ASSERT_EQUAL(rc, MOSQ_ERR_SUCCESS);
|
CU_ASSERT_PTR_NOT_NULL(proplist);
|
rc = mosquitto_property_add_byte(&proplist, MQTT_PROP_REQUEST_PROBLEM_INFORMATION, 1);
|
CU_ASSERT_EQUAL(rc, MOSQ_ERR_SUCCESS);
|
CU_ASSERT_PTR_NOT_NULL(proplist);
|
rc = mosquitto_property_add_byte(&proplist, MQTT_PROP_REQUEST_RESPONSE_INFORMATION, 1);
|
CU_ASSERT_EQUAL(rc, MOSQ_ERR_SUCCESS);
|
CU_ASSERT_PTR_NOT_NULL(proplist);
|
rc = mosquitto_property_add_int16(&proplist, MQTT_PROP_RECEIVE_MAXIMUM, 1024);
|
CU_ASSERT_EQUAL(rc, MOSQ_ERR_SUCCESS);
|
CU_ASSERT_PTR_NOT_NULL(proplist);
|
rc = mosquitto_property_add_int16(&proplist, MQTT_PROP_TOPIC_ALIAS_MAXIMUM, 64);
|
CU_ASSERT_EQUAL(rc, MOSQ_ERR_SUCCESS);
|
CU_ASSERT_PTR_NOT_NULL(proplist);
|
rc = mosquitto_property_add_string_pair(&proplist, MQTT_PROP_USER_PROPERTY, "user-agent", "mosquitto/test");
|
CU_ASSERT_EQUAL(rc, MOSQ_ERR_SUCCESS);
|
CU_ASSERT_PTR_NOT_NULL(proplist);
|
rc = mosquitto_property_add_int32(&proplist, MQTT_PROP_MAXIMUM_PACKET_SIZE, 200000000);
|
CU_ASSERT_EQUAL(rc, MOSQ_ERR_SUCCESS);
|
CU_ASSERT_PTR_NOT_NULL(proplist);
|
|
p = proplist;
|
count = 0;
|
while(p){
|
count++;
|
p = p->next;
|
}
|
CU_ASSERT_EQUAL(count, 9);
|
|
mosquitto_property_free_all(&proplist);
|
}
|
|
|
static void TEST_add_all_connack(void)
|
{
|
mosquitto_property *proplist = NULL;
|
mosquitto_property *p;
|
int count;
|
int rc;
|
|
rc = mosquitto_property_add_int32(&proplist, MQTT_PROP_SESSION_EXPIRY_INTERVAL, 86400);
|
CU_ASSERT_EQUAL(rc, MOSQ_ERR_SUCCESS);
|
CU_ASSERT_PTR_NOT_NULL(proplist);
|
rc = mosquitto_property_add_string(&proplist, MQTT_PROP_ASSIGNED_CLIENT_IDENTIFIER, "clientid");
|
CU_ASSERT_EQUAL(rc, MOSQ_ERR_SUCCESS);
|
CU_ASSERT_PTR_NOT_NULL(proplist);
|
rc = mosquitto_property_add_int16(&proplist, MQTT_PROP_SERVER_KEEP_ALIVE, 900);
|
CU_ASSERT_EQUAL(rc, MOSQ_ERR_SUCCESS);
|
CU_ASSERT_PTR_NOT_NULL(proplist);
|
rc = mosquitto_property_add_string(&proplist, MQTT_PROP_AUTHENTICATION_METHOD, "basic");
|
CU_ASSERT_EQUAL(rc, MOSQ_ERR_SUCCESS);
|
CU_ASSERT_PTR_NOT_NULL(proplist);
|
rc = mosquitto_property_add_binary(&proplist, MQTT_PROP_AUTHENTICATION_DATA, "password", strlen("password"));
|
CU_ASSERT_EQUAL(rc, MOSQ_ERR_SUCCESS);
|
CU_ASSERT_PTR_NOT_NULL(proplist);
|
rc = mosquitto_property_add_string(&proplist, MQTT_PROP_RESPONSE_INFORMATION, "response");
|
CU_ASSERT_EQUAL(rc, MOSQ_ERR_SUCCESS);
|
CU_ASSERT_PTR_NOT_NULL(proplist);
|
rc = mosquitto_property_add_string(&proplist, MQTT_PROP_SERVER_REFERENCE, "localhost");
|
CU_ASSERT_EQUAL(rc, MOSQ_ERR_SUCCESS);
|
CU_ASSERT_PTR_NOT_NULL(proplist);
|
rc = mosquitto_property_add_string(&proplist, MQTT_PROP_REASON_STRING, "reason");
|
CU_ASSERT_EQUAL(rc, MOSQ_ERR_SUCCESS);
|
CU_ASSERT_PTR_NOT_NULL(proplist);
|
rc = mosquitto_property_add_int16(&proplist, MQTT_PROP_RECEIVE_MAXIMUM, 1024);
|
CU_ASSERT_EQUAL(rc, MOSQ_ERR_SUCCESS);
|
CU_ASSERT_PTR_NOT_NULL(proplist);
|
rc = mosquitto_property_add_int16(&proplist, MQTT_PROP_TOPIC_ALIAS_MAXIMUM, 64);
|
CU_ASSERT_EQUAL(rc, MOSQ_ERR_SUCCESS);
|
CU_ASSERT_PTR_NOT_NULL(proplist);
|
rc = mosquitto_property_add_byte(&proplist, MQTT_PROP_MAXIMUM_QOS, 1);
|
CU_ASSERT_EQUAL(rc, MOSQ_ERR_SUCCESS);
|
CU_ASSERT_PTR_NOT_NULL(proplist);
|
rc = mosquitto_property_add_byte(&proplist, MQTT_PROP_RETAIN_AVAILABLE, 0);
|
CU_ASSERT_EQUAL(rc, MOSQ_ERR_SUCCESS);
|
CU_ASSERT_PTR_NOT_NULL(proplist);
|
rc = mosquitto_property_add_string_pair(&proplist, MQTT_PROP_USER_PROPERTY, "user-agent", "mosquitto/test");
|
CU_ASSERT_EQUAL(rc, MOSQ_ERR_SUCCESS);
|
CU_ASSERT_PTR_NOT_NULL(proplist);
|
rc = mosquitto_property_add_int32(&proplist, MQTT_PROP_MAXIMUM_PACKET_SIZE, 200000000);
|
CU_ASSERT_EQUAL(rc, MOSQ_ERR_SUCCESS);
|
CU_ASSERT_PTR_NOT_NULL(proplist);
|
rc = mosquitto_property_add_byte(&proplist, MQTT_PROP_WILDCARD_SUB_AVAILABLE, 0);
|
CU_ASSERT_EQUAL(rc, MOSQ_ERR_SUCCESS);
|
CU_ASSERT_PTR_NOT_NULL(proplist);
|
rc = mosquitto_property_add_byte(&proplist, MQTT_PROP_SUBSCRIPTION_ID_AVAILABLE, 0);
|
CU_ASSERT_EQUAL(rc, MOSQ_ERR_SUCCESS);
|
CU_ASSERT_PTR_NOT_NULL(proplist);
|
rc = mosquitto_property_add_byte(&proplist, MQTT_PROP_SHARED_SUB_AVAILABLE, 0);
|
CU_ASSERT_EQUAL(rc, MOSQ_ERR_SUCCESS);
|
CU_ASSERT_PTR_NOT_NULL(proplist);
|
|
p = proplist;
|
count = 0;
|
while(p){
|
count++;
|
p = p->next;
|
}
|
CU_ASSERT_EQUAL(count, 17);
|
|
mosquitto_property_free_all(&proplist);
|
}
|
|
/* ========================================================================
|
* TEST SUITE SETUP
|
* ======================================================================== */
|
|
int init_property_add_tests(void)
|
{
|
CU_pSuite test_suite = NULL;
|
|
test_suite = CU_add_suite("Property add", NULL, NULL);
|
if(!test_suite){
|
printf("Error adding CUnit Property add test suite.\n");
|
return 1;
|
}
|
|
if(0
|
|| !CU_add_test(test_suite, "Add bad byte", TEST_add_bad_byte)
|
|| !CU_add_test(test_suite, "Add bad int16", TEST_add_bad_int16)
|
|| !CU_add_test(test_suite, "Add bad int32", TEST_add_bad_int32)
|
|| !CU_add_test(test_suite, "Add bad varint", TEST_add_bad_varint)
|
|| !CU_add_test(test_suite, "Add bad binary", TEST_add_bad_binary)
|
|| !CU_add_test(test_suite, "Add bad string", TEST_add_bad_string)
|
|| !CU_add_test(test_suite, "Add bad string pair", TEST_add_bad_string_pair)
|
|| !CU_add_test(test_suite, "Add single byte", TEST_add_single_byte)
|
|| !CU_add_test(test_suite, "Add single int16", TEST_add_single_int16)
|
|| !CU_add_test(test_suite, "Add single int32", TEST_add_single_int32)
|
|| !CU_add_test(test_suite, "Add single varint", TEST_add_single_varint)
|
|| !CU_add_test(test_suite, "Add single binary", TEST_add_single_binary)
|
|| !CU_add_test(test_suite, "Add single string", TEST_add_single_string)
|
|| !CU_add_test(test_suite, "Add single string pair", TEST_add_single_string_pair)
|
|| !CU_add_test(test_suite, "Add all CONNECT", TEST_add_all_connect)
|
|| !CU_add_test(test_suite, "Add all CONNACK", TEST_add_all_connack)
|
){
|
|
printf("Error adding Property Add CUnit tests.\n");
|
return 1;
|
}
|
|
return 0;
|
}
|
