X-Git-Url: https://git.netwichtig.de/gitweb/?a=blobdiff_plain;f=lib%2Frbot%2Fplugins.rb;h=6f308609f55d1adb60eac2060504399d07af71ee;hb=d06b96bf95563cea4ebf31e2e324536d812efdbd;hp=54b814e0eb400c89e5c58c09c0f017a3141ce93d;hpb=2ed83d89e5fad7d0bed1003fdc60b538a4187162;p=user%2Fhenk%2Fcode%2Fruby%2Frbot.git diff --git a/lib/rbot/plugins.rb b/lib/rbot/plugins.rb index 54b814e0..6f308609 100644 --- a/lib/rbot/plugins.rb +++ b/lib/rbot/plugins.rb @@ -1,217 +1,582 @@ +#-- vim:sw=2:et +#++ +# +# :title: rbot plugin management + +require 'singleton' + module Irc +class Bot + Config.register Config::ArrayValue.new('plugins.blacklist', + :default => [], :wizard => false, :requires_rescan => true, + :desc => "Plugins that should not be loaded") module Plugins require 'rbot/messagemapper' - # base class for all rbot plugins - # certain methods will be called if they are provided, if you define one of - # the following methods, it will be called as appropriate: - # - # map(template, options):: - # map is the new, cleaner way to respond to specific message formats - # without littering your plugin code with regexps. examples: - # - # plugin.map 'karmastats', :action => 'karma_stats' - # - # # while in the plugin... - # def karma_stats(m, params) - # m.reply "..." - # end - # - # # the default action is the first component - # plugin.map 'karma' - # - # # attributes can be pulled out of the match string - # plugin.map 'karma for :key' - # plugin.map 'karma :key' - # - # # while in the plugin... - # def karma(m, params) - # item = params[:key] - # m.reply 'karma for #{item}' - # end - # - # # you can setup defaults, to make parameters optional - # plugin.map 'karma :key', :defaults => {:key => 'defaultvalue'} - # - # # the default auth check is also against the first component - # # but that can be changed - # plugin.map 'karmastats', :auth => 'karma' - # - # # maps can be restricted to public or private message: - # plugin.map 'karmastats', :private false, - # plugin.map 'karmastats', :public false, - # end - # - # To activate your maps, you simply register them - # plugin.register_maps - # This also sets the privmsg handler to use the map lookups for - # handling messages. You can still use listen(), kick() etc methods - # - # listen(UserMessage):: - # Called for all messages of any type. To - # differentiate them, use message.kind_of? It'll be - # either a PrivMessage, NoticeMessage, KickMessage, - # QuitMessage, PartMessage, JoinMessage, NickMessage, - # etc. - # - # privmsg(PrivMessage):: - # called for a PRIVMSG if the first word matches one - # the plugin register()d for. Use m.plugin to get - # that word and m.params for the rest of the message, - # if applicable. - # - # kick(KickMessage):: - # Called when a user (or the bot) is kicked from a - # channel the bot is in. - # - # join(JoinMessage):: - # Called when a user (or the bot) joins a channel - # - # part(PartMessage):: - # Called when a user (or the bot) parts a channel - # - # quit(QuitMessage):: - # Called when a user (or the bot) quits IRC - # - # nick(NickMessage):: - # Called when a user (or the bot) changes Nick - # topic(TopicMessage):: - # Called when a user (or the bot) changes a channel - # topic - # - # connect():: Called when a server is joined successfully, but - # before autojoin channels are joined (no params) - # - # save:: Called when you are required to save your plugin's - # state, if you maintain data between sessions - # - # cleanup:: called before your plugin is "unloaded", prior to a - # plugin reload or bot quit - close any open - # files/connections or flush caches here - class Plugin +=begin rdoc + BotModule is the base class for the modules that enhance the rbot + functionality. Rather than subclassing BotModule, however, one should + subclass either CoreBotModule (reserved for system modules) or Plugin + (for user plugins). + + A BotModule interacts with Irc events by defining one or more of the following + methods, which get called as appropriate when the corresponding Irc event + happens. + + map(template, options):: + map!(template, options):: + map is the new, cleaner way to respond to specific message formats without + littering your plugin code with regexps, and should be used instead of + #register() and #privmsg() (see below) when possible. + + The difference between map and map! is that map! will not register the new + command as an alternative name for the plugin. + + Examples: + + plugin.map 'karmastats', :action => 'karma_stats' + + # while in the plugin... + def karma_stats(m, params) + m.reply "..." + end + + # the default action is the first component + plugin.map 'karma' + + # attributes can be pulled out of the match string + plugin.map 'karma for :key' + plugin.map 'karma :key' + + # while in the plugin... + def karma(m, params) + item = params[:key] + m.reply 'karma for #{item}' + end + + # you can setup defaults, to make parameters optional + plugin.map 'karma :key', :defaults => {:key => 'defaultvalue'} + + # the default auth check is also against the first component + # but that can be changed + plugin.map 'karmastats', :auth => 'karma' + + # maps can be restricted to public or private message: + plugin.map 'karmastats', :private => false + plugin.map 'karmastats', :public => false + + See MessageMapper#map for more information on the template format and the + allowed options. + + listen(UserMessage):: + Called for all messages of any type. To + differentiate them, use message.kind_of? It'll be + either a PrivMessage, NoticeMessage, KickMessage, + QuitMessage, PartMessage, JoinMessage, NickMessage, + etc. + + ctcp_listen(UserMessage):: + Called for all messages that contain a CTCP command. + Use message.ctcp to get the CTCP command, and + message.message to get the parameter string. To reply, + use message.ctcp_reply, which sends a private NOTICE + to the sender. + + privmsg(PrivMessage):: + Called for a PRIVMSG if the first word matches one + the plugin #register()ed for. Use m.plugin to get + that word and m.params for the rest of the message, + if applicable. + + unreplied(PrivMessage):: + Called for a PRIVMSG which has not been replied to. + + kick(KickMessage):: + Called when a user (or the bot) is kicked from a + channel the bot is in. + + join(JoinMessage):: + Called when a user (or the bot) joins a channel + + part(PartMessage):: + Called when a user (or the bot) parts a channel + + quit(QuitMessage):: + Called when a user (or the bot) quits IRC + + nick(NickMessage):: + Called when a user (or the bot) changes Nick + topic(TopicMessage):: + Called when a user (or the bot) changes a channel + topic + + connect:: Called when a server is joined successfully, but + before autojoin channels are joined (no params) + + set_language(String):: + Called when the user sets a new language + whose name is the given String + + save:: Called when you are required to save your plugin's + state, if you maintain data between sessions + + cleanup:: called before your plugin is "unloaded", prior to a + plugin reload or bot quit - close any open + files/connections or flush caches here +=end + + class BotModule attr_reader :bot # the associated bot - # initialise your plugin. Always call super if you override this method, - # as important variables are set up for you + + # Initialise your bot module. Always call super if you override this method, + # as important variables are set up for you: + # + # @bot:: + # the rbot instance + # @registry:: + # the botmodule's registry, which can be used to store permanent data + # (see Registry::Accessor for additional documentation) + # + # Other instance variables which are defined and should not be overwritten + # byt the user, but aren't usually accessed directly, are: + # + # @manager:: + # the plugins manager instance + # @botmodule_triggers:: + # an Array of words this plugin #register()ed itself for + # @handler:: + # the MessageMapper that handles this plugin's maps + # def initialize - @bot = Plugins.bot - @names = Array.new + @manager = Plugins::manager + @bot = @manager.bot + + @botmodule_triggers = Array.new + @handler = MessageMapper.new(self) - @registry = BotRegistryAccessor.new(@bot, self.class.to_s.gsub(/^.*::/, "")) + @registry = Registry::Accessor.new(@bot, self.class.to_s.gsub(/^.*::/, "")) + + @manager.add_botmodule(self) + if self.respond_to?('set_language') + self.set_language(@bot.lang.language) + end end + # Returns the symbol :BotModule + def botmodule_class + :BotModule + end + + # Method called to flush the registry, thus ensuring that the botmodule's permanent + # data is committed to disk + # def flush_registry + # debug "Flushing #{@registry}" @registry.flush end + # Method called to cleanup before the plugin is unloaded. If you overload + # this method to handle additional cleanup tasks, remember to call super() + # so that the default cleanup actions are taken care of as well. + # + def cleanup + # debug "Closing #{@registry}" + @registry.close + end + + # Handle an Irc::PrivMessage for which this BotModule has a map. The method + # is called automatically and there is usually no need to call it + # explicitly. + # + def handle(m) + @handler.handle(m) + end + + # Signal to other BotModules that an even happened. + # + def call_event(ev, *args) + @bot.plugins.delegate('event_' + ev.to_s.gsub(/[^\w\?!]+/, '_'), *args) + end + + # call-seq: map(template, options) + # + # This is the preferred way to register the BotModule so that it + # responds to appropriately-formed messages on Irc. + # def map(*args) - @handler.map(*args) + do_map(false, *args) + end + + # call-seq: map!(template, options) + # + # This is the same as map but doesn't register the new command + # as an alternative name for the plugin. + # + def map!(*args) + do_map(true, *args) + end + + # Auxiliary method called by #map and #map! + def do_map(silent, *args) + @handler.map(self, *args) # register this map - name = @handler.last.items[0] - self.register name + map = @handler.last + name = map.items[0] + self.register name, :auth => nil, :hidden => silent + @manager.register_map(self, map) unless self.respond_to?('privmsg') - def self.privmsg(m) - @handler.handle(m) + def self.privmsg(m) #:nodoc: + handle(m) end end end - # return an identifier for this plugin, defaults to a list of the message + # Sets the default auth for command path _cmd_ to _val_ on channel _chan_: + # usually _chan_ is either "*" for everywhere, public and private (in which + # case it can be omitted) or "?" for private communications + # + def default_auth(cmd, val, chan="*") + case cmd + when "*", "" + c = nil + else + c = cmd + end + Auth::defaultbotuser.set_default_permission(propose_default_path(c), val) + end + + # Gets the default command path which would be given to command _cmd_ + def propose_default_path(cmd) + [name, cmd].compact.join("::") + end + + # Return an identifier for this plugin, defaults to a list of the message # prefixes handled (used for error messages etc) def name - @names.join("|") + self.class.to_s.downcase.sub(/^#::/,"").sub(/(plugin|module)?$/,"") + end + + # Just calls name + def to_s + name end - - # return a help string for your module. for complex modules, you may wish + + # Intern the name + def to_sym + self.name.to_sym + end + + # Return a help string for your module. For complex modules, you may wish # to break your help into topics, and return a list of available topics if # +topic+ is nil. +plugin+ is passed containing the matching prefix for - # this message - if your plugin handles multiple prefixes, make sure your + # this message - if your plugin handles multiple prefixes, make sure you # return the correct help for the prefix requested def help(plugin, topic) "no help" end - - # register the plugin as a handler for messages prefixed +name+ - # this can be called multiple times for a plugin to handle multiple - # message prefixes - def register(name) - return if Plugins.plugins.has_key?(name) - Plugins.plugins[name] = self - @names << name + + # Register the plugin as a handler for messages prefixed _cmd_. + # + # This can be called multiple times for a plugin to handle multiple message + # prefixes. + # + # This command is now superceded by the #map() command, which should be used + # instead whenever possible. + # + def register(cmd, opts={}) + raise ArgumentError, "Second argument must be a hash!" unless opts.kind_of?(Hash) + who = @manager.who_handles?(cmd) + if who + raise "Command #{cmd} is already handled by #{who.botmodule_class} #{who}" if who != self + return + end + if opts.has_key?(:auth) + @manager.register(self, cmd, opts[:auth]) + else + @manager.register(self, cmd, propose_default_path(cmd)) + end + @botmodule_triggers << cmd unless opts.fetch(:hidden, false) end - # default usage method provided as a utility for simple plugins. The + # Default usage method provided as a utility for simple plugins. The # MessageMapper uses 'usage' as its default fallback method. + # def usage(m, params = {}) - m.reply "incorrect usage, ask for help using '#{@bot.nick}: help #{m.plugin}'" + m.reply(_("incorrect usage, ask for help using '%{command}'") % {:command => "#{@bot.nick}: help #{m.plugin}"}) end end - # class to manage multiple plugins and delegate messages to them for + # A CoreBotModule is a BotModule that provides core functionality. + # + # This class should not be used by user plugins, as it's reserved for system + # plugins such as the ones that handle authentication, configuration and basic + # functionality. + # + class CoreBotModule < BotModule + def botmodule_class + :CoreBotModule + end + end + + # A Plugin is a BotModule that provides additional functionality. + # + # A user-defined plugin should subclass this, and then define any of the + # methods described in the documentation for BotModule to handle interaction + # with Irc events. + # + class Plugin < BotModule + def botmodule_class + :Plugin + end + end + + # Singleton to manage multiple plugins and delegate messages to them for # handling - class Plugins - # hash of registered message prefixes and associated plugins - @@plugins = Hash.new - # associated IrcBot class - @@bot = nil - - # bot:: associated IrcBot class - # dirlist:: array of directories to scan (in order) for plugins + class PluginManagerClass + include Singleton + attr_reader :bot + attr_reader :botmodules + attr_reader :maps + + # This is the list of patterns commonly delegated to plugins. + # A fast delegation lookup is enabled for them. + DEFAULT_DELEGATE_PATTERNS = %r{^(?: + connect|names|nick| + listen|ctcp_listen|privmsg|unreplied| + kick|join|part|quit| + save|cleanup|flush_registry| + set_.*|event_.* + )$}x + + def initialize + @botmodules = { + :CoreBotModule => [], + :Plugin => [] + } + + @names_hash = Hash.new + @commandmappers = Hash.new + @maps = Hash.new + @delegate_list = Hash.new { |h, k| + h[k] = Array.new + } + + @dirs = [] + + @failed = Array.new + @ignored = Array.new + + bot_associate(nil) + end + + def inspect + ret = self.to_s[0..-2] + ret << ' corebotmodules=' + ret << @botmodules[:CoreBotModule].map { |m| + m.name + }.inspect + ret << ' plugins=' + ret << @botmodules[:Plugin].map { |m| + m.name + }.inspect + ret << ">" + end + + # Reset lists of botmodules + def reset_botmodule_lists + @botmodules[:CoreBotModule].clear + @botmodules[:Plugin].clear + @names_hash.clear + @commandmappers.clear + @maps.clear + @failures_shown = false + end + + # Associate with bot _bot_ + def bot_associate(bot) + reset_botmodule_lists + @bot = bot + end + + # Returns the botmodule with the given _name_ + def [](name) + @names_hash[name.to_sym] + end + + # Returns +true+ if _cmd_ has already been registered as a command + def who_handles?(cmd) + return nil unless @commandmappers.has_key?(cmd.to_sym) + return @commandmappers[cmd.to_sym][:botmodule] + end + + # Registers botmodule _botmodule_ with command _cmd_ and command path _auth_path_ + def register(botmodule, cmd, auth_path) + raise TypeError, "First argument #{botmodule.inspect} is not of class BotModule" unless botmodule.kind_of?(BotModule) + @commandmappers[cmd.to_sym] = {:botmodule => botmodule, :auth => auth_path} + end + + # Registers botmodule _botmodule_ with map _map_. This adds the map to the #maps hash + # which has three keys: # - # create a new plugin handler, scanning for plugins in +dirlist+ - def initialize(bot, dirlist) - @@bot = bot - @dirs = dirlist - scan + # botmodule:: the associated botmodule + # auth:: an array of auth keys checked by the map; the first is the full_auth_path of the map + # map:: the actual MessageTemplate object + # + # + def register_map(botmodule, map) + raise TypeError, "First argument #{botmodule.inspect} is not of class BotModule" unless botmodule.kind_of?(BotModule) + @maps[map.template] = { :botmodule => botmodule, :auth => [map.options[:full_auth_path]], :map => map } + end + + def add_botmodule(botmodule) + raise TypeError, "Argument #{botmodule.inspect} is not of class BotModule" unless botmodule.kind_of?(BotModule) + kl = botmodule.botmodule_class + if @names_hash.has_key?(botmodule.to_sym) + case self[botmodule].botmodule_class + when kl + raise "#{kl} #{botmodule} already registered!" + else + raise "#{self[botmodule].botmodule_class} #{botmodule} already registered, cannot re-register as #{kl}" + end + end + @botmodules[kl] << botmodule + @names_hash[botmodule.to_sym] = botmodule + end + + # Returns an array of the loaded plugins + def core_modules + @botmodules[:CoreBotModule] + end + + # Returns an array of the loaded plugins + def plugins + @botmodules[:Plugin] + end + + # Returns a hash of the registered message prefixes and associated + # plugins + def commands + @commandmappers end - - # access to associated bot - def Plugins.bot - @@bot + + # Makes a string of error _err_ by adding text _str_ + def report_error(str, err) + ([str, err.inspect] + err.backtrace).join("\n") end - # access to list of plugins - def Plugins.plugins - @@plugins + # This method is the one that actually loads a module from the + # file _fname_ + # + # _desc_ is a simple description of what we are loading (plugin/botmodule/whatever) + # + # It returns the Symbol :loaded on success, and an Exception + # on failure + # + def load_botmodule_file(fname, desc=nil) + # create a new, anonymous module to "house" the plugin + # the idea here is to prevent namespace pollution. perhaps there + # is another way? + plugin_module = Module.new + + desc = desc.to_s + " " if desc + + begin + plugin_string = IO.readlines(fname).join("") + debug "loading #{desc}#{fname}" + plugin_module.module_eval(plugin_string, fname) + return :loaded + rescue Exception => err + # rescue TimeoutError, StandardError, NameError, LoadError, SyntaxError => err + error report_error("#{desc}#{fname} load failed", err) + bt = err.backtrace.select { |line| + line.match(/^(\(eval\)|#{fname}):\d+/) + } + bt.map! { |el| + el.gsub(/^\(eval\)(:\d+)(:in `.*')?(:.*)?/) { |m| + "#{fname}#{$1}#{$3}" + } + } + msg = err.to_str.gsub(/^\(eval\)(:\d+)(:in `.*')?(:.*)?/) { |m| + "#{fname}#{$1}#{$3}" + } + newerr = err.class.new(msg) + newerr.set_backtrace(bt) + return newerr + end + end + private :load_botmodule_file + + # add one or more directories to the list of directories to + # load botmodules from + # + # TODO find a way to specify necessary plugins which _must_ be loaded + # + def add_botmodule_dir(*dirlist) + @dirs += dirlist + debug "Botmodule loading path: #{@dirs.join(', ')}" + end + + def clear_botmodule_dirs + @dirs.clear + debug "Botmodule loading path cleared" end # load plugins from pre-assigned list of directories def scan - processed = Array.new - dirs = Array.new - dirs << Config::datadir + "/plugins" - dirs += @dirs - dirs.reverse.each {|dir| + @failed.clear + @ignored.clear + @delegate_list.clear + + processed = Hash.new + + @bot.config['plugins.blacklist'].each { |p| + pn = p + ".rb" + processed[pn.intern] = :blacklisted + } + + dirs = @dirs + dirs.each {|dir| if(FileTest.directory?(dir)) d = Dir.new(dir) d.sort.each {|file| + next if(file =~ /^\./) - next if(processed.include?(file)) + + if processed.has_key?(file.intern) + @ignored << {:name => file, :dir => dir, :reason => processed[file.intern]} + next + end + if(file =~ /^(.+\.rb)\.disabled$/) - processed << $1 + # GB: Do we want to do this? This means that a disabled plugin in a directory + # will disable in all subsequent directories. This was probably meant + # to be used before plugins.blacklist was implemented, so I think + # we don't need this anymore + processed[$1.intern] = :disabled + @ignored << {:name => $1, :dir => dir, :reason => processed[$1.intern]} next end + next unless(file =~ /\.rb$/) - tmpfilename = "#{dir}/#{file}" - # create a new, anonymous module to "house" the plugin - # the idea here is to prevent namespace pollution. perhaps there - # is another way? - plugin_module = Module.new - - begin - plugin_string = IO.readlines(tmpfilename).join("") - debug "loading plugin #{tmpfilename}" - plugin_module.module_eval(plugin_string) - processed << file - rescue Exception => err - # rescue TimeoutError, StandardError, NameError, LoadError, SyntaxError => err - puts "warning: plugin #{tmpfilename} load failed: " + err - puts err.backtrace.join("\n") + did_it = load_botmodule_file("#{dir}/#{file}", "plugin") + case did_it + when Symbol + processed[file.intern] = did_it + when Exception + @failed << { :name => file, :dir => dir, :reason => did_it } end + } end } + debug "finished loading plugins: #{status(true)}" + (core_modules + plugins).each { |p| + p.methods.grep(DEFAULT_DELEGATE_PATTERNS).each { |m| + @delegate_list[m.intern] << p + } + } end # call the save method for each active plugin @@ -223,6 +588,7 @@ module Plugins # call the cleanup method for each active plugin def cleanup delegate 'cleanup' + reset_botmodule_lists end # drop all plugins and rescan plugins on disk @@ -230,78 +596,229 @@ module Plugins def rescan save cleanup - @@plugins = Hash.new scan end - # return list of help topics (plugin names) - def helptopics - if(@@plugins.length > 0) - # return " [plugins: " + @@plugins.keys.sort.join(", ") + "]" - return " [#{length} plugins: " + @@plugins.values.uniq.collect{|p| p.name}.sort.join(", ") + "]" + def status(short=false) + output = [] + if self.core_length > 0 + if short + output << n_("%{count} core module loaded", "%{count} core modules loaded", + self.core_length) % {:count => self.core_length} + else + output << n_("%{count} core module: %{list}", + "%{count} core modules: %{list}", self.core_length) % + { :count => self.core_length, + :list => core_modules.collect{ |p| p.name}.sort.join(", ") } + end else - return " [no plugins active]" + output << _("no core botmodules loaded") end + # Active plugins first + if(self.length > 0) + if short + output << n_("%{count} plugin loaded", "%{count} plugins loaded", + self.length) % {:count => self.length} + else + output << n_("%{count} plugin: %{list}", + "%{count} plugins: %{list}", self.length) % + { :count => self.length, + :list => plugins.collect{ |p| p.name}.sort.join(", ") } + end + else + output << "no plugins active" + end + # Ignored plugins next + unless @ignored.empty? or @failures_shown + if short + output << n_("%{highlight}%{count} plugin ignored%{highlight}", + "%{highlight}%{count} plugins ignored%{highlight}", + @ignored.length) % + { :count => @ignored.length, :highlight => Underline } + else + output << n_("%{highlight}%{count} plugin ignored%{highlight}: use %{bold}%{command}%{bold} to see why", + "%{highlight}%{count} plugins ignored%{highlight}: use %{bold}%{command}%{bold} to see why", + @ignored.length) % + { :count => @ignored.length, :highlight => Underline, + :bold => Bold, :command => "help ignored plugins"} + end + end + # Failed plugins next + unless @failed.empty? or @failures_shown + if short + output << n_("%{highlight}%{count} plugin failed to load%{highlight}", + "%{highlight}%{count} plugins failed to load%{highlight}", + @failed.length) % + { :count => @failed.length, :highlight => Reverse } + else + output << n_("%{highlight}%{count} plugin failed to load%{highlight}: use %{bold}%{command}%{bold} to see why", + "%{highlight}%{count} plugins failed to load%{highlight}: use %{bold}%{command}%{bold} to see why", + @failed.length) % + { :count => @failed.length, :highlight => Reverse, + :bold => Bold, :command => "help failed plugins"} + end + end + output.join '; ' + end + + # return list of help topics (plugin names) + def helptopics + rv = status + @failures_shown = true + rv end def length - @@plugins.values.uniq.length + plugins.length + end + + def core_length + core_modules.length end # return help for +topic+ (call associated plugin's help method) def help(topic="") - if(topic =~ /^(\S+)\s*(.*)$/) + case topic + when /fail(?:ed)?\s*plugins?.*(trace(?:back)?s?)?/ + # debug "Failures: #{@failed.inspect}" + return _("no plugins failed to load") if @failed.empty? + return @failed.collect { |p| + _('%{highlight}%{plugin}%{highlight} in %{dir} failed with error %{exception}: %{reason}') % { + :highlight => Bold, :plugin => p[:name], :dir => p[:dir], + :exception => p[:reason].class, :reason => p[:reason], + } + if $1 && !p[:reason].backtrace.empty? + _('at %{backtrace}') % {:backtrace => p[:reason].backtrace.join(', ')} + else + '' + end + }.join("\n") + when /ignored?\s*plugins?/ + return _('no plugins were ignored') if @ignored.empty? + + tmp = Hash.new + @ignored.each do |p| + reason = p[:loaded] ? _('overruled by previous') : _(p[:reason].to_s) + ((tmp[p[:dir]] ||= Hash.new)[reason] ||= Array.new).push(p[:name]) + end + + return tmp.map do |dir, reasons| + # FIXME get rid of these string concatenations to make gettext easier + s = reasons.map { |r, list| + list.map { |_| _.sub(/\.rb$/, '') }.join(', ') + " (#{r})" + }.join('; ') + "in #{dir}: #{s}" + end.join('; ') + when /^(\S+)\s*(.*)$/ key = $1 params = $2 - if(@@plugins.has_key?(key)) + + # Let's see if we can match a plugin by the given name + (core_modules + plugins).each { |p| + next unless p.name == key begin - return @@plugins[key].help(key, params) + return p.help(key, params) rescue Exception => err - #rescue TimeoutError, StandardError, NameError, SyntaxError => err - puts "plugin #{@@plugins[key].name} help() failed: " + err - puts err.backtrace.join("\n") + #rescue TimeoutError, StandardError, NameError, SyntaxError => err + error report_error("#{p.botmodule_class} #{p.name} help() failed:", err) + end + } + + # Nope, let's see if it's a command, and ask for help at the corresponding botmodule + k = key.to_sym + if commands.has_key?(k) + p = commands[k][:botmodule] + begin + return p.help(key, params) + rescue Exception => err + #rescue TimeoutError, StandardError, NameError, SyntaxError => err + error report_error("#{p.botmodule_class} #{p.name} help() failed:", err) end - else - return false end end + return false end - + # see if each plugin handles +method+, and if so, call it, passing # +message+ as a parameter def delegate(method, *args) - @@plugins.values.uniq.each {|p| - if(p.respond_to? method) + # debug "Delegating #{method.inspect}" + ret = Array.new + if method.match(DEFAULT_DELEGATE_PATTERNS) + debug "fast-delegating #{method}" + m = method.to_sym + debug "no-one to delegate to" unless @delegate_list.has_key?(m) + return [] unless @delegate_list.has_key?(m) + @delegate_list[m].each { |p| begin - p.send method, *args + ret.push p.send(method, *args) rescue Exception => err - #rescue TimeoutError, StandardError, NameError, SyntaxError => err - puts "plugin #{p.name} #{method}() failed: " + err - puts err.backtrace.join("\n") + raise if err.kind_of?(SystemExit) + error report_error("#{p.botmodule_class} #{p.name} #{method}() failed:", err) + raise if err.kind_of?(BDB::Fatal) end - end - } + } + else + debug "slow-delegating #{method}" + (core_modules + plugins).each { |p| + if(p.respond_to? method) + begin + # debug "#{p.botmodule_class} #{p.name} responds" + ret.push p.send(method, *args) + rescue Exception => err + raise if err.kind_of?(SystemExit) + error report_error("#{p.botmodule_class} #{p.name} #{method}() failed:", err) + raise if err.kind_of?(BDB::Fatal) + end + end + } + end + return ret + # debug "Finished delegating #{method.inspect}" end # see if we have a plugin that wants to handle this message, if so, pass # it to the plugin and return true, otherwise false def privmsg(m) - return unless(m.plugin) - if (@@plugins.has_key?(m.plugin) && - @@plugins[m.plugin].respond_to?("privmsg") && - @@bot.auth.allow?(m.plugin, m.source, m.replyto)) - begin - @@plugins[m.plugin].privmsg(m) - rescue Exception => err - #rescue TimeoutError, StandardError, NameError, SyntaxError => err - puts "plugin #{@@plugins[m.plugin].name} privmsg() failed: " + err - puts err.backtrace.join("\n") + # debug "Delegating privmsg #{m.message.inspect} from #{m.source} to #{m.replyto} with pluginkey #{m.plugin.inspect}" + return unless m.plugin + k = m.plugin.to_sym + if commands.has_key?(k) + p = commands[k][:botmodule] + a = commands[k][:auth] + # We check here for things that don't check themselves + # (e.g. mapped things) + # debug "Checking auth ..." + if a.nil? || @bot.auth.allow?(a, m.source, m.replyto) + # debug "Checking response ..." + if p.respond_to?("privmsg") + begin + # debug "#{p.botmodule_class} #{p.name} responds" + p.privmsg(m) + rescue Exception => err + raise if err.kind_of?(SystemExit) + error report_error("#{p.botmodule_class} #{p.name} privmsg() failed:", err) + raise if err.kind_of?(BDB::Fatal) + end + # debug "Successfully delegated #{m.message}" + return true + else + # debug "#{p.botmodule_class} #{p.name} is registered, but it doesn't respond to privmsg()" + end + else + # debug "#{p.botmodule_class} #{p.name} is registered, but #{m.source} isn't allowed to call #{m.plugin.inspect} on #{m.replyto}" end - return true end + # debug "Finished delegating privmsg with key #{m.plugin.inspect}" + ( pl.empty? ? "" : " to #{pl.values.first[:botmodule].botmodule_class}s" ) return false + # debug "Finished delegating privmsg with key #{m.plugin.inspect}" end end + # Returns the only PluginManagerClass instance + def Plugins.manager + return PluginManagerClass.instance + end + +end end end