list.go

package ecsta

import (
	"context"
	"fmt"
)

type ListOption struct {
	Family     *string           `help:"Task definition family" short:"f"`
	Service    *string           `help:"Service name" short:"s"`
	OutputTags bool              `help:"Output tags of tasks"`
	Tags       map[string]string `help:"Show only tasks that have specified tags" mapsep:","`
}

func (app *Ecsta) RunList(ctx context.Context, opt *ListOption) error {
	if err := app.SetCluster(ctx); err != nil {
		return err
	}
	tasks, err := app.listTasks(ctx, &optionListTasks{
		family:  opt.Family,
		service: opt.Service,
		tags:    opt.Tags,
	})
	if err != nil {
		return fmt.Errorf("failed to list tasks in cluster %s: %w", app.cluster, err)
	}
	fopt := formatterOption{
		Format:    app.Config.Output,
		HasHeader: true,
		WithTags:  opt.OutputTags,
	}
	if query := app.Config.TaskFormatQuery; query != "" {
		fopt.Format = "json"
		fopt.Query = query
	}
	f, err := newTaskFormatter(app.w, fopt)
	if err != nil {
		return fmt.Errorf("failed to create task formatter: %w", err)
	}
	for _, task := range tasks {
		f.AddTask(task)
	}
	f.Close()
	return nil
}