initial create/update rbac implementation

Author: toepkerd-zz

alerting/src/main/kotlin/org/opensearch/alerting/actionv2/IndexMonitorV2Request.kt

@@ -16,24 +16,24 @@ class IndexMonitorV2Request : ActionRequest {
     val refreshPolicy: WriteRequest.RefreshPolicy
     val method: RestRequest.Method
     var monitorV2: MonitorV2
-//    val rbacRoles: List<String>?
+    val rbacRoles: List<String>?
 
     constructor(
         monitorId: String,
         seqNo: Long,
         primaryTerm: Long,
         refreshPolicy: WriteRequest.RefreshPolicy,
         method: RestRequest.Method,
-        monitorV2: MonitorV2
-//        rbacRoles: List<String>? = null
+        monitorV2: MonitorV2,
+        rbacRoles: List<String>? = null
     ) : super() {
         this.monitorId = monitorId
         this.seqNo = seqNo
         this.primaryTerm = primaryTerm
         this.refreshPolicy = refreshPolicy
         this.method = method
         this.monitorV2 = monitorV2
-//        this.rbacRoles = rbacRoles
+        this.rbacRoles = rbacRoles
     }
 
     @Throws(IOException::class)
@@ -43,8 +43,8 @@ class IndexMonitorV2Request : ActionRequest {
         primaryTerm = sin.readLong(),
         refreshPolicy = WriteRequest.RefreshPolicy.readFrom(sin),
         method = sin.readEnum(RestRequest.Method::class.java),
-        monitorV2 = MonitorV2.readFrom(sin)
-//        rbacRoles = sin.readOptionalStringList()
+        monitorV2 = MonitorV2.readFrom(sin),
+        rbacRoles = sin.readOptionalStringList()
     )
 
     override fun validate(): ActionRequestValidationException? {
@@ -59,6 +59,6 @@ class IndexMonitorV2Request : ActionRequest {
         refreshPolicy.writeTo(out)
         out.writeEnum(method)
         MonitorV2.writeTo(out, monitorV2)
-//        out.writeOptionalStringCollection(rbacRoles)
+        out.writeOptionalStringCollection(rbacRoles)
     }
 }

alerting/src/main/kotlin/org/opensearch/alerting/resthandler/RestIndexMonitorV2Action.kt

@@ -53,8 +53,10 @@ class RestIndexMonitorV2Action : BaseRestHandler() {
         ensureExpectedToken(Token.START_OBJECT, xcp.nextToken(), xcp)
 
         val monitorV2: MonitorV2
+        val rbacRoles: List<String>?
         try {
             monitorV2 = MonitorV2.parse(xcp)
+            rbacRoles = request.contentParser().map()["rbac_roles"] as List<String>?
         } catch (e: Exception) {
             throw AlertingException.wrap(e)
         }
@@ -68,7 +70,7 @@ class RestIndexMonitorV2Action : BaseRestHandler() {
             WriteRequest.RefreshPolicy.IMMEDIATE
         }
 
-        val indexMonitorV2Request = IndexMonitorV2Request(id, seqNo, primaryTerm, refreshPolicy, request.method(), monitorV2)
+        val indexMonitorV2Request = IndexMonitorV2Request(id, seqNo, primaryTerm, refreshPolicy, request.method(), monitorV2, rbacRoles)
 
         return RestChannelConsumer { channel ->
             client.execute(IndexMonitorV2Action.INSTANCE, indexMonitorV2Request, RestToXContentListener(channel))