Streaming operation intake

awslabs · Mar 19, 2024 · cdc1a97 · cdc1a97
1 parent 69d00c8
commit cdc1a97
Show file tree

Hide file tree

Showing 4 changed files with 256 additions and 60 deletions.
diff --git a/include/aws/mqtt/mqtt.h b/include/aws/mqtt/mqtt.h
@@ -84,6 +84,9 @@ enum aws_mqtt_error {
     AWS_ERROR_MQTT_PROTOCOL_ADAPTER_FAILING_REASON_CODE,
     AWS_ERROR_MQTT_REQUEST_RESPONSE_CLIENT_SHUT_DOWN,
     AWS_ERROR_MQTT_REQUEST_RESPONSE_TIMEOUT,
+    AWS_ERROR_MQTT_REQUEST_RESPONSE_NO_SUBSCRIPTION_CAPACITY,
+    AWS_ERROR_MQTT_REQUEST_RESPONSE_SUBSCRIBE_FAILURE,
+    AWS_ERROR_MQTT_REQUEST_RESPONSE_INTERNAL_ERROR,
 
     AWS_ERROR_END_MQTT_RANGE = AWS_ERROR_ENUM_END_RANGE(AWS_C_MQTT_PACKAGE_ID),
 };

diff --git a/include/aws/mqtt/request-response/request_response_client.h b/include/aws/mqtt/request-response/request_response_client.h
@@ -13,7 +13,6 @@
 struct aws_mqtt_request_response_client;
 struct aws_mqtt_client_connection;
 struct aws_mqtt5_client;
-struct aws_mqtt_streaming_operation;
 
 struct aws_mqtt_request_operation_response_path {
     struct aws_byte_cursor topic;

diff --git a/source/mqtt.c b/source/mqtt.c
@@ -242,6 +242,15 @@ bool aws_mqtt_is_valid_topic_filter(const struct aws_byte_cursor *topic_filter)
             AWS_DEFINE_ERROR_INFO_MQTT(
                 AWS_ERROR_MQTT_REQUEST_RESPONSE_TIMEOUT,
                 "Request operation failed due to timeout"),
+            AWS_DEFINE_ERROR_INFO_MQTT(
+                AWS_ERROR_MQTT_REQUEST_RESPONSE_NO_SUBSCRIPTION_CAPACITY,
+                "Streaming request operation failed because there was no space for the subscription"),
+            AWS_DEFINE_ERROR_INFO_MQTT(
+                AWS_ERROR_MQTT_REQUEST_RESPONSE_SUBSCRIBE_FAILURE,
+                "Request operation failed because the associated subscribe failed synchronously"),
+            AWS_DEFINE_ERROR_INFO_MQTT(
+                AWS_ERROR_MQTT_REQUEST_RESPONSE_INTERNAL_ERROR,
+                "Request operation failed due to a non-specific internal error within the client."),
 
         };
 /* clang-format on */