Basic operation submission testing

source/request-response/request_response_client.c

@@ -632,6 +632,8 @@ static struct aws_mqtt_request_response_client *s_aws_mqtt_request_response_clie
         NULL,
         NULL);
 
+    aws_linked_list_init(&rr_client->operation_queue);
+
     aws_task_init(
         &rr_client->external_shutdown_task,
         s_mqtt_request_response_client_external_shutdown_task_fn,
@@ -840,6 +842,14 @@ static bool s_are_request_operation_options_valid(
                 AWS_BYTE_CURSOR_PRI(path->topic));
             return false;
         }
+
+        if (path->correlation_token_json_path.len == 0) {
+            AWS_LOGF_ERROR(
+                AWS_LS_MQTT_REQUEST_RESPONSE,
+                "(%p) rr client request options - empty correlation token json path",
+                (void *)client);
+            return false;
+        }
     }
 
     if (request_options->correlation_token.len == 0) {

tests/CMakeLists.txt

@@ -511,6 +511,17 @@ add_test_case(rrsm_subscription_lost_while_unsubscribing)
 add_test_case(rrc_mqtt5_create_destroy)
 add_test_case(rrc_mqtt311_create_destroy)
 
+add_test_case(rrc_submit_request_operation_failure_no_response_paths)
+add_test_case(rrc_submit_request_operation_failure_invalid_response_topic)
+add_test_case(rrc_submit_request_operation_failure_invalid_response_correlation_token_path)
+add_test_case(rrc_submit_request_operation_failure_no_correlation_token)
+add_test_case(rrc_submit_request_operation_failure_invalid_publish_topic)
+add_test_case(rrc_submit_request_operation_failure_empty_request)
+add_test_case(rrc_submit_streaming_operation_failure_invalid_subscription_topic_filter)
+
+add_test_case(rrc_submit_request_operation_failure_by_shutdown)
+add_test_case(rrc_submit_streaming_operation_and_shutdown)
+
 generate_test_driver(${PROJECT_NAME}-tests)
 
 set(TEST_PAHO_CLIENT_BINARY_NAME ${PROJECT_NAME}-paho-client)