mirror of
https://github.com/gabrie30/ghorg.git
synced 2025-08-10 08:17:10 +02:00
1bbafc7285
Bumps [github.com/ktrysmt/go-bitbucket](https://github.com/ktrysmt/go-bitbucket) from 0.9.55 to 0.9.56. - [Release notes](https://github.com/ktrysmt/go-bitbucket/releases) - [Commits](https://github.com/ktrysmt/go-bitbucket/compare/v0.9.55...v0.9.56) --- updated-dependencies: - dependency-name: github.com/ktrysmt/go-bitbucket dependency-type: direct:production update-type: version-update:semver-patch ... Signed-off-by: dependabot[bot] <support@github.com> Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
116 lines
2.7 KiB
Go
116 lines
2.7 KiB
Go
package bitbucket
|
|
|
|
import (
|
|
"fmt"
|
|
"io/ioutil"
|
|
"net/url"
|
|
)
|
|
|
|
type Pipelines struct {
|
|
c *Client
|
|
}
|
|
|
|
func (p *Pipelines) List(po *PipelinesOptions) (interface{}, error) {
|
|
urlStr := p.c.requestUrl("/repositories/%s/%s/pipelines/", po.Owner, po.RepoSlug)
|
|
|
|
if po.Query != "" {
|
|
parsed, err := url.Parse(urlStr)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
query := parsed.Query()
|
|
query.Set("q", po.Query)
|
|
parsed.RawQuery = query.Encode()
|
|
urlStr = parsed.String()
|
|
}
|
|
|
|
if po.Sort != "" {
|
|
parsed, err := url.Parse(urlStr)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
query := parsed.Query()
|
|
query.Set("sort", po.Sort)
|
|
parsed.RawQuery = query.Encode()
|
|
urlStr = parsed.String()
|
|
}
|
|
|
|
if po.Page != 0 {
|
|
parsed, err := url.Parse(urlStr)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
query := parsed.Query()
|
|
query.Set("page", fmt.Sprint(po.Page))
|
|
parsed.RawQuery = query.Encode()
|
|
urlStr = parsed.String()
|
|
}
|
|
|
|
return p.c.executePaginated("GET", urlStr, "", nil)
|
|
}
|
|
|
|
func (p *Pipelines) Get(po *PipelinesOptions) (interface{}, error) {
|
|
urlStr := p.c.requestUrl("/repositories/%s/%s/pipelines/%s", po.Owner, po.RepoSlug, po.IDOrUuid)
|
|
return p.c.execute("GET", urlStr, "")
|
|
}
|
|
|
|
func (p *Pipelines) ListSteps(po *PipelinesOptions) (interface{}, error) {
|
|
urlStr := p.c.requestUrl("/repositories/%s/%s/pipelines/%s/steps/", po.Owner, po.RepoSlug, po.IDOrUuid)
|
|
|
|
if po.Query != "" {
|
|
parsed, err := url.Parse(urlStr)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
query := parsed.Query()
|
|
query.Set("q", po.Query)
|
|
parsed.RawQuery = query.Encode()
|
|
urlStr = parsed.String()
|
|
}
|
|
|
|
if po.Sort != "" {
|
|
parsed, err := url.Parse(urlStr)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
query := parsed.Query()
|
|
query.Set("sort", po.Sort)
|
|
parsed.RawQuery = query.Encode()
|
|
urlStr = parsed.String()
|
|
}
|
|
|
|
if po.Page != 0 {
|
|
parsed, err := url.Parse(urlStr)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
query := parsed.Query()
|
|
query.Set("page", fmt.Sprint(po.Page))
|
|
parsed.RawQuery = query.Encode()
|
|
urlStr = parsed.String()
|
|
}
|
|
|
|
return p.c.executePaginated("GET", urlStr, "", nil)
|
|
}
|
|
|
|
func (p *Pipelines) GetStep(po *PipelinesOptions) (interface{}, error) {
|
|
urlStr := p.c.requestUrl("/repositories/%s/%s/pipelines/%s/steps/%s", po.Owner, po.RepoSlug, po.IDOrUuid, po.StepUuid)
|
|
return p.c.execute("GET", urlStr, "")
|
|
}
|
|
|
|
func (p *Pipelines) GetLog(po *PipelinesOptions) (string, error) {
|
|
urlStr := p.c.requestUrl("/repositories/%s/%s/pipelines/%s/steps/%s/log", po.Owner, po.RepoSlug, po.IDOrUuid, po.StepUuid)
|
|
responseBody, err := p.c.executeRaw("GET", urlStr, "")
|
|
if err != nil {
|
|
return "", err
|
|
}
|
|
defer responseBody.Close()
|
|
|
|
rawBody, err := ioutil.ReadAll(responseBody)
|
|
if err != nil {
|
|
return "", err
|
|
}
|
|
|
|
return string(rawBody), nil
|
|
}
|