releases_index.go RawHistoryFolder

1// SPDX-License-Identifier: AGPL-3.0-or-later
2package kvstore
3
4import (
5	"context"
6	"fmt"
7	"strconv"
8
9	kv "bnema.dev/ermite-kv"
10	"bnema.dev/ermite/internal/domain"
11)
12
13const releaseLatestIndexMarker = "meta/release-latest-index"
14
15// buildReleaseLatestIndex runs before the store is exposed to writers. A crash
16// before the marker is written safely repeats the pass on the next open.
17// Selection remains owned by domain.LatestRelease.
18func (s *Store) buildReleaseLatestIndex(ctx context.Context) error {
19	if _, ok := s.db.Get(ctx, []byte(releaseLatestIndexMarker)); ok {
20		return nil
21	}
22	var repo domain.RepoName
23	var best domain.Release
24	var eligible bool
25	flush := func() error {
26		var b kv.Batch
27		if eligible {
28			b.Put(relLatestKey(repo), []byte(strconv.FormatInt(best.ID, 10)))
29		} else {
30			b.Delete(relLatestKey(repo))
31		}
32		if _, err := s.db.Apply(ctx, &b); err != nil {
33			return fmt.Errorf("build latest release index: %w", err)
34		}
35		return nil
36	}
37	haveRepo := false
38	for _, item := range s.db.Snapshot(ctx).Prefix(ctx, []byte("rel/")) {
39		rel, err := decodeRelease(item)
40		if err != nil {
41			return fmt.Errorf("build latest release index: %w", err)
42		}
43		if haveRepo && rel.Repo != repo {
44			if err := flush(); err != nil {
45				return err
46			}
47			best, eligible = domain.Release{}, false
48		}
49		repo, haveRepo = rel.Repo, true
50		if eligible {
51			best, eligible = domain.LatestRelease([]domain.Release{best, rel})
52		} else {
53			best, eligible = domain.LatestRelease([]domain.Release{rel})
54		}
55	}
56	if haveRepo {
57		if err := flush(); err != nil {
58			return err
59		}
60	}
61	var b kv.Batch
62	b.Put([]byte(releaseLatestIndexMarker), []byte{1})
63	if _, err := s.db.Apply(ctx, &b); err != nil {
64		return fmt.Errorf("mark latest release index: %w", err)
65	}
66	return nil
67}