9f486efbc6
* add gh repo garden * move file * oops * fixes * fix clearing * block windows sadly * broken wip * fix api thing * do not add to client * move helper as it does not work on windows * hide command * macos fix * Update pkg/cmd/repo/garden/garden.go Co-authored-by: Lee Reilly <lee@github.com> * default for key input loop * get redrawing working * clean up garden update, it all works * notes * fix arrow keys and just do wads/arrows/vi * this function is only called once now * support ghes * add a progress indicator * cap maxCommits Co-authored-by: Lee Reilly <lee@github.com>
105 lines
2.1 KiB
Go
105 lines
2.1 KiB
Go
package garden
|
|
|
|
import (
|
|
"encoding/json"
|
|
"errors"
|
|
"fmt"
|
|
"io/ioutil"
|
|
"net/http"
|
|
"strings"
|
|
"time"
|
|
|
|
"github.com/cli/cli/internal/ghinstance"
|
|
"github.com/cli/cli/internal/ghrepo"
|
|
)
|
|
|
|
func getCommits(client *http.Client, repo ghrepo.Interface, maxCommits int) ([]*Commit, error) {
|
|
type Item struct {
|
|
Author struct {
|
|
Login string
|
|
}
|
|
Sha string
|
|
}
|
|
|
|
type Result []Item
|
|
|
|
commits := []*Commit{}
|
|
|
|
pathF := func(page int) string {
|
|
return fmt.Sprintf("repos/%s/%s/commits?per_page=100&page=%d", repo.RepoOwner(), repo.RepoName(), page)
|
|
}
|
|
|
|
page := 1
|
|
paginating := true
|
|
for paginating {
|
|
if len(commits) >= maxCommits {
|
|
break
|
|
}
|
|
result := Result{}
|
|
resp, err := getResponse(client, pathF(page), &result)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
for _, r := range result {
|
|
colorFunc := shaToColorFunc(r.Sha)
|
|
handle := r.Author.Login
|
|
if handle == "" {
|
|
handle = "a mysterious stranger"
|
|
}
|
|
commits = append(commits, &Commit{
|
|
Handle: handle,
|
|
Sha: r.Sha,
|
|
Char: colorFunc(string(handle[0])),
|
|
})
|
|
}
|
|
link := resp.Header["Link"]
|
|
if !strings.Contains(link[0], "last") {
|
|
paginating = false
|
|
}
|
|
page++
|
|
time.Sleep(500)
|
|
}
|
|
|
|
// reverse to get older commits first
|
|
for i, j := 0, len(commits)-1; i < j; i, j = i+1, j-1 {
|
|
commits[i], commits[j] = commits[j], commits[i]
|
|
}
|
|
|
|
return commits, nil
|
|
}
|
|
|
|
func getResponse(client *http.Client, path string, data interface{}) (*http.Response, error) {
|
|
url := ghinstance.RESTPrefix(ghinstance.OverridableDefault()) + path
|
|
req, err := http.NewRequest("GET", url, nil)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
req.Header.Set("Content-Type", "application/json; charset=utf-8")
|
|
resp, err := client.Do(req)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
defer resp.Body.Close()
|
|
|
|
success := resp.StatusCode >= 200 && resp.StatusCode < 300
|
|
if !success {
|
|
return nil, errors.New("api call failed")
|
|
}
|
|
|
|
if resp.StatusCode == http.StatusNoContent {
|
|
return resp, nil
|
|
}
|
|
|
|
b, err := ioutil.ReadAll(resp.Body)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
err = json.Unmarshal(b, &data)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
return resp, nil
|
|
}
|