143 lines
2.9 KiB
Go
143 lines
2.9 KiB
Go
package cli
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
"os"
|
|
"regexp"
|
|
"sort"
|
|
"sync"
|
|
"text/tabwriter"
|
|
"time"
|
|
|
|
"github.com/google/go-github/v55/github"
|
|
"github.com/sourcegraph/conc/pool"
|
|
"github.com/spf13/cast"
|
|
"github.com/urfave/cli/v2"
|
|
)
|
|
|
|
const maxPoolGoroutine = 8
|
|
|
|
var reGitHub = regexp.MustCompile(`github\.com/([^/]*)/([^/]*)`)
|
|
|
|
type GitHubRepoData struct {
|
|
LastCommitAt time.Time
|
|
Name string
|
|
StarCount int
|
|
}
|
|
|
|
func (a *action) Overlook(c *cli.Context) error {
|
|
// Optional
|
|
if a.ghClient == nil {
|
|
return nil
|
|
}
|
|
|
|
a.getFlags(c)
|
|
|
|
mapImportedModules, err := a.runGetImportedModules(c)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
if len(mapImportedModules) == 0 {
|
|
return nil
|
|
}
|
|
|
|
listGHRepoData := make([]GitHubRepoData, 0, len(mapImportedModules))
|
|
// To avoid duplicate
|
|
mGHRepoData := make(map[string]struct{})
|
|
|
|
p := pool.New().WithMaxGoroutines(maxPoolGoroutine)
|
|
var mMutex sync.Mutex
|
|
var listMutex sync.Mutex
|
|
for module := range mapImportedModules {
|
|
module := module
|
|
p.Go(func() {
|
|
ctx := context.Background()
|
|
|
|
if !reGitHub.MatchString(module) {
|
|
return
|
|
}
|
|
|
|
parts := reGitHub.FindStringSubmatch(module)
|
|
if len(parts) != 3 {
|
|
return
|
|
}
|
|
|
|
name := parts[0]
|
|
mMutex.Lock()
|
|
if _, ok := mGHRepoData[name]; ok {
|
|
mMutex.Unlock()
|
|
return
|
|
}
|
|
mGHRepoData[name] = struct{}{}
|
|
mMutex.Unlock()
|
|
|
|
owner := parts[1]
|
|
repo := parts[2]
|
|
|
|
ghRepo, _, err := a.ghClient.Repositories.Get(ctx, owner, repo)
|
|
if err != nil {
|
|
a.log("GitHub failed to get repo %s/%s: %s\n", owner, repo, err)
|
|
}
|
|
|
|
var starCount int
|
|
if ghRepo.StargazersCount != nil {
|
|
starCount = *ghRepo.StargazersCount
|
|
}
|
|
|
|
ghCommits, _, err := a.ghClient.Repositories.ListCommits(ctx, owner, repo, &github.CommitsListOptions{
|
|
ListOptions: github.ListOptions{
|
|
Page: 1,
|
|
PerPage: 1,
|
|
},
|
|
})
|
|
if err != nil {
|
|
a.log("GitHub failed to get commits %s/%s: %s\n", owner, repo, err)
|
|
}
|
|
|
|
var lastCommitAt time.Time
|
|
if len(ghCommits) != 0 {
|
|
if ghCommits[0].Commit != nil &&
|
|
ghCommits[0].Commit.Author != nil &&
|
|
ghCommits[0].Commit.Author.Date != nil {
|
|
lastCommitAt = ghCommits[0].Commit.Author.Date.Time
|
|
}
|
|
}
|
|
|
|
listMutex.Lock()
|
|
listGHRepoData = append(listGHRepoData, GitHubRepoData{
|
|
LastCommitAt: lastCommitAt,
|
|
Name: name,
|
|
StarCount: starCount,
|
|
})
|
|
listMutex.Unlock()
|
|
})
|
|
}
|
|
p.Wait()
|
|
|
|
// Sort for consistency
|
|
sort.Slice(listGHRepoData, func(i, j int) bool {
|
|
return listGHRepoData[i].Name < listGHRepoData[j].Name
|
|
})
|
|
|
|
// Print
|
|
w := tabwriter.NewWriter(os.Stdout, 0, 0, 2, ' ', 0)
|
|
for _, r := range listGHRepoData {
|
|
fmt.Fprintf(w, "Module %s\t%s\t⭐\tLast commit %s\n", r.Name, roundK(r.StarCount), r.LastCommitAt.Format(time.DateOnly))
|
|
}
|
|
w.Flush()
|
|
|
|
return nil
|
|
}
|
|
|
|
// Nearest thounsand
|
|
// 1234 -> 1K
|
|
func roundK(v int) string {
|
|
if v < 1000 {
|
|
return cast.ToString(v)
|
|
}
|
|
|
|
return fmt.Sprintf("%dK", v/1000)
|
|
}
|