Monitor model changed to add an optional fanoutEnabled field

Signed-off-by: Riya Saxena <riysaxen@amazon.com>

Author: riysaxen-amzn

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

@@ -44,7 +44,8 @@ data class Monitor(
     val dataSources: DataSources = DataSources(),
     val deleteQueryIndexInEveryRun: Boolean? = false,
     val shouldCreateSingleAlertForFindings: Boolean? = false,
-    val owner: String? = "alerting"
+    val owner: String? = "alerting",
+    val fanoutEnabled: Boolean? = true,
 ) : ScheduledJob {
 
     override val type = MONITOR_TYPE
@@ -114,6 +115,7 @@ data class Monitor(
         },
         deleteQueryIndexInEveryRun = sin.readOptionalBoolean(),
         shouldCreateSingleAlertForFindings = sin.readOptionalBoolean(),
+        fanoutEnabled = sin.readOptionalBoolean(),
         owner = sin.readOptionalString()
     )
 
@@ -175,6 +177,7 @@ data class Monitor(
         builder.field(DATA_SOURCES_FIELD, dataSources)
         builder.field(DELETE_QUERY_INDEX_IN_EVERY_RUN_FIELD, deleteQueryIndexInEveryRun)
         builder.field(SHOULD_CREATE_SINGLE_ALERT_FOR_FINDINGS_FIELD, shouldCreateSingleAlertForFindings)
+        builder.field(FAN_OUT_ENABLED_FIELD, fanoutEnabled)
         builder.field(OWNER_FIELD, owner)
         if (params.paramAsBoolean("with_type", false)) builder.endObject()
         return builder.endObject()
@@ -228,6 +231,7 @@ data class Monitor(
         dataSources.writeTo(out)
         out.writeOptionalBoolean(deleteQueryIndexInEveryRun)
         out.writeOptionalBoolean(shouldCreateSingleAlertForFindings)
+        out.writeOptionalBoolean(fanoutEnabled)
         out.writeOptionalString(owner)
     }
 
@@ -250,6 +254,7 @@ data class Monitor(
         const val ENABLED_TIME_FIELD = "enabled_time"
         const val DELETE_QUERY_INDEX_IN_EVERY_RUN_FIELD = "delete_query_index_in_every_run"
         const val SHOULD_CREATE_SINGLE_ALERT_FOR_FINDINGS_FIELD = "should_create_single_alert_for_findings"
+        const val FAN_OUT_ENABLED_FIELD = "fan_out_enabled"
         const val OWNER_FIELD = "owner"
         val MONITOR_TYPE_PATTERN = Pattern.compile("[a-zA-Z0-9_]{5,25}")
 
@@ -281,6 +286,7 @@ data class Monitor(
             var deleteQueryIndexInEveryRun = false
             var delegateMonitor = false
             var owner = "alerting"
+            var fanoutEnabled = true
 
             XContentParserUtils.ensureExpectedToken(XContentParser.Token.START_OBJECT, xcp.currentToken(), xcp)
             while (xcp.nextToken() != XContentParser.Token.END_OBJECT) {
@@ -343,6 +349,11 @@ data class Monitor(
                     } else {
                         xcp.booleanValue()
                     }
+                    FAN_OUT_ENABLED_FIELD -> fanoutEnabled = if (xcp.currentToken() == XContentParser.Token.VALUE_NULL) {
+                        fanoutEnabled
+                    } else {
+                        xcp.booleanValue()
+                    }
                     OWNER_FIELD -> owner = if (xcp.currentToken() == XContentParser.Token.VALUE_NULL) owner else xcp.text()
                     else -> {
                         xcp.skipChildren()
@@ -372,7 +383,8 @@ data class Monitor(
                 dataSources,
                 deleteQueryIndexInEveryRun,
                 delegateMonitor,
-                owner
+                owner,
+                fanoutEnabled
             )
         }