mirror of
https://github.com/gabrie30/ghorg.git
synced 2025-08-09 15:57:09 +02:00
f5f10e7d22
* add `make fmt` to format go code * use interface * move all SCM things into scm package
90 lines
2.1 KiB
Go
90 lines
2.1 KiB
Go
package scm
|
|
|
|
import (
|
|
"os"
|
|
"strings"
|
|
|
|
"github.com/ktrysmt/go-bitbucket"
|
|
)
|
|
|
|
var (
|
|
_ Client = Bitbucket{}
|
|
)
|
|
|
|
func init() {
|
|
registerClient(Bitbucket{})
|
|
}
|
|
|
|
type Bitbucket struct{}
|
|
|
|
func (_ Bitbucket) GetType() string {
|
|
return "bitbucket"
|
|
}
|
|
|
|
// GetOrgRepos gets org repos
|
|
func (c Bitbucket) GetOrgRepos(targetOrg string) ([]Repo, error) {
|
|
|
|
client := bitbucket.NewBasicAuth(os.Getenv("GHORG_BITBUCKET_USERNAME"), os.Getenv("GHORG_BITBUCKET_APP_PASSWORD"))
|
|
|
|
resp, err := client.Teams.Repositories(targetOrg)
|
|
if err != nil {
|
|
return []Repo{}, err
|
|
}
|
|
|
|
return c.filter(resp)
|
|
}
|
|
|
|
// GetUserRepos gets user repos from bitbucket
|
|
func (c Bitbucket) GetUserRepos(targetUser string) ([]Repo, error) {
|
|
|
|
client := bitbucket.NewBasicAuth(os.Getenv("GHORG_BITBUCKET_USERNAME"), os.Getenv("GHORG_BITBUCKET_APP_PASSWORD"))
|
|
|
|
resp, err := client.Users.Repositories(targetUser)
|
|
if err != nil {
|
|
return []Repo{}, err
|
|
}
|
|
|
|
return c.filter(resp)
|
|
}
|
|
|
|
func (_ Bitbucket) filter(resp interface{}) (repoData []Repo, err error) {
|
|
cloneData := []Repo{}
|
|
values := resp.(map[string]interface{})["values"].([]interface{})
|
|
|
|
for _, a := range values {
|
|
clone := a.(map[string]interface{})
|
|
links := clone["links"].(map[string]interface{})["clone"].([]interface{})
|
|
for _, l := range links {
|
|
link := l.(map[string]interface{})["href"]
|
|
linkType := l.(map[string]interface{})["name"]
|
|
|
|
if os.Getenv("GHORG_MATCH_PREFIX") != "" {
|
|
repoName := strings.ToLower(clone["name"].(string))
|
|
foundPrefix := false
|
|
pfs := strings.Split(os.Getenv("GHORG_MATCH_PREFIX"), ",")
|
|
for _, p := range pfs {
|
|
if strings.HasPrefix(repoName, strings.ToLower(p)) {
|
|
foundPrefix = true
|
|
}
|
|
}
|
|
if foundPrefix == false {
|
|
continue
|
|
}
|
|
}
|
|
|
|
r := Repo{}
|
|
if os.Getenv("GHORG_CLONE_PROTOCOL") == "ssh" && linkType == "ssh" {
|
|
r.URL = link.(string)
|
|
r.CloneURL = link.(string)
|
|
cloneData = append(cloneData, r)
|
|
} else if os.Getenv("GHORG_CLONE_PROTOCOL") == "https" && linkType == "https" {
|
|
r.URL = link.(string)
|
|
r.CloneURL = link.(string)
|
|
cloneData = append(cloneData, r)
|
|
}
|
|
}
|
|
}
|
|
|
|
return cloneData, nil
|
|
}
|