# HG changeset patch # User James Callahan # Date 1323687089 -39600 # Node ID b6d2ac38612067ac877da7987452533b8b6f2ee6 # Parent 0e9b43db7a2c0b9d3a3f35276623a37299026691 Rename to mongodb diff -r 0e9b43db7a2c -r b6d2ac386120 mod_storage_mondodb/mod_storage_mongodb.lua --- a/mod_storage_mondodb/mod_storage_mongodb.lua Mon Dec 12 21:39:08 2011 +1100 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,54 +0,0 @@ -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); diff -r 0e9b43db7a2c -r b6d2ac386120 mod_storage_mongodb/mod_storage_mongodb.lua --- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/mod_storage_mongodb/mod_storage_mongodb.lua Mon Dec 12 21:51:29 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);