adding a bunch more models

Author: toepkerd-zz

src/main/kotlin/org/opensearch/commons/alerting/action/AlertingActions.kt

@@ -28,6 +28,7 @@ object AlertingActions {
 
     // Alerting V2
     const val INDEX_MONITOR_V2_ACTION_NAME = "cluster:admin/opensearch/alerting/v2/monitor/write"
+    const val GET_MONITOR_V2_ACTION_NAME = "cluster:admin/opensearch/alerting/v2/monitor/get"
     const val SEARCH_MONITORS_V2_ACTION_NAME = "cluster:admin/opensearch/alerting/v2/monitor/search"
     const val DELETE_MONITOR_V2_ACTION_NAME = "cluster:admin/opensearch/alerting/v2/monitor/delete"
 
@@ -99,6 +100,10 @@ object AlertingActions {
     val INDEX_MONITOR_V2_ACTION_TYPE =
         ActionType(INDEX_MONITOR_V2_ACTION_NAME, ::IndexMonitorV2Response)
 
+    @JvmField
+    val GET_MONITOR_V2_ACTION_TYPE =
+        ActionType(GET_MONITOR_V2_ACTION_NAME, ::GetMonitorV2Response)
+
     @JvmField
     val SEARCH_MONITORS_V2_ACTION_TYPE =
         ActionType(SEARCH_MONITORS_V2_ACTION_NAME, ::SearchResponse)

src/main/kotlin/org/opensearch/commons/alerting/action/GetMonitorV2Request.kt

@@ -0,0 +1,47 @@
+package org.opensearch.commons.alerting.action
+
+import java.io.IOException
+import org.opensearch.action.ActionRequest
+import org.opensearch.action.ActionRequestValidationException
+import org.opensearch.core.common.io.stream.StreamInput
+import org.opensearch.core.common.io.stream.StreamOutput
+import org.opensearch.search.fetch.subphase.FetchSourceContext
+
+class GetMonitorV2Request : ActionRequest {
+    val monitorV2Id: String
+    val version: Long
+    val srcContext: FetchSourceContext?
+
+    constructor(
+        monitorV2Id: String,
+        version: Long,
+        srcContext: FetchSourceContext?
+    ) : super() {
+        this.monitorV2Id = monitorV2Id
+        this.version = version
+        this.srcContext = srcContext
+    }
+
+    @Throws(IOException::class)
+    constructor(sin: StreamInput) : this(
+        sin.readString(), // monitorV2Id
+        sin.readLong(), // version
+        if (sin.readBoolean()) {
+            FetchSourceContext(sin) // srcContext
+        } else {
+            null
+        }
+    )
+
+    override fun validate(): ActionRequestValidationException? {
+        return null
+    }
+
+    @Throws(IOException::class)
+    override fun writeTo(out: StreamOutput) {
+        out.writeString(monitorV2Id)
+        out.writeLong(version)
+        out.writeBoolean(srcContext != null)
+        srcContext?.writeTo(out)
+    }
+}

src/main/kotlin/org/opensearch/commons/alerting/action/GetMonitorV2Response.kt

@@ -0,0 +1,75 @@
+package org.opensearch.commons.alerting.action
+
+import java.io.IOException
+import org.opensearch.commons.alerting.model.MonitorV2
+import org.opensearch.commons.alerting.util.IndexUtils.Companion._ID
+import org.opensearch.commons.alerting.util.IndexUtils.Companion._PRIMARY_TERM
+import org.opensearch.commons.alerting.util.IndexUtils.Companion._SEQ_NO
+import org.opensearch.commons.alerting.util.IndexUtils.Companion._VERSION
+import org.opensearch.commons.notifications.action.BaseResponse
+import org.opensearch.core.common.io.stream.StreamInput
+import org.opensearch.core.common.io.stream.StreamOutput
+import org.opensearch.core.xcontent.ToXContent
+import org.opensearch.core.xcontent.XContentBuilder
+
+class GetMonitorV2Response : BaseResponse {
+    var id: String
+    var version: Long
+    var seqNo: Long
+    var primaryTerm: Long
+    var monitorV2: MonitorV2?
+
+    constructor(
+        id: String,
+        version: Long,
+        seqNo: Long,
+        primaryTerm: Long,
+        monitorV2: MonitorV2?
+    ) : super() {
+        this.id = id
+        this.version = version
+        this.seqNo = seqNo
+        this.primaryTerm = primaryTerm
+        this.monitorV2 = monitorV2
+    }
+
+    @Throws(IOException::class)
+    constructor(sin: StreamInput) : this(
+        id = sin.readString(), // id
+        version = sin.readLong(), // version
+        seqNo = sin.readLong(), // seqNo
+        primaryTerm = sin.readLong(), // primaryTerm
+        monitorV2 = if (sin.readBoolean()) {
+            MonitorV2.readFrom(sin) // monitorV2
+        } else {
+            null
+        }
+    )
+
+    @Throws(IOException::class)
+    override fun writeTo(out: StreamOutput) {
+        out.writeString(id)
+        out.writeLong(version)
+        out.writeLong(seqNo)
+        out.writeLong(primaryTerm)
+        if (monitorV2 != null) {
+            out.writeBoolean(true)
+            monitorV2?.writeTo(out)
+        } else {
+            out.writeBoolean(false)
+        }
+    }
+
+    @Throws(IOException::class)
+    override fun toXContent(builder: XContentBuilder, params: ToXContent.Params): XContentBuilder {
+        builder.startObject()
+            .field(_ID, id)
+            .field(_VERSION, version)
+            .field(_SEQ_NO, seqNo)
+            .field(_PRIMARY_TERM, primaryTerm)
+        if (monitorV2 != null) {
+            builder.field("monitorV2", monitorV2)
+        }
+        return builder.endObject()
+    }
+}

src/main/kotlin/org/opensearch/commons/alerting/model/MonitorV2.kt

@@ -30,9 +30,10 @@ interface MonitorV2 : ScheduledJob {
     override val schedule: Schedule
     override val lastUpdateTime: Instant // required for scheduled job maintenance
     override val enabledTime: Instant? // required for scheduled job maintenance
-    val labels: Map<String, String>?
     val triggers: List<TriggerV2>
 
+    fun asTemplateArg(): Map<String, Any?>
+
     enum class MonitorV2Type(val value: String) {
         PPL_MONITOR(PPL_MONITOR_TYPE);
 
@@ -47,8 +48,6 @@ interface MonitorV2 : ScheduledJob {
         }
     }
 
-    fun asTemplateArg(): Map<String, Any?>
-
     companion object {
         // scheduled job field names
         const val TYPE_FIELD = "type"
@@ -61,7 +60,6 @@ interface MonitorV2 : ScheduledJob {
         const val SCHEDULE_FIELD = "schedule"
         const val LAST_UPDATE_TIME_FIELD = "last_update_time"
         const val ENABLED_TIME_FIELD = "enabled_time"
-        const val LABELS_FIELD = "labels"
         const val TRIGGERS_FIELD = "triggers"
 
         // default values
@@ -108,14 +106,5 @@ interface MonitorV2 : ScheduledJob {
                 }
             }
         }
-
-        @Suppress("UNCHECKED_CAST")
-        fun convertLabelsMap(map: Map<String, Any>): Map<String, String> {
-            if (map.values.all { it is String }) {
-                return map as Map<String, String>
-            } else {
-                throw ClassCastException("at least one value in the map was not a string: $map")
-            }
-        }
     }
 }