mirror of
https://github.com/hanzoai/deploy.git
synced 2026-10-07 08:44:50 +00:00
zeekayandHanzo Dev
1ab6e799c1
go.mod still declared `module github.com/hanzoai/deploy` after the repo was renamed. A Go module path is not cosmetic — it is the resolvable location. So `go get github.com/hanzoai/cd` could not work, and anything importing this module had to spell a name that no longer exists at that address. The build log of v3.6.0 is where it surfaced: the compiler was still emitting github.com/hanzoai/deploy/cmd/cd/commands. 3541 import paths across 690 .go, 19 .proto, 4 .yaml, 3 .sh, 2 .mod, Procfile and Makefile. Plus the 62 ghcr.io/hanzoai/deploy image references, moved to ghcr.io/hanzoai/cd to match hanzo.yml's build target — a distinct string from the module path, replaced separately so neither could clobber the other. go mod tidy clean, CGO_ENABLED=0 GOOS=linux GOARCH=amd64 go build ./... clean. Co-authored-by: Hanzo Dev <[email protected]>
110 lines
3.0 KiB
Go
110 lines
3.0 KiB
Go
package pull_request
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
"net/http"
|
|
"os"
|
|
|
|
"github.com/hashicorp/go-retryablehttp"
|
|
gitlab "gitlab.com/gitlab-org/api/client-go"
|
|
|
|
"github.com/hanzoai/cd/applicationset/utils"
|
|
"github.com/hanzoai/cd/util/proxy"
|
|
)
|
|
|
|
type GitLabService struct {
|
|
client *gitlab.Client
|
|
project string
|
|
labels []string
|
|
pullRequestState string
|
|
}
|
|
|
|
var _ PullRequestService = (*GitLabService)(nil)
|
|
|
|
func NewGitLabService(token, url, project string, labels []string, pullRequestState string, scmRootCAPath string, insecure bool, caCerts []byte, proxyURL, noProxy string) (PullRequestService, error) {
|
|
var clientOptionFns []gitlab.ClientOptionFunc
|
|
|
|
// Set a custom Gitlab base URL if one is provided
|
|
if url != "" {
|
|
clientOptionFns = append(clientOptionFns, gitlab.WithBaseURL(url))
|
|
}
|
|
|
|
if token == "" {
|
|
token = os.Getenv("GITLAB_TOKEN")
|
|
}
|
|
|
|
tr := http.DefaultTransport.(*http.Transport).Clone()
|
|
tr.TLSClientConfig = utils.GetTlsConfig(scmRootCAPath, insecure, caCerts)
|
|
tr.Proxy = proxy.GetCallback(proxyURL, noProxy)
|
|
|
|
retryClient := retryablehttp.NewClient()
|
|
retryClient.HTTPClient.Transport = tr
|
|
|
|
clientOptionFns = append(clientOptionFns, gitlab.WithHTTPClient(retryClient.HTTPClient))
|
|
|
|
client, err := gitlab.NewClient(token, clientOptionFns...)
|
|
if err != nil {
|
|
return nil, fmt.Errorf("error creating Gitlab client: %w", err)
|
|
}
|
|
|
|
return &GitLabService{
|
|
client: client,
|
|
project: project,
|
|
labels: labels,
|
|
pullRequestState: pullRequestState,
|
|
}, nil
|
|
}
|
|
|
|
func (g *GitLabService) List(ctx context.Context) ([]*PullRequest, error) {
|
|
// Filter the merge requests on labels, if they are specified.
|
|
var labels *gitlab.LabelOptions
|
|
if len(g.labels) > 0 {
|
|
var labelsList gitlab.LabelOptions = g.labels
|
|
labels = &labelsList
|
|
}
|
|
|
|
snippetsListOptions := gitlab.ExploreSnippetsOptions{
|
|
ListOptions: gitlab.ListOptions{
|
|
PerPage: 100,
|
|
},
|
|
}
|
|
opts := &gitlab.ListProjectMergeRequestsOptions{
|
|
ListOptions: snippetsListOptions.ListOptions,
|
|
Labels: labels,
|
|
}
|
|
|
|
if g.pullRequestState != "" {
|
|
opts.State = &g.pullRequestState
|
|
}
|
|
|
|
pullRequests := []*PullRequest{}
|
|
for {
|
|
mrs, resp, err := g.client.MergeRequests.ListProjectMergeRequests(g.project, opts, gitlab.WithContext(ctx))
|
|
if err != nil {
|
|
if resp != nil && resp.StatusCode == http.StatusNotFound {
|
|
// return a custom error indicating that the repository is not found,
|
|
// but also returning the empty result since the decision to continue or not in this case is made by the caller
|
|
return pullRequests, NewRepositoryNotFoundError(err)
|
|
}
|
|
return nil, fmt.Errorf("error listing merge requests for project '%s': %w", g.project, err)
|
|
}
|
|
for _, mr := range mrs {
|
|
pullRequests = append(pullRequests, &PullRequest{
|
|
Number: mr.IID,
|
|
Title: mr.Title,
|
|
Branch: mr.SourceBranch,
|
|
TargetBranch: mr.TargetBranch,
|
|
HeadSHA: mr.SHA,
|
|
Labels: mr.Labels,
|
|
Author: mr.Author.Username,
|
|
})
|
|
}
|
|
if resp.NextPage == 0 {
|
|
break
|
|
}
|
|
opts.Page = resp.NextPage
|
|
}
|
|
return pullRequests, nil
|
|
}
|