package outbox

import (
	"testing"

	"github.com/stretchr/testify/require"
)

func TestGetMessages(t *testing.T) {
	p := NewFileRepository("./testdata/outbox", "tlog", 0)

	messages := p.GetMessages(5)
	require.Equal(t, 5, len(messages))

	msg1 := messages["1a86d77f-7f0a-47e8-946f-aaf5cbdb7530"]
	require.Equal(t, "1a86d77f-7f0a-47e8-946f-aaf5cbdb7530", msg1.ID.String())

	require.Equal(t, "tenant-123", msg1.TenantID)

	year, month, day := msg1.CreatedAt.Date()
	//"2021-04-25T14:40:04.252806294Z"
	require.Equal(t, 2021, year)
	require.Equal(t, "April", month.String())
	require.Equal(t, 25, day)
	require.Equal(t, 14, msg1.CreatedAt.Hour())
	require.Equal(t, 40, msg1.CreatedAt.Minute())
	require.Equal(t, 4, msg1.CreatedAt.Second())

	require.Equal(t, "SomeSignature", msg1.Signature)
	require.Equal(t, "./testdata/outbox/tlog/0/tlog_1a86d77f-7f0a-47e8-946f-aaf5cbdb7530.dsm", msg1.FilePath)

	//TODO: test also the payload (compressed and not-compressed)
	//require.Equal(t, "aa", msg1.Payload)
}