Restore: автозамена minio/minio и minio/mc на pgsty/silo и pgsty/mc

Образы minio удалены с Docker Hub, Stoat перешёл на silo (drop-in).
Замена идёт через compose.restore.yml, исходные compose-файлы не трогаются.

Co-Authored-By: Claude Sonnet 5.5 <noreply@anthropic.com>

internal/restore/compose.go

@@ -54,6 +54,7 @@ func (r *restorer) restoreCompose(c manifest.Category) error {
 
 	if err := compose("pull", "--ignore-buildable", "--quiet"); err != nil {
 		r.warn("%s: pull: %v", c.Name, err)
+		r.pullFallback(c, compose)
 	}
 	if hasBuilt(info) {
 		if err := compose("build"); err != nil {
@@ -94,6 +95,62 @@ func hasBuilt(info *manifest.Compose) bool {
 
 // writePinFile пишет compose.restore.yml с образами по digest. Пустая строка — закреплять нечего.
 func (r *restorer) writePinFile(c manifest.Category) (string, error) {
+	return r.writePinFileSkip(c, nil)
+}
+
+// pullFallback вызывается, когда общий pull не удался (например, образ по digest
+// удалён из реестра — так случилось с minio/minio на Docker Hub). Тянет сервисы
+// по одному; для тех, что не нашлись по digest, снимает закрепление и пробует
+// тег из исходного compose-файла.
+func (r *restorer) pullFallback(c manifest.Category, compose func(...string) error) {
+	var failed []string
+	for svc, img := range c.Compose.Images {
+		if img.Built {
+			continue
+		}
+		if err := compose("pull", "--quiet", svc); err != nil {
+			failed = append(failed, svc)
+		}
+	}
+	if len(failed) == 0 {
+		return
+	}
+	slices.Sort(failed)
+	skip := map[string]bool{}
+	for _, svc := range failed {
+		skip[svc] = true
+	}
+	if _, err := r.writePinFileSkip(c, skip); err != nil {
+		r.warn("%s: не удалось переписать %s: %v", c.Name, pinFile, err)
+		return
+	}
+	for _, svc := range failed {
+		if err := compose("pull", "--quiet", svc); err != nil {
+			r.warn("%s: образ сервиса %s недоступен ни по digest, ни по тегу: %v", c.Name, svc, err)
+			r.todo = append(r.todo, fmt.Sprintf("%s: образ сервиса %s недоступен в реестре (возможно, удалён или переехал, напр. minio/minio → quay.io/minio/minio). Поправьте image в compose-файле и выполните `docker compose up -d`", c.Name, svc))
+			continue
+		}
+		r.warn("%s: сервис %s: образ по digest недоступен, взят по тегу из compose-файла (версия может отличаться)", c.Name, svc)
+	}
+}
+
+// removedImages — образы, исчезнувшие из реестров, и их drop-in замены.
+// minio/* убраны с Docker Hub; Stoat перешёл на форк silo (stoatchat/self-hosted#306),
+// который сам мигрирует каталог данных minio.
+var removedImages = map[string]string{
+	"minio/minio": "docker.io/pgsty/silo",
+	"minio/mc":    "docker.io/pgsty/mc",
+}
+
+func replacedImage(ref string) (string, bool) {
+	repo, _, _ := strings.Cut(ref, "@")
+	repo, _, _ = strings.Cut(repo, ":")
+	repo = strings.TrimPrefix(repo, "docker.io/")
+	repl, ok := removedImages[repo]
+	return repl, ok
+}
+
+func (r *restorer) writePinFileSkip(c manifest.Category, skip map[string]bool) (string, error) {
 	var services []string
 	for name := range c.Compose.Images {
 		services = append(services, name)
@@ -105,16 +162,27 @@ func (r *restorer) writePinFile(c manifest.Category) (string, error) {
 	n := 0
 	for _, svc := range services {
 		img := c.Compose.Images[svc]
-		if img.Built || img.Digest == "" {
+		if img.Built || img.Digest == "" || skip[svc] {
 			continue
 		}
-		fmt.Fprintf(&b, "  %q:\n    image: %q\n", svc, img.Digest)
+		ref := img.Digest
+		if repl, ok := replacedImage(ref); ok {
+			if skip == nil {
+				r.warn("%s: образ %s удалён из реестра, сервис %s переведён на %s", c.Name, ref, svc, repl)
+			}
+			ref = repl
+		}
+		fmt.Fprintf(&b, "  %q:\n    image: %q\n", svc, ref)
 		n++
 	}
+	p := filepath.Join(c.Compose.Dir, pinFile)
 	if n == 0 {
+		if skip != nil {
+			// файл уже подключён через -f: оставляем валидный пустой
+			return p, os.WriteFile(p, []byte("services: {}\n"), 0o644)
+		}
 		return "", nil
 	}
-	p := filepath.Join(c.Compose.Dir, pinFile)
 	return p, os.WriteFile(p, []byte(b.String()), 0o644)
 }
 

internal/restore/images_test.go

@@ -0,0 +1,20 @@
+package restore
+
+import "testing"
+
+func TestReplacedImage(t *testing.T) {
+	cases := map[string]string{
+		"minio/minio@sha256:abc":    "docker.io/pgsty/silo",
+		"docker.io/minio/mc:latest": "docker.io/pgsty/mc",
+		"minio/minio":               "docker.io/pgsty/silo",
+	}
+	for in, want := range cases {
+		got, ok := replacedImage(in)
+		if !ok || got != want {
+			t.Errorf("%s: got %q,%v want %q", in, got, ok, want)
+		}
+	}
+	if _, ok := replacedImage("mongo@sha256:abc"); ok {
+		t.Error("mongo не должен заменяться")
+	}
+}