123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498 |
- package models
- import (
- "container/list"
- "fmt"
- "net/url"
- "strings"
- "time"
- "github.com/Unknwon/com"
- "github.com/go-xorm/xorm"
- log "gopkg.in/clog.v1"
- "gopkg.in/ini.v1"
- "github.com/gogs/git-module"
- "github.com/gogs/gogs/models/errors"
- "github.com/gogs/gogs/pkg/process"
- "github.com/gogs/gogs/pkg/setting"
- "github.com/gogs/gogs/pkg/sync"
- )
- var MirrorQueue = sync.NewUniqueQueue(setting.Repository.MirrorQueueLength)
- type Mirror struct {
- ID int64
- RepoID int64
- Repo *Repository `xorm:"-" json:"-"`
- Interval int
- EnablePrune bool `xorm:"NOT NULL DEFAULT true"`
-
- LastSync time.Time `xorm:"-" json:"-"`
- LastSyncUnix int64 `xorm:"updated_unix"`
- NextSync time.Time `xorm:"-" json:"-"`
- NextSyncUnix int64 `xorm:"next_update_unix"`
- address string `xorm:"-" json:"-"`
- }
- func (m *Mirror) BeforeInsert() {
- m.NextSyncUnix = m.NextSync.Unix()
- }
- func (m *Mirror) BeforeUpdate() {
- m.LastSyncUnix = m.LastSync.Unix()
- m.NextSyncUnix = m.NextSync.Unix()
- }
- func (m *Mirror) AfterSet(colName string, _ xorm.Cell) {
- var err error
- switch colName {
- case "repo_id":
- m.Repo, err = GetRepositoryByID(m.RepoID)
- if err != nil {
- log.Error(3, "GetRepositoryByID [%d]: %v", m.ID, err)
- }
- case "updated_unix":
- m.LastSync = time.Unix(m.LastSyncUnix, 0).Local()
- case "next_update_unix":
- m.NextSync = time.Unix(m.NextSyncUnix, 0).Local()
- }
- }
- func (m *Mirror) ScheduleNextSync() {
- m.NextSync = time.Now().Add(time.Duration(m.Interval) * time.Hour)
- }
- func findPasswordInMirrorAddress(addr string) (start int, end int, found bool) {
-
- end = strings.LastIndex(addr, "@")
- if end == -1 {
- return -1, -1, false
- }
-
- start = strings.Index(addr, "://")
- if start == -1 {
- return -1, -1, false
- }
- start += 3
- delim := strings.Index(addr[start:], ":")
- if delim == -1 {
- return -1, -1, false
- }
- delim += 1
- if start+delim >= end {
- return -1, -1, false
- }
- return start + delim, end, true
- }
- func unescapeMirrorCredentials(addr string) string {
- start, end, found := findPasswordInMirrorAddress(addr)
- if !found {
- return addr
- }
- password, _ := url.QueryUnescape(addr[start:end])
- return addr[:start] + password + addr[end:]
- }
- func (m *Mirror) readAddress() {
- if len(m.address) > 0 {
- return
- }
- cfg, err := ini.Load(m.Repo.GitConfigPath())
- if err != nil {
- log.Error(2, "Load: %v", err)
- return
- }
- m.address = cfg.Section("remote \"origin\"").Key("url").Value()
- }
- func HandleMirrorCredentials(url string, mosaics bool) string {
- i := strings.Index(url, "@")
- if i == -1 {
- return url
- }
- start := strings.Index(url, "://")
- if start == -1 {
- return url
- }
- if mosaics {
- return url[:start+3] + "<credentials>" + url[i:]
- }
- return url[:start+3] + url[i+1:]
- }
- func (m *Mirror) Address() string {
- m.readAddress()
- return HandleMirrorCredentials(m.address, false)
- }
- func (m *Mirror) MosaicsAddress() string {
- m.readAddress()
- return HandleMirrorCredentials(m.address, true)
- }
- func (m *Mirror) RawAddress() string {
- m.readAddress()
- return m.address
- }
- func (m *Mirror) FullAddress() string {
- m.readAddress()
- return unescapeMirrorCredentials(m.address)
- }
- func escapeMirrorCredentials(addr string) string {
- start, end, found := findPasswordInMirrorAddress(addr)
- if !found {
- return addr
- }
- return addr[:start] + url.QueryEscape(addr[start:end]) + addr[end:]
- }
- func (m *Mirror) SaveAddress(addr string) error {
- configPath := m.Repo.GitConfigPath()
- cfg, err := ini.Load(configPath)
- if err != nil {
- return fmt.Errorf("Load: %v", err)
- }
- cfg.Section(`remote "origin"`).Key("url").SetValue(escapeMirrorCredentials(addr))
- return cfg.SaveToIndent(configPath, "\t")
- }
- const GIT_SHORT_EMPTY_SHA = "0000000"
- type mirrorSyncResult struct {
- refName string
- oldCommitID string
- newCommitID string
- }
- func parseRemoteUpdateOutput(output string) []*mirrorSyncResult {
- results := make([]*mirrorSyncResult, 0, 3)
- lines := strings.Split(output, "\n")
- for i := range lines {
-
- idx := strings.Index(lines[i], "-> ")
- if idx == -1 {
- continue
- }
- refName := lines[i][idx+3:]
- switch {
- case strings.HasPrefix(lines[i], " * "):
- results = append(results, &mirrorSyncResult{
- refName: refName,
- oldCommitID: GIT_SHORT_EMPTY_SHA,
- })
- case strings.HasPrefix(lines[i], " - "):
- results = append(results, &mirrorSyncResult{
- refName: refName,
- newCommitID: GIT_SHORT_EMPTY_SHA,
- })
- case strings.HasPrefix(lines[i], " "):
- delimIdx := strings.Index(lines[i][3:], " ")
- if delimIdx == -1 {
- log.Error(2, "SHA delimiter not found: %q", lines[i])
- continue
- }
- shas := strings.Split(lines[i][3:delimIdx+3], "..")
- if len(shas) != 2 {
- log.Error(2, "Expect two SHAs but not what found: %q", lines[i])
- continue
- }
- results = append(results, &mirrorSyncResult{
- refName: refName,
- oldCommitID: shas[0],
- newCommitID: shas[1],
- })
- default:
- log.Warn("parseRemoteUpdateOutput: unexpected update line %q", lines[i])
- }
- }
- return results
- }
- func (m *Mirror) runSync() ([]*mirrorSyncResult, bool) {
- repoPath := m.Repo.RepoPath()
- wikiPath := m.Repo.WikiPath()
- timeout := time.Duration(setting.Git.Timeout.Mirror) * time.Second
-
-
- if !git.IsRepoURLAccessible(git.NetworkOptions{
- URL: m.RawAddress(),
- Timeout: 10 * time.Second,
- }) {
- desc := fmt.Sprintf("Source URL of mirror repository '%s' is not accessible: %s", m.Repo.FullName(), m.MosaicsAddress())
- if err := CreateRepositoryNotice(desc); err != nil {
- log.Error(2, "CreateRepositoryNotice: %v", err)
- }
- return nil, false
- }
- gitArgs := []string{"remote", "update"}
- if m.EnablePrune {
- gitArgs = append(gitArgs, "--prune")
- }
- _, stderr, err := process.ExecDir(
- timeout, repoPath, fmt.Sprintf("Mirror.runSync: %s", repoPath),
- "git", gitArgs...)
- if err != nil {
- desc := fmt.Sprintf("Fail to update mirror repository '%s': %s", repoPath, stderr)
- log.Error(2, desc)
- if err = CreateRepositoryNotice(desc); err != nil {
- log.Error(2, "CreateRepositoryNotice: %v", err)
- }
- return nil, false
- }
- output := stderr
- if err := m.Repo.UpdateSize(); err != nil {
- log.Error(2, "UpdateSize [repo_id: %d]: %v", m.Repo.ID, err)
- }
- if m.Repo.HasWiki() {
-
- if _, stderr, err := process.ExecDir(
- timeout, wikiPath, fmt.Sprintf("Mirror.runSync: %s", wikiPath),
- "git", "remote", "update", "--prune"); err != nil {
- desc := fmt.Sprintf("Fail to update mirror wiki repository '%s': %s", wikiPath, stderr)
- log.Error(2, desc)
- if err = CreateRepositoryNotice(desc); err != nil {
- log.Error(2, "CreateRepositoryNotice: %v", err)
- }
- }
- }
- return parseRemoteUpdateOutput(output), true
- }
- func getMirrorByRepoID(e Engine, repoID int64) (*Mirror, error) {
- m := &Mirror{RepoID: repoID}
- has, err := e.Get(m)
- if err != nil {
- return nil, err
- } else if !has {
- return nil, errors.MirrorNotExist{repoID}
- }
- return m, nil
- }
- func GetMirrorByRepoID(repoID int64) (*Mirror, error) {
- return getMirrorByRepoID(x, repoID)
- }
- func updateMirror(e Engine, m *Mirror) error {
- _, err := e.ID(m.ID).AllCols().Update(m)
- return err
- }
- func UpdateMirror(m *Mirror) error {
- return updateMirror(x, m)
- }
- func DeleteMirrorByRepoID(repoID int64) error {
- _, err := x.Delete(&Mirror{RepoID: repoID})
- return err
- }
- func MirrorUpdate() {
- if taskStatusTable.IsRunning(_MIRROR_UPDATE) {
- return
- }
- taskStatusTable.Start(_MIRROR_UPDATE)
- defer taskStatusTable.Stop(_MIRROR_UPDATE)
- log.Trace("Doing: MirrorUpdate")
- if err := x.Where("next_update_unix<=?", time.Now().Unix()).Iterate(new(Mirror), func(idx int, bean interface{}) error {
- m := bean.(*Mirror)
- if m.Repo == nil {
- log.Error(2, "Disconnected mirror repository found: %d", m.ID)
- return nil
- }
- MirrorQueue.Add(m.RepoID)
- return nil
- }); err != nil {
- log.Error(2, "MirrorUpdate: %v", err)
- }
- }
- func SyncMirrors() {
-
- for repoID := range MirrorQueue.Queue() {
- log.Trace("SyncMirrors [repo_id: %s]", repoID)
- MirrorQueue.Remove(repoID)
- m, err := GetMirrorByRepoID(com.StrTo(repoID).MustInt64())
- if err != nil {
- log.Error(2, "GetMirrorByRepoID [%d]: %v", m.RepoID, err)
- continue
- }
- results, ok := m.runSync()
- if !ok {
- continue
- }
- m.ScheduleNextSync()
- if err = UpdateMirror(m); err != nil {
- log.Error(2, "UpdateMirror [%d]: %v", m.RepoID, err)
- continue
- }
-
-
-
- var gitRepo *git.Repository
- if len(results) == 0 {
- log.Trace("SyncMirrors [repo_id: %d]: no commits fetched", m.RepoID)
- } else {
- gitRepo, err = git.OpenRepository(m.Repo.RepoPath())
- if err != nil {
- log.Error(2, "OpenRepository [%d]: %v", m.RepoID, err)
- continue
- }
- }
- for _, result := range results {
-
- if strings.HasPrefix(result.refName, "refs/pull/") {
- continue
- }
-
- if result.newCommitID == GIT_SHORT_EMPTY_SHA {
- if err = MirrorSyncDeleteAction(m.Repo, result.refName); err != nil {
- log.Error(2, "MirrorSyncDeleteAction [repo_id: %d]: %v", m.RepoID, err)
- }
- continue
- }
-
- isNewRef := false
- if result.oldCommitID == GIT_SHORT_EMPTY_SHA {
- if err = MirrorSyncCreateAction(m.Repo, result.refName); err != nil {
- log.Error(2, "MirrorSyncCreateAction [repo_id: %d]: %v", m.RepoID, err)
- continue
- }
- isNewRef = true
- }
-
- var commits *list.List
- var oldCommitID string
- var newCommitID string
- if !isNewRef {
- oldCommitID, err = git.GetFullCommitID(gitRepo.Path, result.oldCommitID)
- if err != nil {
- log.Error(2, "GetFullCommitID [%d]: %v", m.RepoID, err)
- continue
- }
- newCommitID, err = git.GetFullCommitID(gitRepo.Path, result.newCommitID)
- if err != nil {
- log.Error(2, "GetFullCommitID [%d]: %v", m.RepoID, err)
- continue
- }
- commits, err = gitRepo.CommitsBetweenIDs(newCommitID, oldCommitID)
- if err != nil {
- log.Error(2, "CommitsBetweenIDs [repo_id: %d, new_commit_id: %s, old_commit_id: %s]: %v", m.RepoID, newCommitID, oldCommitID, err)
- continue
- }
- } else {
- refNewCommitID, err := gitRepo.GetBranchCommitID(result.refName)
- if err != nil {
- log.Error(2, "GetFullCommitID [%d]: %v", m.RepoID, err)
- continue
- }
- if newCommit, err := gitRepo.GetCommit(refNewCommitID); err != nil {
- log.Error(2, "GetCommit [repo_id: %d, commit_id: %s]: %v", m.RepoID, refNewCommitID, err)
- continue
- } else {
-
- commits, err = newCommit.CommitsBeforeLimit(10)
- if err != nil {
- log.Error(2, "CommitsBeforeLimit [repo_id: %d, commit_id: %s]: %v", m.RepoID, refNewCommitID, err)
- }
- oldCommitID = git.EMPTY_SHA
- newCommitID = refNewCommitID
- }
- }
- if err = MirrorSyncPushAction(m.Repo, MirrorSyncPushActionOptions{
- RefName: result.refName,
- OldCommitID: oldCommitID,
- NewCommitID: newCommitID,
- Commits: ListToPushCommits(commits),
- }); err != nil {
- log.Error(2, "MirrorSyncPushAction [repo_id: %d]: %v", m.RepoID, err)
- continue
- }
- }
- if _, err = x.Exec("UPDATE mirror SET updated_unix = ? WHERE repo_id = ?", time.Now().Unix(), m.RepoID); err != nil {
- log.Error(2, "Update 'mirror.updated_unix' [%d]: %v", m.RepoID, err)
- continue
- }
-
-
- commitDate, err := git.GetLatestCommitDate(m.Repo.RepoPath(), "")
- if err != nil {
- log.Error(2, "GetLatestCommitDate [%d]: %v", m.RepoID, err)
- continue
- } else if commitDate.Before(m.Repo.Updated) {
- continue
- }
- if _, err = x.Exec("UPDATE repository SET updated_unix = ? WHERE id = ?", commitDate.Unix(), m.RepoID); err != nil {
- log.Error(2, "Update 'repository.updated_unix' [%d]: %v", m.RepoID, err)
- continue
- }
- }
- }
- func InitSyncMirrors() {
- go SyncMirrors()
- }
|