2013-08-26 10:52:36 +08:00
|
|
|
# API to wrap up plugin store rows
|
|
|
|
class PluginStore
|
|
|
|
def self.get(plugin_name, key)
|
2014-05-06 21:41:59 +08:00
|
|
|
if row = PluginStoreRow.find_by(plugin_name: plugin_name, key: key)
|
2013-08-26 10:52:36 +08:00
|
|
|
cast_value(row.type_name, row.value)
|
|
|
|
end
|
|
|
|
end
|
|
|
|
|
|
|
|
def self.set(plugin_name, key, value)
|
2017-07-28 09:20:09 +08:00
|
|
|
hash = { plugin_name: plugin_name, key: key }
|
2014-08-19 20:40:23 +08:00
|
|
|
row = PluginStoreRow.find_by(hash) || PluginStoreRow.new(hash)
|
2013-08-26 10:52:36 +08:00
|
|
|
|
|
|
|
row.type_name = determine_type(value)
|
|
|
|
# nil are stored as nil
|
|
|
|
row.value =
|
|
|
|
if row.type_name == "JSON"
|
|
|
|
value.to_json
|
|
|
|
elsif value
|
|
|
|
value.to_s
|
|
|
|
end
|
|
|
|
|
|
|
|
row.save
|
|
|
|
end
|
|
|
|
|
2014-02-25 08:11:31 +08:00
|
|
|
def self.remove(plugin_name, key)
|
2014-02-26 00:26:35 +08:00
|
|
|
PluginStoreRow.where(plugin_name: plugin_name, key: key).destroy_all
|
2014-02-25 08:11:31 +08:00
|
|
|
end
|
|
|
|
|
2013-08-26 10:52:36 +08:00
|
|
|
def self.determine_type(value)
|
2014-03-10 17:22:59 +08:00
|
|
|
value.is_a?(Hash) || value.is_a?(Array) ? "JSON" : value.class.to_s
|
|
|
|
end
|
|
|
|
|
|
|
|
def self.map_json(item)
|
|
|
|
if item.is_a? Hash
|
|
|
|
ActiveSupport::HashWithIndifferentAccess.new item
|
|
|
|
elsif item.is_a? Array
|
2017-07-28 09:20:09 +08:00
|
|
|
item.map { |subitem| map_json subitem }
|
2014-03-10 17:22:59 +08:00
|
|
|
else
|
|
|
|
item
|
|
|
|
end
|
2013-08-26 10:52:36 +08:00
|
|
|
end
|
|
|
|
|
|
|
|
def self.cast_value(type, value)
|
|
|
|
case type
|
2017-04-15 12:11:02 +08:00
|
|
|
when "Integer", "Fixnum" then value.to_i
|
2013-08-26 10:52:36 +08:00
|
|
|
when "TrueClass", "FalseClass" then value == "true"
|
2014-03-10 17:22:59 +08:00
|
|
|
when "JSON" then map_json(::JSON.parse(value))
|
2013-08-26 10:52:36 +08:00
|
|
|
else value
|
|
|
|
end
|
|
|
|
end
|
|
|
|
end
|