local olddm = {}; -- maintain old datamanager, for backwards compatibility
for k,v in pairs(datamanager) do olddm[k] = v; end
+local prosody = prosody;
module("storagemanager")
local stores_available = multitable.new();
function initialize_host(host)
+ local host_session = hosts[host];
host_session.events.add_handler("item-added/data-driver", function (event)
local item = event.item;
stores_available:set(host, item.name, item);
stores_available:set(host, item.name, nil);
end);
end
+prosody.events.add_handler("host-activated", initialize_host, 101);
local function load_driver(host, driver_name)
if not driver_name then
return;
end
local driver = stores_available:get(host, driver_name);
- if not driver then
- if driver_name ~= "internal" then
- modulemanager.load(host, "storage_"..driver_name);
- return stores_available:get(host, driver_name);
- else
- return setmetatable({host = host}, default_driver_mt);
+ if driver then return driver; end
+ if driver_name ~= "internal" then
+ local ok, err = modulemanager.load(host, "storage_"..driver_name);
+ if not ok then
+ log("error", "Failed to load storage driver plugin %s: %s", driver_name, err);
end
+ return stores_available:get(host, driver_name);
+ else
+ return setmetatable({host = host}, default_driver_mt);
end
end
driver_name = config.get(host, "core", "default_storage");
driver = load_driver(host, driver_name);
if not driver then
+ if driver_name or (type(storage) == "string"
+ or type(storage) == "table" and storage[store]) then
+ log("warn", "Falling back to default driver for %s storage on %s", store, host);
+ end
driver_name = "internal";
- log("warn", "Falling back to default driver for %s storage on %s", store, host);
driver = load_driver(host, driver_name);
end
end