Refactor to remove legacyconfig object

At best legacyconfig belongs to the individual plugins, simplify the
existing wiring contract by removing it from the wiring context.
ec2compute v2 no longer has a v1 version present so remove the extra
package, add an api to allow outside users to set the default set of
tags passed in the entangler context

cmd/orchestration/app/BUILD.bazel

@@ -12,6 +12,7 @@ go_library(
     deps = [
         "//:go_default_library",
         "//cmd:go_default_library",
+        "//pkg/apis/orchestration/meta:go_default_library",
         "//pkg/apis/orchestration/v1:go_default_library",
         "//pkg/k8s:go_default_library",
         "//pkg/options:go_default_library",
@@ -20,7 +21,6 @@ go_library(
         "//pkg/orchestration/informer:go_default_library",
         "//pkg/orchestration/updater:go_default_library",
         "//pkg/orchestration/wiring:go_default_library",
-        "//pkg/orchestration/wiring/legacy:go_default_library",
         "//pkg/orchestration/wiring/registry:go_default_library",
         "//pkg/orchestration/wiring/wiringplugin:go_default_library",
         "//pkg/util/crash:go_default_library",

cmd/orchestration/app/controller_constructor.go

@@ -17,7 +17,6 @@ import (
 	orchInf "github.com/atlassian/voyager/pkg/orchestration/informer"
 	orchUpdater "github.com/atlassian/voyager/pkg/orchestration/updater"
 	"github.com/atlassian/voyager/pkg/orchestration/wiring"
-	"github.com/atlassian/voyager/pkg/orchestration/wiring/legacy"
 	"github.com/atlassian/voyager/pkg/orchestration/wiring/wiringplugin"
 	prom_util "github.com/atlassian/voyager/pkg/util/prometheus"
 	"github.com/pkg/errors"
@@ -30,9 +29,9 @@ import (
 )
 
 type ControllerConstructor struct {
-	FlagConfigFile      string
-	GetLegacyConfigFunc func(voyager.Location) *legacy.Config
-	Plugins             map[voyager.ResourceType]wiringplugin.WiringPlugin
+	FlagConfigFile string
+	Plugins        map[voyager.ResourceType]wiringplugin.WiringPlugin
+	Tags           wiring.TagGenerator
 }
 
 func (cc *ControllerConstructor) AddFlags(flagset ctrl.FlagSet) {
@@ -88,14 +87,7 @@ func (cc *ControllerConstructor) New(config *ctrl.Config, cctx *ctrl.Context) (*
 		Plugins:         cc.Plugins,
 		ClusterLocation: opts.Location.ClusterLocation(),
 		ClusterConfig:   toClusterConfig(opts.Cluster),
-		TagNames: wiring.TagNames{
-			ServiceNameTag:     opts.TagNames.ServiceName,
-			BusinessUnitTag:    opts.TagNames.BusinessUnit,
-			ResourceOwnerTag:   opts.TagNames.ResourceOwner,
-			PlatformTag:        opts.TagNames.Platform,
-			EnvironmentTypeTag: opts.TagNames.EnvironmentType,
-		},
-		GetLegacyConfigFunc: cc.GetLegacyConfigFunc,
+		Tags:            cc.Tags,
 	}
 
 	// Spec check

cmd/orchestration/app/main.go

@@ -11,7 +11,7 @@ import (
 	ctrlApp "github.com/atlassian/ctrl/app"
 	"github.com/atlassian/voyager"
 	"github.com/atlassian/voyager/cmd"
-	"github.com/atlassian/voyager/pkg/orchestration/wiring/legacy"
+	orch_meta "github.com/atlassian/voyager/pkg/apis/orchestration/meta"
 	"github.com/atlassian/voyager/pkg/orchestration/wiring/registry"
 	"github.com/atlassian/voyager/pkg/orchestration/wiring/wiringplugin"
 	"github.com/atlassian/voyager/pkg/util/crash"
@@ -23,18 +23,18 @@ const (
 )
 
 func Main() {
-	CustomMain(emptyLegacyConfigFunc, registry.KnownWiringPlugins)
+	CustomMain(registry.KnownWiringPlugins)
 }
 
-func CustomMain(getLegacyConfigFunc func(voyager.Location) *legacy.Config, plugins map[voyager.ResourceType]wiringplugin.WiringPlugin) {
+func CustomMain(plugins map[voyager.ResourceType]wiringplugin.WiringPlugin) {
 	rand.Seed(time.Now().UnixNano())
 	klog.InitFlags(nil)
 	cmd.RunInterruptably(func(ctx context.Context) error {
 		crash.InstallAPIMachineryLoggers()
 		controllers := []ctrl.Constructor{
 			&ControllerConstructor{
-				GetLegacyConfigFunc: getLegacyConfigFunc,
-				Plugins:             plugins,
+				Plugins: plugins,
+				Tags:    ExampleTags,
 			},
 		}
 
@@ -48,6 +48,12 @@ func CustomMain(getLegacyConfigFunc func(voyager.Location) *legacy.Config, plugi
 	})
 }
 
-func emptyLegacyConfigFunc(location voyager.Location) *legacy.Config {
-	return &legacy.Config{}
+func ExampleTags(
+	_ voyager.ClusterLocation,
+	_ wiringplugin.ClusterConfig,
+	_ voyager.Location,
+	_ voyager.ServiceName,
+	_ orch_meta.ServiceProperties,
+) map[voyager.Tag]string {
+	return make(map[voyager.Tag]string)
 }

cmd/orchestration/app/options.go

@@ -3,28 +3,15 @@ package app
 import (
 	"io/ioutil"
 
-	"github.com/atlassian/voyager"
 	"github.com/atlassian/voyager/pkg/options"
 	"github.com/pkg/errors"
 	utilerrors "k8s.io/apimachinery/pkg/util/errors"
 	"sigs.k8s.io/yaml"
 )
 
-// TagNames tell us what tag to store each of these properties under.
-// e.g. ServiceName = "application_name", and the service name is put into the
-// application_name tag.
-type TagNames struct {
-	ServiceName     voyager.Tag `json:"serviceName"`
-	BusinessUnit    voyager.Tag `json:"businessUnit"`
-	ResourceOwner   voyager.Tag `json:"resourceOwner"`
-	Platform        voyager.Tag `json:"platform"`
-	EnvironmentType voyager.Tag `json:"environmentType"`
-}
-
 type Options struct {
 	Location options.Location `json:"location"`
 	Cluster  options.Cluster  `json:"cluster"`
-	TagNames TagNames         `json:"tagNames"`
 }
 
 func (o *Options) DefaultAndValidate() []error {

pkg/creator/BUILD.bazel

@@ -16,7 +16,7 @@ go_library(
         "//pkg/apis/creator/v1:go_default_library",
         "//pkg/creator/luigi:go_default_library",
         "//pkg/creator/ssam:go_default_library",
-        "//pkg/orchestration/wiring/ec2compute/common:go_default_library",
+        "//pkg/orchestration/wiring/ec2compute/v2:go_default_library",
         "//pkg/pagerduty:go_default_library",
         "//pkg/servicecentral:go_default_library",
         "//pkg/util:go_default_library",

pkg/creator/handler.go

@@ -13,7 +13,7 @@ import (
 	creator_v1 "github.com/atlassian/voyager/pkg/apis/creator/v1"
 	"github.com/atlassian/voyager/pkg/creator/luigi"
 	"github.com/atlassian/voyager/pkg/creator/ssam"
-	ec2compute_common "github.com/atlassian/voyager/pkg/orchestration/wiring/ec2compute/common"
+	ec2compute_v2 "github.com/atlassian/voyager/pkg/orchestration/wiring/ec2compute/v2"
 	"github.com/atlassian/voyager/pkg/pagerduty"
 	"github.com/atlassian/voyager/pkg/servicecentral"
 	"github.com/atlassian/voyager/pkg/util"
@@ -33,7 +33,7 @@ const (
 	ServiceNameMinimumLength    = 1
 	ServiceNameMaximumLength    = 24
 	ServiceNameExpr             = schema.ResourceNameSchemaPattern
-	EC2ComputeNameMaximumLength = ec2compute_common.MaximumServiceNameLength
+	EC2ComputeNameMaximumLength = ec2compute_v2.MaximumServiceNameLength
 )
 
 var (

pkg/orchestration/BUILD.bazel

@@ -46,10 +46,10 @@ go_test(
     race = "on",
     deps = [
         "//:go_default_library",
+        "//pkg/apis/orchestration/meta:go_default_library",
         "//pkg/apis/orchestration/v1:go_default_library",
         "//pkg/orchestration/client/fake:go_default_library",
         "//pkg/orchestration/wiring:go_default_library",
-        "//pkg/orchestration/wiring/legacy:go_default_library",
         "//pkg/orchestration/wiring/registry:go_default_library",
         "//pkg/orchestration/wiring/wiringplugin:go_default_library",
         "//pkg/util/testutil:go_default_library",

pkg/orchestration/controller_test.go

@@ -8,10 +8,10 @@ import (
 
 	smith_v1 "github.com/atlassian/smith/pkg/apis/smith/v1"
 	"github.com/atlassian/voyager"
+	orch_meta "github.com/atlassian/voyager/pkg/apis/orchestration/meta"
 	orch_v1 "github.com/atlassian/voyager/pkg/apis/orchestration/v1"
 	stateclient_fake "github.com/atlassian/voyager/pkg/orchestration/client/fake"
 	"github.com/atlassian/voyager/pkg/orchestration/wiring"
-	"github.com/atlassian/voyager/pkg/orchestration/wiring/legacy"
 	"github.com/atlassian/voyager/pkg/orchestration/wiring/registry"
 	"github.com/atlassian/voyager/pkg/orchestration/wiring/wiringplugin"
 	"github.com/atlassian/voyager/pkg/util/testutil"
@@ -27,6 +27,10 @@ const (
 	fixtureBundleOutputSuffix = ".bundle.output.yaml"
 	fixtureStateOutputSuffix  = ".state.output.yaml"
 	fixtureGlob               = "*" + fixtureStateInputSuffix
+
+	testAccount = "testaccount"
+	testEnv     = "testenv"
+	testRegion  = "testregion"
 )
 
 func testHandleProcessResult(t *testing.T, filePrefix string) {
@@ -192,26 +196,26 @@ func entanglerForTests() *wiring.Entangler {
 	return &wiring.Entangler{
 		Plugins: registry.KnownWiringPlugins,
 		ClusterLocation: voyager.ClusterLocation{
-			Account: legacy.TestAccountName,
-			Region:  legacy.TestRegion,
-			EnvType: legacy.TestEnvironment,
+			Account: testAccount,
+			Region:  testRegion,
+			EnvType: testEnv,
 		},
 		ClusterConfig: wiringplugin.ClusterConfig{
 			ClusterDomainName: "internal.ap-southeast-2.kitt-integration.kitt-inf.net",
 			KittClusterEnv:    "test",
 			Kube2iamAccount:   "test",
 		},
-		TagNames: wiring.TagNames{
-			ServiceNameTag:     "service_name",
-			BusinessUnitTag:    "business_unit",
-			ResourceOwnerTag:   "resource_owner",
-			PlatformTag:        "platform",
-			EnvironmentTypeTag: "environment_type",
-		},
-		GetLegacyConfigFunc: getTestLegacyConfig,
+		Tags: testingTags,
 	}
 }
 
-func getTestLegacyConfig(location voyager.Location) *legacy.Config {
-	return legacy.GetLegacyConfigFromMap(legacy.TestLegacyConfigs, location)
+func testingTags(
+	_ voyager.ClusterLocation,
+	_ wiringplugin.ClusterConfig,
+	_ voyager.Location,
+	_ voyager.ServiceName,
+	_ orch_meta.ServiceProperties,
+) map[voyager.Tag]string {
+	tags := make(map[voyager.Tag]string)
+	return tags
 }

pkg/orchestration/wiring/BUILD.bazel

@@ -9,7 +9,6 @@ go_library(
         "//:go_default_library",
         "//pkg/apis/orchestration/meta:go_default_library",
         "//pkg/apis/orchestration/v1:go_default_library",
-        "//pkg/orchestration/wiring/legacy:go_default_library",
         "//pkg/orchestration/wiring/wiringplugin:go_default_library",
         "//vendor/github.com/atlassian/smith/pkg/apis/smith/v1:go_default_library",
         "//vendor/github.com/atlassian/smith/pkg/util:go_default_library",
@@ -35,7 +34,6 @@ go_test(
         "//cmd/smith/config:go_default_library",
         "//pkg/apis/orchestration/meta:go_default_library",
         "//pkg/apis/orchestration/v1:go_default_library",
-        "//pkg/orchestration/wiring/legacy:go_default_library",
         "//pkg/orchestration/wiring/registry:go_default_library",
         "//pkg/orchestration/wiring/wiringplugin:go_default_library",
         "//pkg/orchestration/wiring/wiringutil/knownshapes:go_default_library",

pkg/orchestration/wiring/aws/plugin.go

@@ -28,6 +28,8 @@ type WiringPlugin struct {
 
 	OAPResourceTypeName        oap.ResourceType
 	generateServiceEnvironment ServiceEnvironmentGenerator
+
+	VPC func(location voyager.Location) *oap.VPCEnvironment
 }
 
 func Resource(resourceType voyager.ResourceType,
@@ -36,6 +38,7 @@ func Resource(resourceType voyager.ResourceType,
 	clusterServicePlanExternalID servicecatalog.PlanExternalID,
 	generateServiceEnvironment ServiceEnvironmentGenerator,
 	shapes svccatentangler.ShapesFunc,
+	vpc func(voyager.Location) *oap.VPCEnvironment,
 ) *WiringPlugin {
 	wiringPlugin := &WiringPlugin{
 		SvcCatEntangler: svccatentangler.SvcCatEntangler{
@@ -46,6 +49,7 @@ func Resource(resourceType voyager.ResourceType,
 		},
 		OAPResourceTypeName:        oapResourceTypeName,
 		generateServiceEnvironment: generateServiceEnvironment,
+		VPC:                        vpc,
 	}
 	wiringPlugin.SvcCatEntangler.InstanceSpec = wiringPlugin.instanceSpec
 	wiringPlugin.SvcCatEntangler.ObjectMeta = wiringPlugin.objectMeta
@@ -86,7 +90,8 @@ func (awp *WiringPlugin) instanceSpec(resource *orch_v1.StateResource, context *
 	}
 
 	serviceName := serviceName(userServiceName, context)
-	environment := awp.generateServiceEnvironment(oap.MakeServiceEnvironmentFromContext(context))
+	vpc := awp.VPC(context.StateContext.Location)
+	environment := awp.generateServiceEnvironment(oap.MakeServiceEnvironmentFromContext(context, vpc))
 	return instanceSpec(serviceName, resourceName, awp.OAPResourceTypeName, *environment, attributes, alarms)
 }
 

pkg/orchestration/wiring/aws/resources.go

@@ -34,11 +34,16 @@ const (
 
 // All osb-aws-provider resources are 'almost' the same, differing only in the service/plan names,
 // what they need passed in the ServiceEnvironment.
-var ResourceTypes = map[voyager.ResourceType]wiringplugin.WiringPlugin{
-	DynamoDB: wiringutil.StatusAdapter(Resource(DynamoDB, DynamoDBName, DynamoDBClass, DynamoDBPlan, dynamoDbServiceEnvironment, dynamoDbShapes).WireUp),
-	S3:       wiringutil.StatusAdapter(Resource(S3, S3Name, S3Class, S3Plan, s3ServiceEnvironment, s3Shapes).WireUp),
-	Cfn:      wiringutil.StatusAdapter(Resource(Cfn, CfnName, CfnClass, CfnPlan, CfnServiceEnvironment, cfnShapes).WireUp),
-}
+var (
+	emptyVPC = func(location voyager.Location) *oap.VPCEnvironment {
+		return oap.ExampleVPC(location.Label, location.Region)
+	}
+	DynamoDBPlugin = wiringutil.StatusAdapter(Resource(DynamoDB, DynamoDBName, DynamoDBClass, DynamoDBPlan, dynamoDbServiceEnvironment, dynamoDbShapes, emptyVPC).WireUp)
+
+	S3Plugin = wiringutil.StatusAdapter(Resource(S3, S3Name, S3Class, S3Plan, s3ServiceEnvironment, s3Shapes, emptyVPC).WireUp)
+
+	CfnPlugin = wiringutil.StatusAdapter(Resource(Cfn, CfnName, CfnClass, CfnPlan, CfnServiceEnvironment, cfnShapes, emptyVPC).WireUp)
+)
 
 func cfnShapes(resource *orch_v1.StateResource, smithResource *smith_v1.Resource, _ *wiringplugin.WiringContext) ([]wiringplugin.Shape, bool /* externalErr */, bool /* retriableErr */, error) {
 	templateName, external, retriable, err := oap.TemplateName(resource.Spec)

pkg/orchestration/wiring/ec2compute/v2/plugin.go

@@ -195,13 +195,26 @@ func constructComputeParameters(origSpec *runtime.RawExtension, iamRoleRef, iamI
 }
 
 func New() *WiringPlugin {
-	return &WiringPlugin{}
+	return &WiringPlugin{
+		DeveloperRole: func(_ voyager.Location) []string {
+			return []string{"arn:aws:iam::123456789012:role/micros-server-iam-MicrosServer-ABC"} //example
+		},
+		ManagedPolicies: func(_ voyager.Location) []string {
+			return []string{"arn:aws:iam::123456789012:policy/SOX-DENY-IAM-CREATE-DELETE", "arn:aws:iam::123456789012:policy/micros-iam-DefaultServicePolicy-ABC"} // example
+		},
+		VPC: func(location voyager.Location) *oap.VPCEnvironment {
+			return oap.ExampleVPC(location.Label, location.Region)
+		},
+	}
 }
 
 type WiringPlugin struct {
+	DeveloperRole   func(location voyager.Location) []string
+	ManagedPolicies func(location voyager.Location) []string
+	VPC             func(location voyager.Location) *oap.VPCEnvironment
 }
 
-func WireUp(stateResource *orch_v1.StateResource, context *wiringplugin.WiringContext) wiringplugin.WiringResult {
+func (p *WiringPlugin) WireUp(stateResource *orch_v1.StateResource, context *wiringplugin.WiringContext) wiringplugin.WiringResult {
 	if stateResource.Type != ResourceType {
 		return &wiringplugin.WiringResultFailure{
 			Error: errors.Errorf("invalid resource type: %q", stateResource.Type),
@@ -221,7 +234,7 @@ func WireUp(stateResource *orch_v1.StateResource, context *wiringplugin.WiringCo
 		}
 	}
 
-	return wireUp(userInput.Service.ID, ec2ComputePlanName, stateResource, context, constructComputeParameters)
+	return p.wireUp(userInput.Service.ID, ec2ComputePlanName, stateResource, context, constructComputeParameters)
 }
 
 func generateSecretResource(compute voyager.ResourceName, envVars map[string]string, dependencyReferences []smith_v1.Reference) (smith_v1.Resource, error) {
@@ -264,7 +277,7 @@ func calculateServiceName(serviceName voyager.ServiceName, resourceName voyager.
 	return microsServiceName, nil
 }
 
-func wireUp(microServiceNameInSpec, ec2ComputePlanName string, stateResource *orch_v1.StateResource, context *wiringplugin.WiringContext, constructComputeParameters ConstructComputeParametersFunction) wiringplugin.WiringResult {
+func (p *WiringPlugin) wireUp(microServiceNameInSpec, ec2ComputePlanName string, stateResource *orch_v1.StateResource, context *wiringplugin.WiringContext, constructComputeParameters ConstructComputeParametersFunction) wiringplugin.WiringResult {
 	dependencies := context.Dependencies
 
 	if err := compute.ValidateASAPDependencies(context); err != nil {
@@ -387,8 +400,8 @@ func wireUp(microServiceNameInSpec, ec2ComputePlanName string, stateResource *or
 		bindingResources = append(bindingResources, secretResource)
 	}
 
-	assumeRoles := []string{context.StateContext.LegacyConfig.DeployerRole}
-	managedPolicies := context.StateContext.LegacyConfig.ManagedPolicies
+	assumeRoles := p.DeveloperRole(context.StateContext.Location)
+	managedPolicies := p.ManagedPolicies(context.StateContext.Location)
 
 	// The only things that generate IamSnippets are the things that have the correct shape
 	iamPluginInstanceSmithResource, err := iam.PluginServiceInstance(
@@ -400,6 +413,7 @@ func wireUp(microServiceNameInSpec, ec2ComputePlanName string, stateResource *or
 		context,
 		managedPolicies,
 		assumeRoles,
+		p.VPC(context.StateContext.Location),
 	)
 	if err != nil {
 		return &wiringplugin.WiringResultFailure{