| @@ -24,6 +24,8 class Repository::Mercurial < Repository | |||||
| 24 | attr_protected :root_url |
|
24 | attr_protected :root_url | |
| 25 | validates_presence_of :url |
|
25 | validates_presence_of :url | |
| 26 |
|
26 | |||
|
|
27 | FETCH_AT_ONCE = 100 # number of changesets to fetch at once | |||
|
|
28 | ||||
| 27 | def self.scm_adapter_class |
|
29 | def self.scm_adapter_class | |
| 28 | Redmine::Scm::Adapters::MercurialAdapter |
|
30 | Redmine::Scm::Adapters::MercurialAdapter | |
| 29 | end |
|
31 | end | |
| @@ -94,38 +96,24 class Repository::Mercurial < Repository | |||||
| 94 | end |
|
96 | end | |
| 95 |
|
97 | |||
| 96 | def fetch_changesets |
|
98 | def fetch_changesets | |
| 97 | scm_info = scm.info |
|
99 | scm_rev = scm.info.lastrev.revision.to_i | |
| 98 | if scm_info |
|
100 | db_rev = latest_changeset ? latest_changeset.revision.to_i : -1 | |
| 99 | # latest revision found in database |
|
101 | return unless db_rev < scm_rev # already up-to-date | |
| 100 | db_revision = latest_changeset ? latest_changeset.revision.to_i : -1 |
|
102 | ||
| 101 | # latest revision in the repository |
|
103 | logger.debug "Fetching changesets for repository #{url}" if logger | |
| 102 | latest_revision = scm_info.lastrev |
|
104 | (db_rev + 1).step(scm_rev, FETCH_AT_ONCE) do |i| | |
| 103 | return if latest_revision.nil? |
|
105 | transaction do | |
| 104 | scm_revision = latest_revision.identifier.to_i |
|
106 | scm.each_revision('', i, [i + FETCH_AT_ONCE - 1, scm_rev].min) do |re| | |
| 105 | if db_revision < scm_revision |
|
107 | cs = Changeset.create(:repository => self, | |
| 106 | logger.debug "Fetching changesets for repository #{url}" if logger && logger.debug? |
|
108 | :revision => re.revision, | |
| 107 | identifier_from = db_revision + 1 |
|
109 | :scmid => re.scmid, | |
| 108 | while (identifier_from <= scm_revision) |
|
110 | :committer => re.author, | |
| 109 | # loads changesets by batches of 100 |
|
111 | :committed_on => re.time, | |
| 110 | identifier_to = [identifier_from + 99, scm_revision].min |
|
112 | :comments => re.message) | |
| 111 | revisions = scm.revisions('', identifier_from, identifier_to, :with_paths => true) |
|
113 | re.paths.each { |e| cs.create_change(e) } | |
| 112 | transaction do |
|
|||
| 113 | revisions.each do |revision| |
|
|||
| 114 | changeset = Changeset.create(:repository => self, |
|
|||
| 115 | :revision => revision.revision, |
|
|||
| 116 | :scmid => revision.scmid, |
|
|||
| 117 | :committer => revision.author, |
|
|||
| 118 | :committed_on => revision.time, |
|
|||
| 119 | :comments => revision.message) |
|
|||
| 120 |
|
||||
| 121 | revision.paths.each do |change| |
|
|||
| 122 | changeset.create_change(change) |
|
|||
| 123 | end |
|
|||
| 124 | end |
|
|||
| 125 | end unless revisions.nil? |
|
|||
| 126 | identifier_from = identifier_to + 1 |
|
|||
| 127 | end |
|
114 | end | |
| 128 | end |
|
115 | end | |
| 129 | end |
|
116 | end | |
|
|
117 | self | |||
| 130 | end |
|
118 | end | |
| 131 | end |
|
119 | end | |
General Comments 0
You need to be logged in to leave comments.
Login now