feat: warn user when deploying over a paused workflow

cmd/workflow/deploy/deploy.go

@@ -338,9 +338,16 @@ func (h *handler) Execute(ctx context.Context) error {
 	if err := h.upsert(); err != nil {
 		return fmt.Errorf("failed to register workflow: %w", err)
 	}
+	warnIfPausedWorkflowUpdate(h.existingWorkflowStatus)
 	return nil
 }
 
+func warnIfPausedWorkflowUpdate(status *uint8) {
+	if status != nil && *status == workflowStatusPaused {
+		ui.Warning("Your workflow is paused and has been updated")
+	}
+}
+
 func (h *handler) workflowExists() error {
 	workflow, err := h.wrc.GetWorkflow(common.HexToAddress(h.settings.Workflow.UserWorkflowSettings.WorkflowOwnerAddress), h.inputs.WorkflowName, h.inputs.WorkflowTag)
 	if err != nil {

cmd/workflow/deploy/deploy_test.go

@@ -1,9 +1,12 @@
 package deploy
 
 import (
+	"bytes"
 	"errors"
 	"io"
 	"math/big"
+	"os"
+	"strings"
 	"testing"
 
 	"github.com/ethereum/go-ethereum/common"
@@ -454,6 +457,47 @@ func (f fakeUserDonLimitClient) GetWorkflowListByOwnerAndName(common.Address, st
 	return f.workflowsByOwnerName, nil
 }
 
+func TestWarnExistingPausedWorkflowUpdate(t *testing.T) {
+	// Do not use t.Parallel: stderr redirection uses package-global os.Stderr.
+
+	captureStderr := func(f func()) string {
+		t.Helper()
+		old := os.Stderr
+		r, w, err := os.Pipe()
+		require.NoError(t, err)
+		os.Stderr = w
+
+		f()
+
+		require.NoError(t, w.Close())
+		os.Stderr = old
+
+		var buf bytes.Buffer
+		_, copyErr := io.Copy(&buf, r)
+		require.NoError(t, copyErr)
+		require.NoError(t, r.Close())
+		return buf.String()
+	}
+
+	t.Run("no output when status is nil", func(t *testing.T) {
+		out := captureStderr(func() { warnIfPausedWorkflowUpdate(nil) })
+		assert.Empty(t, strings.TrimSpace(out))
+	})
+
+	t.Run("no output when workflow is active", func(t *testing.T) {
+		active := workflowStatusActive
+		out := captureStderr(func() { warnIfPausedWorkflowUpdate(&active) })
+		assert.Empty(t, strings.TrimSpace(out))
+	})
+
+	t.Run("prints warning when workflow is paused", func(t *testing.T) {
+		paused := workflowStatusPaused
+		out := captureStderr(func() { warnIfPausedWorkflowUpdate(&paused) })
+		assert.Contains(t, out, "Your workflow is paused")
+		assert.Contains(t, out, "and has been updated")
+	})
+}
+
 func TestCheckUserDonLimitBeforeDeploy(t *testing.T) {
 	owner := common.HexToAddress(chainsim.TestAddress)
 	donFamily := "test-don"

cmd/workflow/deploy/limits.go

@@ -11,6 +11,7 @@ import (
 
 const (
 	workflowStatusActive = uint8(0)
+	workflowStatusPaused = uint8(1)
 	workflowListPageSize = int64(200)
 )