publish: return ErrPublishAborted when user declines interactive prompts

Signed-off-by: Ishwar <ishwarcm@iitbhilai.ac.in>

Author: ishwar170695

pkg/compose/publish.go

@@ -42,6 +42,9 @@ import (
 	"github.com/docker/compose/v5/pkg/compose/transform"
 )
 
+
+var ErrPublishAborted = errors.New("publish aborted by user")
+
 func (s *composeService) Publish(ctx context.Context, project *types.Project, repository string, options api.PublishOptions) error {
 	return Run(ctx, func(ctx context.Context) error {
 		return s.publish(ctx, project, repository, options)
@@ -59,7 +62,7 @@ func (s *composeService) publish(ctx context.Context, project *types.Project, re
 		return err
 	}
 	if !accept {
-		return nil
+		return ErrPublishAborted
 	}
 	err = s.Push(ctx, project, api.PushOptions{IgnoreFailures: true, ImageMandatory: true})
 	if err != nil {

pkg/compose/publish_test.go

@@ -17,6 +17,7 @@
 package compose
 
 import (
+	"errors"
 	"slices"
 	"testing"
 
@@ -100,3 +101,60 @@ services:
 		return !slices.Contains([]string{".Data", ".Digest", ".Size"}, path.String())
 	}, cmp.Ignore()))
 }
+
+func Test_preChecks_decline_returns_ErrPublishAborted(t *testing.T) {
+	project := &types.Project{
+		Services: types.Services{
+			"web": {
+				Name:  "web",
+				Image: "nginx",
+				Volumes: []types.ServiceVolumeConfig{
+					{
+						Type:   types.VolumeTypeBind,
+						Source: "/host/path",
+						Target: "/container/path",
+					},
+				},
+			},
+		},
+	}
+
+	declined := func(message string, defaultValue bool) (bool, error) {
+		return false, nil
+	}
+	svc := &composeService{
+		prompt: declined,
+	}
+
+	_, err := svc.preChecks(project, api.PublishOptions{})
+	assert.NilError(t, err)
+}
+func Test_publish_decline_returns_ErrPublishAborted(t *testing.T) {
+	project := &types.Project{
+		Services: types.Services{
+			"web": {
+				Name:  "web",
+				Image: "nginx",
+				Volumes: []types.ServiceVolumeConfig{
+					{
+						Type:   types.VolumeTypeBind,
+						Source: "/host/path",
+						Target: "/container/path",
+					},
+				},
+			},
+		},
+	}
+
+	declined := func(message string, defaultValue bool) (bool, error) {
+		return false, nil
+	}
+	svc := &composeService{
+		prompt: declined,
+		events: &ignore{},
+	}
+
+	err := svc.publish(t.Context(), project, "docker.io/myorg/myapp:latest", api.PublishOptions{})
+	assert.Assert(t, errors.Is(err, ErrPublishAborted),
+		"expected ErrPublishAborted when user declines, got: %v", err)
+}