From 15f56352982d8120aa6b89ea2fc4a4a7c5979607 Mon Sep 17 00:00:00 2001
From: yiyiyimu <wosoyoung@gmail.com>
Date: Thu, 5 Aug 2021 15:15:41 -0400
Subject: [PATCH] feat: add tool to support pull contributor metadata

Signed-off-by: yiyiyimu <wosoyoung@gmail.com>
---
 api-go/tools/get-contributor-info/main.go | 113 ++++++++++++++++++++++
 1 file changed, 113 insertions(+)
 create mode 100644 api-go/tools/get-contributor-info/main.go

diff --git a/api-go/tools/get-contributor-info/main.go b/api-go/tools/get-contributor-info/main.go
new file mode 100644
index 0000000..95a455e
--- /dev/null
+++ b/api-go/tools/get-contributor-info/main.go
@@ -0,0 +1,113 @@
+package main
+
+import (
+	"context"
+	"encoding/csv"
+	"fmt"
+	"log"
+	"os"
+	"strconv"
+
+	"cloud.google.com/go/datastore"
+	"github.com/api7/contributor-graph/api/internal/gcpdb"
+	"github.com/api7/contributor-graph/api/internal/ghapi"
+	"github.com/api7/contributor-graph/api/internal/utils"
+	"github.com/google/go-github/v33/github"
+)
+
+var repos = []string{"repo"}
+
+func main() {
+	ctx := context.Background()
+	dbCli, err := datastore.NewClient(ctx, utils.ProjectID)
+	if err != nil {
+		panic(err)
+	}
+	defer dbCli.Close()
+
+	tokens, err := gcpdb.GetTokens(dbCli)
+	if err != nil {
+		panic(err)
+	}
+
+	ghCli := ghapi.GetGithubClient(ctx, tokens[0].Token)
+
+	for _, repo := range repos {
+		var res [][]string
+		res = append(res, []string{"id", "name", "email", "contributrions", "compamy", "location", "bio", "github url"})
+
+		fmt.Println(repo)
+		logins, contributions := getTop500Contributors(ghCli, repo)
+		fmt.Printf("get %d contributors\n", len(logins))
+
+		users := getUserMeta(ghCli, logins)
+
+		for i, u := range users {
+			res = append(res, []string{logins[i], u.GetName(), u.GetEmail(), contributions[i], u.GetCompany(), u.GetLocation(), fmt.Sprintf("%q", u.GetBio()), u.GetHTMLURL()})
+		}
+
+		_, repoName, err := ghapi.SplitRepo(repo)
+		if err != nil {
+			panic(err)
+		}
+
+		file, err := os.Create(repoName + "_contributors.csv")
+		if err != nil {
+			panic(err)
+		}
+
+		w := csv.NewWriter(file)
+		for _, r := range res {
+			if err := w.Write(r); err != nil {
+				panic(err)
+			}
+		}
+
+		w.Flush()
+		if err := w.Error(); err != nil {
+			log.Fatal(err)
+		}
+	}
+}
+
+func getTop500Contributors(client *github.Client, repo string) ([]string, []string) {
+	ctx := context.Background()
+	owner, repoName, err := ghapi.SplitRepo(repo)
+	if err != nil {
+		panic(err)
+	}
+
+	listConOpts := &github.ListContributorsOptions{ListOptions: ghapi.ListOpts}
+	var logins, contributions []string
+	for {
+		cons, resp, err := client.Repositories.ListContributors(ctx, owner, repoName, listConOpts)
+		if err != nil {
+			panic(err)
+		}
+		for _, c := range cons {
+			logins = append(logins, c.GetLogin())
+			contributions = append(contributions, strconv.Itoa(c.GetContributions()))
+		}
+		if resp.NextPage == 0 {
+			break
+		}
+		listConOpts.Page = resp.NextPage
+	}
+
+	return logins, contributions
+}
+
+func getUserMeta(client *github.Client, logins []string) []*github.User {
+	ctx := context.Background()
+
+	var users []*github.User
+	for _, l := range logins {
+		user, _, err := client.Users.Get(ctx, l)
+		if err != nil {
+			panic(err)
+		}
+		users = append(users, user)
+	}
+
+	return users
+}