Chris@909
|
1 # Redmine - project management software
|
Chris@1115
|
2 # Copyright (C) 2006-2012 Jean-Philippe Lang
|
Chris@0
|
3 #
|
Chris@0
|
4 # This program is free software; you can redistribute it and/or
|
Chris@0
|
5 # modify it under the terms of the GNU General Public License
|
Chris@0
|
6 # as published by the Free Software Foundation; either version 2
|
Chris@0
|
7 # of the License, or (at your option) any later version.
|
Chris@909
|
8 #
|
Chris@0
|
9 # This program is distributed in the hope that it will be useful,
|
Chris@0
|
10 # but WITHOUT ANY WARRANTY; without even the implied warranty of
|
Chris@0
|
11 # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
Chris@0
|
12 # GNU General Public License for more details.
|
Chris@909
|
13 #
|
Chris@0
|
14 # You should have received a copy of the GNU General Public License
|
Chris@0
|
15 # along with this program; if not, write to the Free Software
|
Chris@0
|
16 # Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.
|
Chris@0
|
17
|
Chris@0
|
18 module Redmine #:nodoc:
|
Chris@0
|
19
|
Chris@0
|
20 class PluginNotFound < StandardError; end
|
Chris@0
|
21 class PluginRequirementError < StandardError; end
|
Chris@909
|
22
|
Chris@0
|
23 # Base class for Redmine plugins.
|
Chris@0
|
24 # Plugins are registered using the <tt>register</tt> class method that acts as the public constructor.
|
Chris@909
|
25 #
|
Chris@0
|
26 # Redmine::Plugin.register :example do
|
Chris@0
|
27 # name 'Example plugin'
|
Chris@0
|
28 # author 'John Smith'
|
Chris@0
|
29 # description 'This is an example plugin for Redmine'
|
Chris@0
|
30 # version '0.0.1'
|
Chris@0
|
31 # settings :default => {'foo'=>'bar'}, :partial => 'settings/settings'
|
Chris@0
|
32 # end
|
Chris@909
|
33 #
|
Chris@0
|
34 # === Plugin attributes
|
Chris@909
|
35 #
|
Chris@0
|
36 # +settings+ is an optional attribute that let the plugin be configurable.
|
Chris@0
|
37 # It must be a hash with the following keys:
|
Chris@0
|
38 # * <tt>:default</tt>: default value for the plugin settings
|
Chris@0
|
39 # * <tt>:partial</tt>: path of the configuration partial view, relative to the plugin <tt>app/views</tt> directory
|
Chris@0
|
40 # Example:
|
Chris@0
|
41 # settings :default => {'foo'=>'bar'}, :partial => 'settings/settings'
|
Chris@0
|
42 # In this example, the settings partial will be found here in the plugin directory: <tt>app/views/settings/_settings.rhtml</tt>.
|
Chris@909
|
43 #
|
Chris@0
|
44 # When rendered, the plugin settings value is available as the local variable +settings+
|
Chris@0
|
45 class Plugin
|
Chris@1115
|
46 cattr_accessor :directory
|
Chris@1115
|
47 self.directory = File.join(Rails.root, 'plugins')
|
Chris@1115
|
48
|
Chris@1115
|
49 cattr_accessor :public_directory
|
Chris@1115
|
50 self.public_directory = File.join(Rails.root, 'public', 'plugin_assets')
|
Chris@1115
|
51
|
Chris@0
|
52 @registered_plugins = {}
|
Chris@0
|
53 class << self
|
Chris@0
|
54 attr_reader :registered_plugins
|
Chris@0
|
55 private :new
|
Chris@0
|
56
|
Chris@0
|
57 def def_field(*names)
|
Chris@909
|
58 class_eval do
|
Chris@0
|
59 names.each do |name|
|
Chris@909
|
60 define_method(name) do |*args|
|
Chris@0
|
61 args.empty? ? instance_variable_get("@#{name}") : instance_variable_set("@#{name}", *args)
|
Chris@0
|
62 end
|
Chris@0
|
63 end
|
Chris@0
|
64 end
|
Chris@0
|
65 end
|
Chris@0
|
66 end
|
Chris@0
|
67 def_field :name, :description, :url, :author, :author_url, :version, :settings
|
Chris@0
|
68 attr_reader :id
|
Chris@909
|
69
|
Chris@0
|
70 # Plugin constructor
|
Chris@0
|
71 def self.register(id, &block)
|
Chris@0
|
72 p = new(id)
|
Chris@0
|
73 p.instance_eval(&block)
|
Chris@0
|
74 # Set a default name if it was not provided during registration
|
Chris@0
|
75 p.name(id.to_s.humanize) if p.name.nil?
|
Chris@1115
|
76
|
Chris@0
|
77 # Adds plugin locales if any
|
Chris@0
|
78 # YAML translation files should be found under <plugin>/config/locales/
|
Chris@1115
|
79 ::I18n.load_path += Dir.glob(File.join(p.directory, 'config', 'locales', '*.yml'))
|
Chris@1115
|
80
|
Chris@1115
|
81 # Prepends the app/views directory of the plugin to the view path
|
Chris@1115
|
82 view_path = File.join(p.directory, 'app', 'views')
|
Chris@1115
|
83 if File.directory?(view_path)
|
Chris@1115
|
84 ActionController::Base.prepend_view_path(view_path)
|
Chris@1115
|
85 ActionMailer::Base.prepend_view_path(view_path)
|
Chris@1115
|
86 end
|
Chris@1115
|
87
|
Chris@1115
|
88 # Adds the app/{controllers,helpers,models} directories of the plugin to the autoload path
|
Chris@1115
|
89 Dir.glob File.expand_path(File.join(p.directory, 'app', '{controllers,helpers,models}')) do |dir|
|
Chris@1115
|
90 ActiveSupport::Dependencies.autoload_paths += [dir]
|
Chris@1115
|
91 end
|
Chris@1115
|
92
|
Chris@0
|
93 registered_plugins[id] = p
|
Chris@0
|
94 end
|
Chris@909
|
95
|
Chris@909
|
96 # Returns an array of all registered plugins
|
Chris@0
|
97 def self.all
|
Chris@0
|
98 registered_plugins.values.sort
|
Chris@0
|
99 end
|
Chris@909
|
100
|
Chris@0
|
101 # Finds a plugin by its id
|
Chris@0
|
102 # Returns a PluginNotFound exception if the plugin doesn't exist
|
Chris@0
|
103 def self.find(id)
|
Chris@0
|
104 registered_plugins[id.to_sym] || raise(PluginNotFound)
|
Chris@0
|
105 end
|
Chris@909
|
106
|
Chris@0
|
107 # Clears the registered plugins hash
|
Chris@0
|
108 # It doesn't unload installed plugins
|
Chris@0
|
109 def self.clear
|
Chris@0
|
110 @registered_plugins = {}
|
Chris@0
|
111 end
|
chris@37
|
112
|
chris@37
|
113 # Checks if a plugin is installed
|
chris@37
|
114 #
|
chris@37
|
115 # @param [String] id name of the plugin
|
chris@37
|
116 def self.installed?(id)
|
chris@37
|
117 registered_plugins[id.to_sym].present?
|
chris@37
|
118 end
|
Chris@909
|
119
|
Chris@1115
|
120 def self.load
|
Chris@1115
|
121 Dir.glob(File.join(self.directory, '*')).sort.each do |directory|
|
Chris@1115
|
122 if File.directory?(directory)
|
Chris@1115
|
123 lib = File.join(directory, "lib")
|
Chris@1115
|
124 if File.directory?(lib)
|
Chris@1115
|
125 $:.unshift lib
|
Chris@1115
|
126 ActiveSupport::Dependencies.autoload_paths += [lib]
|
Chris@1115
|
127 end
|
Chris@1115
|
128 initializer = File.join(directory, "init.rb")
|
Chris@1115
|
129 if File.file?(initializer)
|
Chris@1115
|
130 require initializer
|
Chris@1115
|
131 end
|
Chris@1115
|
132 end
|
Chris@1115
|
133 end
|
Chris@1115
|
134 end
|
Chris@1115
|
135
|
Chris@0
|
136 def initialize(id)
|
Chris@0
|
137 @id = id.to_sym
|
Chris@0
|
138 end
|
Chris@909
|
139
|
Chris@1115
|
140 def directory
|
Chris@1115
|
141 File.join(self.class.directory, id.to_s)
|
Chris@1115
|
142 end
|
Chris@1115
|
143
|
Chris@1115
|
144 def public_directory
|
Chris@1115
|
145 File.join(self.class.public_directory, id.to_s)
|
Chris@1115
|
146 end
|
Chris@1115
|
147
|
Chris@1115
|
148 def assets_directory
|
Chris@1115
|
149 File.join(directory, 'assets')
|
Chris@1115
|
150 end
|
Chris@1115
|
151
|
Chris@0
|
152 def <=>(plugin)
|
Chris@0
|
153 self.id.to_s <=> plugin.id.to_s
|
Chris@0
|
154 end
|
Chris@909
|
155
|
Chris@0
|
156 # Sets a requirement on Redmine version
|
Chris@0
|
157 # Raises a PluginRequirementError exception if the requirement is not met
|
Chris@0
|
158 #
|
Chris@0
|
159 # Examples
|
Chris@0
|
160 # # Requires Redmine 0.7.3 or higher
|
Chris@0
|
161 # requires_redmine :version_or_higher => '0.7.3'
|
Chris@0
|
162 # requires_redmine '0.7.3'
|
Chris@0
|
163 #
|
Chris@1115
|
164 # # Requires Redmine 0.7.x or higher
|
Chris@1115
|
165 # requires_redmine '0.7'
|
Chris@1115
|
166 #
|
Chris@0
|
167 # # Requires a specific Redmine version
|
Chris@0
|
168 # requires_redmine :version => '0.7.3' # 0.7.3 only
|
Chris@1115
|
169 # requires_redmine :version => '0.7' # 0.7.x
|
Chris@0
|
170 # requires_redmine :version => ['0.7.3', '0.8.0'] # 0.7.3 or 0.8.0
|
Chris@1115
|
171 #
|
Chris@1115
|
172 # # Requires a Redmine version within a range
|
Chris@1115
|
173 # requires_redmine :version => '0.7.3'..'0.9.1' # >= 0.7.3 and <= 0.9.1
|
Chris@1115
|
174 # requires_redmine :version => '0.7'..'0.9' # >= 0.7.x and <= 0.9.x
|
Chris@0
|
175 def requires_redmine(arg)
|
Chris@0
|
176 arg = { :version_or_higher => arg } unless arg.is_a?(Hash)
|
Chris@0
|
177 arg.assert_valid_keys(:version, :version_or_higher)
|
Chris@909
|
178
|
Chris@0
|
179 current = Redmine::VERSION.to_a
|
Chris@1115
|
180 arg.each do |k, req|
|
Chris@0
|
181 case k
|
Chris@0
|
182 when :version_or_higher
|
Chris@1115
|
183 raise ArgumentError.new(":version_or_higher accepts a version string only") unless req.is_a?(String)
|
Chris@1115
|
184 unless compare_versions(req, current) <= 0
|
Chris@1115
|
185 raise PluginRequirementError.new("#{id} plugin requires Redmine #{req} or higher but current is #{current.join('.')}")
|
Chris@0
|
186 end
|
Chris@0
|
187 when :version
|
Chris@1115
|
188 req = [req] if req.is_a?(String)
|
Chris@1115
|
189 if req.is_a?(Array)
|
Chris@1115
|
190 unless req.detect {|ver| compare_versions(ver, current) == 0}
|
Chris@1115
|
191 raise PluginRequirementError.new("#{id} plugin requires one the following Redmine versions: #{req.join(', ')} but current is #{current.join('.')}")
|
Chris@1115
|
192 end
|
Chris@1115
|
193 elsif req.is_a?(Range)
|
Chris@1115
|
194 unless compare_versions(req.first, current) <= 0 && compare_versions(req.last, current) >= 0
|
Chris@1115
|
195 raise PluginRequirementError.new("#{id} plugin requires a Redmine version between #{req.first} and #{req.last} but current is #{current.join('.')}")
|
Chris@1115
|
196 end
|
Chris@1115
|
197 else
|
Chris@1115
|
198 raise ArgumentError.new(":version option accepts a version string, an array or a range of versions")
|
Chris@0
|
199 end
|
Chris@0
|
200 end
|
Chris@0
|
201 end
|
Chris@0
|
202 true
|
Chris@0
|
203 end
|
Chris@0
|
204
|
Chris@1115
|
205 def compare_versions(requirement, current)
|
Chris@1115
|
206 requirement = requirement.split('.').collect(&:to_i)
|
Chris@1115
|
207 requirement <=> current.slice(0, requirement.size)
|
Chris@1115
|
208 end
|
Chris@1115
|
209 private :compare_versions
|
Chris@1115
|
210
|
Chris@0
|
211 # Sets a requirement on a Redmine plugin version
|
Chris@0
|
212 # Raises a PluginRequirementError exception if the requirement is not met
|
Chris@0
|
213 #
|
Chris@0
|
214 # Examples
|
Chris@0
|
215 # # Requires a plugin named :foo version 0.7.3 or higher
|
Chris@0
|
216 # requires_redmine_plugin :foo, :version_or_higher => '0.7.3'
|
Chris@0
|
217 # requires_redmine_plugin :foo, '0.7.3'
|
Chris@0
|
218 #
|
Chris@0
|
219 # # Requires a specific version of a Redmine plugin
|
Chris@0
|
220 # requires_redmine_plugin :foo, :version => '0.7.3' # 0.7.3 only
|
Chris@0
|
221 # requires_redmine_plugin :foo, :version => ['0.7.3', '0.8.0'] # 0.7.3 or 0.8.0
|
Chris@0
|
222 def requires_redmine_plugin(plugin_name, arg)
|
Chris@0
|
223 arg = { :version_or_higher => arg } unless arg.is_a?(Hash)
|
Chris@0
|
224 arg.assert_valid_keys(:version, :version_or_higher)
|
Chris@0
|
225
|
Chris@0
|
226 plugin = Plugin.find(plugin_name)
|
Chris@0
|
227 current = plugin.version.split('.').collect(&:to_i)
|
Chris@0
|
228
|
Chris@0
|
229 arg.each do |k, v|
|
Chris@0
|
230 v = [] << v unless v.is_a?(Array)
|
Chris@0
|
231 versions = v.collect {|s| s.split('.').collect(&:to_i)}
|
Chris@0
|
232 case k
|
Chris@0
|
233 when :version_or_higher
|
Chris@0
|
234 raise ArgumentError.new("wrong number of versions (#{versions.size} for 1)") unless versions.size == 1
|
Chris@0
|
235 unless (current <=> versions.first) >= 0
|
Chris@0
|
236 raise PluginRequirementError.new("#{id} plugin requires the #{plugin_name} plugin #{v} or higher but current is #{current.join('.')}")
|
Chris@0
|
237 end
|
Chris@0
|
238 when :version
|
Chris@0
|
239 unless versions.include?(current.slice(0,3))
|
Chris@0
|
240 raise PluginRequirementError.new("#{id} plugin requires one the following versions of #{plugin_name}: #{v.join(', ')} but current is #{current.join('.')}")
|
Chris@0
|
241 end
|
Chris@0
|
242 end
|
Chris@0
|
243 end
|
Chris@0
|
244 true
|
Chris@0
|
245 end
|
Chris@0
|
246
|
Chris@0
|
247 # Adds an item to the given +menu+.
|
Chris@0
|
248 # The +id+ parameter (equals to the project id) is automatically added to the url.
|
Chris@0
|
249 # menu :project_menu, :plugin_example, { :controller => 'example', :action => 'say_hello' }, :caption => 'Sample'
|
Chris@909
|
250 #
|
Chris@0
|
251 # +name+ parameter can be: :top_menu, :account_menu, :application_menu or :project_menu
|
Chris@909
|
252 #
|
Chris@0
|
253 def menu(menu, item, url, options={})
|
Chris@0
|
254 Redmine::MenuManager.map(menu).push(item, url, options)
|
Chris@0
|
255 end
|
Chris@0
|
256 alias :add_menu_item :menu
|
Chris@909
|
257
|
Chris@0
|
258 # Removes +item+ from the given +menu+.
|
Chris@0
|
259 def delete_menu_item(menu, item)
|
Chris@0
|
260 Redmine::MenuManager.map(menu).delete(item)
|
Chris@0
|
261 end
|
Chris@0
|
262
|
Chris@0
|
263 # Defines a permission called +name+ for the given +actions+.
|
Chris@909
|
264 #
|
Chris@0
|
265 # The +actions+ argument is a hash with controllers as keys and actions as values (a single value or an array):
|
Chris@0
|
266 # permission :destroy_contacts, { :contacts => :destroy }
|
Chris@0
|
267 # permission :view_contacts, { :contacts => [:index, :show] }
|
Chris@909
|
268 #
|
Chris@1115
|
269 # The +options+ argument is a hash that accept the following keys:
|
Chris@1115
|
270 # * :public => the permission is public if set to true (implicitly given to any user)
|
Chris@1115
|
271 # * :require => can be set to one of the following values to restrict users the permission can be given to: :loggedin, :member
|
Chris@1115
|
272 # * :read => set it to true so that the permission is still granted on closed projects
|
Chris@909
|
273 #
|
Chris@0
|
274 # Examples
|
Chris@0
|
275 # # A permission that is implicitly given to any user
|
Chris@0
|
276 # # This permission won't appear on the Roles & Permissions setup screen
|
Chris@1115
|
277 # permission :say_hello, { :example => :say_hello }, :public => true, :read => true
|
Chris@909
|
278 #
|
Chris@0
|
279 # # A permission that can be given to any user
|
Chris@0
|
280 # permission :say_hello, { :example => :say_hello }
|
Chris@909
|
281 #
|
Chris@0
|
282 # # A permission that can be given to registered users only
|
Chris@0
|
283 # permission :say_hello, { :example => :say_hello }, :require => :loggedin
|
Chris@909
|
284 #
|
Chris@0
|
285 # # A permission that can be given to project members only
|
Chris@0
|
286 # permission :say_hello, { :example => :say_hello }, :require => :member
|
Chris@0
|
287 def permission(name, actions, options = {})
|
Chris@0
|
288 if @project_module
|
Chris@0
|
289 Redmine::AccessControl.map {|map| map.project_module(@project_module) {|map|map.permission(name, actions, options)}}
|
Chris@0
|
290 else
|
Chris@0
|
291 Redmine::AccessControl.map {|map| map.permission(name, actions, options)}
|
Chris@0
|
292 end
|
Chris@0
|
293 end
|
Chris@909
|
294
|
Chris@0
|
295 # Defines a project module, that can be enabled/disabled for each project.
|
Chris@0
|
296 # Permissions defined inside +block+ will be bind to the module.
|
Chris@909
|
297 #
|
Chris@0
|
298 # project_module :things do
|
Chris@0
|
299 # permission :view_contacts, { :contacts => [:list, :show] }, :public => true
|
Chris@0
|
300 # permission :destroy_contacts, { :contacts => :destroy }
|
Chris@0
|
301 # end
|
Chris@0
|
302 def project_module(name, &block)
|
Chris@0
|
303 @project_module = name
|
Chris@0
|
304 self.instance_eval(&block)
|
Chris@0
|
305 @project_module = nil
|
Chris@0
|
306 end
|
Chris@909
|
307
|
Chris@0
|
308 # Registers an activity provider.
|
Chris@0
|
309 #
|
Chris@0
|
310 # Options:
|
Chris@0
|
311 # * <tt>:class_name</tt> - one or more model(s) that provide these events (inferred from event_type by default)
|
Chris@0
|
312 # * <tt>:default</tt> - setting this option to false will make the events not displayed by default
|
Chris@909
|
313 #
|
Chris@0
|
314 # A model can provide several activity event types.
|
Chris@909
|
315 #
|
Chris@0
|
316 # Examples:
|
Chris@0
|
317 # register :news
|
Chris@0
|
318 # register :scrums, :class_name => 'Meeting'
|
Chris@0
|
319 # register :issues, :class_name => ['Issue', 'Journal']
|
Chris@909
|
320 #
|
Chris@0
|
321 # Retrieving events:
|
Chris@0
|
322 # Associated model(s) must implement the find_events class method.
|
Chris@0
|
323 # ActiveRecord models can use acts_as_activity_provider as a way to implement this class method.
|
Chris@909
|
324 #
|
Chris@909
|
325 # The following call should return all the scrum events visible by current user that occured in the 5 last days:
|
Chris@0
|
326 # Meeting.find_events('scrums', User.current, 5.days.ago, Date.today)
|
Chris@0
|
327 # Meeting.find_events('scrums', User.current, 5.days.ago, Date.today, :project => foo) # events for project foo only
|
Chris@909
|
328 #
|
Chris@0
|
329 # Note that :view_scrums permission is required to view these events in the activity view.
|
Chris@0
|
330 def activity_provider(*args)
|
Chris@0
|
331 Redmine::Activity.register(*args)
|
Chris@0
|
332 end
|
Chris@909
|
333
|
Chris@0
|
334 # Registers a wiki formatter.
|
Chris@0
|
335 #
|
Chris@0
|
336 # Parameters:
|
Chris@0
|
337 # * +name+ - human-readable name
|
Chris@0
|
338 # * +formatter+ - formatter class, which should have an instance method +to_html+
|
Chris@0
|
339 # * +helper+ - helper module, which will be included by wiki pages
|
Chris@0
|
340 def wiki_format_provider(name, formatter, helper)
|
Chris@0
|
341 Redmine::WikiFormatting.register(name, formatter, helper)
|
Chris@0
|
342 end
|
Chris@0
|
343
|
Chris@0
|
344 # Returns +true+ if the plugin can be configured.
|
Chris@0
|
345 def configurable?
|
Chris@0
|
346 settings && settings.is_a?(Hash) && !settings[:partial].blank?
|
Chris@0
|
347 end
|
Chris@1115
|
348
|
Chris@1115
|
349 def mirror_assets
|
Chris@1115
|
350 source = assets_directory
|
Chris@1115
|
351 destination = public_directory
|
Chris@1115
|
352 return unless File.directory?(source)
|
Chris@1115
|
353
|
Chris@1115
|
354 source_files = Dir[source + "/**/*"]
|
Chris@1115
|
355 source_dirs = source_files.select { |d| File.directory?(d) }
|
Chris@1115
|
356 source_files -= source_dirs
|
Chris@1115
|
357
|
Chris@1115
|
358 unless source_files.empty?
|
Chris@1115
|
359 base_target_dir = File.join(destination, File.dirname(source_files.first).gsub(source, ''))
|
Chris@1115
|
360 begin
|
Chris@1115
|
361 FileUtils.mkdir_p(base_target_dir)
|
Chris@1115
|
362 rescue Exception => e
|
Chris@1115
|
363 raise "Could not create directory #{base_target_dir}: " + e.message
|
Chris@1115
|
364 end
|
Chris@1115
|
365 end
|
Chris@1115
|
366
|
Chris@1115
|
367 source_dirs.each do |dir|
|
Chris@1115
|
368 # strip down these paths so we have simple, relative paths we can
|
Chris@1115
|
369 # add to the destination
|
Chris@1115
|
370 target_dir = File.join(destination, dir.gsub(source, ''))
|
Chris@1115
|
371 begin
|
Chris@1115
|
372 FileUtils.mkdir_p(target_dir)
|
Chris@1115
|
373 rescue Exception => e
|
Chris@1115
|
374 raise "Could not create directory #{target_dir}: " + e.message
|
Chris@1115
|
375 end
|
Chris@1115
|
376 end
|
Chris@1115
|
377
|
Chris@1115
|
378 source_files.each do |file|
|
Chris@1115
|
379 begin
|
Chris@1115
|
380 target = File.join(destination, file.gsub(source, ''))
|
Chris@1115
|
381 unless File.exist?(target) && FileUtils.identical?(file, target)
|
Chris@1115
|
382 FileUtils.cp(file, target)
|
Chris@1115
|
383 end
|
Chris@1115
|
384 rescue Exception => e
|
Chris@1115
|
385 raise "Could not copy #{file} to #{target}: " + e.message
|
Chris@1115
|
386 end
|
Chris@1115
|
387 end
|
Chris@1115
|
388 end
|
Chris@1115
|
389
|
Chris@1115
|
390 # Mirrors assets from one or all plugins to public/plugin_assets
|
Chris@1115
|
391 def self.mirror_assets(name=nil)
|
Chris@1115
|
392 if name.present?
|
Chris@1115
|
393 find(name).mirror_assets
|
Chris@1115
|
394 else
|
Chris@1115
|
395 all.each do |plugin|
|
Chris@1115
|
396 plugin.mirror_assets
|
Chris@1115
|
397 end
|
Chris@1115
|
398 end
|
Chris@1115
|
399 end
|
Chris@1115
|
400
|
Chris@1115
|
401 # The directory containing this plugin's migrations (<tt>plugin/db/migrate</tt>)
|
Chris@1115
|
402 def migration_directory
|
Chris@1115
|
403 File.join(Rails.root, 'plugins', id.to_s, 'db', 'migrate')
|
Chris@1115
|
404 end
|
Chris@1115
|
405
|
Chris@1115
|
406 # Returns the version number of the latest migration for this plugin. Returns
|
Chris@1115
|
407 # nil if this plugin has no migrations.
|
Chris@1115
|
408 def latest_migration
|
Chris@1115
|
409 migrations.last
|
Chris@1115
|
410 end
|
Chris@1115
|
411
|
Chris@1115
|
412 # Returns the version numbers of all migrations for this plugin.
|
Chris@1115
|
413 def migrations
|
Chris@1115
|
414 migrations = Dir[migration_directory+"/*.rb"]
|
Chris@1115
|
415 migrations.map { |p| File.basename(p).match(/0*(\d+)\_/)[1].to_i }.sort
|
Chris@1115
|
416 end
|
Chris@1115
|
417
|
Chris@1115
|
418 # Migrate this plugin to the given version
|
Chris@1115
|
419 def migrate(version = nil)
|
Chris@1115
|
420 puts "Migrating #{id} (#{name})..."
|
Chris@1115
|
421 Redmine::Plugin::Migrator.migrate_plugin(self, version)
|
Chris@1115
|
422 end
|
Chris@1115
|
423
|
Chris@1115
|
424 # Migrates all plugins or a single plugin to a given version
|
Chris@1115
|
425 # Exemples:
|
Chris@1115
|
426 # Plugin.migrate
|
Chris@1115
|
427 # Plugin.migrate('sample_plugin')
|
Chris@1115
|
428 # Plugin.migrate('sample_plugin', 1)
|
Chris@1115
|
429 #
|
Chris@1115
|
430 def self.migrate(name=nil, version=nil)
|
Chris@1115
|
431 if name.present?
|
Chris@1115
|
432 find(name).migrate(version)
|
Chris@1115
|
433 else
|
Chris@1115
|
434 all.each do |plugin|
|
Chris@1115
|
435 plugin.migrate
|
Chris@1115
|
436 end
|
Chris@1115
|
437 end
|
Chris@1115
|
438 end
|
Chris@1115
|
439
|
Chris@1115
|
440 class Migrator < ActiveRecord::Migrator
|
Chris@1115
|
441 # We need to be able to set the 'current' plugin being migrated.
|
Chris@1115
|
442 cattr_accessor :current_plugin
|
Chris@1115
|
443
|
Chris@1115
|
444 class << self
|
Chris@1115
|
445 # Runs the migrations from a plugin, up (or down) to the version given
|
Chris@1115
|
446 def migrate_plugin(plugin, version)
|
Chris@1115
|
447 self.current_plugin = plugin
|
Chris@1115
|
448 return if current_version(plugin) == version
|
Chris@1115
|
449 migrate(plugin.migration_directory, version)
|
Chris@1115
|
450 end
|
Chris@1115
|
451
|
Chris@1115
|
452 def current_version(plugin=current_plugin)
|
Chris@1115
|
453 # Delete migrations that don't match .. to_i will work because the number comes first
|
Chris@1115
|
454 ::ActiveRecord::Base.connection.select_values(
|
Chris@1115
|
455 "SELECT version FROM #{schema_migrations_table_name}"
|
Chris@1115
|
456 ).delete_if{ |v| v.match(/-#{plugin.id}/) == nil }.map(&:to_i).max || 0
|
Chris@1115
|
457 end
|
Chris@1115
|
458 end
|
Chris@1115
|
459
|
Chris@1115
|
460 def migrated
|
Chris@1115
|
461 sm_table = self.class.schema_migrations_table_name
|
Chris@1115
|
462 ::ActiveRecord::Base.connection.select_values(
|
Chris@1115
|
463 "SELECT version FROM #{sm_table}"
|
Chris@1115
|
464 ).delete_if{ |v| v.match(/-#{current_plugin.id}/) == nil }.map(&:to_i).sort
|
Chris@1115
|
465 end
|
Chris@1115
|
466
|
Chris@1115
|
467 def record_version_state_after_migrating(version)
|
Chris@1115
|
468 super(version.to_s + "-" + current_plugin.id.to_s)
|
Chris@1115
|
469 end
|
Chris@1115
|
470 end
|
Chris@0
|
471 end
|
Chris@0
|
472 end
|