service.go RawHistoryFolder

1// Package volumes implements volume management operations.
2package volumes
3
4import (
5	"context"
6	"fmt"
7
8	"github.com/bnema/zerowrap"
9
10	"github.com/bnema/gordon/internal/boundaries/out"
11	"github.com/bnema/gordon/internal/domain"
12)
13
14// Service implements the VolumeService interface.
15type Service struct {
16	runtime out.ContainerRuntime
17}
18
19// NewService creates a new volume service.
20func NewService(runtime out.ContainerRuntime) *Service {
21	return &Service{runtime: runtime}
22}
23
24// ListVolumes returns all volumes with usage status.
25func (s *Service) ListVolumes(ctx context.Context) ([]*domain.VolumeInfo, error) {
26	ctx = zerowrap.CtxWithFields(ctx, map[string]any{
27		zerowrap.FieldLayer:   "usecase",
28		zerowrap.FieldUseCase: "ListVolumes",
29	})
30
31	vols, err := s.runtime.ListVolumes(ctx)
32	if err != nil {
33		return nil, fmt.Errorf("failed to list volumes: %w", err)
34	}
35	return vols, nil
36}
37
38// PruneVolumes removes volumes not mounted by any container.
39// Returns a report and the list of volumes that were (or would be) removed.
40func (s *Service) PruneVolumes(ctx context.Context, dryRun bool) (*domain.VolumePruneReport, []*domain.VolumeInfo, error) {
41	ctx = zerowrap.CtxWithFields(ctx, map[string]any{
42		zerowrap.FieldLayer:   "usecase",
43		zerowrap.FieldUseCase: "PruneVolumes",
44		"dry_run":             dryRun,
45	})
46	log := zerowrap.FromCtx(ctx)
47
48	vols, err := s.runtime.ListVolumes(ctx)
49	if err != nil {
50		return nil, nil, fmt.Errorf("failed to list volumes: %w", err)
51	}
52
53	report := &domain.VolumePruneReport{}
54	var removed []*domain.VolumeInfo
55
56	for _, vol := range vols {
57		if vol.InUse {
58			continue
59		}
60
61		if !dryRun {
62			if err := s.runtime.RemoveVolume(ctx, vol.Name, false); err != nil {
63				log.Warn().Err(err).Str("volume", vol.Name).Msg("failed to remove volume, skipping")
64				continue
65			}
66		}
67
68		removed = append(removed, vol)
69		report.VolumesRemoved++
70		report.SpaceReclaimed += vol.Size
71	}
72
73	return report, removed, nil
74}