Method ContainerCtrl

app/application/http/controller/compose-container.go:335–374

(http *gin.Context)

}

func (self Compose) ContainerCtrl(http *gin.Context) {
	type ParamsValidate struct {
		Id string `json:"id" binding:"required"`
		Op string `json:"op" binding:"required" oneof:"start restart stop pause unpause ls"`
	}
	params := ParamsValidate{}
	if !self.Validate(http, &params) {
		return
	}
	composeRow, _ := logic.Compose{}.Get(params.Id)
	if composeRow == nil {
		self.JsonResponseWithError(http, function.ErrorMessage(define.ErrorMessageCommonDataNotFoundOrDeleted), 500)
		return
	}
	tasker, _, err := logic.Compose{}.GetTasker(composeRow)
	if err != nil {
		self.JsonResponseWithError(http, err, 500)
		return
	}

	progress := ws.NewProgressPip(fmt.Sprintf(ws.MessageTypeCompose, params.Id))
	defer progress.Close()

	response, err := tasker.Ctrl(params.Op)
	if err != nil {
		self.JsonResponseWithError(http, err, 500)
		return
	}
	go func() {
		<-progress.Done()
		_ = response.Close()
	}()
	_, err = io.Copy(progress, response)
	if err != nil {
		slog.Warn("compose destroy copy", "error", err)
	}

	self.JsonSuccessResponse(http)
	return
}

func (self Compose) ContainerLog(http *gin.Context) {
	type ParamsValidate struct {