# HG changeset patch
# User James Callahan <james@chatid.com>
# Date 1323686348 -39600
# Node ID 0e9b43db7a2c0b9d3a3f35276623a37299026691
# Parent  db32236d7682956913f68c2ef6eb4d66272bef30
mod_storage_mondodb: Add module

diff -r db32236d7682 -r 0e9b43db7a2c mod_storage_mondodb/mod_storage_mongodb.lua
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/mod_storage_mondodb/mod_storage_mongodb.lua	Mon Dec 12 21:39:08 2011 +1100
@@ -0,0 +1,54 @@
+local next = next;
+local setmetatable = setmetatable;
+
+local log = require "util.logger".init("mongodb");
+local params = module:get_option("mongodb");
+
+local mongo = require "mongo";
+
+local conn = mongo.Connection.New ( true );
+conn:connect ( params.server );
+conn:auth ( params );
+
+local keyval_store = {};
+keyval_store.__index = keyval_store;
+
+function keyval_store:get(username)
+	local host, store = module.host, self.store;
+
+	local namespace = params.dbname .. "." .. host;
+	local v = { _id = { store = store ; username = username } };
+
+	local cursor , err = conn:query ( namespace , v );
+	if not cursor then return nil , err end;
+
+	local r , err = cursor:next ( );
+	if not r then return nil , err end;
+	return r.data;
+end
+
+function keyval_store:set(username, data)
+	local host, store = module.host, self.store;
+	if not host then return nil , "mongodb cannot currently be used for host-less data" end;
+
+	local namespace = params.dbname .. "." .. host;
+	local v = { _id = { store = store ; username = username } };
+
+	if next(data) ~= nil then -- set data
+		v.data = data;
+		return conn:insert ( namespace , v );
+	else -- delete data
+		return conn:remove ( namespace , v );
+	end;
+end
+
+local driver = { name = "mongodb" };
+
+function driver:open(store, typ)
+	if not typ then -- default key-value store
+		return setmetatable({ store = store }, keyval_store);
+	end;
+	return nil, "unsupported-store";
+end
+
+module:add_item("data-driver", driver);