func deploy()

in cmd/aro/deploy.go [22:147]
98 lines of code
21 McCabe index (conditional complexity)

func deploy(ctx context.Context, log *logrus.Entry) error {
	// TODO(mjudeikis): Remove this hack in public once we moved to EV2
	// We are not able to use MSI in public cloud CI as we would need
	// to have dedicated node pool with MSI where we can controll which jobs are running
	// on them. Deploy code needs to have privileged access into production, and those should
	// not be exposed to arbitrary CI nodes.
	// This should go away once we move to EV2 in public cloud,
	// env.NewCoreForCI is used in CI context to mock MSI, where env.NewCore uses
	// MSI in production to populate env.Environment, Subscription, Location, etc
	var _env env.Core
	var tokenCredential azcore.TokenCredential
	if os.Getenv("AZURE_EV2") != "" { // running in EV2 - use MSI
		var err error
		_env, err = env.NewCore(ctx, log, env.COMPONENT_DEPLOY)
		if err != nil {
			return err
		}
		options := _env.Environment().ManagedIdentityCredentialOptions()
		tokenCredential, err = azidentity.NewManagedIdentityCredential(options)
		if err != nil {
			return err
		}
	} else { // running in CI node/Public - Use SP from Env
		err := env.ValidateVars(
			"AZURE_CLIENT_ID",
			"AZURE_CLIENT_SECRET",
			"AZURE_SUBSCRIPTION_ID",
			"AZURE_TENANT_ID")

		if err != nil {
			return err
		}

		_env, err = env.NewCoreForCI(ctx, log)
		if err != nil {
			return err
		}
		options := _env.Environment().EnvironmentCredentialOptions()
		tokenCredential, err = azidentity.NewEnvironmentCredential(options)
		if err != nil {
			return err
		}
	}
	env := _env

	deployVersion, location := version.GitCommit, flag.Arg(2)

	log.Printf("deploying version %s to location %s", deployVersion, location)

	if deployVersion == "unknown" ||
		(!env.IsLocalDevelopmentMode() && strings.Contains(deployVersion, "dirty")) {
		return fmt.Errorf("invalid deploy version %q", deployVersion)
	}

	if strings.ToLower(location) != location {
		return fmt.Errorf("location %s must be lower case", location)
	}

	config, err := pkgdeploy.GetConfig(flag.Arg(1), location)
	if err != nil {
		return err
	}

	deployer, err := pkgdeploy.New(ctx, log, env, config, deployVersion, tokenCredential)
	if err != nil {
		return err
	}

	err = deployer.PreDeploy(ctx, 30)
	if err != nil {
		return err
	}

	errch := make(chan error, 2)
	go func() {
		err := deployer.DeployRP(ctx)
		if err != nil {
			log.Error(err)
			errch <- err
			return
		}

		err = deployer.UpgradeRP(ctx)
		if err != nil {
			log.Error(err)
			errch <- err
			return
		}

		errch <- nil
	}()

	go func() {
		err := deployer.DeployGateway(ctx)
		if err != nil {
			log.Error(err)
			errch <- err
			return
		}

		err = deployer.UpgradeGateway(ctx)
		if err != nil {
			log.Error(err)
			errch <- err
			return
		}

		errch <- nil
	}()

	var errorOccurred bool
	for i := 0; i < 2; i++ {
		err = <-errch
		if err != nil {
			errorOccurred = true
		}
	}

	if errorOccurred {
		return fmt.Errorf("an error occurred")
	}

	// Must be last step so we can be sure there are no RPs at older versions
	// still serving
	return deployer.SaveVersion(ctx)
}