cvs.rb
161 lines
| 6.2 KiB
| text/x-ruby
|
RubyLexer
Jean-Philippe Lang
|
r556 | # redMine - project management software | ||
| # Copyright (C) 2006-2007 Jean-Philippe Lang | ||||
| # | ||||
| # This program is free software; you can redistribute it and/or | ||||
| # modify it under the terms of the GNU General Public License | ||||
| # as published by the Free Software Foundation; either version 2 | ||||
| # of the License, or (at your option) any later version. | ||||
| # | ||||
| # This program is distributed in the hope that it will be useful, | ||||
| # but WITHOUT ANY WARRANTY; without even the implied warranty of | ||||
| # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the | ||||
| # GNU General Public License for more details. | ||||
| # | ||||
| # You should have received a copy of the GNU General Public License | ||||
| # along with this program; if not, write to the Free Software | ||||
| # Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA. | ||||
| require 'redmine/scm/adapters/cvs_adapter' | ||||
| require 'digest/sha1' | ||||
| class Repository::Cvs < Repository | ||||
| validates_presence_of :url, :root_url | ||||
| def scm_adapter | ||||
| Redmine::Scm::Adapters::CvsAdapter | ||||
| end | ||||
| def self.scm_name | ||||
| 'CVS' | ||||
| end | ||||
|
Jean-Philippe Lang
|
r1539 | def entry(path=nil, identifier=nil) | ||
| rev = identifier.nil? ? nil : changesets.find_by_revision(identifier) | ||||
| scm.entry(path, rev.nil? ? nil : rev.committed_on) | ||||
|
Jean-Philippe Lang
|
r556 | end | ||
| def entries(path=nil, identifier=nil) | ||||
|
Jean-Philippe Lang
|
r1314 | rev = identifier.nil? ? nil : changesets.find_by_revision(identifier) | ||
| entries = scm.entries(path, rev.nil? ? nil : rev.committed_on) | ||||
|
Jean-Philippe Lang
|
r556 | if entries | ||
| entries.each() do |entry| | ||||
| unless entry.lastrev.nil? || entry.lastrev.identifier | ||||
| change=changes.find_by_revision_and_path( entry.lastrev.revision, scm.with_leading_slash(entry.path) ) | ||||
| if change | ||||
| entry.lastrev.identifier=change.changeset.revision | ||||
| entry.lastrev.author=change.changeset.committer | ||||
| entry.lastrev.revision=change.revision | ||||
| entry.lastrev.branch=change.branch | ||||
| end | ||||
| end | ||||
| end | ||||
| end | ||||
| entries | ||||
| end | ||||
|
Jean-Philippe Lang
|
r1539 | def cat(path, identifier=nil) | ||
| rev = identifier.nil? ? nil : changesets.find_by_revision(identifier) | ||||
| scm.cat(path, rev.nil? ? nil : rev.committed_on) | ||||
| end | ||||
|
Jean-Philippe Lang
|
r1499 | def diff(path, rev, rev_to) | ||
|
Jean-Philippe Lang
|
r556 | #convert rev to revision. CVS can't handle changesets here | ||
| diff=[] | ||||
| changeset_from=changesets.find_by_revision(rev) | ||||
| if rev_to.to_i > 0 | ||||
| changeset_to=changesets.find_by_revision(rev_to) | ||||
| end | ||||
| changeset_from.changes.each() do |change_from| | ||||
| revision_from=nil | ||||
| revision_to=nil | ||||
| revision_from=change_from.revision if path.nil? || (change_from.path.starts_with? scm.with_leading_slash(path)) | ||||
| if revision_from | ||||
| if changeset_to | ||||
| changeset_to.changes.each() do |change_to| | ||||
| revision_to=change_to.revision if change_to.path==change_from.path | ||||
| end | ||||
| end | ||||
| unless revision_to | ||||
| revision_to=scm.get_previous_revision(revision_from) | ||||
| end | ||||
|
Jean-Philippe Lang
|
r1511 | file_diff = scm.diff(change_from.path, revision_from, revision_to) | ||
| diff = diff + file_diff unless file_diff.nil? | ||||
|
Jean-Philippe Lang
|
r556 | end | ||
| end | ||||
| return diff | ||||
| end | ||||
| def fetch_changesets | ||||
| # some nifty bits to introduce a commit-id with cvs | ||||
| # natively cvs doesn't provide any kind of changesets, there is only a revision per file. | ||||
| # we now take a guess using the author, the commitlog and the commit-date. | ||||
| # last one is the next step to take. the commit-date is not equal for all | ||||
| # commits in one changeset. cvs update the commit-date when the *,v file was touched. so | ||||
| # we use a small delta here, to merge all changes belonging to _one_ changeset | ||||
| time_delta=10.seconds | ||||
|
Jean-Philippe Lang
|
r1222 | fetch_since = latest_changeset ? latest_changeset.committed_on : nil | ||
|
Jean-Philippe Lang
|
r556 | transaction do | ||
|
Jean-Philippe Lang
|
r1222 | tmp_rev_num = 1 | ||
| scm.revisions('', fetch_since, nil, :with_paths => true) do |revision| | ||||
|
Jean-Philippe Lang
|
r556 | # only add the change to the database, if it doen't exists. the cvs log | ||
| # is not exclusive at all. | ||||
| unless changes.find_by_path_and_revision(scm.with_leading_slash(revision.paths[0][:path]), revision.paths[0][:revision]) | ||||
| revision | ||||
|
Jean-Philippe Lang
|
r592 | cs = changesets.find(:first, :conditions=>{ | ||
|
Jean-Philippe Lang
|
r556 | :committed_on=>revision.time-time_delta..revision.time+time_delta, | ||
| :committer=>revision.author, | ||||
|
Jean-Philippe Lang
|
r1767 | :comments=>Changeset.normalize_comments(revision.message) | ||
|
Jean-Philippe Lang
|
r556 | }) | ||
| # create a new changeset.... | ||||
|
Jean-Philippe Lang
|
r1222 | unless cs | ||
| # we use a temporaray revision number here (just for inserting) | ||||
|
Jean-Philippe Lang
|
r556 | # later on, we calculate a continous positive number | ||
|
Jean-Philippe Lang
|
r1222 | latest = changesets.find(:first, :order => 'id DESC') | ||
| cs = Changeset.create(:repository => self, | ||||
| :revision => "_#{tmp_rev_num}", | ||||
| :committer => revision.author, | ||||
| :committed_on => revision.time, | ||||
| :comments => revision.message) | ||||
| tmp_rev_num += 1 | ||||
|
Jean-Philippe Lang
|
r556 | end | ||
| #convert CVS-File-States to internal Action-abbrevations | ||||
| #default action is (M)odified | ||||
| action="M" | ||||
| if revision.paths[0][:action]=="Exp" && revision.paths[0][:revision]=="1.1" | ||||
| action="A" #add-action always at first revision (= 1.1) | ||||
| elsif revision.paths[0][:action]=="dead" | ||||
| action="D" #dead-state is similar to Delete | ||||
| end | ||||
| Change.create(:changeset => cs, | ||||
| :action => action, | ||||
| :path => scm.with_leading_slash(revision.paths[0][:path]), | ||||
| :revision => revision.paths[0][:revision], | ||||
| :branch => revision.paths[0][:branch] | ||||
| ) | ||||
| end | ||||
| end | ||||
|
Jean-Philippe Lang
|
r1222 | # Renumber new changesets in chronological order | ||
| changesets.find(:all, :order => 'committed_on ASC, id ASC', :conditions => "revision LIKE '_%'").each do |changeset| | ||||
|
Jean-Philippe Lang
|
r1340 | changeset.update_attribute :revision, next_revision_number | ||
|
Jean-Philippe Lang
|
r556 | end | ||
|
Jean-Philippe Lang
|
r1222 | end # transaction | ||
|
Jean-Philippe Lang
|
r556 | end | ||
|
Jean-Philippe Lang
|
r1340 | |||
| private | ||||
| # Returns the next revision number to assign to a CVS changeset | ||||
| def next_revision_number | ||||
| # Need to retrieve existing revision numbers to sort them as integers | ||||
| @current_revision_number ||= (connection.select_values("SELECT revision FROM #{Changeset.table_name} WHERE repository_id = #{id} AND revision NOT LIKE '_%'").collect(&:to_i).max || 0) | ||||
| @current_revision_number += 1 | ||||
| end | ||||
|
Jean-Philippe Lang
|
r556 | end | ||