func deployTrigger()

in reference-architectures/cloud_deploy_flow/CloudFunctions/createRelease/main.go [59:145]
65 lines of code
9 McCabe index (conditional complexity)

func deployTrigger(ctx context.Context, e event.Event) error {
	log.Printf("Deploy trigger function invoked")

	// Parse the Pub/Sub message data into MessagePublishedData struct
	var msg MessagePublishedData
	if err := e.DataAs(&msg); err != nil {
		return fmt.Errorf("event.DataAs: %w", err)
	}

	// Unmarshal CloudBuild data into BuildMessage struct
	log.Printf("Converting Byte to Struct Object")
	var buildNotification BuildMessage
	if err := json.Unmarshal(msg.Message.Data, &buildNotification); err != nil {
		return fmt.Errorf("error parsing JIRA notification: %v", err)
	}

	// Check for specific build criteria (trigger ID and status)
	log.Printf("Checking if proper build")
	if buildNotification.BuildTriggerID != c.TriggerID || buildNotification.Status != "SUCCESS" {
		log.Printf("Build trigger ID or status does not match, returning early")
		// Return nil to indicate successful processing without further actions
		return nil
	}

	// Extract relevant image information from the build notification
	log.Printf("Pulling relevant image")
	image := buildNotification.Artifacts.Images[0]
	log.Printf("Received Image from Cloud Build: %s", image)

	// Create a Cloud Deploy client for further interactions
	deployClient, err := deploy.NewCloudDeployClient(ctx,
		option.WithUserAgent("cloud-solutions/platform-engineering-cloud-deploy-pipeline-code-v1"),
	)
	if err != nil {
		return fmt.Errorf("error creating Cloud Deploy client: %v", err)
	}
	defer deployClient.Close()

	// Construct the name of the delivery pipeline from environment variables
	pipelineName := fmt.Sprintf("projects/%s/locations/%s/deliveryPipelines/%s", c.ProjectId, c.Location, c.Pipeline)
	// Retrieve the delivery pipeline information
	pipeline, err := deployClient.GetDeliveryPipeline(ctx, &deploypb.GetDeliveryPipelineRequest{
		Name: pipelineName,
	})
	if err != nil {
		return fmt.Errorf("error getting delivery pipeline: %v", err)
	}

	// Generate a unique release ID with a random suffix
	randomID, err := generateRandomID(6) // Generate a random ID of 6 bytes (12 hex characters)
	if err != nil {
		log.Fatalf("Error generating random ID: %v", err)
	}
	releaseID := fmt.Sprintf("release-%s", randomID) // Set the release ID

	// Define a new release request with the image and pipeline details
	var command = CommandMessage{
		Commmand: "CreateRelease",
		CreateRelease: deploypb.CreateReleaseRequest{
			Parent:    pipeline.Name,
			ReleaseId: releaseID,
			Release: &deploypb.Release{
				// Configure the release with image details
				BuildArtifacts: []*deploypb.BuildArtifact{
					{
						Tag:   image,   // Set the container image
						Image: "pizza", // Placeholder for substitution in run.yaml
					},
				},
				// Skaffold config details for deployment
				SkaffoldConfigUri: fmt.Sprintf("%s/%s.tar.gz",
					buildNotification.Substitutions.DeployGCS,
					buildNotification.Substitutions.CommitSha,
				),
				SkaffoldConfigPath: "skaffold.yaml", // Path to Skaffold config file
			},
		},
	}

	// Send the command message to Pub/Sub for deployment
	err = sendCommandPubSub(ctx, &command)
	if err != nil {
		return fmt.Errorf("failed to send pubsub command: %v", err)
	}
	log.Printf("Deployment triggered successfully")
	return nil
}