jro_apps/redmine Commit - r10216:2058c66d734c

1

# Redmine - project management software

1

# Redmine - project management software

2

3

#

3

#

4

# This program is free software; you can redistribute it and/or

4

# This program is free software; you can redistribute it and/or

5

# modify it under the terms of the GNU General Public License

5

# modify it under the terms of the GNU General Public License

6

# as published by the Free Software Foundation; either version 2

6

# as published by the Free Software Foundation; either version 2

7

# of the License, or (at your option) any later version.

7

# of the License, or (at your option) any later version.

8

#

8

#

9

# This program is distributed in the hope that it will be useful,

9

# This program is distributed in the hope that it will be useful,

10

# but WITHOUT ANY WARRANTY; without even the implied warranty of

10

# but WITHOUT ANY WARRANTY; without even the implied warranty of

11

# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the

11

# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the

12

# GNU General Public License for more details.

12

# GNU General Public License for more details.

13

#

13

#

14

# You should have received a copy of the GNU General Public License

14

# You should have received a copy of the GNU General Public License

15

# along with this program; if not, write to the Free Software

15

# along with this program; if not, write to the Free Software

16

# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.

16

# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.

17

18

require 'redmine/scm/adapters/bazaar_adapter'

18

require 'redmine/scm/adapters/bazaar_adapter'

19

20

class Repository::Bazaar < Repository

20

class Repository::Bazaar < Repository

21

attr_protected :root_url

21

attr_protected :root_url

22

validates_presence_of :url, :log_encoding

22

validates_presence_of :url, :log_encoding

23

24

def self.human_attribute_name(attribute_key_name, *args)

24

def self.human_attribute_name(attribute_key_name, *args)

25

attr_name = attribute_key_name.to_s

25

attr_name = attribute_key_name.to_s

26

if attr_name == "url"

26

if attr_name == "url"

27

attr_name = "path_to_repository"

27

attr_name = "path_to_repository"

28

end

28

end

29

super(attr_name, *args)

29

super(attr_name, *args)

30

end

30

end

31

32

def self.scm_adapter_class

32

def self.scm_adapter_class

33

Redmine::Scm::Adapters::BazaarAdapter

33

Redmine::Scm::Adapters::BazaarAdapter

34

end

34

end

35

36

def self.scm_name

36

def self.scm_name

37

'Bazaar'

37

'Bazaar'

38

end

38

end

39

40

def entries(path=nil, identifier=nil)

40

def entries(path=nil, identifier=nil)

41

entries = scm.entries(path, identifier)

41

entries = scm.entries(path, identifier)

42

if entries

42

if entries

43

entries.each do |e|

43

entries.each do |e|

44

next if e.lastrev.revision.blank?

44

next if e.lastrev.revision.blank?

45

# Set the filesize unless browsing a specific revision

45

# Set the filesize unless browsing a specific revision

46

if identifier.nil? && e.is_file?

46

if identifier.nil? && e.is_file?

47

full_path = File.join(root_url, e.path)

47

full_path = File.join(root_url, e.path)

48

e.size = File.stat(full_path).size if File.file?(full_path)

48

e.size = File.stat(full_path).size if File.file?(full_path)

49

end

49

end

50

c = Change.find(

50

c = Change.find(

51

:first,

51

:first,

52

:include => :changeset,

52

:include => :changeset,

53

:conditions => [

53

:conditions => [

54

"#{Change.table_name}.revision = ? and #{Changeset.table_name}.repository_id = ?",

54

"#{Change.table_name}.revision = ? and #{Changeset.table_name}.repository_id = ?",

55

e.lastrev.revision,

55

e.lastrev.revision,

56

id

56

id

57

],

57

],

58

:order => "#{Changeset.table_name}.revision DESC")

58

:order => "#{Changeset.table_name}.revision DESC")

59

if c

59

if c

60

e.lastrev.identifier = c.changeset.revision

60

e.lastrev.identifier = c.changeset.revision

61

e.lastrev.name = c.changeset.revision

61

e.lastrev.name = c.changeset.revision

62

e.lastrev.author = c.changeset.committer

62

e.lastrev.author = c.changeset.committer

63

end

63

end

64

end

64

end

65

end

65

end

66

load_entries_changesets(entries)

66

load_entries_changesets(entries)

67

entries

67

entries

68

end

68

end

69

70

def fetch_changesets

70

def fetch_changesets

71

scm_info = scm.info

71

scm_info = scm.info

72

if scm_info

72

if scm_info

73

# latest revision found in database

73

# latest revision found in database

74

db_revision = latest_changeset ? latest_changeset.revision.to_i : 0

74

db_revision = latest_changeset ? latest_changeset.revision.to_i : 0

75

# latest revision in the repository

75

# latest revision in the repository

76

scm_revision = scm_info.lastrev.identifier.to_i

76

scm_revision = scm_info.lastrev.identifier.to_i

77

if db_revision < scm_revision

77

if db_revision < scm_revision

78

logger.debug "Fetching changesets for repository #{url}" if logger && logger.debug?

78

logger.debug "Fetching changesets for repository #{url}" if logger && logger.debug?

79

identifier_from = db_revision + 1

