1package dag
2
3import (
4 "testing"
5
6 "github.com/stretchr/testify/require"
7)
8
9func TestWriteRead(t *testing.T) {
10 repo, id1, id2, 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.CommitAdNeeded(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.CommitAdNeeded(repo))
25 require.False(t, entity.NeedCommit())
26
27 read, err := Read(def, repo, entity.Id())
28 require.NoError(t, err)
29
30 assertEqualEntities(t, entity, read)
31}
32
33func assertEqualEntities(t *testing.T, a, b *Entity) {
34 // testify doesn't support comparing functions and systematically fail if they are not nil
35 // so we have to set them to nil temporarily
36
37 backOpUnA := a.Definition.operationUnmarshaler
38 backOpUnB := b.Definition.operationUnmarshaler
39
40 a.Definition.operationUnmarshaler = nil
41 b.Definition.operationUnmarshaler = nil
42
43 backIdResA := a.Definition.identityResolver
44 backIdResB := b.Definition.identityResolver
45
46 a.Definition.identityResolver = nil
47 b.Definition.identityResolver = nil
48
49 defer func() {
50 a.Definition.operationUnmarshaler = backOpUnA
51 b.Definition.operationUnmarshaler = backOpUnB
52 a.Definition.identityResolver = backIdResA
53 b.Definition.identityResolver = backIdResB
54 }()
55
56 require.Equal(t, a, b)
57}