fix: bitbucket set status test

Signed-off-by: Gosha <[email protected]>

pkg/git_provider/bitbucket_test.go

@@ -2,9 +2,11 @@ package git_provider
 
 import (
  "encoding/json"
+ "errors"
  "fmt"
  "github.com/ktrysmt/go-bitbucket"
  "github.com/rookout/piper/pkg/conf"
+ "github.com/rookout/piper/pkg/utils"
  assertion "github.com/stretchr/testify/assert"
  "golang.org/x/net/context"
  "net/http"
@@ -58,3 +60,116 @@ func TestBitbucketListFiles(t *testing.T) {
  assert.Equal(expectedContent, actualContent)
 
 }
+
+func TestBitbucketSetStatus(t *testing.T) {
+ // Prepare
+ ctx := context.Background()
+ assert := assertion.New(t)
+ client, mux, _, teardown := setupBitbucket()
+ defer teardown()
+
+ mux.HandleFunc("/repositories/test/test-repo1/commit/test-commit/statuses/build", func(w http.ResponseWriter, r *http.Request) {
+ testMethod(t, r, "POST")
+ testFormValues(t, r, values{})
+
+ w.WriteHeader(http.StatusCreated)
+ jsonBytes := []byte(`{"status": "ok"}`)
+ _, _ = fmt.Fprint(w, string(jsonBytes))
+ })
+
+ c := BitbucketClientImpl{
+ client: client,
+ cfg: &conf.GlobalConfig{
+ GitProviderConfig: conf.GitProviderConfig{
+ Provider: "bitbucket",
+ OrgLevelWebhook: false,
+ OrgName: "test",
+ RepoList: "test-repo1",
+ },
+ },
+ }
+
+ // Define test cases
+ tests := []struct {
+ name string
+ repo *string
+ commit *string
+ linkURL *string
+ status *string
+ message *string
+ wantedError error
+ }{
+ {
+ name: "Notify success",
+ repo: utils.SPtr("test-repo1"),
+ commit: utils.SPtr("test-commit"),
+ linkURL: utils.SPtr("https://argo"),
+ status: utils.SPtr("success"),
+ message: utils.SPtr(""),
+ wantedError: nil,
+ },
+ {
+ name: "Notify pending",
+ repo: utils.SPtr("test-repo1"),
+ commit: utils.SPtr("test-commit"),
+ linkURL: utils.SPtr("https://argo"),
+ status: utils.SPtr("pending"),
+ message: utils.SPtr(""),
+ wantedError: nil,
+ },
+ {
+ name: "Notify error",
+ repo: utils.SPtr("test-repo1"),
+ commit: utils.SPtr("test-commit"),
+ linkURL: utils.SPtr("https://argo"),
+ status: utils.SPtr("error"),
+ message: utils.SPtr("some message"),
+ wantedError: nil,
+ },
+ {
+ name: "Notify failure",
+ repo: utils.SPtr("test-repo1"),
+ commit: utils.SPtr("test-commit"),
+ linkURL: utils.SPtr("https://argo"),
+ status: utils.SPtr("failure"),
+ message: utils.SPtr(""),
+ wantedError: nil,
+ },
+ {
+ name: "Non managed repo",
+ repo: utils.SPtr("non-existing-repo"),
+ commit: utils.SPtr("test-commit"),
+ linkURL: utils.SPtr("https://argo"),
+ status: utils.SPtr("error"),
+ message: utils.SPtr(""),
+ wantedError: errors.New("some error"),
+ },
+ {
+ name: "Non existing commit",
+ repo: utils.SPtr("test-repo1"),
+ commit: utils.SPtr("not-exists"),
+ linkURL: utils.SPtr("https://argo"),
+ status: utils.SPtr("error"),
+ message: utils.SPtr(""),
+ wantedError: errors.New("some error"),
+ },
+ }
+ // Run test cases
+ for _, test := range tests {
+ t.Run(test.name, func(t *testing.T) {
+
+ // Call the function being tested
+ err := c.SetStatus(&ctx, test.repo, test.commit, test.linkURL, test.status, test.message)
+
+ // Use assert to check the equality of the error
+ if test.wantedError != nil {
+ assert.Error(err)
+ assert.NotNil(err)
+ } else {
+ assert.NoError(err)
+ assert.Nil(err)
+ }
+ })
+ }
+
+}