rough controller generation for cp

cmd/ack-generate/command/crossplane.go

@@ -0,0 +1,162 @@
+// Copyright Amazon.com Inc. or its affiliates. All Rights Reserved.
+//
+// Licensed under the Apache License, Version 2.0 (the "License"). You may
+// not use this file except in compliance with the License. A copy of the
+// License is located at
+//
+//     http://aws.amazon.com/apache2.0/
+//
+// or in the "license" file accompanying this file. This file is distributed
+// on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either
+// express or implied. See the License for the specific language governing
+// permissions and limitations under the License.
+
+package command
+
+import (
+	"fmt"
+	"path/filepath"
+	"strings"
+
+	"github.com/spf13/cobra"
+
+	"github.com/aws/aws-controllers-k8s/pkg/generate"
+	"github.com/aws/aws-controllers-k8s/pkg/model"
+	ackmodel "github.com/aws/aws-controllers-k8s/pkg/model"
+)
+
+// crossplaneCmd is the command that generates Crossplane API types
+var crossplaneCmd = &cobra.Command{
+	Use:   "crossplane <service>",
+	Short: "Generate Crossplane-compatible Kubernetes API type definitions for a service",
+	RunE:  generateCrossplane,
+}
+
+var providerDir string
+
+func init() {
+	crossplaneCmd.PersistentFlags().StringVar(
+		&providerDir, "provider-dir", ".", "the directory of the Crossplane provider",
+	)
+	rootCmd.AddCommand(crossplaneCmd)
+}
+
+func generateCrossplane(cmd *cobra.Command, args []string) error {
+	if err := generateCrossplaneAPIs(cmd, args); err != nil {
+		return err
+	}
+	if err := generateCrossplaneControllers(cmd, args); err != nil {
+		return err
+	}
+	return nil
+}
+
+// generateCrossplaneAPIs generates the Go files for Crossplane-compatible
+// resources in the AWS service API.
+func generateCrossplaneAPIs(_ *cobra.Command, args []string) error {
+	if len(args) != 1 {
+		return fmt.Errorf("please specify the service alias for the AWS service API to generate")
+	}
+	optTemplatesDir = filepath.Join(optTemplatesDir, "crossplane")
+	svcAlias := strings.ToLower(args[0])
+	if !optDryRun {
+		apisVersionPath = filepath.Join(providerDir, "apis", svcAlias, optGenVersion)
+		if _, err := ensureDir(apisVersionPath); err != nil {
+			return err
+		}
+	}
+	if err := ensureSDKRepo(optCacheDir); err != nil {
+		return err
+	}
+	sdkHelper := model.NewSDKHelper(sdkDir)
+	sdkAPI, err := sdkHelper.API(svcAlias)
+	if err != nil {
+		return err
+	}
+	g, err := generate.New(
+		sdkAPI, optGenVersion, optGeneratorConfigPath, optTemplatesDir,
+	)
+	if err != nil {
+		return err
+	}
+
+	crds, err := g.GetCRDs()
+	if err != nil {
+		return err
+	}
+	typeDefs, _, err := g.GetTypeDefs()
+	if err != nil {
+		return err
+	}
+	enumDefs, err := g.GetEnumDefs()
+	if err != nil {
+		return err
+	}
+
+	if err = writeDocGo(g); err != nil {
+		return err
+	}
+
+	if err = writeGroupVersionInfoGo(g); err != nil {
+		return err
+	}
+
+	if err = writeEnumsGo(g, enumDefs); err != nil {
+		return err
+	}
+
+	if err = writeTypesGo(g, typeDefs); err != nil {
+		return err
+	}
+
+	for _, crd := range crds {
+		if err = writeCRDGo(g, crd); err != nil {
+			return err
+		}
+	}
+	return nil
+}
+
+// generateCrossplaneControllers generates the Go files for a service controller
+func generateCrossplaneControllers(_ *cobra.Command, args []string) error {
+	if len(args) != 1 {
+		return fmt.Errorf("please specify the service alias for the AWS service API to generate")
+	}
+	svcAlias := strings.ToLower(args[0])
+	optControllerOutputPath = providerDir
+	if !optDryRun {
+		pkgResourcePath = filepath.Join(providerDir, "pkg", "controller", svcAlias)
+		if _, err := ensureDir(pkgResourcePath); err != nil {
+			return err
+		}
+	}
+
+	if err := ensureSDKRepo(optCacheDir); err != nil {
+		return err
+	}
+	sdkHelper := ackmodel.NewSDKHelper(sdkDir)
+	sdkAPI, err := sdkHelper.API(svcAlias)
+	if err != nil {
+		return err
+	}
+	latestAPIVersion, err = getLatestAPIVersion()
+	if err != nil {
+		return err
+	}
+	g, err := generate.New(
+		sdkAPI, latestAPIVersion, optGeneratorConfigPath, optTemplatesDir,
+	)
+	if err != nil {
+		return err
+	}
+
+	crds, err := g.GetCRDs()
+	if err != nil {
+		return err
+	}
+
+	if err = writeResourcePackage(g, crds); err != nil {
+		return err
+	}
+	return nil
+}

go.mod

@@ -4,22 +4,23 @@ go 1.14
 
 require (
 	github.com/aws/aws-sdk-go v1.34.18
+	github.com/crossplane/crossplane-runtime v0.10.0
+	github.com/crossplane/provider-aws v0.12.0
 	github.com/dlclark/regexp2 v1.2.0
 	// pin to v0.1.1 due to release problem with v0.1.2
 	github.com/gertd/go-pluralize v0.1.1
 	github.com/ghodss/yaml v1.0.0
 	github.com/go-logr/logr v0.1.0
-	github.com/google/go-cmp v0.3.0
+	github.com/google/go-cmp v0.5.0
 	github.com/iancoleman/strcase v0.0.0-20191112232945-16388991a334
 	github.com/mitchellh/go-homedir v1.1.0
 	github.com/pkg/errors v0.9.1
 	github.com/spf13/cobra v1.0.0
 	github.com/spf13/pflag v1.0.5
 	github.com/stretchr/testify v1.5.1
 	go.uber.org/zap v1.10.0
-	k8s.io/api v0.18.2
-	k8s.io/apimachinery v0.18.6
-	k8s.io/client-go v0.18.2
-	sigs.k8s.io/controller-runtime v0.6.0
-	sigs.k8s.io/controller-tools v0.3.1-0.20200716001835-4a903ddb7005 // indirect
+	k8s.io/api v0.18.8
+	k8s.io/apimachinery v0.18.8
+	k8s.io/client-go v0.18.8
+	sigs.k8s.io/controller-runtime v0.6.2
 )