79

identifier_from = db_revision + 1

80

while (identifier_from <= scm_revision)

80

while (identifier_from <= scm_revision)

81

# loads changesets by batches of 200

81

# loads changesets by batches of 200

82

identifier_to = [identifier_from + 199, scm_revision].min

82

identifier_to = [identifier_from + 199, scm_revision].min

83

revisions = scm.revisions('', identifier_to, identifier_from, ~~:with_paths~~ => ~~true~~)

83

revisions = scm.revisions('', identifier_to, identifier_from)

84

transaction do

84

transaction do

85

revisions.reverse_each do |revision|

85

revisions.reverse_each do |revision|

86

changeset = Changeset.create(:repository => self,

86

changeset = Changeset.create(:repository => self,

87

:revision => revision.identifier,

87

:revision => revision.identifier,

88

:committer => revision.author,

88

:committer => revision.author,

89

:committed_on => revision.time,

89

:committed_on => revision.time,

90

:scmid => revision.scmid,

90

:scmid => revision.scmid,

91

:comments => revision.message)

91

:comments => revision.message)

92

93

revision.paths.each do |change|

93

revision.paths.each do |change|

94

Change.create(:changeset => changeset,

94

Change.create(:changeset => changeset,

95

:action => change[:action],

95

:action => change[:action],

96

:path => change[:path],

96

:path => change[:path],

97

:revision => change[:revision])

97

:revision => change[:revision])

98

end

98

end

99

end

99

end

100

end unless revisions.nil?

100

end unless revisions.nil?

101

identifier_from = identifier_to + 1

101

identifier_from = identifier_to + 1

102

end

102

end

103

end

103

end

104

end

104

end

105

end

105

end

106

end

106

end

	Site-wide shortcuts
/	Use quick search box
g h	Goto home page
g g	Goto my private gists page
g G	Goto my public gists page
g 0-9	Goto bookmarked items from 0-9
n r	New repository page
n g	New gist page

	Repositories
g s	Goto summary page
g c	Goto changelog page
g f	Goto files page
g F	Goto files page with file search activated
g p	Goto pull requests page
g o	Goto repository settings
g O	Goto repository access permissions settings
t s	Toggle sidebar on some pages

             # Redmine - project management software
             # Copyright (C) 2006-2012  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/bazaar_adapter'
             class Repository::Bazaar < Repository
               attr_protected :root_url
               validates_presence_of :url, :log_encoding
               def self.human_attribute_name(attribute_key_name, *args)
                 attr_name = attribute_key_name.to_s
                 if attr_name == "url"
                   attr_name = "path_to_repository"
                 end
                 super(attr_name, *args)
               end
               def self.scm_adapter_class
                 Redmine::Scm::Adapters::BazaarAdapter
               end
               def self.scm_name
                 'Bazaar'
               end
               def entries(path=nil, identifier=nil)
                 entries = scm.entries(path, identifier)
                 if entries
                   entries.each do |e|
                     next if e.lastrev.revision.blank?
                     # Set the filesize unless browsing a specific revision
                     if identifier.nil? && e.is_file?
                       full_path = File.join(root_url, e.path)
                       e.size = File.stat(full_path).size if File.file?(full_path)
                     end
                     c = Change.find(
                            :first,
                            :include    => :changeset,
                            :conditions => [
                                "#{Change.table_name}.revision = ? and #{Changeset.table_name}.repository_id = ?",
                                e.lastrev.revision,
                                id
                                ],
                            :order => "#{Changeset.table_name}.revision DESC")
                     if c
                       e.lastrev.identifier = c.changeset.revision
                       e.lastrev.name       = c.changeset.revision
                       e.lastrev.author     = c.changeset.committer
                     end
                   end
                 end
                 load_entries_changesets(entries)
                 entries
               end
               def fetch_changesets
                 scm_info = scm.info
                 if scm_info
                   # latest revision found in database
                   db_revision = latest_changeset ? latest_changeset.revision.to_i : 0
                   # latest revision in the repository
                   scm_revision = scm_info.lastrev.identifier.to_i
                   if db_revision < scm_revision
                     logger.debug "Fetching changesets for repository #{url}" if logger && logger.debug?
                     identifier_from = db_revision + 1
                     while (identifier_from <= scm_revision)
                       # loads changesets by batches of 200
                       identifier_to = [identifier_from + 199, scm_revision].min
-                      revisions = scm.revisions('', identifier_to, identifier_from, :with_paths => true)
+                      revisions = scm.revisions('', identifier_to, identifier_from)
                       transaction do
                         revisions.reverse_each do |revision|
                           changeset = Changeset.create(:repository   => self,
                                                        :revision     => revision.identifier,
                                                        :committer    => revision.author,
                                                        :committed_on => revision.time,
                                                        :scmid        => revision.scmid,
                                                        :comments     => revision.message)
                           revision.paths.each do |change|
                             Change.create(:changeset => changeset,
                                           :action    => change[:action],
                                           :path      => change[:path],
                                           :revision  => change[:revision])
                           end
                         end
                       end unless revisions.nil?
                       identifier_from = identifier_to + 1
                     end
                   end
                 end
               end
             end