feat: update app show to display if workload is deployed

internal/pkg/cli/app_show.go

@@ -5,11 +5,14 @@ package cli
 
 import (
 	"fmt"
-	"io"
-
 	"github.com/aws/aws-sdk-go/aws"
 	"github.com/aws/aws-sdk-go/service/ssm"
 	"github.com/aws/copilot-cli/internal/pkg/aws/identity"
+	"golang.org/x/net/context"
+	"golang.org/x/sync/errgroup"
+	"io"
+	"sort"
+	"sync"
 
 	"github.com/aws/copilot-cli/internal/pkg/aws/codepipeline"
 	"github.com/aws/copilot-cli/internal/pkg/aws/sessions"
@@ -40,18 +43,25 @@ type showAppOpts struct {
 	w                io.Writer
 	sel              appSelector
 	pipelineSvc      pipelineGetter
+	deployStore      deployedEnvironmentLister
 	newVersionGetter func(string) (versionGetter, error)
 }
 
 func newShowAppOpts(vars showAppVars) (*showAppOpts, error) {
-	defaultSession, err := sessions.ImmutableProvider(sessions.UserAgentExtras("app show")).Default()
+	sessProvider := sessions.ImmutableProvider(sessions.UserAgentExtras("app show"))
+	defaultSession, err := sessProvider.Default()
 	if err != nil {
 		return nil, fmt.Errorf("default session: %w", err)
 	}
 	store := config.NewSSMStore(identity.New(defaultSession), ssm.New(defaultSession), aws.StringValue(defaultSession.Config.Region))
+	deployStore, err := deploy.NewStore(sessProvider, store)
+	if err != nil {
+		return nil, fmt.Errorf("connect to deploy store: %w", err)
+	}
 	return &showAppOpts{
 		showAppVars: vars,
 		store:       store,
+		deployStore: deployStore,
 		w:           log.OutputWriter,
 		sel:         selector.NewSelect(prompt.New(), store),
 		pipelineSvc: codepipeline.New(defaultSession),
@@ -105,6 +115,7 @@ func (o *showAppOpts) Execute() error {
 }
 
 func (o *showAppOpts) description() (*describe.App, error) {
+	wkldDeployedtoEnvs := make(map[string][]string)
 	app, err := o.store.GetApplication(o.name)
 	if err != nil {
 		return nil, fmt.Errorf("get application %s: %w", o.name, err)
@@ -121,7 +132,45 @@ func (o *showAppOpts) description() (*describe.App, error) {
 	if err != nil {
 		return nil, fmt.Errorf("list jobs in application %s: %w", o.name, err)
 	}
+	var mux sync.Mutex
+	g, ctx := errgroup.WithContext(context.Background())
+	defer ctx.Done()
+	for i := range envs {
+		env := envs[i]
+		g.Go(func() error {
+			deployedJobs, err := o.deployStore.ListDeployedJobs(o.name, env.Name)
+			if err != nil {
+				return fmt.Errorf("list jobs deployed to %s: %w", env.Name, err)
+			}
 
+			mux.Lock()
+			defer mux.Unlock()
+			for _, job := range deployedJobs {
+				wkldDeployedtoEnvs[job] = append(wkldDeployedtoEnvs[job], env.Name)
+			}
+			return nil
+		})
+		g.Go(func() error {
+			deployedSvcs, err := o.deployStore.ListDeployedServices(o.name, env.Name)
+			if err != nil {
+				return fmt.Errorf("list services deployed to %s: %w", env.Name, err)
+			}
+			mux.Lock()
+			defer mux.Unlock()
+			for _, svc := range deployedSvcs {
+				wkldDeployedtoEnvs[svc] = append(wkldDeployedtoEnvs[svc], env.Name)
+			}
+			return nil
+		})
+	}
+	if err := g.Wait(); err != nil {
+		return nil, err
+	}
+	// Sort the map values so that `output` is consistent and the unit test won't be flaky.
+	for key, value := range wkldDeployedtoEnvs {
+		sort.Strings(value)
+		wkldDeployedtoEnvs[key] = value
+	}
 	pipelines, err := o.pipelineSvc.GetPipelinesByTags(map[string]string{
 		deploy.AppTagKey: o.name,
 	})
@@ -162,13 +211,14 @@ func (o *showAppOpts) description() (*describe.App, error) {
 		return nil, fmt.Errorf("get version for application %s: %w", o.name, err)
 	}
 	return &describe.App{
-		Name:      app.Name,
-		Version:   version,
-		URI:       app.Domain,
-		Envs:      trimmedEnvs,
-		Services:  trimmedSvcs,
-		Jobs:      trimmedJobs,
-		Pipelines: pipelines,
+		Name:               app.Name,
+		Version:            version,
+		URI:                app.Domain,
+		Envs:               trimmedEnvs,
+		Services:           trimmedSvcs,
+		Jobs:               trimmedJobs,
+		Pipelines:          pipelines,
+		WkldDeployedtoEnvs: wkldDeployedtoEnvs,
 	}, nil
 }