1// SPDX-License-Identifier: AGPL-3.0-or-later
2
3package usecase
4
5import (
6 "context"
7 "errors"
8 "testing"
9 "time"
10
11 "github.com/stretchr/testify/mock"
12 "github.com/stretchr/testify/require"
13
14 "bnema.dev/ermite/internal/domain"
15 "bnema.dev/ermite/internal/ports/mocks"
16)
17
18func TestTouchActiveAt(t *testing.T) {
19 name, err := domain.ParseRepoName("proj")
20 require.NoError(t, err)
21 now := time.Now().UTC()
22 t.Run("preserves later activity", func(t *testing.T) {
23 meta := mocks.NewRepoMetaStore(t)
24 later := domain.Repo{Name: name, ActiveAt: now.Add(time.Hour)}
25 meta.EXPECT().Mutate(mock.Anything, name, mock.Anything).RunAndReturn(func(_ context.Context, _ domain.RepoName, fn func(*domain.Repo) (bool, error)) (domain.Repo, error) {
26 repo := later
27 changed, err := fn(&repo)
28 require.NoError(t, err)
29 require.False(t, changed)
30 return repo, nil
31 })
32 got, err := touchActiveAt(t.Context(), meta, name, now)
33 require.NoError(t, err)
34 require.Equal(t, later, got)
35 })
36 t.Run("deleted repository", func(t *testing.T) {
37 meta := mocks.NewRepoMetaStore(t)
38 meta.EXPECT().Mutate(mock.Anything, name, mock.Anything).Return(domain.Repo{}, domain.ErrNotFound)
39 _, err := touchActiveAt(t.Context(), meta, name, now)
40 require.NoError(t, err)
41 })
42 t.Run("best effort failure", func(t *testing.T) {
43 meta := mocks.NewRepoMetaStore(t)
44 meta.EXPECT().Mutate(mock.Anything, name, mock.Anything).Return(domain.Repo{}, errors.New("offline"))
45 require.NotPanics(t, func() { recordActivity(t.Context(), meta, name, now) })
46 })
47}