notify_test.go

package notify_test

import (
	"context"
	"fmt"
	"net/http"
	"testing"

	"github.com/stretchr/testify/assert"
	"go.uber.org/zap"

	"gitlab.eclipse.org/eclipse/xfsc/tsa/policy/internal/notify"
	"gitlab.eclipse.org/eclipse/xfsc/tsa/policy/internal/notify/notifyfakes"
	"gitlab.eclipse.org/eclipse/xfsc/tsa/policy/internal/storage"
)

func TestNotify_PolicyDataChange(t *testing.T) {
	tests := []struct {
		name              string
		events            notify.Events
		storage           notify.Storage
		eventPolicyChange *notify.EventPolicyChange

		errText string
	}{
		{
			name:              "error when sending event",
			eventPolicyChange: &notify.EventPolicyChange{Name: "exampleName", Version: "exampleVersion", Group: "exampleGroup"},
			storage: &notifyfakes.FakeStorage{PolicyChangeSubscribersStub: func(ctx context.Context, s1, s2, s3 string) ([]*storage.Subscriber, error) {
				return []*storage.Subscriber{}, nil
			}},
			events: &notifyfakes.FakeEvents{SendStub: func(ctx context.Context, a any) error {
				return fmt.Errorf("some error")
			}},

			errText: "some error",
		},

		{
			name:              "sending event is successful",
			eventPolicyChange: &notify.EventPolicyChange{Name: "exampleName", Version: "exampleVersion", Group: "exampleGroup"},
			storage: &notifyfakes.FakeStorage{PolicyChangeSubscribersStub: func(ctx context.Context, s1, s2, s3 string) ([]*storage.Subscriber, error) {
				return []*storage.Subscriber{}, nil
			}},
			events: &notifyfakes.FakeEvents{SendStub: func(ctx context.Context, a any) error {
				return nil
			}},
		},
	}

	for _, test := range tests {
		t.Run(test.name, func(t *testing.T) {
			notifier := notify.New(test.events, test.storage, http.DefaultClient, zap.NewNop())
			err := notifier.PolicyDataChange(context.Background(), test.eventPolicyChange.Name, test.eventPolicyChange.Group, test.eventPolicyChange.Version)
			if test.errText != "" {
				assert.ErrorContains(t, err, test.errText)
			} else {
				assert.NoError(t, err)
			}
		})
	}
}