eventdestination_test.go

//
// SPDX-License-Identifier: BSD-3-Clause
//

package redfish

import (
	"encoding/json"
	"strings"
	"testing"

	"github.com/stmcginnis/gofish/common"
)

var eventDestinationBody = `{
		"@odata.context": "/redfish/v1/$metadata#EventDestination.EventDestination",
		"@odata.type": "#EventDestination.v1_0_0.EventDestination",
		"@odata.id": "/redfish/v1/EventDestination",
		"Id": "EventDestination-1",
		"Name": "EventDestinationOne",
		"Description": "EventDestination One",
		"Context": "MyContext",
		"Destination": "http://example.com/events",
		"EventFormatType": "MetricReport",
		"EventTypes":[
			"StatusChange",
			"ResourceUpdated",
			"ResourceAdded",
			"ResourceRemoved",
			"Alert"
		],
		"HttpHeaders": [],
		"MessageIds": ["One", "Two"],
		"Protocol": "Redfish",
		"RegistryPrefixes": ["ONE_", "TWO_"],
		"ResourceTypes": ["one", "two"],
		"SubordinateResources": false,
		"SubscriptionType": "SSE"
	}`

var eventDestinationsBody = `{
		"@odata.context": "/redfish/v1/$metadata#EventDestinationCollection.EventDestinationCollection",
		"@odata.etag": "W/\"AA6D42B0\"",
		"@odata.id": "/redfish/v1/EventService/Subscriptions/",
		"@odata.type": "#EventDestinationCollection.EventDestinationCollection",
		"Description": "User Event Subscriptions",
		"Name": "EventSubscriptions",
		"Members": [
			{
				"@odata.id": "/redfish/v1/EventService/Subscriptions/EventDestination-1/"
			}
		],
		"Members@odata.count": 1
	}`

// TestEventDestination tests the parsing of EventDestination objects.
func TestEventDestination(t *testing.T) {
	var result EventDestination
	err := json.NewDecoder(strings.NewReader(eventDestinationBody)).Decode(&result)

	if err != nil {
		t.Errorf("Error decoding JSON: %s", err)
	}

	if result.ID != "EventDestination-1" {
		t.Errorf("Received invalid ID: %s", result.ID)
	}

	if result.Name != "EventDestinationOne" {
		t.Errorf("Received invalid name: %s", result.Name)
	}

	if len(result.HTTPHeaders) != 0 {
		t.Errorf("Expected 0 headers, got: %d", len(result.HTTPHeaders))
	}

	if result.EventFormatType != MetricReportEventFormatType {
		t.Errorf("Invalid event format type: %s", result.EventFormatType)
	}

	if result.Protocol != RedfishEventDestinationProtocol {
		t.Errorf("Invalid event protocol: %s", result.Protocol)
	}

	if result.SubordinateResources {
		t.Error("Subordinate resources should be False")
	}

	for _, et := range result.EventTypes {
		if !et.IsValidEventType() {
			t.Errorf("invalid event type: %s", et)
		}
	}
}

// TestEventDestinationUpdate tests the Update call.
func TestEventDestinationUpdate(t *testing.T) {
	var result EventDestination
	err := json.NewDecoder(strings.NewReader(eventDestinationBody)).Decode(&result)

	if err != nil {
		t.Errorf("Error decoding JSON: %s", err)
	}

	testClient := &common.TestClient{}
	result.SetClient(testClient)

	result.Context = "NewContext"
	err = result.Update()

	if err != nil {
		t.Errorf("Error making Update call: %s", err)
	}

	calls := testClient.CapturedCalls()

	if !strings.Contains(calls[0].Payload, "Context:NewContext") {
		t.Errorf("Unexpected Context update payload: %s", calls[0].Payload)
	}
}