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) }