1package dag
 2
 3import (
 4	"testing"
 5
 6	"github.com/stretchr/testify/require"
 7)
 8
 9func TestWriteRead(t *testing.T) {
10	repo, id1, id2, resolver, def := makeTestContext()
11
12	entity := wrapper(New(def))
13	require.False(t, entity.NeedCommit())
14
15	entity.Append(newOp1(id1, "foo"))
16	entity.Append(newOp2(id1, "bar"))
17
18	require.True(t, entity.NeedCommit())
19	require.NoError(t, entity.CommitAsNeeded(repo))
20	require.False(t, entity.NeedCommit())
21
22	entity.Append(newOp2(id2, "foobar"))
23	require.True(t, entity.NeedCommit())
24	require.NoError(t, entity.CommitAsNeeded(repo))
25	require.False(t, entity.NeedCommit())
26
27	read, err := Read(def, wrapper, repo, resolver, entity.Id())
28	require.NoError(t, err)
29
30	assertEqualEntities(t, entity.Entity, read.Entity)
31}
32
33func TestWriteReadMultipleAuthor(t *testing.T) {
34	repo, id1, id2, resolver, def := makeTestContext()
35
36	entity := wrapper(New(def))
37
38	entity.Append(newOp1(id1, "foo"))
39	entity.Append(newOp2(id2, "bar"))
40
41	require.NoError(t, entity.CommitAsNeeded(repo))
42
43	entity.Append(newOp2(id1, "foobar"))
44	require.NoError(t, entity.CommitAsNeeded(repo))
45
46	read, err := Read(def, wrapper, repo, resolver, entity.Id())
47	require.NoError(t, err)
48
49	assertEqualEntities(t, entity.Entity, read.Entity)
50}
51
52func assertEqualEntities(t *testing.T, a, b *Entity) {
53	t.Helper()
54
55	// testify doesn't support comparing functions and systematically fail if they are not nil
56	// so we have to set them to nil temporarily
57
58	backOpUnA := a.Definition.OperationUnmarshaler
59	backOpUnB := b.Definition.OperationUnmarshaler
60
61	a.Definition.OperationUnmarshaler = nil
62	b.Definition.OperationUnmarshaler = nil
63
64	defer func() {
65		a.Definition.OperationUnmarshaler = backOpUnA
66		b.Definition.OperationUnmarshaler = backOpUnB
67	}()
68
69	require.Equal(t, a, b)
70}