X-Git-Url: https://git.netwichtig.de/gitweb/?a=blobdiff_plain;ds=sidebyside;f=lib%2Frbot%2Fregistry.rb;h=b85a622426de23442a71b5039e144c4051ce3f3b;hb=2d2e6d1fb24e5d687eab7e77bf251ad777ca736d;hp=d1388ce2fd14aa4a3dce1cb84eed5f5d55016280;hpb=069d8c8dd5ab841cc5efcfeae1cdc2e7f93c2976;p=user%2Fhenk%2Fcode%2Fruby%2Frbot.git diff --git a/lib/rbot/registry.rb b/lib/rbot/registry.rb index d1388ce2..b85a6224 100644 --- a/lib/rbot/registry.rb +++ b/lib/rbot/registry.rb @@ -1,10 +1,11 @@ require 'rbot/dbhash' module Irc +class Bot - # this class is now used purely for upgrading from prior versions of rbot + # This class is now used purely for upgrading from prior versions of rbot # the new registry is split into multiple DBHash objects, one per plugin - class BotRegistry + class Registry def initialize(bot) @bot = bot upgrade_data @@ -71,7 +72,6 @@ module Irc env.close end end - end # This class provides persistent storage for plugins via a hash interface. @@ -94,7 +94,7 @@ module Irc # in object store mode, don't make the mistake of treating it like a live # object, e.g. (using the example above) # @registry[:blah][:foo] = "flump" - # will NOT modify the object in the registry - remember that BotRegistry#[] + # will NOT modify the object in the registry - remember that Registry#[] # returns a Marshal.restore'd object, the object you just modified in place # will disappear. You would need to: # blah = @registry[:blah] @@ -117,16 +117,17 @@ module Irc # Your plugins section of the registry is private, it has its own namespace # (derived from the plugin's class name, so change it and lose your data). # Calls to registry.each etc, will only iterate over your namespace. - class BotRegistryAccessor + class Accessor attr_accessor :recovery - # plugins don't call this - a BotRegistryAccessor is created for them and + # plugins don't call this - a Registry::Accessor is created for them and # is accessible via @registry. def initialize(bot, name) @bot = bot @name = name.downcase - dirs = File.dirname("#{@bot.botclass}/registry/#{@name}").split("/") + @filename = "#{@bot.botclass}/registry/#{@name}" + dirs = File.dirname(@filename).split("/") dirs.length.times { |i| dir = dirs[0,i+1].join("/")+"/" unless File.exist?(dir) @@ -134,9 +135,10 @@ module Irc Dir.mkdir(dir) end } + @filename << ".db" @registry = nil @default = nil - @recover = nil + @recovery = nil # debug "initializing registry accessor with name #{@name}" end @@ -181,7 +183,7 @@ module Irc rescue Exception => e error _("failed to restore marshal data for #{val.inspect}, attempting recovery or fallback to default") debug e - if @recovery + if defined? @recovery and @recovery begin return @recovery.call(val) rescue Exception => ee @@ -189,26 +191,16 @@ module Irc debug ee end end - unless @default.nil? - begin - return Marshal.restore(@default) - rescue - return nil - end - else - return nil - end + return default end end # lookup a key in the registry def [](key) - if registry.has_key?(key) + if File.exist?(@filename) && registry.has_key?(key) return restore(registry[key]) - elsif @default != nil - return restore(@default) else - return nil + return default end end @@ -220,11 +212,16 @@ module Irc # set the default value for registry lookups, if the key sought is not # found, the default will be returned. The default default (har) is nil. def set_default (default) - @default = store(default) + @default = default + end + + def default + @default && (@default.dup rescue @default) end # just like Hash#each def each(&block) + return nil unless File.exist?(@filename) registry.each {|key,value| block.call(key, restore(value)) } @@ -232,6 +229,7 @@ module Irc # just like Hash#each_key def each_key(&block) + return nil unless File.exist?(@filename) registry.each {|key, value| block.call(key) } @@ -239,6 +237,7 @@ module Irc # just like Hash#each_value def each_value(&block) + return nil unless File.exist?(@filename) registry.each {|key, value| block.call(restore(value)) } @@ -246,23 +245,28 @@ module Irc # just like Hash#has_key? def has_key?(key) + return false unless File.exist?(@filename) return registry.has_key?(key) end alias include? has_key? alias member? has_key? + alias key? has_key? # just like Hash#has_both? def has_both?(key, value) + return false unless File.exist?(@filename) return registry.has_both?(key, store(value)) end # just like Hash#has_value? def has_value?(value) + return false unless File.exist?(@filename) return registry.has_value?(store(value)) end # just like Hash#index? def index(value) + return nil unless File.exist?(@filename) ind = registry.index(store(value)) if ind return ind @@ -273,16 +277,19 @@ module Irc # delete a key from the registry def delete(key) + return default unless File.exist?(@filename) return registry.delete(key) end # returns a list of your keys def keys + return [] unless File.exist?(@filename) return registry.keys end # Return an array of all associations [key, value] in your namespace def to_a + return [] unless File.exist?(@filename) ret = Array.new registry.each {|key, value| ret << [key, restore(value)] @@ -292,6 +299,7 @@ module Irc # Return an hash of all associations {key => value} in your namespace def to_hash + return {} unless File.exist?(@filename) ret = Hash.new registry.each {|key, value| ret[key] = restore(value) @@ -301,12 +309,14 @@ module Irc # empties the registry (restricted to your namespace) def clear + return true unless File.exist?(@filename) registry.clear end alias truncate clear # returns an array of the values in your namespace of the registry def values + return [] unless File.exist?(@filename) ret = Array.new self.each {|k,v| ret << restore(v) @@ -315,7 +325,7 @@ module Irc end def sub_registry(prefix) - return BotRegistryAccessor.new(@bot, @name + "/" + prefix.to_s) + return Accessor.new(@bot, @name + "/" + prefix.to_s) end # returns the number of keys in your registry namespace @@ -326,4 +336,6 @@ module Irc end + end +end end