mirrors_key_fixture_test.go RawHistoryFolder

1// SPDX-License-Identifier: AGPL-3.0-or-later
2
3package usecase_test
4
5import (
6	"errors"
7	"sync"
8	"testing"
9
10	"github.com/stretchr/testify/mock"
11
12	"bnema.dev/ermite/internal/domain"
13	"bnema.dev/ermite/internal/ports/mocks"
14	"bnema.dev/ermite/internal/usecase"
15)
16
17// keyFixture is a Mirrors with only the key store, a sealing fake and a clock.
18type keyFixture struct {
19	m               *usecase.Mirrors
20	keys            *mocks.MirrorKeyStore
21	sealerOpenFails bool
22	mu              sync.Mutex
23	sealed          [][]byte
24}
25
26func newKeyFixture(t *testing.T) *keyFixture {
27	t.Helper()
28	f := &keyFixture{keys: mocks.NewMirrorKeyStore(t)}
29	sealer, clock := mocks.NewSecretSealer(t), mocks.NewClock(t)
30	clock.EXPECT().Now().Return(now).Maybe()
31	sealer.EXPECT().Seal(mock.Anything, []byte(domain.MirrorKeyPath)).RunAndReturn(func(seed, _ []byte) []byte {
32		f.mu.Lock()
33		defer f.mu.Unlock()
34		f.sealed = append(f.sealed, append([]byte(nil), seed...))
35		return append([]byte("sealed:"), seed...)
36	}).Maybe()
37	sealer.EXPECT().Open(mock.Anything, []byte(domain.MirrorKeyPath)).RunAndReturn(func(b, _ []byte) ([]byte, error) {
38		if f.sealerOpenFails {
39			return nil, errors.New("cannot open")
40		}
41		return b[len("sealed:"):], nil
42	}).Maybe()
43	f.m = usecase.NewMirrors(usecase.MirrorsConfig{Keys: f.keys, Sealer: sealer, Clock: clock, PublicURL: "https://forge.example.com"})
44	return f
45}
46
47// seeds are the seeds generated so far.
48func (f *keyFixture) seeds() [][]byte {
49	f.mu.Lock()
50	defer f.mu.Unlock()
51	return append([][]byte(nil), f.sealed...)
52}