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]>
535 lines
14 KiB
Go
535 lines
14 KiB
Go
package pull_request
|
|
|
|
import (
|
|
"fmt"
|
|
"io"
|
|
"net/http"
|
|
"net/http/httptest"
|
|
"testing"
|
|
|
|
"github.com/stretchr/testify/assert"
|
|
"github.com/stretchr/testify/require"
|
|
|
|
"github.com/hanzoai/cd/pkg/apis/application/v1alpha1"
|
|
)
|
|
|
|
func defaultHandlerCloud(t *testing.T) func(http.ResponseWriter, *http.Request) {
|
|
t.Helper()
|
|
return func(w http.ResponseWriter, r *http.Request) {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
var err error
|
|
switch r.RequestURI {
|
|
case "/repositories/OWNER/REPO/pullrequests/":
|
|
_, err = io.WriteString(w, `{
|
|
"size": 1,
|
|
"pagelen": 10,
|
|
"page": 1,
|
|
"values": [
|
|
{
|
|
"id": 101,
|
|
"title": "feat(foo-bar)",
|
|
"source": {
|
|
"branch": {
|
|
"name": "feature/foo-bar"
|
|
},
|
|
"commit": {
|
|
"type": "commit",
|
|
"hash": "1a8dd249c04a"
|
|
}
|
|
},
|
|
"author": {
|
|
"nickname": "testName"
|
|
}
|
|
}
|
|
]
|
|
}`)
|
|
default:
|
|
t.Fail()
|
|
}
|
|
if err != nil {
|
|
t.Fail()
|
|
}
|
|
}
|
|
}
|
|
|
|
func TestParseUrlEmptyUrl(t *testing.T) {
|
|
t.Parallel()
|
|
url, err := parseURL("")
|
|
bitbucketURL, _ := url.Parse("https://api.bitbucket.org/2.0")
|
|
|
|
require.NoError(t, err)
|
|
assert.Equal(t, bitbucketURL, url)
|
|
}
|
|
|
|
func TestInvalidBaseUrlBasicAuthCloud(t *testing.T) {
|
|
t.Parallel()
|
|
_, err := NewBitbucketCloudServiceBasicAuth("http:// example.org", "user", "password", "OWNER", "REPO")
|
|
|
|
require.Error(t, err)
|
|
}
|
|
|
|
func TestInvalidBaseUrlBearerTokenCloud(t *testing.T) {
|
|
t.Parallel()
|
|
_, err := NewBitbucketCloudServiceBearerToken("http:// example.org", "TOKEN", "OWNER", "REPO")
|
|
|
|
require.Error(t, err)
|
|
}
|
|
|
|
func TestInvalidBaseUrlNoAuthCloud(t *testing.T) {
|
|
t.Parallel()
|
|
_, err := NewBitbucketCloudServiceNoAuth("http:// example.org", "OWNER", "REPO")
|
|
|
|
require.Error(t, err)
|
|
}
|
|
|
|
func TestListPullRequestBearerTokenCloud(t *testing.T) {
|
|
t.Parallel()
|
|
ts := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
|
assert.Equal(t, "Bearer TOKEN", r.Header.Get("Authorization"))
|
|
defaultHandlerCloud(t)(w, r)
|
|
}))
|
|
defer ts.Close()
|
|
svc, err := NewBitbucketCloudServiceBearerToken(ts.URL, "TOKEN", "OWNER", "REPO")
|
|
require.NoError(t, err)
|
|
pullRequests, err := ListPullRequests(t.Context(), svc, []v1alpha1.PullRequestGeneratorFilter{})
|
|
require.NoError(t, err)
|
|
assert.Len(t, pullRequests, 1)
|
|
assert.Equal(t, int64(101), pullRequests[0].Number)
|
|
assert.Equal(t, "feat(foo-bar)", pullRequests[0].Title)
|
|
assert.Equal(t, "feature/foo-bar", pullRequests[0].Branch)
|
|
assert.Equal(t, "1a8dd249c04a", pullRequests[0].HeadSHA)
|
|
assert.Equal(t, "testName", pullRequests[0].Author)
|
|
}
|
|
|
|
func TestListPullRequestNoAuthCloud(t *testing.T) {
|
|
t.Parallel()
|
|
ts := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
|
assert.Empty(t, r.Header.Get("Authorization"))
|
|
defaultHandlerCloud(t)(w, r)
|
|
}))
|
|
defer ts.Close()
|
|
svc, err := NewBitbucketCloudServiceNoAuth(ts.URL, "OWNER", "REPO")
|
|
require.NoError(t, err)
|
|
pullRequests, err := ListPullRequests(t.Context(), svc, []v1alpha1.PullRequestGeneratorFilter{})
|
|
require.NoError(t, err)
|
|
assert.Len(t, pullRequests, 1)
|
|
assert.Equal(t, int64(101), pullRequests[0].Number)
|
|
assert.Equal(t, "feat(foo-bar)", pullRequests[0].Title)
|
|
assert.Equal(t, "feature/foo-bar", pullRequests[0].Branch)
|
|
assert.Equal(t, "1a8dd249c04a", pullRequests[0].HeadSHA)
|
|
assert.Equal(t, "testName", pullRequests[0].Author)
|
|
}
|
|
|
|
func TestListPullRequestBasicAuthCloud(t *testing.T) {
|
|
t.Parallel()
|
|
ts := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
|
assert.Equal(t, "Basic dXNlcjpwYXNzd29yZA==", r.Header.Get("Authorization"))
|
|
defaultHandlerCloud(t)(w, r)
|
|
}))
|
|
defer ts.Close()
|
|
svc, err := NewBitbucketCloudServiceBasicAuth(ts.URL, "user", "password", "OWNER", "REPO")
|
|
require.NoError(t, err)
|
|
pullRequests, err := ListPullRequests(t.Context(), svc, []v1alpha1.PullRequestGeneratorFilter{})
|
|
require.NoError(t, err)
|
|
assert.Len(t, pullRequests, 1)
|
|
assert.Equal(t, int64(101), pullRequests[0].Number)
|
|
assert.Equal(t, "feat(foo-bar)", pullRequests[0].Title)
|
|
assert.Equal(t, "feature/foo-bar", pullRequests[0].Branch)
|
|
assert.Equal(t, "1a8dd249c04a", pullRequests[0].HeadSHA)
|
|
assert.Equal(t, "testName", pullRequests[0].Author)
|
|
}
|
|
|
|
func TestListPullRequestPaginationCloud(t *testing.T) {
|
|
t.Parallel()
|
|
ts := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
var err error
|
|
switch r.RequestURI {
|
|
case "/repositories/OWNER/REPO/pullrequests/":
|
|
_, err = fmt.Fprintf(w, `{
|
|
"size": 2,
|
|
"pagelen": 1,
|
|
"page": 1,
|
|
"next": "http://%s/repositories/OWNER/REPO/pullrequests/?pagelen=1&page=2",
|
|
"values": [
|
|
{
|
|
"id": 101,
|
|
"title": "feat(101)",
|
|
"source": {
|
|
"branch": {
|
|
"name": "feature-101"
|
|
},
|
|
"commit": {
|
|
"type": "commit",
|
|
"hash": "1a8dd249c04a"
|
|
}
|
|
},
|
|
"author": {
|
|
"nickname": "testName"
|
|
}
|
|
},
|
|
{
|
|
"id": 102,
|
|
"title": "feat(102)",
|
|
"source": {
|
|
"branch": {
|
|
"name": "feature-102"
|
|
},
|
|
"commit": {
|
|
"type": "commit",
|
|
"hash": "4cf807e67a6d"
|
|
}
|
|
},
|
|
"author": {
|
|
"nickname": "testName"
|
|
}
|
|
}
|
|
]
|
|
}`, r.Host)
|
|
case "/repositories/OWNER/REPO/pullrequests/?pagelen=1&page=2":
|
|
_, err = fmt.Fprintf(w, `{
|
|
"size": 2,
|
|
"pagelen": 1,
|
|
"page": 2,
|
|
"previous": "http://%s/repositories/OWNER/REPO/pullrequests/?pagelen=1&page=1",
|
|
"values": [
|
|
{
|
|
"id": 103,
|
|
"title": "feat(103)",
|
|
"source": {
|
|
"branch": {
|
|
"name": "feature-103"
|
|
},
|
|
"commit": {
|
|
"type": "commit",
|
|
"hash": "6344d9623e3b"
|
|
}
|
|
},
|
|
"author": {
|
|
"nickname": "testName"
|
|
}
|
|
}
|
|
]
|
|
}`, r.Host)
|
|
default:
|
|
t.Fail()
|
|
}
|
|
if err != nil {
|
|
t.Fail()
|
|
}
|
|
}))
|
|
defer ts.Close()
|
|
svc, err := NewBitbucketCloudServiceNoAuth(ts.URL, "OWNER", "REPO")
|
|
require.NoError(t, err)
|
|
pullRequests, err := ListPullRequests(t.Context(), svc, []v1alpha1.PullRequestGeneratorFilter{})
|
|
require.NoError(t, err)
|
|
assert.Len(t, pullRequests, 3)
|
|
assert.Equal(t, PullRequest{
|
|
Number: 101,
|
|
Title: "feat(101)",
|
|
Branch: "feature-101",
|
|
HeadSHA: "1a8dd249c04a",
|
|
Author: "testName",
|
|
}, *pullRequests[0])
|
|
assert.Equal(t, PullRequest{
|
|
Number: 102,
|
|
Title: "feat(102)",
|
|
Branch: "feature-102",
|
|
HeadSHA: "4cf807e67a6d",
|
|
Author: "testName",
|
|
}, *pullRequests[1])
|
|
assert.Equal(t, PullRequest{
|
|
Number: 103,
|
|
Title: "feat(103)",
|
|
Branch: "feature-103",
|
|
HeadSHA: "6344d9623e3b",
|
|
Author: "testName",
|
|
}, *pullRequests[2])
|
|
}
|
|
|
|
func TestListResponseErrorCloud(t *testing.T) {
|
|
t.Parallel()
|
|
ts := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, _ *http.Request) {
|
|
w.WriteHeader(http.StatusInternalServerError)
|
|
}))
|
|
defer ts.Close()
|
|
svc, _ := NewBitbucketCloudServiceNoAuth(ts.URL, "OWNER", "REPO")
|
|
_, err := ListPullRequests(t.Context(), svc, []v1alpha1.PullRequestGeneratorFilter{})
|
|
require.Error(t, err)
|
|
}
|
|
|
|
func TestListResponseMalformedCloud(t *testing.T) {
|
|
t.Parallel()
|
|
ts := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
switch r.RequestURI {
|
|
case "/repositories/OWNER/REPO/pullrequests/":
|
|
_, err := io.WriteString(w, `[{
|
|
"size": 1,
|
|
"pagelen": 10,
|
|
"page": 1,
|
|
"values": [{ "id": 101 }]
|
|
}]`)
|
|
if err != nil {
|
|
t.Fail()
|
|
}
|
|
default:
|
|
t.Fail()
|
|
}
|
|
}))
|
|
defer ts.Close()
|
|
svc, _ := NewBitbucketCloudServiceNoAuth(ts.URL, "OWNER", "REPO")
|
|
_, err := ListPullRequests(t.Context(), svc, []v1alpha1.PullRequestGeneratorFilter{})
|
|
require.Error(t, err)
|
|
}
|
|
|
|
func TestListResponseMalformedValuesCloud(t *testing.T) {
|
|
t.Parallel()
|
|
ts := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
switch r.RequestURI {
|
|
case "/repositories/OWNER/REPO/pullrequests/":
|
|
_, err := io.WriteString(w, `{
|
|
"size": 1,
|
|
"pagelen": 10,
|
|
"page": 1,
|
|
"values": { "id": 101 }
|
|
}`)
|
|
if err != nil {
|
|
t.Fail()
|
|
}
|
|
default:
|
|
t.Fail()
|
|
}
|
|
}))
|
|
defer ts.Close()
|
|
svc, _ := NewBitbucketCloudServiceNoAuth(ts.URL, "OWNER", "REPO")
|
|
_, err := ListPullRequests(t.Context(), svc, []v1alpha1.PullRequestGeneratorFilter{})
|
|
require.Error(t, err)
|
|
}
|
|
|
|
func TestListResponseEmptyCloud(t *testing.T) {
|
|
t.Parallel()
|
|
ts := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
switch r.RequestURI {
|
|
case "/repositories/OWNER/REPO/pullrequests/":
|
|
_, err := io.WriteString(w, `{
|
|
"size": 1,
|
|
"pagelen": 10,
|
|
"page": 1,
|
|
"values": []
|
|
}`)
|
|
if err != nil {
|
|
t.Fail()
|
|
}
|
|
default:
|
|
t.Fail()
|
|
}
|
|
}))
|
|
defer ts.Close()
|
|
svc, err := NewBitbucketCloudServiceNoAuth(ts.URL, "OWNER", "REPO")
|
|
require.NoError(t, err)
|
|
pullRequests, err := ListPullRequests(t.Context(), svc, []v1alpha1.PullRequestGeneratorFilter{})
|
|
require.NoError(t, err)
|
|
assert.Empty(t, pullRequests)
|
|
}
|
|
|
|
func TestListPullRequestBranchMatchCloud(t *testing.T) {
|
|
t.Parallel()
|
|
ts := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
var err error
|
|
switch r.RequestURI {
|
|
case "/repositories/OWNER/REPO/pullrequests/":
|
|
_, err = fmt.Fprintf(w, `{
|
|
"size": 2,
|
|
"pagelen": 1,
|
|
"page": 1,
|
|
"next": "http://%s/repositories/OWNER/REPO/pullrequests/?pagelen=1&page=2",
|
|
"values": [
|
|
{
|
|
"id": 101,
|
|
"title": "feat(101)",
|
|
"source": {
|
|
"branch": {
|
|
"name": "feature-101"
|
|
},
|
|
"commit": {
|
|
"type": "commit",
|
|
"hash": "1a8dd249c04a"
|
|
}
|
|
},
|
|
"author": {
|
|
"nickname": "testName"
|
|
},
|
|
"destination": {
|
|
"branch": {
|
|
"name": "master"
|
|
}
|
|
}
|
|
},
|
|
{
|
|
"id": 200,
|
|
"title": "feat(200)",
|
|
"source": {
|
|
"branch": {
|
|
"name": "feature-200"
|
|
},
|
|
"commit": {
|
|
"type": "commit",
|
|
"hash": "4cf807e67a6d"
|
|
}
|
|
},
|
|
"author": {
|
|
"nickname": "testName"
|
|
},
|
|
"destination": {
|
|
"branch": {
|
|
"name": "branch-200"
|
|
}
|
|
}
|
|
}
|
|
]
|
|
}`, r.Host)
|
|
case "/repositories/OWNER/REPO/pullrequests/?pagelen=1&page=2":
|
|
_, err = fmt.Fprintf(w, `{
|
|
"size": 2,
|
|
"pagelen": 1,
|
|
"page": 2,
|
|
"previous": "http://%s/repositories/OWNER/REPO/pullrequests/?pagelen=1&page=1",
|
|
"values": [
|
|
{
|
|
"id": 102,
|
|
"title": "feat(102)",
|
|
"source": {
|
|
"branch": {
|
|
"name": "feature-102"
|
|
},
|
|
"commit": {
|
|
"type": "commit",
|
|
"hash": "6344d9623e3b"
|
|
}
|
|
},
|
|
"author": {
|
|
"nickname": "testName"
|
|
},
|
|
"destination": {
|
|
"branch": {
|
|
"name": "master"
|
|
}
|
|
}
|
|
}
|
|
]
|
|
}`, r.Host)
|
|
default:
|
|
t.Fail()
|
|
}
|
|
if err != nil {
|
|
t.Fail()
|
|
}
|
|
}))
|
|
defer ts.Close()
|
|
regexp := `feature-1[\d]{2}`
|
|
svc, err := NewBitbucketCloudServiceNoAuth(ts.URL, "OWNER", "REPO")
|
|
require.NoError(t, err)
|
|
pullRequests, err := ListPullRequests(t.Context(), svc, []v1alpha1.PullRequestGeneratorFilter{
|
|
{
|
|
BranchMatch: ®exp,
|
|
},
|
|
})
|
|
require.NoError(t, err)
|
|
assert.Len(t, pullRequests, 2)
|
|
assert.Equal(t, PullRequest{
|
|
Number: 101,
|
|
Title: "feat(101)",
|
|
Branch: "feature-101",
|
|
HeadSHA: "1a8dd249c04a",
|
|
Author: "testName",
|
|
TargetBranch: "master",
|
|
}, *pullRequests[0])
|
|
assert.Equal(t, PullRequest{
|
|
Number: 102,
|
|
Title: "feat(102)",
|
|
Branch: "feature-102",
|
|
HeadSHA: "6344d9623e3b",
|
|
Author: "testName",
|
|
TargetBranch: "master",
|
|
}, *pullRequests[1])
|
|
|
|
regexp = `.*2$`
|
|
svc, err = NewBitbucketCloudServiceNoAuth(ts.URL, "OWNER", "REPO")
|
|
require.NoError(t, err)
|
|
pullRequests, err = ListPullRequests(t.Context(), svc, []v1alpha1.PullRequestGeneratorFilter{
|
|
{
|
|
BranchMatch: ®exp,
|
|
},
|
|
})
|
|
require.NoError(t, err)
|
|
assert.Len(t, pullRequests, 1)
|
|
assert.Equal(t, PullRequest{
|
|
Number: 102,
|
|
Title: "feat(102)",
|
|
Branch: "feature-102",
|
|
HeadSHA: "6344d9623e3b",
|
|
Author: "testName",
|
|
TargetBranch: "master",
|
|
}, *pullRequests[0])
|
|
|
|
regexp = `[\d{2}`
|
|
svc, err = NewBitbucketCloudServiceNoAuth(ts.URL, "OWNER", "REPO")
|
|
require.NoError(t, err)
|
|
_, err = ListPullRequests(t.Context(), svc, []v1alpha1.PullRequestGeneratorFilter{
|
|
{
|
|
BranchMatch: ®exp,
|
|
},
|
|
})
|
|
require.Error(t, err)
|
|
|
|
regexp = `feature-2[\d]{2}`
|
|
targetRegexp := `branch.*`
|
|
pullRequests, err = ListPullRequests(t.Context(), svc, []v1alpha1.PullRequestGeneratorFilter{
|
|
{
|
|
BranchMatch: ®exp,
|
|
TargetBranchMatch: &targetRegexp,
|
|
},
|
|
})
|
|
require.NoError(t, err)
|
|
assert.Len(t, pullRequests, 1)
|
|
assert.Equal(t, PullRequest{
|
|
Number: 200,
|
|
Title: "feat(200)",
|
|
Branch: "feature-200",
|
|
HeadSHA: "4cf807e67a6d",
|
|
Author: "testName",
|
|
TargetBranch: "branch-200",
|
|
}, *pullRequests[0])
|
|
}
|
|
|
|
func TestBitbucketCloudListReturnsRepositoryNotFoundError(t *testing.T) {
|
|
t.Parallel()
|
|
mux := http.NewServeMux()
|
|
server := httptest.NewServer(mux)
|
|
defer server.Close()
|
|
|
|
path := "/repositories/nonexistent/nonexistent/pullrequests/"
|
|
|
|
mux.HandleFunc(path, func(w http.ResponseWriter, _ *http.Request) {
|
|
// Return 404 status to simulate repository not found
|
|
w.WriteHeader(http.StatusNotFound)
|
|
_, _ = w.Write([]byte(`{"message": "404 Project Not Found"}`))
|
|
})
|
|
|
|
svc, err := NewBitbucketCloudServiceNoAuth(server.URL, "nonexistent", "nonexistent")
|
|
require.NoError(t, err)
|
|
|
|
prs, err := svc.List(t.Context())
|
|
|
|
// Should return empty pull requests list
|
|
assert.Empty(t, prs)
|
|
|
|
// Should return RepositoryNotFoundError
|
|
require.Error(t, err)
|
|
assert.True(t, IsRepositoryNotFoundError(err), "Expected RepositoryNotFoundError but got: %v", err)
|
|
}
|