docker-compose/ecs/pkg/amazon/up.go

package amazon

import (
	"context"
	"fmt"

	"github.com/awslabs/goformation/v4/cloudformation"
	"github.com/docker/ecs-plugin/pkg/compose"
)

func (c *client) ComposeUp(ctx context.Context, project *compose.Project) error {
	if c.Cluster != "" {
		ok, err := c.api.ClusterExists(ctx, c.Cluster)
		if err != nil {
			return err
		}
		if !ok {
			return fmt.Errorf("configured cluster %q does not exist", c.Cluster)
		}
	}

	update, err := c.api.StackExists(ctx, project.Name)
	if err != nil {
		return err
	}
	if update {
		return fmt.Errorf("we do not (yet) support updating an existing CloudFormation stack")
	}

	err = c.Validate(project)
	if err != nil {
		return err
	}

	template, err := c.Convert(project)
	if err != nil {
		return err
	}

	vpc, err := c.GetVPC(ctx, project)
	if err != nil {
		return err
	}

	subNets, err := c.api.GetSubNets(ctx, vpc)
	if err != nil {
		return err
	}

	parameters := map[string]string{
		ParameterClusterName: c.Cluster,
		ParameterVPCId:       vpc,
		ParameterSubnet1Id:   subNets[0],
		ParameterSubnet2Id:   subNets[1],
	}

	err = c.api.CreateStack(ctx, project.Name, template, parameters)
	if err != nil {
		return err
	}

	return c.WaitStackCompletion(ctx, project.Name, StackCreate)
}

func (c client) GetVPC(ctx context.Context, project *compose.Project) (string, error) {
	//check compose file for the default external network
	if net, ok := project.Networks["default"]; ok {
		if net.External.External {
			vpc := net.Name
			ok, err := c.api.VpcExists(ctx, vpc)
			if err != nil {
				return "", err
			}
			if !ok {
				return "", fmt.Errorf("VPC does not exist: %s", vpc)
			}
			return vpc, nil
		}
	}
	defaultVPC, err := c.api.GetDefaultVPC(ctx)
	if err != nil {
		return "", err
	}
	return defaultVPC, nil
}

type upAPI interface {
	waitAPI
	GetDefaultVPC(ctx context.Context) (string, error)
	VpcExists(ctx context.Context, vpcID string) (bool, error)
	GetSubNets(ctx context.Context, vpcID string) ([]string, error)

	ClusterExists(ctx context.Context, name string) (bool, error)
	StackExists(ctx context.Context, name string) (bool, error)
	CreateStack(ctx context.Context, name string, template *cloudformation.Template, parameters map[string]string) error
}