func()

in tools/eksDistroBuildToolingOpsTools/pkg/externalplugin/golangPatchReleaseRequest.go [24:89]

• 62 lines of code
• 16 McCabe index (conditional complexity)

func (s *Server) handleGolangPatchRelease(l *logrus.Entry, requestor string, issue *github.Issue, org, repo, title, body string, num int) error {
	var lock *sync.Mutex
	func() {
		s.mapLock.Lock()
		defer s.mapLock.Unlock()
		if _, ok := s.lockGolangPatchMap[golangPatchReleaseRequest{org, repo, num}]; !ok {
			if s.lockGolangPatchMap == nil {
				s.lockGolangPatchMap = map[golangPatchReleaseRequest]*sync.Mutex{}
			}
			s.lockGolangPatchMap[golangPatchReleaseRequest{org, repo, num}] = &sync.Mutex{}
		}
		lock = s.lockGolangPatchMap[golangPatchReleaseRequest{org, repo, num}]
	}()
	lock.Lock()
	defer lock.Unlock()

	// This check is to all only AWS org members to trigger the automation.
	if !s.AllowAll {
		// eks-distro-bot is not part of the AWS org so we add exception for the bot account.
		if requestor != constants.EksDistroBotName {
			ok, err := s.Ghc.IsMember(org, requestor)
			if err != nil {
				return err
			}
			if !ok {
				resp := fmt.Sprintf(constants.AllowAllFailRespTemplate, requestor, org, org)
				l.Info(resp)
				return s.Ghc.CreateComment(org, repo, num, resp)
			}
		}
	}

	var golangVersionsRe = regexp.MustCompile(`(?m)(\d+.\d+.\d+)`)
	var issNumRe = regexp.MustCompile(`(#\d+)`)
	m := make(map[string]int)
	for _, version := range golangVersionsRe.FindAllString(issue.Title, -1) {
		query := fmt.Sprintf("repo:%s/%s milestone:Go%s label:Security", constants.GolangOrgName, constants.GoRepoName, version)
		milestoneIssues, err := s.Ghc.FindIssuesWithOrg(constants.GolangOrgName, query, "", false)
		if err != nil {
			return fmt.Errorf("Find Golang Milestone: %v", err)
		}
		for _, i := range milestoneIssues {
			for _, biMatch := range issNumRe.FindAllString(i.Body, -1) {
				if m[biMatch] == 0 {
					m[biMatch] = 1
				}
			}
		}
	}
	for biNum := range m {
		biInt, err := strconv.Atoi(biNum[1:])
		if err != nil {
			return fmt.Errorf("Converting issue number to int: %w", err)
		}
		baseIssue, err := s.Ghc.GetIssue(constants.GolangOrgName, constants.GoRepoName, biInt)
		if err != nil {
			return fmt.Errorf("Getting base issue(%s/%s#%d): %w", constants.GolangOrgName, constants.GoRepoName, biInt, err)
		}
		miNum, err := s.Ghc.CreateIssue(constants.AwsOrgName, constants.EksdBuildToolingRepoName, baseIssue.Title, baseIssue.Body, 0, nil, nil)
		if err != nil {
			return fmt.Errorf("Creating mirrored issue: %w", err)
		}
		l.Info(fmt.Sprintf("Created Issue: %s/%s#%d", constants.AwsOrgName, constants.EksdBuildToolingRepoName, miNum))
	}
	return nil
}