bazaar_adapter.rb
338 lines
| 11.4 KiB
| text/x-ruby
|
RubyLexer
Toshi MARUYAMA
|
r5548 | # Redmine - project management software | ||
|
Toshi MARUYAMA
|
r12461 | # Copyright (C) 2006-2014 Jean-Philippe Lang | ||
Jean-Philippe Lang
|
r937 | # | ||
| # 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. | ||||
|
Toshi MARUYAMA
|
r5548 | # | ||
|
Jean-Philippe Lang
|
r937 | # 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. | ||||
|
Toshi MARUYAMA
|
r5548 | # | ||
|
Jean-Philippe Lang
|
r937 | # 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. | ||||
|
Toshi MARUYAMA
|
r12181 | require 'redmine/scm/adapters/abstract_adapter' | ||
|
Jean-Philippe Lang
|
r937 | |||
| module Redmine | ||||
| module Scm | ||||
|
Toshi MARUYAMA
|
r4701 | module Adapters | ||
|
Jean-Philippe Lang
|
r937 | class BazaarAdapter < AbstractAdapter | ||
|
Toshi MARUYAMA
|
r4701 | |||
|
Jean-Philippe Lang
|
r937 | # Bazaar executable name | ||
|
Toshi MARUYAMA
|
r4677 | BZR_BIN = Redmine::Configuration['scm_bazaar_command'] || "bzr" | ||
|
Toshi MARUYAMA
|
r4701 | |||
| class << self | ||||
| def client_command | ||||
| @@bin ||= BZR_BIN | ||||
| end | ||||
| def sq_bin | ||||
|
Toshi MARUYAMA
|
r6162 | @@sq_bin ||= shell_quote_command | ||
|
Toshi MARUYAMA
|
r4701 | end | ||
|
Toshi MARUYAMA
|
r4711 | |||
| def client_version | ||||
| @@client_version ||= (scm_command_version || []) | ||||
| end | ||||
| def client_available | ||||
| !client_version.empty? | ||||
| end | ||||
| def scm_command_version | ||||
|
Jean-Philippe Lang
|
r13100 | scm_version = scm_version_from_command_line.dup.force_encoding('ASCII-8BIT') | ||
|
Toshi MARUYAMA
|
r4711 | if m = scm_version.match(%r{\A(.*?)((\d+\.)+\d+)}) | ||
| m[2].scan(%r{\d+}).collect(&:to_i) | ||||
| end | ||||
| end | ||||
| def scm_version_from_command_line | ||||
| shellout("#{sq_bin} --version") { |io| io.read }.to_s | ||||
| end | ||||
|
Toshi MARUYAMA
|
r4701 | end | ||
|
Toshi MARUYAMA
|
r10232 | def initialize(url, root_url=nil, login=nil, password=nil, path_encoding=nil) | ||
|
Toshi MARUYAMA
|
r10239 | @url = url | ||
| @root_url = url | ||||
|
Toshi MARUYAMA
|
r10232 | @path_encoding = 'UTF-8' | ||
|
Toshi MARUYAMA
|
r10239 | # do not call *super* for non ASCII repository path | ||
|
Toshi MARUYAMA
|
r10232 | end | ||
|
Toshi MARUYAMA
|
r10237 | def bzr_path_encodig=(encoding) | ||
| @path_encoding = encoding | ||||
| end | ||||
|
Jean-Philippe Lang
|
r937 | # Get info about the repository | ||
| def info | ||||
|
Toshi MARUYAMA
|
r5788 | cmd_args = %w|revno| | ||
| cmd_args << bzr_target('') | ||||
|
Jean-Philippe Lang
|
r937 | info = nil | ||
|
Toshi MARUYAMA
|
r5788 | scm_cmd(*cmd_args) do |io| | ||
|
Jean-Philippe Lang
|
r3609 | if io.read =~ %r{^(\d+)\r?$} | ||
|
Jean-Philippe Lang
|
r937 | info = Info.new({:root_url => url, | ||
| :lastrev => Revision.new({ | ||||
| :identifier => $1 | ||||
| }) | ||||
| }) | ||||
| end | ||||
| end | ||||
| info | ||||
|
Toshi MARUYAMA
|
r5788 | rescue ScmCommandAborted | ||
|
Jean-Philippe Lang
|
r937 | return nil | ||
| end | ||||
|
Toshi MARUYAMA
|
r4701 | |||
|
Jean-Philippe Lang
|
r937 | # Returns an Entries collection | ||
| # or nil if the given path doesn't exist in the repository | ||||
|
Toshi MARUYAMA
|
r5518 | def entries(path=nil, identifier=nil, options={}) | ||
|
Jean-Philippe Lang
|
r937 | path ||= '' | ||
| entries = Entries.new | ||||
|
Toshi MARUYAMA
|
r5425 | identifier = -1 unless identifier && identifier.to_i > 0 | ||
|
Toshi MARUYAMA
|
r5806 | cmd_args = %w|ls -v --show-ids| | ||
| cmd_args << "-r#{identifier.to_i}" | ||||
| cmd_args << bzr_target(path) | ||||
| scm_cmd(*cmd_args) do |io| | ||||
|
Toshi MARUYAMA
|
r10235 | prefix_utf8 = "#{url}/#{path}".gsub('\\', '/') | ||
| logger.debug "PREFIX: #{prefix_utf8}" | ||||
| prefix = scm_iconv(@path_encoding, 'UTF-8', prefix_utf8) | ||||
|
Jean-Philippe Lang
|
r13100 | prefix.force_encoding('ASCII-8BIT') | ||
|
Jean-Philippe Lang
|
r3609 | re = %r{^V\s+(#{Regexp.escape(prefix)})?(\/?)([^\/]+)(\/?)\s+(\S+)\r?$} | ||
|
Jean-Philippe Lang
|
r937 | io.each_line do |line| | ||
| next unless line =~ re | ||||
|
Jean-Philippe Lang
|
r11048 | name_locale, slash, revision = $3.strip, $4, $5.strip | ||
|
Toshi MARUYAMA
|
r10235 | name = scm_iconv('UTF-8', @path_encoding, name_locale) | ||
| entries << Entry.new({:name => name, | ||||
| :path => ((path.empty? ? "" : "#{path}/") + name), | ||||
|
Jean-Philippe Lang
|
r11048 | :kind => (slash.blank? ? 'file' : 'dir'), | ||
|
Jean-Philippe Lang
|
r937 | :size => nil, | ||
|
Jean-Philippe Lang
|
r11048 | :lastrev => Revision.new(:revision => revision) | ||
|
Jean-Philippe Lang
|
r937 | }) | ||
| end | ||||
| end | ||||
|
Toshi MARUYAMA
|
r5806 | if logger && logger.debug? | ||
| logger.debug("Found #{entries.size} entries in the repository for #{target(path)}") | ||||
| end | ||||
|
Jean-Philippe Lang
|
r937 | entries.sort_by_name | ||
|
Toshi MARUYAMA
|
r5806 | rescue ScmCommandAborted | ||
| return nil | ||||
|
Jean-Philippe Lang
|
r937 | end | ||
|
Toshi MARUYAMA
|
r4701 | |||
|
Jean-Philippe Lang
|
r937 | def revisions(path=nil, identifier_from=nil, identifier_to=nil, options={}) | ||
| path ||= '' | ||||
|
Jean-Philippe Lang
|
r4425 | identifier_from = (identifier_from and identifier_from.to_i > 0) ? identifier_from.to_i : 'last:1' | ||
| identifier_to = (identifier_to and identifier_to.to_i > 0) ? identifier_to.to_i : 1 | ||||
|
Jean-Philippe Lang
|
r937 | revisions = Revisions.new | ||
|
Toshi MARUYAMA
|
r5809 | cmd_args = %w|log -v --show-ids| | ||
| cmd_args << "-r#{identifier_to}..#{identifier_from}" | ||||
| cmd_args << bzr_target(path) | ||||
| scm_cmd(*cmd_args) do |io| | ||||
|
Jean-Philippe Lang
|
r937 | revision = nil | ||
|
Toshi MARUYAMA
|
r5809 | parsing = nil | ||
|
Jean-Philippe Lang
|
r937 | io.each_line do |line| | ||
| if line =~ /^----/ | ||||
| revisions << revision if revision | ||||
| revision = Revision.new(:paths => [], :message => '') | ||||
| parsing = nil | ||||
| else | ||||
| next unless revision | ||||
|
Jean-Philippe Lang
|
r2680 | if line =~ /^revno: (\d+)($|\s\[merge\]$)/ | ||
|
Jean-Philippe Lang
|
r937 | revision.identifier = $1.to_i | ||
| elsif line =~ /^committer: (.+)$/ | ||||
| revision.author = $1.strip | ||||
| elsif line =~ /^revision-id:(.+)$/ | ||||
| revision.scmid = $1.strip | ||||
| elsif line =~ /^timestamp: (.+)$/ | ||||
| revision.time = Time.parse($1).localtime | ||||
|
Jean-Philippe Lang
|
r949 | elsif line =~ /^ -----/ | ||
| # partial revisions | ||||
| parsing = nil unless parsing == 'message' | ||||
|
Jean-Philippe Lang
|
r937 | elsif line =~ /^(message|added|modified|removed|renamed):/ | ||
| parsing = $1 | ||||
|
Jean-Philippe Lang
|
r949 | elsif line =~ /^ (.*)$/ | ||
|
Jean-Philippe Lang
|
r937 | if parsing == 'message' | ||
| revision.message << "#{$1}\n" | ||||
| else | ||||
| if $1 =~ /^(.*)\s+(\S+)$/ | ||||
|
Toshi MARUYAMA
|
r10234 | path_locale = $1.strip | ||
| path = scm_iconv('UTF-8', @path_encoding, path_locale) | ||||
|
Jean-Philippe Lang
|
r937 | revid = $2 | ||
| case parsing | ||||
| when 'added' | ||||
| revision.paths << {:action => 'A', :path => "/#{path}", :revision => revid} | ||||
| when 'modified' | ||||
| revision.paths << {:action => 'M', :path => "/#{path}", :revision => revid} | ||||
| when 'removed' | ||||
| revision.paths << {:action => 'D', :path => "/#{path}", :revision => revid} | ||||
| when 'renamed' | ||||
| new_path = path.split('=>').last | ||||
|
Toshi MARUYAMA
|
r10226 | if new_path | ||
| revision.paths << {:action => 'M', :path => "/#{new_path.strip}", | ||||
| :revision => revid} | ||||
| end | ||||
|
Jean-Philippe Lang
|
r937 | end | ||
| end | ||||
| end | ||||
| else | ||||
| parsing = nil | ||||
| end | ||||
| end | ||||
| end | ||||
| revisions << revision if revision | ||||
| end | ||||
| revisions | ||||
|
Toshi MARUYAMA
|
r5809 | rescue ScmCommandAborted | ||
| return nil | ||||
|
Jean-Philippe Lang
|
r937 | end | ||
|
Toshi MARUYAMA
|
r4701 | |||
|
Jean-Philippe Lang
|
r1499 | def diff(path, identifier_from, identifier_to=nil) | ||
|
Jean-Philippe Lang
|
r937 | path ||= '' | ||
| if identifier_to | ||||
|
Toshi MARUYAMA
|
r5425 | identifier_to = identifier_to.to_i | ||
|
Jean-Philippe Lang
|
r937 | else | ||
| identifier_to = identifier_from.to_i - 1 | ||||
| end | ||||
|
Jean-Philippe Lang
|
r4425 | if identifier_from | ||
| identifier_from = identifier_from.to_i | ||||
| end | ||||
|
Jean-Philippe Lang
|
r937 | diff = [] | ||
|
Toshi MARUYAMA
|
r5803 | cmd_args = %w|diff| | ||
| cmd_args << "-r#{identifier_to}..#{identifier_from}" | ||||
| cmd_args << bzr_target(path) | ||||
| scm_cmd_no_raise(*cmd_args) do |io| | ||||
|
Jean-Philippe Lang
|
r937 | io.each_line do |line| | ||
| diff << line | ||||
| end | ||||
| end | ||||
|
Jean-Philippe Lang
|
r1499 | diff | ||
|
Jean-Philippe Lang
|
r937 | end | ||
|
Toshi MARUYAMA
|
r4701 | |||
|
Jean-Philippe Lang
|
r937 | def cat(path, identifier=nil) | ||
| cat = nil | ||||
|
Toshi MARUYAMA
|
r5799 | cmd_args = %w|cat| | ||
| cmd_args << "-r#{identifier.to_i}" if identifier && identifier.to_i > 0 | ||||
| cmd_args << bzr_target(path) | ||||
| scm_cmd(*cmd_args) do |io| | ||||
|
Jean-Philippe Lang
|
r937 | io.binmode | ||
| cat = io.read | ||||
| end | ||||
| cat | ||||
|
Toshi MARUYAMA
|
r5799 | rescue ScmCommandAborted | ||
| return nil | ||||
|
Jean-Philippe Lang
|
r937 | end | ||
|
Toshi MARUYAMA
|
r4701 | |||
|
Jean-Philippe Lang
|
r937 | def annotate(path, identifier=nil) | ||
| blame = Annotate.new | ||||
|
Toshi MARUYAMA
|
r5795 | cmd_args = %w|annotate -q --all| | ||
|
Toshi MARUYAMA
|
r5792 | cmd_args << "-r#{identifier.to_i}" if identifier && identifier.to_i > 0 | ||
| cmd_args << bzr_target(path) | ||||
| scm_cmd(*cmd_args) do |io| | ||||
| author = nil | ||||
|
Jean-Philippe Lang
|
r937 | identifier = nil | ||
| io.each_line do |line| | ||||
| next unless line =~ %r{^(\d+) ([^|]+)\| (.*)$} | ||||
|
Toshi MARUYAMA
|
r5280 | rev = $1 | ||
|
Toshi MARUYAMA
|
r5272 | blame.add_line($3.rstrip, | ||
| Revision.new( | ||||
| :identifier => rev, | ||||
| :revision => rev, | ||||
| :author => $2.strip | ||||
| )) | ||||
|
Jean-Philippe Lang
|
r937 | end | ||
| end | ||||
| blame | ||||
|
Toshi MARUYAMA
|
r5792 | rescue ScmCommandAborted | ||
| return nil | ||||
|
Jean-Philippe Lang
|
r937 | end | ||
|
Toshi MARUYAMA
|
r5770 | |||
| def self.branch_conf_path(path) | ||||
| bcp = nil | ||||
| m = path.match(%r{^(.*[/\\])\.bzr.*$}) | ||||
| if m | ||||
| bcp = m[1] | ||||
| else | ||||
| bcp = path | ||||
| end | ||||
|
Toshi MARUYAMA
|
r5780 | bcp.gsub!(%r{[\/\\]$}, "") | ||
|
Toshi MARUYAMA
|
r5770 | if bcp | ||
| bcp = File.join(bcp, ".bzr", "branch", "branch.conf") | ||||
| end | ||||
|
Toshi MARUYAMA
|
r5774 | bcp | ||
|
Toshi MARUYAMA
|
r5770 | end | ||
|
Toshi MARUYAMA
|
r5772 | |||
| def append_revisions_only | ||||
| return @aro if ! @aro.nil? | ||||
| @aro = false | ||||
| bcp = self.class.branch_conf_path(url) | ||||
|
Toshi MARUYAMA
|
r5775 | if bcp && File.exist?(bcp) | ||
|
Toshi MARUYAMA
|
r5772 | begin | ||
| f = File::open(bcp, "r") | ||||
| cnt = 0 | ||||
| f.each_line do |line| | ||||
| l = line.chomp.to_s | ||||
| if l =~ /^\s*append_revisions_only\s*=\s*(\w+)\s*$/ | ||||
| str_aro = $1 | ||||
| if str_aro.upcase == "TRUE" | ||||
| @aro = true | ||||
| cnt += 1 | ||||
| elsif str_aro.upcase == "FALSE" | ||||
| @aro = false | ||||
| cnt += 1 | ||||
| end | ||||
| if cnt > 1 | ||||
| @aro = false | ||||
| break | ||||
| end | ||||
| end | ||||
| end | ||||
| ensure | ||||
| f.close | ||||
| end | ||||
| end | ||||
| @aro | ||||
| end | ||||
|
Toshi MARUYAMA
|
r5785 | |||
| def scm_cmd(*args, &block) | ||||
|
Toshi MARUYAMA
|
r6163 | full_args = [] | ||
|
Toshi MARUYAMA
|
r5785 | full_args += args | ||
|
Toshi MARUYAMA
|
r10233 | full_args_locale = [] | ||
| full_args.map do |e| | ||||
| full_args_locale << scm_iconv(@path_encoding, 'UTF-8', e) | ||||
| end | ||||
|
Toshi MARUYAMA
|
r6163 | ret = shellout( | ||
|
Toshi MARUYAMA
|
r10233 | self.class.sq_bin + ' ' + | ||
| full_args_locale.map { |e| shell_quote e.to_s }.join(' '), | ||||
|
Toshi MARUYAMA
|
r6163 | &block | ||
| ) | ||||
|
Toshi MARUYAMA
|
r5785 | if $? && $?.exitstatus != 0 | ||
| raise ScmCommandAborted, "bzr exited with non-zero status: #{$?.exitstatus}" | ||||
| end | ||||
| ret | ||||
| end | ||||
| private :scm_cmd | ||||
|
Toshi MARUYAMA
|
r5787 | |||
|
Toshi MARUYAMA
|
r5800 | def scm_cmd_no_raise(*args, &block) | ||
|
Toshi MARUYAMA
|
r6164 | full_args = [] | ||
|
Toshi MARUYAMA
|
r5800 | full_args += args | ||
|
Toshi MARUYAMA
|
r10233 | full_args_locale = [] | ||
| full_args.map do |e| | ||||
| full_args_locale << scm_iconv(@path_encoding, 'UTF-8', e) | ||||
| end | ||||
|
Toshi MARUYAMA
|
r6164 | ret = shellout( | ||
|
Toshi MARUYAMA
|
r10233 | self.class.sq_bin + ' ' + | ||
| full_args_locale.map { |e| shell_quote e.to_s }.join(' '), | ||||
|
Toshi MARUYAMA
|
r6164 | &block | ||
| ) | ||||
|
Toshi MARUYAMA
|
r5800 | ret | ||
| end | ||||
| private :scm_cmd_no_raise | ||||
|
Toshi MARUYAMA
|
r5787 | def bzr_target(path) | ||
| target(path, false) | ||||
| end | ||||
| private :bzr_target | ||||
|
Jean-Philippe Lang
|
r937 | end | ||
| end | ||||
| end | ||||
| end | ||||