/*
 * Copyright OpenSearch Contributors
 * SPDX-License-Identifier: Apache-2.0
 */
package org.opensearch.commons.notifications.model

import com.fasterxml.jackson.core.JsonParseException
import org.junit.jupiter.api.Assertions
import org.junit.jupiter.api.Assertions.assertEquals
import org.junit.jupiter.api.Test
import org.junit.jupiter.api.assertThrows
import org.opensearch.commons.utils.createObjectFromJsonString
import org.opensearch.commons.utils.getJsonString
import org.opensearch.commons.utils.recreateObject

internal class EventStatusTests {

    @Test
    fun `Event Status serialize and deserialize should be equal`() {
        val sampleStatus = EventStatus(
            "config_id",
            "name",
            ConfigType.SLACK,
            deliveryStatus = DeliveryStatus("404", "invalid recipient")
        )
        val recreatedObject = recreateObject(sampleStatus) { EventStatus(it) }
        assertEquals(sampleStatus, recreatedObject)
    }

    @Test
    fun `Event Status serialize and deserialize using json should be equal`() {
        val sampleStatus = EventStatus(
            "config_id",
            "name",
            ConfigType.SLACK,
            deliveryStatus = DeliveryStatus("404", "invalid recipient")
        )
        val jsonString = getJsonString(sampleStatus)
        val recreatedObject = createObjectFromJsonString(jsonString) { EventStatus.parse(it) }
        assertEquals(sampleStatus, recreatedObject)
    }

    @Test
    fun `Event Status should safely ignore extra field in json object`() {
        val sampleStatus = EventStatus(
            "config_id",
            "name",
            ConfigType.SLACK,
            deliveryStatus = DeliveryStatus("404", "invalid recipient")
        )
        val jsonString = """
        {
           "config_id":"config_id",
           "config_type":"slack",
           "config_name":"name",
           "email_recipient_status":[],
           "delivery_status":
           {
                "status_code":"404",
                "status_text":"invalid recipient"
           },
           "extra_field_1":["extra", "value"],
           "extra_field_2":{"extra":"value"},
           "extra_field_3":"extra value 3"
        }
        """.trimIndent()
        val recreatedObject = createObjectFromJsonString(jsonString) { EventStatus.parse(it) }
        assertEquals(sampleStatus, recreatedObject)
    }

    @Test
    fun `Event Status should throw exception when config type is email with empty emailRecipientList`() {
        val jsonString = """
        {
           "config_id":"config_id",
           "config_type":"email",
           "config_name":"name",
           "delivery_status":
           {
                "status_code":"404",
                "status_text":"invalid recipient"
           },
           "email_recipient_status":[]
        }
        """.trimIndent()
        assertThrows<IllegalArgumentException> {
            createObjectFromJsonString(jsonString) { EventStatus.parse(it) }
        }
    }

    @Test
    fun `Event should throw exception when invalid json object is passed`() {
        val jsonString = "sample message"
        assertThrows<JsonParseException> {
            createObjectFromJsonString(jsonString) { EventSource.parse(it) }
        }
    }

    @Test
    fun `Event throw exception if deliveryStatus is empty for config type Slack`() {
        Assertions.assertThrows(IllegalArgumentException::class.java) {
            EventStatus(
                "config_id",
                "name",
                ConfigType.SLACK
            )
        }
    }

    @Test
    fun `Event throw exception if deliveryStatus is empty for config type Chime`() {
        Assertions.assertThrows(IllegalArgumentException::class.java) {
            EventStatus(
                "config_id",
                "name",
                ConfigType.CHIME
            )
        }
    }

    @Test
    fun `Event throw exception if deliveryStatus is empty for config type Webhook`() {
        Assertions.assertThrows(IllegalArgumentException::class.java) {
            EventStatus(
                "config_id",
                "name",
                ConfigType.WEBHOOK
            )
        }
    }

    @Test
    fun `Event throw exception if emailRecipientStatus is empty for config type Email`() {
        Assertions.assertThrows(IllegalArgumentException::class.java) {
            EventStatus(
                "config_id",
                "name",
                ConfigType.EMAIL
            )
        }
    }
}