outbox_test.go RawHistoryFolder

1// SPDX-License-Identifier: MIT
2
3package host
4
5import (
6	"context"
7	"strings"
8	"testing"
9	"time"
10
11	"github.com/bnema/zerowrap"
12)
13
14// AppendNow says so when an earlier send was cut short and the offset may be
15// behind the server's (GO-005), and stays silent otherwise.
16func TestAppendNowWarnsOfAStaleOffset(t *testing.T) {
17	const warning = "log offset may be stale"
18	logs := &logBuf{}
19	log := zerowrap.New(zerowrap.Config{Level: "debug", Format: "json", Output: logs})
20	tm := Timing{CallTimeout: time.Hour, BackoffMin: time.Millisecond, BackoffMax: time.Millisecond}
21	cl := &stubClient{hang: true}
22	o := newOutbox(cl, "j1", tm, func(error) {}, log)
23
24	// A send that Close cut short: the server may have applied it.
25	ctx, cancel := context.WithTimeout(context.Background(), 50*time.Millisecond)
26	defer cancel()
27	o.sendLines(ctx, []event{{line: &logLine{step: 1, text: "a"}}})
28
29	cl.mu.Lock()
30	cl.hang = false
31	cl.mu.Unlock()
32	o.AppendNow(context.Background(), logLine{step: 1, text: "b"})
33	if !strings.Contains(logs.String(), warning) {
34		t.Fatalf("no warning about the offset: %q", logs.String())
35	}
36
37	// The send went through: the offset is the server's again.
38	logs.mu.Lock()
39	logs.b.Reset()
40	logs.mu.Unlock()
41	o.AppendNow(context.Background(), logLine{step: 1, text: "c"})
42	if strings.Contains(logs.String(), warning) {
43		t.Fatalf("a warning with a fresh offset: %q", logs.String())
44	}
45}