|
|
|
|
|
|
|
|
repo = new(Repository) |
|
|
repo = new(Repository) |
|
|
has, err := sess.ID(release.RepoID).Get(repo) |
|
|
has, err := sess.ID(release.RepoID).Get(repo) |
|
|
if err != nil { |
|
|
if err != nil { |
|
|
log.Error("Error whilst loading repository[%d] for release[%d] with tag name %s", release.RepoID, release.ID, release.TagName) |
|
|
|
|
|
|
|
|
log.Error("Error whilst loading repository[%d] for release[%d] with tag name %s. Error: %v", release.RepoID, release.ID, release.TagName, err) |
|
|
return err |
|
|
return err |
|
|
} else if !has { |
|
|
} else if !has { |
|
|
log.Warn("Release[%d] is orphaned and refers to non-existing repository %d", release.ID, release.RepoID) |
|
|
log.Warn("Release[%d] is orphaned and refers to non-existing repository %d", release.ID, release.RepoID) |
|
|
|
|
|
|
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
if _, err := sess.ID(release.RepoID).Get(repo); err != nil { |
|
|
if _, err := sess.ID(release.RepoID).Get(repo); err != nil { |
|
|
log.Error("Error whilst loading repository[%d] for release[%d] with tag name %s", release.RepoID, release.ID, release.TagName) |
|
|
|
|
|
|
|
|
log.Error("Error whilst loading repository[%d] for release[%d] with tag name %s. Error: %v", release.RepoID, release.ID, release.TagName, err) |
|
|
return err |
|
|
return err |
|
|
} |
|
|
} |
|
|
} |
|
|
} |
|
|
gitRepo, err = git.OpenRepository(repoPath(repo.OwnerName, repo.Name)) |
|
|
gitRepo, err = git.OpenRepository(repoPath(repo.OwnerName, repo.Name)) |
|
|
if err != nil { |
|
|
if err != nil { |
|
|
log.Error("Error whilst opening git repo for %-v", repo) |
|
|
|
|
|
|
|
|
log.Error("Error whilst opening git repo for [%d]%s/%s. Error: %v", repo.ID, repo.OwnerName, repo.Name, err) |
|
|
return err |
|
|
return err |
|
|
} |
|
|
} |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
commit, err := gitRepo.GetTagCommit(release.TagName) |
|
|
commit, err := gitRepo.GetTagCommit(release.TagName) |
|
|
if err != nil { |
|
|
if err != nil { |
|
|
if git.IsErrNotExist(err) { |
|
|
if git.IsErrNotExist(err) { |
|
|
log.Warn("Unable to find commit %s for Tag: %s in %-v. Cannot update publisher ID.", err.(git.ErrNotExist).ID, release.TagName, repo) |
|
|
|
|
|
|
|
|
log.Warn("Unable to find commit %s for Tag: %s in [%d]%s/%s. Cannot update publisher ID.", err.(git.ErrNotExist).ID, release.TagName, repo.ID, repo.OwnerName, repo.Name) |
|
|
continue |
|
|
continue |
|
|
} |
|
|
} |
|
|
log.Error("Error whilst getting commit for Tag: %s in %-v.", release.TagName, repo) |
|
|
|
|
|
|
|
|
log.Error("Error whilst getting commit for Tag: %s in [%d]%s/%s. Error: %v", release.TagName, repo.ID, repo.OwnerName, repo.Name, err) |
|
|
return fmt.Errorf("GetTagCommit: %v", err) |
|
|
return fmt.Errorf("GetTagCommit: %v", err) |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
if commit.Author.Email == "" { |
|
|
|
|
|
log.Warn("Tag: %s in Repo[%d]%s/%s does not have a tagger.", release.TagName, repo.ID, repo.OwnerName, repo.Name) |
|
|
|
|
|
commit, err = gitRepo.GetCommit(commit.ID.String()) |
|
|
|
|
|
if err != nil { |
|
|
|
|
|
if git.IsErrNotExist(err) { |
|
|
|
|
|
log.Warn("Unable to find commit %s for Tag: %s in [%d]%s/%s. Cannot update publisher ID.", err.(git.ErrNotExist).ID, release.TagName, repo.ID, repo.OwnerName, repo.Name) |
|
|
|
|
|
continue |
|
|
|
|
|
} |
|
|
|
|
|
log.Error("Error whilst getting commit for Tag: %s in [%d]%s/%s. Error: %v", release.TagName, repo.ID, repo.OwnerName, repo.Name, err) |
|
|
|
|
|
return fmt.Errorf("GetCommit: %v", err) |
|
|
|
|
|
} |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
if commit.Author.Email == "" { |
|
|
|
|
|
log.Warn("Tag: %s in Repo[%d]%s/%s does not have a Tagger and its underlying commit does not have an Author either!", release.TagName, repo.ID, repo.OwnerName, repo.Name) |
|
|
|
|
|
continue |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
if user == nil || !strings.EqualFold(user.Email, commit.Author.Email) { |
|
|
if user == nil || !strings.EqualFold(user.Email, commit.Author.Email) { |
|
|
user = new(User) |
|
|
user = new(User) |
|
|
_, err = sess.Where("email=?", commit.Author.Email).Get(user) |
|
|
_, err = sess.Where("email=?", commit.Author.Email).Get(user) |
|
|
if err != nil { |
|
|
if err != nil { |
|
|
log.Error("Error whilst getting commit author by email: %s for Tag: %s in %-v.", commit.Author.Email, release.TagName, repo) |
|
|
|
|
|
|
|
|
log.Error("Error whilst getting commit author by email: %s for Tag: %s in [%d]%s/%s. Error: %v", commit.Author.Email, release.TagName, repo.ID, repo.OwnerName, repo.Name, err) |
|
|
return err |
|
|
return err |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
release.PublisherID = user.ID |
|
|
release.PublisherID = user.ID |
|
|
if _, err := sess.ID(release.ID).Cols("publisher_id").Update(release); err != nil { |
|
|
if _, err := sess.ID(release.ID).Cols("publisher_id").Update(release); err != nil { |
|
|
log.Error("Error whilst updating publisher[%d] for release[%d] with tag name %s", release.PublisherID, release.ID, release.TagName) |
|
|
|
|
|
|
|
|
log.Error("Error whilst updating publisher[%d] for release[%d] with tag name %s. Error: %v", release.PublisherID, release.ID, release.TagName, err) |
|
|
return err |
|
|
return err |
|
|
} |
|
|
} |
|
|
} |
|
|
} |