localhots
/
empact
1
0
Fork 0
Code Releases Activity

Update contrib model

This commit is contained in:
Gregory Eremin 2015-03-20 18:48:42 +07:00
parent f01da56147
commit ede2707070
2 changed files with 14 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
db/contrib.go
View File

@ -6,21 +6,20 @@ import (
type Contrib struct {
Week uint64 `json:"week"`
Author string `json:"author"`
Owner string `json:"owner"`
Repo string `json:"repo"`
OrgID uint64 `json:"org_id"`
RepoID uint64 `json:"repo_id"`
UserID uint64 `json:"user_id"`
Commits uint64 `json:"commits"`
Additions uint64 `json:"additions"`
Deletions uint64 `json:"deletions"`
}
const saveContribQuery = `
insert into contribs (week, author, owner, repo, commits, additions, deletions)
values (:week, :author, :owner, :repo, :commits, :additions, :deletions)
on duplicate key update
commits=values(commits), additions=values(additions), deletions=values(deletions)`
func (c *Contrib) Save() {
defer measure("SaveContrib", time.Now())
mustExecN(saveContribQuery, c)
mustExecN(`
insert into contribs (week, org_id, repo_id, user_id, commits, additions, deletions)
values (:week, :org_id, :repo_id, :user_id, :commits, :additions, :deletions)
on duplicate key update
commits=values(commits), additions=values(additions), deletions=values(deletions)
`, c)
}

10
task/sync.go
View File

@ -39,11 +39,11 @@ func SyncRepos(token, owner string) {
}
}
func SyncContrib(token, owner, repo string) {
func SyncContrib(token, owner string, repo *db.Repo) {
defer report("SyncContrib", time.Now())
client := newGithubClient(token)
contribs, resp, err := client.Repositories.ListContributorsStats(owner, repo)
contribs, resp, err := client.Repositories.ListContributorsStats(owner, repo.Name)
saveResponseMeta(token, resp)
if err != nil {
if err.Error() == "EOF" {
@ -60,9 +60,9 @@ func SyncContrib(token, owner, repo string) {
c := &db.Contrib{
Week: uint64(week.Week.Time.Unix()),
Author: *contrib.Author.Login,
Owner: owner,
Repo: repo,
OrgID: repo.OrgID,
RepoID: repo.ID,
UserID: uint64(*contrib.Author.ID),
Commits: uint64(*week.Commits),
Additions: uint64(*week.Additions),
Deletions: uint64(*week.Deletions),