blobdisk_test.go RawHistoryFolder

1// SPDX-License-Identifier: AGPL-3.0-or-later
2package blobdisk_test
3
4import (
5	"context"
6	"os"
7	"path/filepath"
8	"testing"
9
10	"bnema.dev/ermite/internal/adapters/blobdisk"
11	"bnema.dev/ermite/internal/adapters/blobtest"
12	"bnema.dev/ermite/internal/domain"
13	"bnema.dev/ermite/internal/ports"
14	"github.com/stretchr/testify/require"
15)
16
17func TestContract(t *testing.T) {
18	blobtest.Run(t, func(t *testing.T) ports.BlobStore { return blobdisk.New(t.TempDir()) })
19}
20func TestCrashTempInvisible(t *testing.T) {
21	root := t.TempDir()
22	s := blobdisk.New(root)
23	ctx := context.Background()
24	require.NoError(t, s.Check(ctx))
25	require.NoError(t, os.WriteFile(filepath.Join(root, "tmp", ".tmp-crashed"), []byte("partial"), 0600))
26	require.NoError(t, s.List(ctx, "", func(ports.BlobInfo) error { t.Fatal("temporary object listed"); return nil }))
27	_, e := s.Stat(ctx, ".tmp-crashed")
28	require.ErrorIs(t, e, domain.ErrNotFound)
29}