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