stack/components/fctl/cmd/orchestration/instances/stop.go

package instances

import (
	fctl "github.com/formancehq/fctl/pkg"
	"github.com/formancehq/formance-sdk-go/v2/pkg/models/operations"
	"github.com/pterm/pterm"
	"github.com/spf13/cobra"
)

type InstancesStopStore struct {
	Success    bool   `json:"success"`
	InstanceID string `json:"instanceId"`
}
type InstancesStopController struct {
	store *InstancesStopStore
}

var _ fctl.Controller[*InstancesStopStore] = (*InstancesStopController)(nil)

func NewDefaultInstancesStopStore() *InstancesStopStore {
	return &InstancesStopStore{}
}

func NewInstancesStopController() *InstancesStopController {
	return &InstancesStopController{
		store: NewDefaultInstancesStopStore(),
	}
}

func NewStopCommand() *cobra.Command {
	return fctl.NewCommand("stop <instance-id>",
		fctl.WithShortDescription("Stop a specific workflow instance"),
		fctl.WithArgs(cobra.ExactArgs(1)),
		fctl.WithController[*InstancesStopStore](NewInstancesStopController()),
	)
}

func (c *InstancesStopController) GetStore() *InstancesStopStore {
	return c.store
}

func (c *InstancesStopController) Run(cmd *cobra.Command, args []string) (fctl.Renderable, error) {
	store := fctl.GetStackStore(cmd.Context())

	_, err := store.Client().Orchestration.V1.CancelEvent(cmd.Context(), operations.CancelEventRequest{
		InstanceID: args[0],
	})
	if err != nil {
		return nil, err
	}

	c.store.Success = true
	c.store.InstanceID = args[0]

	return c, nil
}

func (c *InstancesStopController) Render(cmd *cobra.Command, args []string) error {
	// Print the instance information
	pterm.Success.WithWriter(cmd.OutOrStdout()).Printfln("Workflow Instance with ID: %s successfully canceled ", c.store.InstanceID)

	return nil
}