fix serde of RemoteDocLevelMonitorInput (#666)

sbcd90 · web-flow · commit 0d215268815a · 2024-06-05T11:34:30.000-07:00
Signed-off-by: Subhobrata Dey &lt;sbcd90@gmail.com&gt;
diff --git a/src/main/kotlin/org/opensearch/commons/alerting/model/remote/monitors/RemoteDocLevelMonitorInput.kt b/src/main/kotlin/org/opensearch/commons/alerting/model/remote/monitors/RemoteDocLevelMonitorInput.kt
@@ -68,7 +68,10 @@ data class RemoteDocLevelMonitorInput(val input: BytesReference, val docLevelMon
                 when (fieldName) {
                     RemoteMonitorInput.INPUT_FIELD -> bytes = xcp.binaryValue()
                     RemoteMonitorInput.INPUT_SIZE -> size = xcp.intValue()
-                    Input.Type.DOCUMENT_LEVEL_INPUT.value -> docLevelMonitorInput = DocLevelMonitorInput.parse(xcp)
+                    Input.Type.DOCUMENT_LEVEL_INPUT.value -> {
+                        docLevelMonitorInput = DocLevelMonitorInput.parse(xcp)
+                        XContentParserUtils.ensureExpectedToken(XContentParser.Token.END_OBJECT, xcp.nextToken(), xcp)
+                    }
                 }
             }
             val input = BytesReference.fromByteBuffer(ByteBuffer.wrap(bytes, 0, size))

Original file line number	Diff line number	Diff line change
`@@ -68,7 +68,10 @@ data class RemoteDocLevelMonitorInput(val input: BytesReference, val docLevelMon`
`68`	`68`	`when (fieldName) {`
`69`	`69`	`RemoteMonitorInput.INPUT_FIELD -> bytes = xcp.binaryValue()`
`70`	`70`	`RemoteMonitorInput.INPUT_SIZE -> size = xcp.intValue()`
`71`		`- Input.Type.DOCUMENT_LEVEL_INPUT.value -> docLevelMonitorInput = DocLevelMonitorInput.parse(xcp)`
	`71`	`+ Input.Type.DOCUMENT_LEVEL_INPUT.value -> {`
	`72`	`+ docLevelMonitorInput = DocLevelMonitorInput.parse(xcp)`
	`73`	`+ XContentParserUtils.ensureExpectedToken(XContentParser.Token.END_OBJECT, xcp.nextToken(), xcp)`
	`74`	`+ }`
`72`	`75`	`}`
`73`	`76`	`}`
`74`	`77`	`val input = BytesReference.fromByteBuffer(ByteBuffer.wrap(bytes, 0, size))`