services_backup_ports_test.go RawHistoryFolder

1package app
2
3import (
4	"context"
5	"net/http"
6	"net/http/httptest"
7	"testing"
8
9	"github.com/bnema/zerowrap"
10	"github.com/stretchr/testify/assert"
11	"github.com/stretchr/testify/require"
12
13	"github.com/bnema/gordon/internal/adapters/in/http/admin"
14	"github.com/bnema/gordon/internal/domain"
15	"github.com/bnema/gordon/internal/usecase/backup"
16)
17
18func TestBackupServicePortsReturnUntypedNilWhenDisabled(t *testing.T) {
19	assert.True(t, backupServicePort(nil) == nil)
20	assert.True(t, volumeBackupServicePort(nil) == nil)
21
22	assert.True(t, backupServicePort(&backup.Service{}) != nil)
23	assert.True(t, volumeBackupServicePort(&backup.VolumeService{}) != nil)
24}
25
26// TestAdminBackupRoutesWhenBackupsDisabled proves the admin API answers
27// 503 instead of panicking when database or volume backups are disabled.
28func TestAdminBackupRoutesWhenBackupsDisabled(t *testing.T) {
29	var disabled *backup.Service
30	var disabledVolumes *backup.VolumeService
31	handler := admin.NewHandler(admin.HandlerDeps{
32		Log:             zerowrap.Default(),
33		BackupSvc:       backupServicePort(disabled),
34		VolumeBackupSvc: volumeBackupServicePort(disabledVolumes),
35	})
36
37	for _, path := range []string{"/admin/backups/status", "/admin/backups/volumes/status"} {
38		t.Run(path, func(t *testing.T) {
39			req := httptest.NewRequest(http.MethodGet, path, nil)
40			req = req.WithContext(context.WithValue(req.Context(), domain.ContextKeyScopes, []string{"admin:*:*"}))
41			rec := httptest.NewRecorder()
42
43			require.NotPanics(t, func() { handler.ServeHTTP(rec, req) })
44			assert.Equal(t, http.StatusServiceUnavailable, rec.Code)
45		})
46	}
47}