Checkpoint

awslabs · Jan 18, 2024 · 013168b · 013168b
1 parent 7a1db26
commit 013168b
Show file tree

Hide file tree

Showing 7 changed files with 363 additions and 205 deletions.
diff --git a/include/aws/mqtt/private/request-response/protocol_adapter.h b/include/aws/mqtt/private/request-response/protocol_adapter.h
@@ -28,35 +28,48 @@ struct aws_protocol_adapter_publish_options {
     struct aws_byte_cursor topic;
     struct aws_byte_cursor payload;
 
-    void (*completion_callback_fn)(int, void *);
+    void (*completion_callback_fn)(bool, void *);
     void *user_data;
     uint32_t ack_timeout_seconds;
 };
 
-enum aws_protocol_adapter_subscription_status_update {
-    AWS_PASS_ESTABLISHMENT_SUCCESS,
-    AWS_PASS_ESTABLISHMENT_FAILURE,
-    AWS_PASS_REMOVED
+enum aws_protocol_adapter_subscription_event_type {
+    AWS_PASET_SUBSCRIBE_SUCCESS,
+    AWS_PASET_SUBSCRIBE_FAILURE,
+    AWS_PASET_UNSUBSCRIBE_SUCCESS,
+    AWS_PASET_UNSUBSCRIBE_FAILURE,
 };
 
-struct aws_protocol_adapter_subscription_status_update_event {
+struct aws_protocol_adapter_subscription_event {
     struct aws_byte_cursor topic_filter;
-    enum aws_protocol_adapter_subscription_status_update status_update;
+    enum aws_protocol_adapter_subscription_event_type event_type;
 };
 
 struct aws_protocol_adapter_incoming_publish_event {
     struct aws_byte_cursor topic;
     struct aws_byte_cursor payload;
 };
 
-typedef void(aws_protocol_adapter_subscription_status_fn)(struct aws_protocol_adapter_subscription_status_update_event *update, void *user_data);
+enum aws_protocol_adapter_connection_event_type {
+    AWS_PACET_OFFLINE,
+    AWS_PACET_ONLINE,
+};
+
+struct aws_protocol_adapter_connection_event {
+    enum aws_protocol_adapter_connection_event_type event_type;
+    bool rejoined_session;
+};
+
+typedef void(aws_protocol_adapter_subscription_event_fn)(struct aws_protocol_adapter_subscription_event *event, void *user_data);
 typedef void(aws_protocol_adapter_incoming_publish_fn)(struct aws_protocol_adapter_incoming_publish_event *publish, void *user_data);
 typedef void(aws_protocol_adapter_terminate_callback_fn)(void *user_data);
+typedef void(aws_protocol_adapter_connection_event_fn)(struct aws_protocol_adapter_connection_event *event, void *user_data);
 
 struct aws_mqtt_protocol_adapter_options {
-    aws_protocol_adapter_subscription_status_fn *subscription_status_update_callback;
+    aws_protocol_adapter_subscription_event_fn *subscription_event_callback;
     aws_protocol_adapter_incoming_publish_fn *incoming_publish_callback;
     aws_protocol_adapter_terminate_callback_fn *terminate_callback;
+    aws_protocol_adapter_connection_event_fn *connection_event_callback;
 
     void *user_data;
 };