jro_apps/redmine Commit - r5632:850059d0cfa3

1

# ~~redM~~ine - 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)

24

def self.human_attribute_name(attribute_key_name)

25

attr_name = attribute_key_name

25

attr_name = attribute_key_name

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)

29

super(attr_name)

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(:first,

50

c = Change.find(:first,

51

:include => :changeset,

51

:include => :changeset,

52

:conditions => ["#{Change.table_name}.revision = ? and #{Changeset.table_name}.repository_id = ?", e.lastrev.revision, id],

52

:conditions => ["#{Change.table_name}.revision = ? and #{Changeset.table_name}.repository_id = ?", e.lastrev.revision, id],

53

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

53

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

54

if c

54

if c

55

e.lastrev.identifier = c.changeset.revision

55

e.lastrev.identifier = c.changeset.revision

56

e.lastrev.name = c.changeset.revision

56

e.lastrev.name = c.changeset.revision

57

e.lastrev.author = c.changeset.committer

57

e.lastrev.author = c.changeset.committer

58

end

58

end

59

end

59

end

60

end

60

end

61

end

61

end

62

63

def fetch_changesets

63

def fetch_changesets

64

scm_info = scm.info

64

scm_info = scm.info

65

if scm_info

65

if scm_info

66

# latest revision found in database

66

# latest revision found in database

67

db_revision = latest_changeset ? latest_changeset.revision.to_i : 0

67

db_revision = latest_changeset ? latest_changeset.revision.to_i : 0

68

# latest revision in the repository

68

# latest revision in the repository

69

scm_revision = scm_info.lastrev.identifier.to_i

69

scm_revision = scm_info.lastrev.identifier.to_i

70

if db_revision < scm_revision

70

if db_revision < scm_revision

71

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

71

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

72

identifier_from = db_revision + 1

72

identifier_from = db_revision + 1

73

while (identifier_from <= scm_revision)

73

while (identifier_from <= scm_revision)

74

# loads changesets by batches of 200

74

# loads changesets by batches of 200

75

identifier_to = [identifier_from + 199, scm_revision].min

75

identifier_to = [identifier_from + 199, scm_revision].min

76

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

76

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

77

transaction do

77

transaction do

78

revisions.reverse_each do |revision|

78

revisions.reverse_each do |revision|

79

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

79

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

80

:revision => revision.identifier,

80

:revision => revision.identifier,

81

:committer => revision.author,

81

:committer => revision.author,

82

:committed_on => revision.time,

82

:committed_on => revision.time,

83

:scmid => revision.scmid,

83

:scmid => revision.scmid,

84

:comments => revision.message)

84

:comments => revision.message)

85

86

revision.paths.each do |change|

86

revision.paths.each do |change|

87

Change.create(:changeset => changeset,

87

Change.create(:changeset => changeset,

88

:action => change[:action],

88

:action => change[:action],

89

:path => change[:path],

89

:path => change[:path],

90

:revision => change[:revision])

90

:revision => change[:revision])

91

end

91

end

92

end

92

end

93

end unless revisions.nil?

93

end unless revisions.nil?

94

identifier_from = identifier_to + 1

94

identifier_from = identifier_to + 1

95

end

95

end

96

end

96

end

97

end

97

end

98

end

98

end

99

end

99

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
+            # Redmine - project management software
-            # Copyright (C) 2006-2007  Jean-Philippe Lang
+            # Copyright (C) 2006-2011  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)
                 attr_name = attribute_key_name
                 if attr_name == "url"
                   attr_name = "path_to_repository"
                 end
                 super(attr_name)
               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
               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)
                       transaction do
                         revisions.reverse_each do |revision|
-                          changeset = Changeset.create(:repository => self,
+                          changeset = Changeset.create(:repository   => self,
-                                                       :revision => revision.identifier,
+                                                       :revision     => revision.identifier,
-                                                       :committer => revision.author,
+                                                       :committer    => revision.author,
                                                        :committed_on => revision.time,
-                                                       :scmid => revision.scmid,
+                                                       :scmid        => revision.scmid,
-                                                       :comments => revision.message)
+                                                       :comments     => revision.message)
                           revision.paths.each do |change|
                             Change.create(:changeset => changeset,
-                                          :action => change[:action],
+                                          :action    => change[:action],
-                                          :path => change[:path],
+                                          :path      => change[:path],
-                                          :revision => change[:revision])
+                                          :revision  => change[:revision])
                           end
                         end
                       end unless revisions.nil?
                       identifier_from = identifier_to + 1
                     end
                   end
                 end
               end
             end