Skip to content

Commit

Permalink
Unit test for webcfg_notify.c
Browse files Browse the repository at this point in the history
  • Loading branch information
@nlrcomcast
nlrcomcast committed Oct 25, 2023
1 parent fcd6400 commit 3402dba
Show file tree
Hide file tree
Showing 2 changed files with 216 additions and 0 deletions.
12 changes: 12 additions & 0 deletions tests/CMakeLists.txt
View file
Original file line number Diff line number Diff line change
Expand Up @@ -321,6 +321,15 @@ endif (WEBCONFIG_BIN_SUPPORT)

target_link_libraries (test_timer gcov -Wl,--no-as-needed )

#-------------------------------------------------------------------------------
# test_notify
#-------------------------------------------------------------------------------
add_test(NAME test_notify COMMAND ${MEMORY_CHECK} ./test_notify)
add_executable(test_notify test_notify.c ../src/webcfg_notify.c)
target_link_libraries (test_notify -lcunit -lmsgpackc -lcimplog -ltrower-base64 -lwdmp-c -lcjson -lpthread)

target_link_libraries (test_notify gcov -Wl,--no-as-needed )

# Code coverage

add_custom_target(coverage
Expand Down Expand Up @@ -350,6 +359,8 @@ COMMAND lcov -q --capture --directory
${CMAKE_CURRENT_BINARY_DIR}/CMakeFiles/test_rbus_fr.dir/__/src --output-file test_rbus_fr.info
COMMAND lcov -q --capture --directory
${CMAKE_CURRENT_BINARY_DIR}/CMakeFiles/test_timer.dir/__/src --output-file test_timer.info
COMMAND lcov -q --capture --directory
${CMAKE_CURRENT_BINARY_DIR}/CMakeFiles/test_notify.dir/__/src --output-file test_notify.info


COMMAND lcov
Expand All @@ -366,6 +377,7 @@ COMMAND lcov
-a test_generic.info
-a test_rbus_fr.info
-a test_timer.info
-a test_notify.info
--output-file coverage.info

COMMAND genhtml coverage.info
Expand Down
204 changes: 204 additions & 0 deletions tests/test_notify.c
View file
Original file line number Diff line number Diff line change
@@ -0,0 +1,204 @@
#include <stdio.h>
#include <string.h>
#include <stdlib.h>
#include <CUnit/Basic.h>
#include "../src/webcfg_notify.h"
extern void free_notify_params_struct(notify_params_t *param);
void* processWebConfgNotification();
#define UNUSED(x) (void )(x)
bool shutdown_flag = false;
char *test_mac=NULL;

extern pthread_mutex_t notify_mut;
extern pthread_cond_t notify_con;

char *get_deviceMAC(void)
{
return test_mac;
}
char *global_payload=NULL;
char *global_source=NULL;
char *global_destination=NULL;
void sendNotification_rbus(char *payload, char *source, char *destination)
{
global_payload = payload;
global_source = source;
global_destination = destination;
}

void sendNotification(char *payload, char *source, char *destination)
{
WebcfgDebug("B4 sendNotification_rbus\n");
sendNotification_rbus(payload, source, destination);
}

bool get_global_shutdown()
{
return shutdown_flag;
}

void test_getStatusErrorCodeAndMessage()
{
char* result = NULL;
uint16_t ret = 0;
ret = getStatusErrorCodeAndMessage(DECODE_ROOT_FAILURE,&result);
CU_ASSERT_EQUAL(ret, 111);
CU_ASSERT_STRING_EQUAL(result, "decode_root_failure");

ret = getStatusErrorCodeAndMessage(INCORRECT_BLOB_TYPE,&result);
CU_ASSERT_EQUAL(ret, 211);
CU_ASSERT_STRING_EQUAL(result, "incorrect_blob_type");

ret = getStatusErrorCodeAndMessage(BLOB_PARAM_VALIDATION_FAILURE,&result);
CU_ASSERT_EQUAL(ret, 211);
CU_ASSERT_STRING_EQUAL(result, "blob_param_validation_failure");

ret = getStatusErrorCodeAndMessage(WEBCONFIG_DATA_EMPTY,&result);
CU_ASSERT_EQUAL(ret, 211);
CU_ASSERT_STRING_EQUAL(result, "webconfig_data_empty");

ret = getStatusErrorCodeAndMessage(MULTIPART_BOUNDARY_NULL,&result);
CU_ASSERT_EQUAL(ret, 211);
CU_ASSERT_STRING_EQUAL(result, "multipart_boundary_NULL");

ret = getStatusErrorCodeAndMessage(INVALID_CONTENT_TYPE,&result);
CU_ASSERT_EQUAL(ret, 211);
CU_ASSERT_STRING_EQUAL(result, "invalid_content_type");

ret = getStatusErrorCodeAndMessage(ADD_TO_CACHE_LIST_FAILURE,&result);
CU_ASSERT_EQUAL(ret, 311);
CU_ASSERT_STRING_EQUAL(result, "add_to_cache_list_failure");

ret = getStatusErrorCodeAndMessage(FAILED_TO_SET_BLOB,&result);
CU_ASSERT_EQUAL(ret, 311);
CU_ASSERT_STRING_EQUAL(result, "failed_to_set_blob");

ret = getStatusErrorCodeAndMessage(MULTIPART_CACHE_NULL,&result);
CU_ASSERT_EQUAL(ret, 311);
CU_ASSERT_STRING_EQUAL(result, "multipart_cache_NULL");

ret = getStatusErrorCodeAndMessage(AKER_SUBDOC_PROCESSING_FAILED,&result);
CU_ASSERT_EQUAL(ret, 411);
CU_ASSERT_STRING_EQUAL(result, "aker_subdoc_processing_failed");

ret = getStatusErrorCodeAndMessage(AKER_RESPONSE_PARSE_FAILURE,&result);
CU_ASSERT_EQUAL(ret, 411);
CU_ASSERT_STRING_EQUAL(result, "aker_response_parse_failure");

ret = getStatusErrorCodeAndMessage(INVALID_AKER_RESPONSE,&result);
CU_ASSERT_EQUAL(ret, 411);
CU_ASSERT_STRING_EQUAL(result, "invalid_aker_response");

ret = getStatusErrorCodeAndMessage(LIBPARODUS_RECEIVE_FAILURE,&result);
CU_ASSERT_EQUAL(ret, 411);
CU_ASSERT_STRING_EQUAL(result, "libparodus_receive_failure");

ret = getStatusErrorCodeAndMessage(COMPONENT_EVENT_PARSE_FAILURE,&result);
CU_ASSERT_EQUAL(ret, 511);
CU_ASSERT_STRING_EQUAL(result, "component_event_parse_failure");

ret = getStatusErrorCodeAndMessage(SUBDOC_RETRY_FAILED,&result);
CU_ASSERT_EQUAL(ret, 611);
CU_ASSERT_STRING_EQUAL(result, "subdoc_retry_failed");

ret = getStatusErrorCodeAndMessage(999,&result);
CU_ASSERT_EQUAL(ret, 0);
CU_ASSERT_STRING_EQUAL(result, "Unknown Error");
}

void test_addWebConfgNotifyMsg()
{
test_mac = strdup("123456789000");
addWebConfgNotifyMsg("moca",0,"xyz","none","1122334455",10,"req",400,"root",200);
shutdown_flag=1;
processWebConfgNotification();
CU_ASSERT_STRING_EQUAL(global_source,"mac:123456789000");
CU_ASSERT_STRING_EQUAL(global_destination,"event:subdoc-report/moca/mac:123456789000/req");
CU_ASSERT_STRING_EQUAL(global_payload,"{\"device_id\":\"mac:123456789000\",\"namespace\":\"moca\",\"application_status\":\"xyz\",\"timeout\":10,\"error_code\":400,\"transaction_uuid\":\"1122334455\",\"version\":\"root\"}");
addWebConfgNotifyMsg("moca",123,"xyz","none","1122334455",10,"req",400,"root",404);
addWebConfgNotifyMsg("moca",123,"xyz","none","1122334455",10,"req",400,"root",404);
processWebConfgNotification();
CU_ASSERT_STRING_EQUAL(global_source,"mac:123456789000");
CU_ASSERT_STRING_EQUAL(global_destination,"event:rootdoc-report/mac:123456789000/req");
CU_ASSERT_STRING_EQUAL(global_payload,"{\"device_id\":\"mac:123456789000\",\"namespace\":\"moca\",\"application_status\":\"xyz\",\"timeout\":10,\"error_code\":400,\"http_status_code\":404,\"transaction_uuid\":\"1122334455\",\"version\":\"123\"}");
}

void test_initWebConfigNotifyTask()
{
initWebConfigNotifyTask();
}

void test_free_notify_params_struct()
{
notify_params_t *msg = NULL;
msg = (notify_params_t *)malloc(sizeof(notify_params_t));
memset(msg, 0, sizeof(notify_params_t));
msg->name = strdup("test1");
free_notify_params_struct(msg);
CU_ASSERT_EQUAL(msg->name,NULL);


msg = (notify_params_t *)malloc(sizeof(notify_params_t));
memset(msg, 0, sizeof(notify_params_t));
msg->version = strdup("test4");
free_notify_params_struct(msg);
CU_ASSERT_EQUAL(msg->version,NULL);

}

void test_get_global_notify_threadid()
{
pthread_t NotificationThreadId_tmp=99;
NotificationThreadId_tmp = get_global_notify_threadid();
CU_ASSERT_EQUAL(NotificationThreadId_tmp, 0);
}

void test_get_global_notify_con()
{
CU_ASSERT_PTR_EQUAL(&notify_con, get_global_notify_con());
}

void test_get_global_notify_mut()
{
CU_ASSERT_PTR_EQUAL(&notify_mut, get_global_notify_mut());
}

void add_suites( CU_pSuite *suite )
{
*suite = CU_add_suite( "tests", NULL, NULL );
CU_add_test( *suite, "test getStatusErrorCodeAndMessage", test_getStatusErrorCodeAndMessage);
CU_add_test( *suite, "test free_notify_params_struct", test_free_notify_params_struct);
CU_add_test( *suite, "test addWebConfgNotifyMsg", test_addWebConfgNotifyMsg);
CU_add_test( *suite, "test get_global_notify_threadid", test_get_global_notify_threadid);
CU_add_test( *suite, "test get_global_notify_con", test_get_global_notify_con);
CU_add_test( *suite, "test get_global_notify_mut", test_get_global_notify_mut);
CU_add_test( *suite, "test initWebConfigNotifyTask", test_initWebConfigNotifyTask);
}

int main( int argc, char *argv[] )
{
unsigned rv = 1;
CU_pSuite suite = NULL;

(void ) argc;
(void ) argv;

if( CUE_SUCCESS == CU_initialize_registry() ) {
add_suites( &suite );

if( NULL != suite ) {
CU_basic_set_mode( CU_BRM_VERBOSE );
CU_basic_run_tests();
printf( "\n" );
CU_basic_show_failures( CU_get_failure_list() );
printf( "\n\n" );
rv = CU_get_number_of_tests_failed();
}

CU_cleanup_registry();

}

return rv;
}

0 comments on commit 3402dba

Please sign in to comment.