activity.go RawHistoryFolder

1// SPDX-License-Identifier: AGPL-3.0-or-later
2
3package usecase
4
5import (
6	"context"
7	"errors"
8	"fmt"
9	"time"
10
11	"github.com/bnema/zerowrap"
12
13	"bnema.dev/ermite/internal/domain"
14	"bnema.dev/ermite/internal/ports"
15)
16
17// recordActivity is best-effort: a metadata failure never fails the action.
18func recordActivity(ctx context.Context, meta ports.RepoMetaStore, name domain.RepoName, at time.Time) {
19	if _, err := touchActiveAt(ctx, meta, name, at); err != nil {
20		log := zerowrap.FromCtx(ctx)
21		log.Error().Err(err).Str("repo", name.String()).Msg("record repository activity")
22	}
23}
24
25// touchActiveAt preserves later activity and retries concurrent metadata writes.
26// A repository deleted meanwhile is not an error.
27func touchActiveAt(ctx context.Context, meta ports.RepoMetaStore, name domain.RepoName, now time.Time) (domain.Repo, error) {
28	repo, err := meta.Mutate(ctx, name, func(repo *domain.Repo) (bool, error) {
29		changed := false
30		if now.After(repo.ActiveAt) {
31			repo.ActiveAt = now
32			changed = true
33		}
34		return changed, nil
35	})
36	if errors.Is(err, domain.ErrNotFound) {
37		return domain.Repo{}, nil
38	}
39	if err != nil {
40		return repo, fmt.Errorf("update repository %q: %w", name, err)
41	}
42	return repo, nil
43}