[clean] add stop container step before clean container

Author: jackblack369

.vscode/launch.json

@@ -202,6 +202,22 @@
             ],
             "showLog": true,
         },
+        {
+            "name": "dingoadm clean -f",
+            "type": "go",
+            "request": "launch",
+            "mode": "auto",
+            "program": "${workspaceFolder}/cmd/dingoadm/main.go",
+            "env": {
+                "CGO_ENABLED": "1",
+                "PATH": "/opt/rh/gcc-toolset-13/root/usr/bin:${env:PATH}"
+            },
+            "args": [
+                "clean",
+                "-f",
+            ],
+            "showLog": true,
+        },
         {
             "name": "dingoadm mount mdsv2 vfs_v2",
             "type": "go",

cli/command/clean.go

@@ -130,6 +130,12 @@ func genCleanPlaybook(dingoadm *cli.DingoAdm,
 	}
 
 	steps := CLEAN_PLAYBOOK_STEPS
+	// check if options's only item include container
+	if utils.Contains(options.only, comm.CLEAN_ITEM_CONTAINER) {
+		// add stop service step before clean service step
+		steps = append([]int{playbook.STOP_SERVICE}, steps...)
+	}
+
 	pb := playbook.NewPlaybook(dingoadm)
 	for _, step := range steps {
 		pb.AddStep(&playbook.PlaybookStep{
@@ -160,7 +166,7 @@ func runClean(dingoadm *cli.DingoAdm, options cleanOptions) error {
 	// 3) confirm by user
 	// 3) force stop
 	if options.force {
-		dingoadm.WriteOut(tui.PromptCancelOpetation("clean service"))
+		dingoadm.WriteOutln(tui.PromptForceOpetation("clean service"))
 		return pb.Run()
 	}
 

internal/task/step/container.go

@@ -269,6 +269,8 @@ func (s *RemoveContainer) Execute(ctx *context.Context) error {
 	return PostHandle(s.Success, s.Out, out, err, errno.ERR_REMOVE_CONTAINER_FAILED.FD("(%s rm CONTAINER)", s.ExecWithEngine))
 }
 
+// ListContainers list containers by `docker ps [OPTIONS]`
+// e.g. docker ps --filter "id=<container_id>" --quiet --all
 func (s *ListContainers) Execute(ctx *context.Context) error {
 	cli := ctx.Module().DockerCli().ListContainers()
 	if len(s.Format) > 0 {

internal/task/task/common/clean_service.go

@@ -43,6 +43,7 @@ import (
 	tui "github.com/dingodb/dingoadm/internal/tui/common"
 	"github.com/dingodb/dingoadm/internal/utils"
 	"github.com/dingodb/dingoadm/pkg/module"
+	"github.com/fatih/color"
 )
 
 const (
@@ -144,6 +145,7 @@ func NewCleanServiceTask(dingoadm *cli.DingoAdm, dc *topology.DeployConfig) (*ta
 	if containerId == comm.CLEANED_CONTAINER_ID {
 		// container has removed, no need to clean
 		dingoadm.Storage().SetContainId(serviceId, comm.CLEANED_CONTAINER_ID)
+		dingoadm.WriteOutln("%s clean service: host=%s role=%s ", color.YellowString("[SKIP]"), dc.GetHost(), dc.GetRole())
 		return nil, nil
 	}
 	if dingoadm.IsSkip(dc) {
@@ -193,7 +195,7 @@ func NewCleanServiceTask(dingoadm *cli.DingoAdm, dc *topology.DeployConfig) (*ta
 		Files:       files,
 		ExecOptions: dingoadm.ExecOptions(),
 	})
-	if clean[comm.CLEAN_ITEM_CONTAINER] == true {
+	if clean[comm.CLEAN_ITEM_CONTAINER] {
 
 		// var status string
 		// t.AddStep(&step.InspectContainer{

internal/tui/common/prompt.go

@@ -72,6 +72,8 @@ to watch the formatting progress.
 `
 	PROMPT_CANCEL_OPERATION = `[x] {{.operation}} canceled`
 
+	PROMPT_FORCE_OPERATION = `[!] {{.operation}} will be forced`
+
 	DEFAULT_CONFIRM_PROMPT = "Do you want to continue?"
 )
 
@@ -227,6 +229,12 @@ func PromptErrorCode(code int, description, clue, logpath string) string {
 	return prompt.Build()
 }
 
+func PromptForceOpetation(operation string) string {
+	prompt := NewPrompt(color.YellowString(PROMPT_FORCE_OPERATION))
+	prompt.data["operation"] = operation
+	return prompt.Build()
+}
+
 func PromptCancelOpetation(operation string) string {
 	prompt := NewPrompt(color.YellowString(PROMPT_CANCEL_OPERATION))
 	prompt.data["operation"] = operation