change transport ack alerts action to accept Action Request and recre…

…ate as AckAlertRequest (opensearch-project#618) (opensearch-project#619) Signed-off-by: Surya Sashank Nistala <[email protected]> Signed-off-by: Surya Sashank Nistala <[email protected]> (cherry picked from commit 2005185fcbbd36e41dc8344ab5a8c717c3043a1a) Co-authored-by: Surya Sashank Nistala <[email protected]>
riysaxen-amzn · Oct 20, 2022 · 7e36861 · 7e36861
1 parent a3e6a1c
commit 7e36861
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/...ting/src/main/kotlin/org/opensearch/alerting/transport/TransportAcknowledgeAlertAction.kt b/...ting/src/main/kotlin/org/opensearch/alerting/transport/TransportAcknowledgeAlertAction.kt
@@ -11,6 +11,7 @@ import kotlinx.coroutines.launch
 import org.apache.logging.log4j.LogManager
 import org.opensearch.ResourceNotFoundException
 import org.opensearch.action.ActionListener
+import org.opensearch.action.ActionRequest
 import org.opensearch.action.bulk.BulkRequest
 import org.opensearch.action.bulk.BulkResponse
 import org.opensearch.action.delete.DeleteRequest
@@ -65,7 +66,7 @@ class TransportAcknowledgeAlertAction @Inject constructor(
     val settings: Settings,
     val xContentRegistry: NamedXContentRegistry,
     val transportGetMonitorAction: TransportGetMonitorAction
-) : HandledTransportAction<AcknowledgeAlertRequest, AcknowledgeAlertResponse>(
+) : HandledTransportAction<ActionRequest, AcknowledgeAlertResponse>(
     AlertingActions.ACKNOWLEDGE_ALERTS_ACTION_NAME, transportService, actionFilters, ::AcknowledgeAlertRequest
 ) {
 
@@ -78,7 +79,7 @@ class TransportAcknowledgeAlertAction @Inject constructor(
 
     override fun doExecute(
         task: Task,
-        acknowledgeAlertRequest: AcknowledgeAlertRequest,
+        acknowledgeAlertRequest: ActionRequest,
         actionListener: ActionListener<AcknowledgeAlertResponse>
     ) {
         val request = acknowledgeAlertRequest as? AcknowledgeAlertRequest