X-Git-Url: http://git.giacomolli.uk/onechat/blobdiff_plain/6755f2645bf6bcf8c7cd5b1f3a682a11bf2392f5..c9183f90d757006e7221ecd0d4dc0db2a25f87e0:/compactor_test.go diff --git a/compactor_test.go b/compactor_test.go index cd6311a..35e09eb 100644 --- a/compactor_test.go +++ b/compactor_test.go @@ -72,11 +72,19 @@ func TestCompactorRetriesALongLineWithTheNewestNote(t *testing.T) { writeEvents(w, completedEvent([]any{messageItem(long[call.number])}, 100, 0, 5)) } - line, err := newTestCompactor(t, server).Summarize(t.Context(), leafTask()) + compactor := newTestCompactor(t, server) + line, err := compactor.Summarize(t.Context(), leafTask()) require.NoError(t, err) require.Equal(t, long[2], line) require.Equal(t, 3, server.Calls()) + records := readUsage(t, compactor.client.usage.path) + require.Len(t, records, 3) + for n, record := range records { + require.Equal(t, &[2]int{0, 0}, record.Node) + require.Equal(t, len(long[n]), record.TextBytes) + } + first := inputParts(t, server.Call(0)) require.Len(t, first, 2) for n, want := range []string{long[0], long[1]} {