refactor(RHINENG-12780): enhance delete events

api/host.py

@@ -243,6 +243,7 @@ def delete_hosts_by_filter(
 
 
 def _delete_host_list(host_id_list, rbac_filter):
+    request_host = flask.request.headers.get("Host", "")
     current_identity = get_current_identity()
     payload_tracker = get_payload_tracker(
         account=current_identity.account_number, org_id=current_identity.org_id, request_id=threadctx.request_id
@@ -260,6 +261,7 @@ def _delete_host_list(host_id_list, rbac_filter):
             inventory_config().host_delete_chunk_size,
             identity=current_identity,
             control_rule=get_control_rule(),
+            is_manual_delete=check_manual_deletion(request_host),
         )
 
         deleted_id_list = [str(r.host_row.id) for r in result_list]
@@ -312,6 +314,10 @@ def delete_host_by_id(host_id_list, rbac_filter=None):
     return flask.Response(None, HTTPStatus.OK)
 
 
+def check_manual_deletion(origin_host: str = ""):
+    return origin_host in ["console.stage.redhat.com", "console.redhat.com"]
+
+
 @api_operation
 @rbac(RbacResourceType.HOSTS, RbacPermission.READ)
 @metrics.api_request_time.time()

app/queue/events.py

@@ -76,6 +76,8 @@ class HostDeleteEvent(Schema):
     org_id = fields.Str()
     insights_id = fields.Str()
     request_id = fields.Str()
+    subscription_manager_id = fields.Str()
+    manual_delete = fields.Bool()
     platform_metadata = fields.Dict()
     metadata = fields.Nested(HostEventMetadataSchema())
 
@@ -113,14 +115,15 @@ def host_create_update_event(event_type, host, platform_metadata=None):
     )
 
 
-def host_delete_event(event_type, host, platform_metadata=None):
+def host_delete_event(event_type, host, is_manual_delete=False, platform_metadata=None):
     delete_event = {
         "timestamp": datetime.now(timezone.utc),
         "type": event_type.name,
         "id": host.id,
         **serialize_canonical_facts(host.canonical_facts),
         "org_id": host.org_id,
         "account": host.account,
+        "manual_delete": is_manual_delete,
         "request_id": threadctx.request_id,
         "platform_metadata": platform_metadata,
         "metadata": {"request_id": threadctx.request_id},

app/queue/host_mq.py

@@ -325,8 +325,13 @@ def handle_message(message, notification_event_producer, message_operation=add_h
             raise
 
 
-def write_delete_event_message(event_producer: EventProducer, result: OperationResult):
-    event = build_event(EventType.delete, result.host_row, platform_metadata=result.platform_metadata)
+def write_delete_event_message(event_producer: EventProducer, result: OperationResult, is_manual_delete: bool):
+    event = build_event(
+        EventType.delete,
+        result.host_row,
+        platform_metadata=result.platform_metadata,
+        is_manual_delete=is_manual_delete,
+    )
     headers = message_headers(
         EventType.delete,
         result.host_row.canonical_facts.get("insights_id"),

lib/host_delete.py

@@ -39,12 +39,15 @@ def _delete_host_db_records(select_query, chunk_size, identity, interrupt, contr
 
 
 def _send_delete_messages_for_batch(
-    processed_rows: list[OperationResult], event_producer: EventProducer, notification_event_producer: EventProducer
+    processed_rows: list[OperationResult],
+    event_producer: EventProducer,
+    notification_event_producer: EventProducer,
+    is_manual_delete: bool,
 ):
     for result in processed_rows:
         if result is not None:
             delete_host_count.inc()
-            write_delete_event_message(event_producer, result)
+            write_delete_event_message(event_producer, result, is_manual_delete)
             send_notification(notification_event_producer, NotificationType.system_deleted, vars(result.host_row))
 
 
@@ -56,12 +59,15 @@ def delete_hosts(
     interrupt=lambda: False,
     identity=None,
     control_rule=None,
+    is_manual_delete=False,
 ):
     while select_query.count():
         if kafka_available():
             with session_guard(select_query.session):
                 batch_events = _delete_host_db_records(select_query, chunk_size, identity, interrupt, control_rule)
-                _send_delete_messages_for_batch(batch_events, event_producer, notification_event_producer)
+                _send_delete_messages_for_batch(
+                    batch_events, event_producer, notification_event_producer, is_manual_delete
+                )
 
                 # yield the items in batch_events
                 yield from batch_events

tests/helpers/mq_utils.py

@@ -118,6 +118,8 @@ def assert_delete_event_is_valid(
         "org_id",
         "insights_id",
         "request_id",
+        "subscription_manager_id",
+        "manual_delete",
         "platform_metadata",
         "metadata",
     }

tests/test_api_hosts_delete.py

@@ -591,7 +591,13 @@ class DeleteHostsMock:
     @classmethod
     def create_mock(cls, hosts_ids_to_delete):
         def _constructor(
-            select_query, event_producer, notification_event_producer, chunk_size, identity=None, control_rule=None
+            select_query,
+            event_producer,
+            notification_event_producer,
+            chunk_size,
+            identity=None,
+            control_rule=None,
+            is_manual_delete=False,
         ):
             return cls(
                 hosts_ids_to_delete,
@@ -601,6 +607,7 @@ def _constructor(
                 chunk_size,
                 identity=identity,
                 control_rule=control_rule,
+                is_manual_delete=is_manual_delete,
             )
 
         return _constructor
@@ -614,6 +621,7 @@ def __init__(
         chunk_size,
         identity=None,
         control_rule=None,
+        is_manual_delete=False,
     ):
         self.host_ids_to_delete = host_ids_to_delete
         self.original_query = delete_hosts(
@@ -623,6 +631,7 @@ def __init__(
             chunk_size,
             identity=identity,
             control_rule=control_rule,
+            is_manual_delete=is_manual_delete,
         )
 
     def __getattr__(self, item):