Source file src/edge-infra.dev/pkg/edge/datasync/internal/outbox/file-repository_test.go

Documentation: edge-infra.dev/pkg/edge/datasync/internal/outbox

     1  package outbox
     2  
     3  import (
     4  	"testing"
     5  
     6  	"github.com/stretchr/testify/require"
     7  )
     8  
     9  func TestGetMessages(t *testing.T) {
    10  	p := NewFileRepository("./testdata/outbox", "tlog", 0)
    11  
    12  	messages := p.GetMessages(5)
    13  	require.Equal(t, 5, len(messages))
    14  
    15  	msg1 := messages["1a86d77f-7f0a-47e8-946f-aaf5cbdb7530"]
    16  	require.Equal(t, "1a86d77f-7f0a-47e8-946f-aaf5cbdb7530", msg1.ID.String())
    17  
    18  	require.Equal(t, "tenant-123", msg1.TenantID)
    19  
    20  	year, month, day := msg1.CreatedAt.Date()
    21  	//"2021-04-25T14:40:04.252806294Z"
    22  	require.Equal(t, 2021, year)
    23  	require.Equal(t, "April", month.String())
    24  	require.Equal(t, 25, day)
    25  	require.Equal(t, 14, msg1.CreatedAt.Hour())
    26  	require.Equal(t, 40, msg1.CreatedAt.Minute())
    27  	require.Equal(t, 4, msg1.CreatedAt.Second())
    28  
    29  	require.Equal(t, "SomeSignature", msg1.Signature)
    30  	require.Equal(t, "./testdata/outbox/tlog/0/tlog_1a86d77f-7f0a-47e8-946f-aaf5cbdb7530.dsm", msg1.FilePath)
    31  
    32  	//TODO: test also the payload (compressed and not-compressed)
    33  	//require.Equal(t, "aa", msg1.Payload)
    34  }
    35  

View as plain text