| 104 | } |
| 105 | |
| 106 | func (s searcher) Commits(query Query) (CommitsResult, error) { |
| 107 | result := CommitsResult{} |
| 108 | |
| 109 | numItemsToRetrieve := query.Limit |
| 110 | query.Limit = min(numItemsToRetrieve, maxPerPage) |
| 111 | query.Page = 1 |
| 112 | |
| 113 | for numItemsToRetrieve > 0 { |
| 114 | page := CommitsResult{} |
| 115 | link, err := s.search(query, &page) |
| 116 | if err != nil { |
| 117 | return result, err |
| 118 | } |
| 119 | |
| 120 | numItemsToAdd := min(len(page.Items), numItemsToRetrieve) |
| 121 | result.IncompleteResults = page.IncompleteResults |
| 122 | result.Total = page.Total |
| 123 | result.Items = append(result.Items, page.Items[:numItemsToAdd]...) |
| 124 | numItemsToRetrieve = numItemsToRetrieve - numItemsToAdd |
| 125 | |
| 126 | query.Page = nextPage(link) |
| 127 | if query.Page == 0 { |
| 128 | break |
| 129 | } |
| 130 | } |
| 131 | return result, nil |
| 132 | } |
| 133 | |
| 134 | func (s searcher) Repositories(query Query) (RepositoriesResult, error) { |
| 135 | result := RepositoriesResult{} |