Add unit tests for webcfg_notify.c

tests/CMakeLists.txt

@@ -321,6 +321,16 @@ 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
@@ -350,6 +360,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
@@ -366,6 +378,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

tests/test_notify.c

@@ -0,0 +1,179 @@
+#include <stdio.h>
+#include <string.h>
+#include <stdlib.h>
+#include <CUnit/Basic.h>
+#include "../src/webcfg_notify.h"
+void free_notify_params_struct(notify_params_t *param);
+void* processWebConfgNotification();
+#define UNUSED(x) (void )(x)
+bool shutdown_flag = false;
+char *test_mac=NULL;
+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\"}");   
+    shutdown_flag=0;  
+}
+
+void test_initWebConfigNotifyTask()
+{
+
+}
+
+void test_free_notify_params_struct()
+{
+	notify_params_t *msg = NULL;
+    free_notify_params_struct(msg);    
+	msg = (notify_params_t *)malloc(sizeof(notify_params_t));
+	memset(msg, 0, sizeof(notify_params_t));    
+    msg->name = strdup("test1");
+    msg->application_status = strdup("test2");
+    msg->error_details = strdup("test3");
+    msg->version = strdup("test4");
+    msg->transaction_uuid = strdup("test5");
+    msg->type = strdup("test6");  
+    free_notify_params_struct(msg);
+    CU_ASSERT_EQUAL(msg->name, NULL);     
+}
+
+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 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;
+}
+