# HG changeset patch
# User Kim Alvefur <zash@zash.se>
# Date 1348240988 -7200
# Node ID 688aeac0012ac37d8891f1a6dc364e0724be9bd6
# Parent  fee5f8d4ec742104f5aff023fe8dd26383520e28
mod_storage_internal, datamanager: Add support for iterating over users with data in a store

diff -r fee5f8d4ec74 -r 688aeac0012a plugins/mod_storage_internal.lua
--- a/plugins/mod_storage_internal.lua	Wed Sep 19 23:29:25 2012 +0200
+++ b/plugins/mod_storage_internal.lua	Fri Sep 21 17:23:08 2012 +0200
@@ -5,8 +5,8 @@
 local driver = {};
 local driver_mt = { __index = driver };
 
-function driver:open(store)
-	return setmetatable({ store = store }, driver_mt);
+function driver:open(store, typ)
+	return setmetatable({ store = store, type = typ }, driver_mt);
 end
 function driver:get(user)
 	return datamanager.load(user, host, self.store);
@@ -20,6 +20,10 @@
 	return datamanager.stores(username, host);
 end
 
+function driver:users()
+	return datamanager.users(host, self.store, self.type);
+end
+
 function driver:purge(user)
 	return datamanager.purge(user, host);
 end
diff -r fee5f8d4ec74 -r 688aeac0012a util/datamanager.lua
--- a/util/datamanager.lua	Wed Sep 19 23:29:25 2012 +0200
+++ b/util/datamanager.lua	Fri Sep 21 17:23:08 2012 +0200
@@ -282,6 +282,25 @@
 	list = "list";
 }
 
+function users(host, store, typ)
+	typ = type_map[typ or "keyval"];
+	local store_dir = format("%s/%s/%s", data_path, encode(host), encode(store));
+
+	local mode, err = lfs.attributes(store_dir, "mode");
+	if not mode then
+		return function() log("debug", err or (store_dir .. " does not exist")) end
+	end
+	local next, state = lfs.dir(store_dir);
+	return function(state)
+		for node in next, state do
+			local file, ext = node:match("^(.*)%.([dalist]+)$");
+			if file and ext == typ then
+				return decode(file);
+			end
+		end
+	end, state;
+end
+
 function stores(username, host, typ)
 	typ = type_map[typ or "keyval"];
 	local store_dir = format("%s/%s/", data_path, encode(host));