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 := 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, repo, resolver, entity.Id())
28 require.NoError(t, err)
29
30 assertEqualEntities(t, entity, read)
31}
32
33func TestWriteReadMultipleAuthor(t *testing.T) {
34 repo, id1, id2, resolver, def := makeTestContext()
35
36 entity := 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, repo, resolver, entity.Id())
47 require.NoError(t, err)
48
49 assertEqualEntities(t, entity, read)
50}
51
52func assertEqualEntities(t *testing.T, a, b *Entity) {
53 // testify doesn't support comparing functions and systematically fail if they are not nil
54 // so we have to set them to nil temporarily
55
56 backOpUnA := a.Definition.OperationUnmarshaler
57 backOpUnB := b.Definition.OperationUnmarshaler
58
59 a.Definition.OperationUnmarshaler = nil
60 b.Definition.OperationUnmarshaler = nil
61
62 defer func() {
63 a.Definition.OperationUnmarshaler = backOpUnA
64 b.Definition.OperationUnmarshaler = backOpUnB
65 }()
66
67 require.Equal(t, a, b)
68}