]> git.netwichtig.de Git - user/henk/code/ruby/rbot.git/blob - lib/rbot/plugins.rb
+ ModeChangeMessage class
[user/henk/code/ruby/rbot.git] / lib / rbot / plugins.rb
1 #-- vim:sw=2:et
2 #++
3 #
4 # :title: rbot plugin management
5
6 require 'singleton'
7
8 module Irc
9 class Bot
10     Config.register Config::ArrayValue.new('plugins.blacklist',
11       :default => [], :wizard => false, :requires_rescan => true,
12       :desc => "Plugins that should not be loaded")
13 module Plugins
14   require 'rbot/messagemapper'
15
16 =begin rdoc
17   BotModule is the base class for the modules that enhance the rbot
18   functionality. Rather than subclassing BotModule, however, one should
19   subclass either CoreBotModule (reserved for system modules) or Plugin
20   (for user plugins).
21
22   A BotModule interacts with Irc events by defining one or more of the following
23   methods, which get called as appropriate when the corresponding Irc event
24   happens.
25
26   map(template, options)::
27   map!(template, options)::
28      map is the new, cleaner way to respond to specific message formats without
29      littering your plugin code with regexps, and should be used instead of
30      #register() and #privmsg() (see below) when possible.
31
32      The difference between map and map! is that map! will not register the new
33      command as an alternative name for the plugin.
34
35      Examples:
36
37        plugin.map 'karmastats', :action => 'karma_stats'
38
39        # while in the plugin...
40        def karma_stats(m, params)
41          m.reply "..."
42        end
43
44        # the default action is the first component
45        plugin.map 'karma'
46
47        # attributes can be pulled out of the match string
48        plugin.map 'karma for :key'
49        plugin.map 'karma :key'
50
51        # while in the plugin...
52        def karma(m, params)
53          item = params[:key]
54          m.reply 'karma for #{item}'
55        end
56
57        # you can setup defaults, to make parameters optional
58        plugin.map 'karma :key', :defaults => {:key => 'defaultvalue'}
59
60        # the default auth check is also against the first component
61        # but that can be changed
62        plugin.map 'karmastats', :auth => 'karma'
63
64        # maps can be restricted to public or private message:
65        plugin.map 'karmastats', :private => false
66        plugin.map 'karmastats', :public => false
67
68      See MessageMapper#map for more information on the template format and the
69      allowed options.
70
71   listen(UserMessage)::
72                          Called for all messages of any type. To
73                          differentiate them, use message.kind_of? It'll be
74                          either a PrivMessage, NoticeMessage, KickMessage,
75                          QuitMessage, PartMessage, JoinMessage, NickMessage,
76                          etc.
77
78   ctcp_listen(UserMessage)::
79                          Called for all messages that contain a CTCP command.
80                          Use message.ctcp to get the CTCP command, and
81                          message.message to get the parameter string. To reply,
82                          use message.ctcp_reply, which sends a private NOTICE
83                          to the sender.
84
85   message(PrivMessage)::
86                          Called for all PRIVMSG. Hook on this method if you
87                          need to handle PRIVMSGs regardless of whether they are
88                          addressed to the bot or not, and regardless of
89
90   privmsg(PrivMessage)::
91                          Called for a PRIVMSG if the first word matches one
92                          the plugin #register()ed for. Use m.plugin to get
93                          that word and m.params for the rest of the message,
94                          if applicable.
95
96   unreplied(PrivMessage)::
97                          Called for a PRIVMSG which has not been replied to.
98
99   notice(NoticeMessage)::
100                          Called for all Notices. Please notice that in general
101                          should not be replied to.
102
103   kick(KickMessage)::
104                          Called when a user (or the bot) is kicked from a
105                          channel the bot is in.
106
107   invite(InviteMessage)::
108                          Called when the bot is invited to a channel.
109
110   join(JoinMessage)::
111                          Called when a user (or the bot) joins a channel
112
113   part(PartMessage)::
114                          Called when a user (or the bot) parts a channel
115
116   quit(QuitMessage)::
117                          Called when a user (or the bot) quits IRC
118
119   nick(NickMessage)::
120                          Called when a user (or the bot) changes Nick
121   modechange(ModeChangeMessage)::
122                          Called when a User or Channel mode is changed
123   topic(TopicMessage)::
124                          Called when a user (or the bot) changes a channel
125                          topic
126
127   welcome(WelcomeMessage)::
128                          Called when the welcome message is received on
129                          joining a server succesfully.
130
131   motd(MotdMessage)::
132                          Called when the Message Of The Day is fully
133                          recevied from the server.
134
135   connect::              Called when a server is joined successfully, but
136                          before autojoin channels are joined (no params)
137
138   set_language(String)::
139                          Called when the user sets a new language
140                          whose name is the given String
141
142   save::                 Called when you are required to save your plugin's
143                          state, if you maintain data between sessions
144
145   cleanup::              called before your plugin is "unloaded", prior to a
146                          plugin reload or bot quit - close any open
147                          files/connections or flush caches here
148 =end
149
150   class BotModule
151     # the associated bot
152     attr_reader :bot
153
154     # the plugin registry
155     attr_reader :registry
156
157     # the message map handler
158     attr_reader :handler
159
160     # Initialise your bot module. Always call super if you override this method,
161     # as important variables are set up for you:
162     #
163     # @bot::
164     #   the rbot instance
165     # @registry::
166     #   the botmodule's registry, which can be used to store permanent data
167     #   (see Registry::Accessor for additional documentation)
168     #
169     # Other instance variables which are defined and should not be overwritten
170     # byt the user, but aren't usually accessed directly, are:
171     #
172     # @manager::
173     #   the plugins manager instance
174     # @botmodule_triggers::
175     #   an Array of words this plugin #register()ed itself for
176     # @handler::
177     #   the MessageMapper that handles this plugin's maps
178     #
179     def initialize
180       @manager = Plugins::manager
181       @bot = @manager.bot
182
183       @botmodule_triggers = Array.new
184
185       @handler = MessageMapper.new(self)
186       @registry = Registry::Accessor.new(@bot, self.class.to_s.gsub(/^.*::/, ""))
187
188       @manager.add_botmodule(self)
189       if self.respond_to?('set_language')
190         self.set_language(@bot.lang.language)
191       end
192     end
193
194     # Changing the value of @priority directly will cause problems,
195     # Please use priority=.
196     def priority
197       @priority ||= 1
198     end
199
200     # Returns the symbol :BotModule 
201     def botmodule_class
202       :BotModule
203     end
204
205     # Method called to flush the registry, thus ensuring that the botmodule's permanent
206     # data is committed to disk
207     #
208     def flush_registry
209       # debug "Flushing #{@registry}"
210       @registry.flush
211     end
212
213     # Method called to cleanup before the plugin is unloaded. If you overload
214     # this method to handle additional cleanup tasks, remember to call super()
215     # so that the default cleanup actions are taken care of as well.
216     #
217     def cleanup
218       # debug "Closing #{@registry}"
219       @registry.close
220     end
221
222     # Handle an Irc::PrivMessage for which this BotModule has a map. The method
223     # is called automatically and there is usually no need to call it
224     # explicitly.
225     #
226     def handle(m)
227       @handler.handle(m)
228     end
229
230     # Signal to other BotModules that an even happened.
231     #
232     def call_event(ev, *args)
233       @bot.plugins.delegate('event_' + ev.to_s.gsub(/[^\w\?!]+/, '_'), *args)
234     end
235
236     # call-seq: map(template, options)
237     #
238     # This is the preferred way to register the BotModule so that it
239     # responds to appropriately-formed messages on Irc.
240     #
241     def map(*args)
242       do_map(false, *args)
243     end
244
245     # call-seq: map!(template, options)
246     #
247     # This is the same as map but doesn't register the new command
248     # as an alternative name for the plugin.
249     #
250     def map!(*args)
251       do_map(true, *args)
252     end
253
254     # Auxiliary method called by #map and #map!
255     def do_map(silent, *args)
256       @handler.map(self, *args)
257       # register this map
258       map = @handler.last
259       name = map.items[0]
260       self.register name, :auth => nil, :hidden => silent
261       @manager.register_map(self, map)
262       unless self.respond_to?('privmsg')
263         def self.privmsg(m) #:nodoc:
264           handle(m)
265         end
266       end
267     end
268
269     # Sets the default auth for command path _cmd_ to _val_ on channel _chan_:
270     # usually _chan_ is either "*" for everywhere, public and private (in which
271     # case it can be omitted) or "?" for private communications
272     #
273     def default_auth(cmd, val, chan="*")
274       case cmd
275       when "*", ""
276         c = nil
277       else
278         c = cmd
279       end
280       Auth::defaultbotuser.set_default_permission(propose_default_path(c), val)
281     end
282
283     # Gets the default command path which would be given to command _cmd_
284     def propose_default_path(cmd)
285       [name, cmd].compact.join("::")
286     end
287
288     # Return an identifier for this plugin, defaults to a list of the message
289     # prefixes handled (used for error messages etc)
290     def name
291       self.class.to_s.downcase.sub(/^#<module:.*?>::/,"").sub(/(plugin|module)?$/,"")
292     end
293
294     # Just calls name
295     def to_s
296       name
297     end
298
299     # Intern the name
300     def to_sym
301       self.name.to_sym
302     end
303
304     # Return a help string for your module. For complex modules, you may wish
305     # to break your help into topics, and return a list of available topics if
306     # +topic+ is nil. +plugin+ is passed containing the matching prefix for
307     # this message - if your plugin handles multiple prefixes, make sure you
308     # return the correct help for the prefix requested
309     def help(plugin, topic)
310       "no help"
311     end
312
313     # Register the plugin as a handler for messages prefixed _cmd_.
314     #
315     # This can be called multiple times for a plugin to handle multiple message
316     # prefixes.
317     #
318     # This command is now superceded by the #map() command, which should be used
319     # instead whenever possible.
320     # 
321     def register(cmd, opts={})
322       raise ArgumentError, "Second argument must be a hash!" unless opts.kind_of?(Hash)
323       who = @manager.who_handles?(cmd)
324       if who
325         raise "Command #{cmd} is already handled by #{who.botmodule_class} #{who}" if who != self
326         return
327       end
328       if opts.has_key?(:auth)
329         @manager.register(self, cmd, opts[:auth])
330       else
331         @manager.register(self, cmd, propose_default_path(cmd))
332       end
333       @botmodule_triggers << cmd unless opts.fetch(:hidden, false)
334     end
335
336     # Default usage method provided as a utility for simple plugins. The
337     # MessageMapper uses 'usage' as its default fallback method.
338     #
339     def usage(m, params = {})
340       m.reply(_("incorrect usage, ask for help using '%{command}'") % {:command => "#{@bot.nick}: help #{m.plugin}"})
341     end
342
343     # Define the priority of the module.  During event delegation, lower 
344     # priority modules will be called first.  Default priority is 1
345     def priority=(prio)
346       if @priority != prio
347         @priority = prio
348         @bot.plugins.mark_priorities_dirty
349       end
350     end
351   end
352
353   # A CoreBotModule is a BotModule that provides core functionality.
354   #
355   # This class should not be used by user plugins, as it's reserved for system
356   # plugins such as the ones that handle authentication, configuration and basic
357   # functionality.
358   #
359   class CoreBotModule < BotModule
360     def botmodule_class
361       :CoreBotModule
362     end
363   end
364
365   # A Plugin is a BotModule that provides additional functionality.
366   #
367   # A user-defined plugin should subclass this, and then define any of the
368   # methods described in the documentation for BotModule to handle interaction
369   # with Irc events.
370   #
371   class Plugin < BotModule
372     def botmodule_class
373       :Plugin
374     end
375   end
376
377   # Singleton to manage multiple plugins and delegate messages to them for
378   # handling
379   class PluginManagerClass
380     include Singleton
381     attr_reader :bot
382     attr_reader :botmodules
383     attr_reader :maps
384
385     # This is the list of patterns commonly delegated to plugins.
386     # A fast delegation lookup is enabled for them.
387     DEFAULT_DELEGATE_PATTERNS = %r{^(?:
388       connect|names|nick|
389       listen|ctcp_listen|privmsg|unreplied|
390       kick|join|part|quit|
391       save|cleanup|flush_registry|
392       set_.*|event_.*
393     )$}x
394
395     def initialize
396       @botmodules = {
397         :CoreBotModule => [],
398         :Plugin => []
399       }
400
401       @names_hash = Hash.new
402       @commandmappers = Hash.new
403       @maps = Hash.new
404
405       # modules will be sorted on first delegate call
406       @sorted_modules = nil
407
408       @delegate_list = Hash.new { |h, k|
409         h[k] = Array.new
410       }
411
412       @dirs = []
413
414       @failed = Array.new
415       @ignored = Array.new
416
417       bot_associate(nil)
418     end
419
420     def inspect
421       ret = self.to_s[0..-2]
422       ret << ' corebotmodules='
423       ret << @botmodules[:CoreBotModule].map { |m|
424         m.name
425       }.inspect
426       ret << ' plugins='
427       ret << @botmodules[:Plugin].map { |m|
428         m.name
429       }.inspect
430       ret << ">"
431     end
432
433     # Reset lists of botmodules
434     def reset_botmodule_lists
435       @botmodules[:CoreBotModule].clear
436       @botmodules[:Plugin].clear
437       @names_hash.clear
438       @commandmappers.clear
439       @maps.clear
440       @failures_shown = false
441       mark_priorities_dirty
442     end
443
444     # Associate with bot _bot_
445     def bot_associate(bot)
446       reset_botmodule_lists
447       @bot = bot
448     end
449
450     # Returns the botmodule with the given _name_
451     def [](name)
452       @names_hash[name.to_sym]
453     end
454
455     # Returns +true+ if _cmd_ has already been registered as a command
456     def who_handles?(cmd)
457       return nil unless @commandmappers.has_key?(cmd.to_sym)
458       return @commandmappers[cmd.to_sym][:botmodule]
459     end
460
461     # Registers botmodule _botmodule_ with command _cmd_ and command path _auth_path_
462     def register(botmodule, cmd, auth_path)
463       raise TypeError, "First argument #{botmodule.inspect} is not of class BotModule" unless botmodule.kind_of?(BotModule)
464       @commandmappers[cmd.to_sym] = {:botmodule => botmodule, :auth => auth_path}
465     end
466
467     # Registers botmodule _botmodule_ with map _map_. This adds the map to the #maps hash
468     # which has three keys:
469     #
470     # botmodule:: the associated botmodule
471     # auth:: an array of auth keys checked by the map; the first is the full_auth_path of the map
472     # map:: the actual MessageTemplate object
473     #
474     #
475     def register_map(botmodule, map)
476       raise TypeError, "First argument #{botmodule.inspect} is not of class BotModule" unless botmodule.kind_of?(BotModule)
477       @maps[map.template] = { :botmodule => botmodule, :auth => [map.options[:full_auth_path]], :map => map }
478     end
479
480     def add_botmodule(botmodule)
481       raise TypeError, "Argument #{botmodule.inspect} is not of class BotModule" unless botmodule.kind_of?(BotModule)
482       kl = botmodule.botmodule_class
483       if @names_hash.has_key?(botmodule.to_sym)
484         case self[botmodule].botmodule_class
485         when kl
486           raise "#{kl} #{botmodule} already registered!"
487         else
488           raise "#{self[botmodule].botmodule_class} #{botmodule} already registered, cannot re-register as #{kl}"
489         end
490       end
491       @botmodules[kl] << botmodule
492       @names_hash[botmodule.to_sym] = botmodule
493       mark_priorities_dirty
494     end
495
496     # Returns an array of the loaded plugins
497     def core_modules
498       @botmodules[:CoreBotModule]
499     end
500
501     # Returns an array of the loaded plugins
502     def plugins
503       @botmodules[:Plugin]
504     end
505
506     # Returns a hash of the registered message prefixes and associated
507     # plugins
508     def commands
509       @commandmappers
510     end
511
512     # Tells the PluginManager that the next time it delegates an event, it
513     # should sort the modules by priority
514     def mark_priorities_dirty
515       @sorted_modules = nil
516     end
517
518     # Makes a string of error _err_ by adding text _str_
519     def report_error(str, err)
520       ([str, err.inspect] + err.backtrace).join("\n")
521     end
522
523     # This method is the one that actually loads a module from the
524     # file _fname_
525     #
526     # _desc_ is a simple description of what we are loading (plugin/botmodule/whatever)
527     #
528     # It returns the Symbol :loaded on success, and an Exception
529     # on failure
530     #
531     def load_botmodule_file(fname, desc=nil)
532       # create a new, anonymous module to "house" the plugin
533       # the idea here is to prevent namespace pollution. perhaps there
534       # is another way?
535       plugin_module = Module.new
536
537       desc = desc.to_s + " " if desc
538
539       begin
540         plugin_string = IO.readlines(fname).join("")
541         debug "loading #{desc}#{fname}"
542         plugin_module.module_eval(plugin_string, fname)
543         return :loaded
544       rescue Exception => err
545         # rescue TimeoutError, StandardError, NameError, LoadError, SyntaxError => err
546         error report_error("#{desc}#{fname} load failed", err)
547         bt = err.backtrace.select { |line|
548           line.match(/^(\(eval\)|#{fname}):\d+/)
549         }
550         bt.map! { |el|
551           el.gsub(/^\(eval\)(:\d+)(:in `.*')?(:.*)?/) { |m|
552             "#{fname}#{$1}#{$3}"
553           }
554         }
555         msg = err.to_str.gsub(/^\(eval\)(:\d+)(:in `.*')?(:.*)?/) { |m|
556           "#{fname}#{$1}#{$3}"
557         }
558         newerr = err.class.new(msg)
559         newerr.set_backtrace(bt)
560         return newerr
561       end
562     end
563     private :load_botmodule_file
564
565     # add one or more directories to the list of directories to
566     # load botmodules from
567     #
568     # TODO find a way to specify necessary plugins which _must_ be loaded
569     #
570     def add_botmodule_dir(*dirlist)
571       @dirs += dirlist
572       debug "Botmodule loading path: #{@dirs.join(', ')}"
573     end
574
575     def clear_botmodule_dirs
576       @dirs.clear
577       debug "Botmodule loading path cleared"
578     end
579
580     # load plugins from pre-assigned list of directories
581     def scan
582       @failed.clear
583       @ignored.clear
584       @delegate_list.clear
585
586       processed = Hash.new
587
588       @bot.config['plugins.blacklist'].each { |p|
589         pn = p + ".rb"
590         processed[pn.intern] = :blacklisted
591       }
592
593       dirs = @dirs
594       dirs.each {|dir|
595         if(FileTest.directory?(dir))
596           d = Dir.new(dir)
597           d.sort.each {|file|
598
599             next if(file =~ /^\./)
600
601             if processed.has_key?(file.intern)
602               @ignored << {:name => file, :dir => dir, :reason => processed[file.intern]}
603               next
604             end
605
606             if(file =~ /^(.+\.rb)\.disabled$/)
607               # GB: Do we want to do this? This means that a disabled plugin in a directory
608               #     will disable in all subsequent directories. This was probably meant
609               #     to be used before plugins.blacklist was implemented, so I think
610               #     we don't need this anymore
611               processed[$1.intern] = :disabled
612               @ignored << {:name => $1, :dir => dir, :reason => processed[$1.intern]}
613               next
614             end
615
616             next unless(file =~ /\.rb$/)
617
618             did_it = load_botmodule_file("#{dir}/#{file}", "plugin")
619             case did_it
620             when Symbol
621               processed[file.intern] = did_it
622             when Exception
623               @failed <<  { :name => file, :dir => dir, :reason => did_it }
624             end
625
626           }
627         end
628       }
629       debug "finished loading plugins: #{status(true)}"
630       (core_modules + plugins).each { |p|
631        p.methods.grep(DEFAULT_DELEGATE_PATTERNS).each { |m|
632          @delegate_list[m.intern] << p
633        }
634       }
635       mark_priorities_dirty
636     end
637
638     # call the save method for each active plugin
639     def save
640       delegate 'flush_registry'
641       delegate 'save'
642     end
643
644     # call the cleanup method for each active plugin
645     def cleanup
646       delegate 'cleanup'
647       reset_botmodule_lists
648     end
649
650     # drop all plugins and rescan plugins on disk
651     # calls save and cleanup for each plugin before dropping them
652     def rescan
653       save
654       cleanup
655       scan
656     end
657
658     def status(short=false)
659       output = []
660       if self.core_length > 0
661         if short
662           output << n_("%{count} core module loaded", "%{count} core modules loaded",
663                     self.core_length) % {:count => self.core_length}
664         else
665           output <<  n_("%{count} core module: %{list}",
666                      "%{count} core modules: %{list}", self.core_length) %
667                      { :count => self.core_length,
668                        :list => core_modules.collect{ |p| p.name}.sort.join(", ") }
669         end
670       else
671         output << _("no core botmodules loaded")
672       end
673       # Active plugins first
674       if(self.length > 0)
675         if short
676           output << n_("%{count} plugin loaded", "%{count} plugins loaded",
677                        self.length) % {:count => self.length}
678         else
679           output << n_("%{count} plugin: %{list}",
680                        "%{count} plugins: %{list}", self.length) %
681                    { :count => self.length,
682                      :list => plugins.collect{ |p| p.name}.sort.join(", ") }
683         end
684       else
685         output << "no plugins active"
686       end
687       # Ignored plugins next
688       unless @ignored.empty? or @failures_shown
689         if short
690           output << n_("%{highlight}%{count} plugin ignored%{highlight}",
691                        "%{highlight}%{count} plugins ignored%{highlight}",
692                        @ignored.length) %
693                     { :count => @ignored.length, :highlight => Underline }
694         else
695           output << n_("%{highlight}%{count} plugin ignored%{highlight}: use %{bold}%{command}%{bold} to see why",
696                        "%{highlight}%{count} plugins ignored%{highlight}: use %{bold}%{command}%{bold} to see why",
697                        @ignored.length) %
698                     { :count => @ignored.length, :highlight => Underline,
699                       :bold => Bold, :command => "help ignored plugins"}
700         end
701       end
702       # Failed plugins next
703       unless @failed.empty? or @failures_shown
704         if short
705           output << n_("%{highlight}%{count} plugin failed to load%{highlight}",
706                        "%{highlight}%{count} plugins failed to load%{highlight}",
707                        @failed.length) %
708                     { :count => @failed.length, :highlight => Reverse }
709         else
710           output << n_("%{highlight}%{count} plugin failed to load%{highlight}: use %{bold}%{command}%{bold} to see why",
711                        "%{highlight}%{count} plugins failed to load%{highlight}: use %{bold}%{command}%{bold} to see why",
712                        @failed.length) %
713                     { :count => @failed.length, :highlight => Reverse,
714                       :bold => Bold, :command => "help failed plugins"}
715         end
716       end
717       output.join '; '
718     end
719
720     # return list of help topics (plugin names)
721     def helptopics
722       rv = status
723       @failures_shown = true
724       rv
725     end
726
727     def length
728       plugins.length
729     end
730
731     def core_length
732       core_modules.length
733     end
734
735     # return help for +topic+ (call associated plugin's help method)
736     def help(topic="")
737       case topic
738       when /fail(?:ed)?\s*plugins?.*(trace(?:back)?s?)?/
739         # debug "Failures: #{@failed.inspect}"
740         return _("no plugins failed to load") if @failed.empty?
741         return @failed.collect { |p|
742           _('%{highlight}%{plugin}%{highlight} in %{dir} failed with error %{exception}: %{reason}') % {
743               :highlight => Bold, :plugin => p[:name], :dir => p[:dir],
744               :exception => p[:reason].class, :reason => p[:reason],
745           } + if $1 && !p[:reason].backtrace.empty?
746                 _('at %{backtrace}') % {:backtrace => p[:reason].backtrace.join(', ')}
747               else
748                 ''
749               end
750         }.join("\n")
751       when /ignored?\s*plugins?/
752         return _('no plugins were ignored') if @ignored.empty?
753
754         tmp = Hash.new
755         @ignored.each do |p|
756           reason = p[:loaded] ? _('overruled by previous') : _(p[:reason].to_s)
757           ((tmp[p[:dir]] ||= Hash.new)[reason] ||= Array.new).push(p[:name])
758         end
759
760         return tmp.map do |dir, reasons|
761           # FIXME get rid of these string concatenations to make gettext easier
762           s = reasons.map { |r, list|
763             list.map { |_| _.sub(/\.rb$/, '') }.join(', ') + " (#{r})"
764           }.join('; ')
765           "in #{dir}: #{s}"
766         end.join('; ')
767       when /^(\S+)\s*(.*)$/
768         key = $1
769         params = $2
770
771         # Let's see if we can match a plugin by the given name
772         (core_modules + plugins).each { |p|
773           next unless p.name == key
774           begin
775             return p.help(key, params)
776           rescue Exception => err
777             #rescue TimeoutError, StandardError, NameError, SyntaxError => err
778             error report_error("#{p.botmodule_class} #{p.name} help() failed:", err)
779           end
780         }
781
782         # Nope, let's see if it's a command, and ask for help at the corresponding botmodule
783         k = key.to_sym
784         if commands.has_key?(k)
785           p = commands[k][:botmodule]
786           begin
787             return p.help(key, params)
788           rescue Exception => err
789             #rescue TimeoutError, StandardError, NameError, SyntaxError => err
790             error report_error("#{p.botmodule_class} #{p.name} help() failed:", err)
791           end
792         end
793       end
794       return false
795     end
796
797     def sort_modules
798       @sorted_modules = (core_modules + plugins).sort do |a, b| 
799         a.priority <=> b.priority
800       end || []
801
802       @delegate_list.each_value do |list|
803         list.sort! {|a,b| a.priority <=> b.priority}
804       end
805     end
806
807     # see if each plugin handles +method+, and if so, call it, passing
808     # +message+ as a parameter.  botmodules are called in order of priority
809     # from lowest to highest.
810     #
811     # If the passed +message+ is marked as +#ignored?+, it will only be
812     # delegated to plugins with negative priority. Conversely, if it's
813     # a fake message  (see BotModule#fake_message), it will only be
814     # delegated to plugins with positive priority.
815     #
816     # For delegation with more extensive options, see delegate_event
817     #
818     def delegate(method, *args)
819       opts = {:args => args}
820       m = args.first
821       if BasicUserMessage === m
822         # ignored messages should not be delegated
823         # to plugins with positive priority
824         opts[:below] = 0 if m.ignored?
825         # fake messages should not be delegated
826         # to plugins with negative priority
827         opts[:above] = 0 if m.recurse_depth > 0
828       end
829       delegate_event(method, opts)
830     end
831
832     # see if each plugin handles +method+, and if so, call it, passing
833     # +opts[:args]+ as a parameter.  +opts[:above]+ and +opts[:below]+
834     # are used for a threshold of botmodule priorities that will be called.
835     # If :above is defined, only botmodules with a priority above the value
836     # will be called, for example.  botmodules are called in order of
837     # priority from lowest to hightest.
838     def delegate_event(method, o={})
839       # if the priorities order of the delegate list is dirty,
840       # meaning some modules have been added or priorities have been
841       # changed, then the delegate list will need to be sorted before
842       # delegation.  This should always be true for the first delegation.
843       sort_modules unless @sorted_modules
844
845       # set defaults
846       opts = {:args => []}.merge(o)
847
848       above = opts[:above]
849       below = opts[:below]
850       args = opts[:args]
851
852       # debug "Delegating #{method.inspect}"
853       ret = Array.new
854       if method.match(DEFAULT_DELEGATE_PATTERNS)
855         debug "fast-delegating #{method}"
856         m = method.to_sym
857         debug "no-one to delegate to" unless @delegate_list.has_key?(m)
858         return [] unless @delegate_list.has_key?(m)
859         @delegate_list[m].each { |p|
860           begin
861             prio = p.priority
862             unless (above and above >= prio) or (below and below <= prio)
863               ret.push p.send(method, *(args||[]))
864             end
865           rescue Exception => err
866             raise if err.kind_of?(SystemExit)
867             error report_error("#{p.botmodule_class} #{p.name} #{method}() failed:", err)
868             raise if err.kind_of?(BDB::Fatal)
869           end
870         }
871       else
872         debug "slow-delegating #{method}"
873         @sorted_modules.each { |p|
874           if(p.respond_to? method)
875             begin
876               # debug "#{p.botmodule_class} #{p.name} responds"
877               prio = p.priority
878               unless (above and above >= prio) or (below and below <= prio)
879                 ret.push p.send(method, *(args||[]))
880               end
881             rescue Exception => err
882               raise if err.kind_of?(SystemExit)
883               error report_error("#{p.botmodule_class} #{p.name} #{method}() failed:", err)
884               raise if err.kind_of?(BDB::Fatal)
885             end
886           end
887         }
888       end
889       return ret
890       # debug "Finished delegating #{method.inspect}"
891     end
892
893     # see if we have a plugin that wants to handle this message, if so, pass
894     # it to the plugin and return true, otherwise false
895     def privmsg(m)
896       debug "Delegating privmsg #{m.inspect} with pluginkey #{m.plugin.inspect}"
897       return unless m.plugin
898       k = m.plugin.to_sym
899       if commands.has_key?(k)
900         p = commands[k][:botmodule]
901         a = commands[k][:auth]
902         # We check here for things that don't check themselves
903         # (e.g. mapped things)
904         debug "Checking auth ..."
905         if a.nil? || @bot.auth.allow?(a, m.source, m.replyto)
906           debug "Checking response ..."
907           if p.respond_to?("privmsg")
908             begin
909               debug "#{p.botmodule_class} #{p.name} responds"
910               p.privmsg(m)
911             rescue Exception => err
912               raise if err.kind_of?(SystemExit)
913               error report_error("#{p.botmodule_class} #{p.name} privmsg() failed:", err)
914               raise if err.kind_of?(BDB::Fatal)
915             end
916             debug "Successfully delegated #{m.inspect}"
917             return true
918           else
919             debug "#{p.botmodule_class} #{p.name} is registered, but it doesn't respond to privmsg()"
920           end
921         else
922           debug "#{p.botmodule_class} #{p.name} is registered, but #{m.source} isn't allowed to call #{m.plugin.inspect} on #{m.replyto}"
923         end
924       else
925         debug "Command #{k} isn't handled"
926       end
927       return false
928     end
929
930     # delegate IRC messages, by delegating 'listen' first, and the actual method
931     # afterwards. Delegating 'privmsg' also delegates ctcp_listen and message
932     # as appropriate.
933     def irc_delegate(method, m)
934       delegate('listen', m)
935       if method.to_sym == :privmsg
936         delegate('ctcp_listen', m) if m.ctcp
937         delegate('message', m)
938         privmsg(m) if m.address?
939         delegate('unreplied', m) unless m.replied
940       else
941         delegate(method, m)
942       end
943     end
944   end
945
946   # Returns the only PluginManagerClass instance
947   def Plugins.manager
948     return PluginManagerClass.instance
949   end
950
951 end
952 end
953 end