package event

import (
	"github.com/leandro-lugaresi/hub"
	"github.com/stretchr/testify/assert"
	"testing"
)

func TestEntitiesUpdated(t *testing.T) {
	s := Subscribe("test.updated")

	assert.IsType(t, hub.Subscription{}, s)

	entities := "test"
	EntitiesUpdated("test", entities)
	msg := <-s.Receiver

	assert.Equal(t, "test.updated", msg.Name)
	assert.Equal(t, Data{"entities": "test"}, msg.Fields)

	Unsubscribe(s)
}

func TestEntitiesCreated(t *testing.T) {
	s := Subscribe("test.created")

	assert.IsType(t, hub.Subscription{}, s)

	entities := "test"
	EntitiesCreated("test", entities)
	msg := <-s.Receiver

	assert.Equal(t, "test.created", msg.Name)
	assert.Equal(t, Data{"entities": "test"}, msg.Fields)

	Unsubscribe(s)
}

func TestEntitiesDeleted(t *testing.T) {
	s := Subscribe("test.deleted")

	assert.IsType(t, hub.Subscription{}, s)

	entities := "test"
	EntitiesDeleted("test", entities)
	msg := <-s.Receiver

	assert.Equal(t, "test.deleted", msg.Name)
	assert.Equal(t, Data{"entities": "test"}, msg.Fields)

	Unsubscribe(s)
}

func TestEntitiesArchived(t *testing.T) {
	s := Subscribe("test.archived")

	assert.IsType(t, hub.Subscription{}, s)

	entities := "test"
	EntitiesArchived("test", entities)
	msg := <-s.Receiver

	assert.Equal(t, "test.archived", msg.Name)
	assert.Equal(t, Data{"entities": "test"}, msg.Fields)

	Unsubscribe(s)
}

func TestEntitiesRestored(t *testing.T) {
	s := Subscribe("test.restored")

	assert.IsType(t, hub.Subscription{}, s)

	entities := "test"
	EntitiesRestored("test", entities)
	msg := <-s.Receiver

	assert.Equal(t, "test.restored", msg.Name)
	assert.Equal(t, Data{"entities": "test"}, msg.Fields)

	Unsubscribe(s)
}