backup_metrics_wiring_test.go RawHistoryFolder

1package app
2
3import (
4	"context"
5	"testing"
6	"time"
7
8	"github.com/bnema/zerowrap"
9	"github.com/stretchr/testify/assert"
10	"github.com/stretchr/testify/require"
11
12	"github.com/bnema/gordon/internal/domain"
13	cronSvc "github.com/bnema/gordon/internal/usecase/cron"
14)
15
16type fakeNextRunObserver struct {
17	got map[domain.BackupKind]func() time.Time
18}
19
20func (f *fakeNextRunObserver) ObserveBackupNextRun(kind domain.BackupKind, next func() time.Time) {
21	if f.got == nil {
22		f.got = map[domain.BackupKind]func() time.Time{}
23	}
24	f.got[kind] = next
25}
26
27func TestObserveSchedulerNextRun_ReadsTheLiveEntry(t *testing.T) {
28	scheduler := cronSvc.NewScheduler(zerowrap.Default())
29	require.NoError(t, scheduler.Add("volume-backup-scheduler", "Volume Backups",
30		domain.CronSchedule{Preset: domain.ScheduleDaily}, func(context.Context) error { return nil }))
31
32	obs := &fakeNextRunObserver{}
33	observeSchedulerNextRun(obs, domain.BackupKindVolume, scheduler, "volume-backup-scheduler")
34
35	require.Contains(t, obs.got, domain.BackupKindVolume)
36	next := obs.got[domain.BackupKindVolume]()
37	assert.Equal(t, nextRunOf(scheduler, "volume-backup-scheduler"), next)
38	assert.True(t, next.After(time.Now()))
39}
40
41func TestObserveSchedulerNextRun_NilSafe(t *testing.T) {
42	scheduler := cronSvc.NewScheduler(zerowrap.Default())
43	assert.NotPanics(t, func() {
44		observeSchedulerNextRun(nil, domain.BackupKindVolume, scheduler, "x")
45	})
46	obs := &fakeNextRunObserver{}
47	observeSchedulerNextRun(obs, domain.BackupKindVolume, nil, "x")
48	assert.Empty(t, obs.got)
49}