]> git.giacomolli.uk - onechat/blobdiff - replay_test.go
Check Go names and declarations with revive
[onechat] / replay_test.go
index dfbe6157a78014be1036fbd9a655ae258f2c3e8c..547b5e4efd44e9284103f8ddd016929d0a197ba0 100644 (file)
@@ -38,7 +38,7 @@ func TestReplaySyntheticLog(t *testing.T) {
        root := t.TempDir()
        clock := newTestClock()
        random := rand.New(rand.NewPCG(1, 2))
        root := t.TempDir()
        clock := newTestClock()
        random := rand.New(rand.NewPCG(1, 2))
-       memory, err := openMemory(t.Context(), root, clock.Now, newFakeSummarizer())
+       memory, err := openMemory(t.Context(), root, clock.Now, newFakeSummarizer(), discardLog())
        require.NoError(t, err)
 
        defer func() {
        require.NoError(t, err)
 
        defer func() {
@@ -71,7 +71,7 @@ func TestReplaySyntheticLog(t *testing.T) {
 
        memory = replayRequireRestart(t, memory, root, clock)
        require.Equal(t, messages, memory.log.Len())
 
        memory = replayRequireRestart(t, memory, root, clock)
        require.Equal(t, messages, memory.log.Len())
-       require.Greater(t, batches, 0)
+       require.Positive(t, batches)
 
        require.NoError(t, memory.Wait(t.Context()))
        t.Logf("%d messages, %d nodes, %d batches in %s", messages, memory.tree.Count(), batches, time.Since(start).Round(time.Second))
 
        require.NoError(t, memory.Wait(t.Context()))
        t.Logf("%d messages, %d nodes, %d batches in %s", messages, memory.tree.Count(), batches, time.Since(start).Round(time.Second))
@@ -98,7 +98,7 @@ func replayRequireRestart(t *testing.T, memory *Memory, root string, clock *Test
        require.NoError(t, err)
        require.NoError(t, memory.Close())
 
        require.NoError(t, err)
        require.NoError(t, memory.Close())
 
-       memory, err = openMemory(t.Context(), root, clock.Now, newFakeSummarizer())
+       memory, err = openMemory(t.Context(), root, clock.Now, newFakeSummarizer(), discardLog())
        require.NoError(t, err)
        require.NoError(t, memory.Wait(t.Context()))
        require.Equal(t, view, memory.View())
        require.NoError(t, err)
        require.NoError(t, memory.Wait(t.Context()))
        require.Equal(t, view, memory.View())