func cancelPreviousBuild()

in cancelot/cancelot/cancelpreviousbuild.go [28:96]
53 lines of code
9 McCabe index (conditional complexity)

func cancelPreviousBuild(ctx context.Context, currentBuildID string, branchName string, sameTriggerOnly bool) error {
	svc := gcbClient(ctx)
	project, err := getProject()
	if err != nil {
		return fmt.Errorf("cancelPreviousBuild: Failed to get project: %v", err)
	}

	log.Printf("Going to fetch current build details for: %s", currentBuildID)

	currentBuildResponse, currentBuildError := svc.Projects.Builds.Get(project, currentBuildID).Do()
	if currentBuildError != nil {
		return fmt.Errorf("cancelPreviousBuild: Failed to get build details from Cloud Build: %v", currentBuildError)
	}

	log.Printf("Going to check ongoing jobs for branch: %s", branchName)

	onGoingJobFilter := fmt.Sprintf(`
		build_id != "%s" AND 
		source.repo_source.branch_name = "%s" AND 
		status = "WORKING" AND 
		start_time<"%s"`,
		currentBuildID,
		branchName,
		currentBuildResponse.StartTime)

	if sameTriggerOnly {
		onGoingJobFilter = fmt.Sprintf(`
		%s AND
		trigger_id = "%s"`,
			onGoingJobFilter,
			currentBuildResponse.BuildTriggerId)
	}

	log.Printf("Builds filter created: %s", onGoingJobFilter)

	onGoingBuildsResponse, onGoingBuildsError := svc.Projects.Builds.List(project).Filter(onGoingJobFilter).Do()

	if onGoingBuildsError != nil {
		return fmt.Errorf("cancelPreviousBuild: Failed to get builds from Cloud Build: %v", onGoingBuildsError)
	}

	onGoingBuilds := onGoingBuildsResponse.Builds
	numOfOnGoingBuilds := len(onGoingBuilds)

	if sameTriggerOnly {
		log.Printf("Ongoing builds triggered by %s for %s has size of: %d", currentBuildResponse.BuildTriggerId, branchName, numOfOnGoingBuilds)
	} else {
		log.Printf("Ongoing builds for %s has size of: %d", branchName, numOfOnGoingBuilds)
	}

	if numOfOnGoingBuilds == 0 {
		return nil
	}

	for _, build := range onGoingBuilds {
		log.Printf("Going to cancel build with id: %s", build.Id)

		cancelBuildCall := svc.Projects.Builds.Cancel(project, build.Id, &cloudbuild.CancelBuildRequest{})
		buildCancelResponse, buildCancelError := cancelBuildCall.Do()

		if buildCancelError != nil {
			return fmt.Errorf("cancelPreviousBuild: Failed to cancel build with id:%s - %v", build.Id, buildCancelError)
		}

		log.Printf("Cancelled build with id:%s", buildCancelResponse.Id)
	}

	return nil
}