FnCLI fn deploy

Author: Jaytee-fn

commands/deploy.go

@@ -390,9 +390,12 @@ func (p *deploycmd) deployFuncV20180708(c *cli.Context, app *models.App, funcfil
 	if !p.local {
 		// fetch the architectures
 		shape = app.Shape
+		fmt.Printf("*****shape is %v *******", shape)
 		if shape == "" {
+			fmt.Printf("shape is default")
 			shape = common.DefaultAppShape
 			app.Shape = shape
+			//shape = "GENERIC_ARM"
 		}
 
 		if _, ok := common.ShapeMap[shape]; !ok {

common/common.go

@@ -32,6 +32,7 @@ import (
 	"os/exec"
 	"os/signal"
 	"path/filepath"
+	"runtime"
 	"strings"
 	"time"
 	"unicode"
@@ -55,6 +56,7 @@ const (
 	MinRequiredDockerVersion = "17.5.0"
 	BuildxBuilderInstance    = "oci_fn_builder"
 	DefaultAppShape          = modelsv2.AppShapeGENERICX86
+	containerEngineTypeDocker      = "docker"
 )
 
 var GlobalVerbose bool
@@ -66,6 +68,12 @@ var ShapeMap = map[string][]string{
 	modelsv2.AppShapeGENERICX86ARM: {"linux/amd64", "linux/arm64"},
 }
 
+var TargetPlatformMap = map[string][]string{
+	modelsv2.AppShapeGENERICX86:    {"amd64"},
+	modelsv2.AppShapeGENERICARM:    {"arm64"},
+	modelsv2.AppShapeGENERICX86ARM: {"amd64_arm64"},
+}
+
 func IsVerbose() bool {
 	return GlobalVerbose || CommandVerbose
 }
@@ -408,15 +416,18 @@ func containerEngineBuildV20180708(verbose bool, fpath string, ff *FuncFileV2018
 	return nil
 }
 
-func buildXDockerCommand(imageName, dockerfile string, buildArgs []string, noCache bool, architectures []string) []string {
+func buildXDockerCommand(imageName, dockerfile string, buildArgs []string, noCache bool, architectures []string, containerEngineType string) []string {
 	var buildCommand = "buildx"
 	var name = imageName
 
+	plat:= strings.Join(architectures,"," )
+	fmt.Println("buildX platform is %v", plat)
 	args := []string{
 		buildCommand,
 		"build",
 		"-t", name,
 		"-f", dockerfile,
+		//"--load",
 		"--platform", strings.Join(architectures, ","),
 	}
 
@@ -435,7 +446,15 @@ func buildXDockerCommand(imageName, dockerfile string, buildArgs []string, noCac
 		var label = "imageName=" + imageName
 		args = append(args, "--build-arg", arg)
 		args = append(args, "--label", label)
+	}
+
+	if containerEngineType != containerEngineTypeDocker {
+		fmt.Println("*** engine type not docker append load")
+		args = append(args, "--load")
+	} else {
+		fmt.Println("*** engine type docker append push")
 		args = append(args, "--push")
+
 	}
 
 	args = append(args,
@@ -512,20 +531,30 @@ func RunBuild(verbose bool, dir, imageName, dockerfile string, buildArgs []strin
 	go func(done chan<- error) {
 		var dockerBuildCmdArgs []string
 		// Depending whether architecture list is passed or not trigger docker buildx or docker build accordingly
-		var mappedArchitectures []string
+
 		if arch, ok := ShapeMap[shape]; ok {
+			var mappedArchitectures []string
 			mappedArchitectures = append(mappedArchitectures, arch...)
-			err := initializeContainerBuilder(containerEngineType, mappedArchitectures)
-			if err != nil {
-				done <- err
-				return
+			var hostedPlatform = runtime.GOARCH
+			if platform, ok := TargetPlatformMap[shape]; ok {
+				// create target platform string to compare with hosted platform
+				targetPlatform := strings.Join(platform," ")
+				fmt.Println("hosted platform %v target platform %v", hostedPlatform, targetPlatform)
+				if targetPlatform != hostedPlatform {
+					fmt.Println("TargetedPlatform and hostPlatform are not same")
+					err := initializeContainerBuilder(containerEngineType, mappedArchitectures)
+					if err != nil {
+						done <- err
+						return
+					}
+					dockerBuildCmdArgs = buildXDockerCommand(imageName, dockerfile, buildArgs, noCache, mappedArchitectures, containerEngineType )
+					// perform cleanup
+					defer cleanupContainerBuilder(containerEngineType)
+				} else {
+					fmt.Println("TargetedPlatform and hostPlatform are same")
+					dockerBuildCmdArgs = buildDockerCommand(imageName, dockerfile, buildArgs, noCache)
+				}
 			}
-
-			dockerBuildCmdArgs = buildXDockerCommand(imageName, dockerfile, buildArgs, noCache, mappedArchitectures)
-			// perform cleanup
-			defer cleanupContainerBuilder(containerEngineType)
-		} else {
-			dockerBuildCmdArgs = buildDockerCommand(imageName, dockerfile, buildArgs, noCache)
 		}
 
 		cmd := exec.Command(containerEngineType, dockerBuildCmdArgs...)
@@ -551,6 +580,18 @@ func RunBuild(verbose bool, dir, imageName, dockerfile string, buildArgs []strin
 		fmt.Fprintln(os.Stderr)
 		return fmt.Errorf("build cancelled on signal %v", signal)
 	}
+	if containerEngineType != containerEngineTypeDocker {
+		fmt.Println("Using Container engine", containerEngineType, "to push as --push id only for docker and --load is for podman")
+		// Push to docker registry
+		fmt.Println("Using Container engine", containerEngineType, "to push")
+		fmt.Printf("Pushing %v to docker registry...", imageName)
+		cmd := exec.Command(containerEngineType, "push", imageName)
+		cmd.Stderr = os.Stderr
+		cmd.Stdout = os.Stdout
+		if err := cmd.Run(); err != nil {
+			return fmt.Errorf("error running %v push, are you logged?: %v", containerEngineType, err)
+		}
+	}
 	return nil
 }
 
@@ -620,6 +661,10 @@ func isSupportedByDefaultBuildxPlatforms(containerEngineType string, platforms [
 
 func initializeContainerBuilder(containerEngineType string, platforms []string) error {
 
+	if containerEngineType != containerEngineTypeDocker {
+		fmt.Println("engine type not docker return nil")
+		return nil
+	}
 	if isSupportedByDefaultBuildxPlatforms(containerEngineType, platforms) {
 		return nil
 	}

objects/app/apps.go

@@ -152,10 +152,11 @@ func (a *appsCmd) create(c *cli.Context) error {
 	}
 
 	appWithFlags(c, app)
+
 	// If architectures flag is not set then default it to nil
 	if c.IsSet(SHAPE_PARAMETER) {
 		shapeParam := c.String(SHAPE_PARAMETER)
-
+		fmt.Printf("in apps.go shape parameter is set and is %v", shapeParam)
 		// Check for architectures parameter passed or set to default
 		if len(shapeParam) == 0 {
 			return errors.New("no shape specified for the application")
@@ -165,6 +166,8 @@ func (a *appsCmd) create(c *cli.Context) error {
 			return errors.New("invalid shape specified for the application")
 		}
 		app.Shape = shapeParam
+	} else {
+		fmt.Printf("in apps.go shape parameter is not set")
 	}
 	_, err := CreateApp(a.client, app)
 	return err
@@ -178,12 +181,14 @@ func CreateApp(a *fnclient.Fn, app *modelsv2.App) (*modelsv2.App, error) {
 	})
 
 	if err != nil {
+
 		switch e := err.(type) {
 		case *apiapps.CreateAppBadRequest:
 			err = fmt.Errorf("%v", e.Payload.Message)
 		case *apiapps.CreateAppConflict:
 			err = fmt.Errorf("%v", e.Payload.Message)
 		}
+		//fmt.Println("create App error is %v", err)
 		return nil, err
 	}
 	fmt.Println("Successfully created app: ", resp.Payload.Name)

objects/app/commands.go

@@ -57,6 +57,7 @@ func Create() cli.Command {
 				Usage: "Syslog URL to send application logs to",
 			},
 			cli.StringFlag{
+			//cli.StringSliceFlag{
 				Name:  "shape",
 				Usage: "Valid values are GENERIC_X86, GENERIC_ARM and GENERIC_X86_ARM. Default is GENERIC_X86. Setting this to GENERIC_X86, will run the functions in the application on X86 processor architecture.\n Setting this to GENERIC_ARM, will run the functions in the application on ARM processor architecture.\n When set to 'GENERIC_X86_ARM', functions in the application are run on either X86 or ARM processor architecture.\n Accepted values are:\n GENERIC_X86, GENERIC_ARM, GENERIC_X86_ARM",
 			},