Mercurial > prosody-modules
view mod_couchdb/couchdb/mod_couchdb.lua @ 4300:3f3b672b7616
mod_vcard_muc: Pass room object around instead of JID, hopefully fixing traceback
More efficient to pass the object around instead of using the JID
and looking up the object when needed.
It seems in some (undetermined) cases get_room_from_jid(room.jid) is nil.
author | Matthew Wild <mwild1@gmail.com> |
---|---|
date | Tue, 15 Dec 2020 10:49:11 +0000 |
parents | 2469f779b3f7 |
children |
line wrap: on
line source
local http = require "socket.http"; local url = require "socket.url"; local couchapi = module:require("couchdb/couchapi"); local json = module:require("couchdb/json"); local couchdb_url = assert(module:get_option("couchdb_url"), "Option couchdb_url not specified"); local db = couchapi.db(couchdb_url); local function couchdb_get(key) local a,b = db:doc(key):get() print(json.encode(a)); if b == 404 then return nil; end if b == 200 then b = nil; end return a.payload,b; end local function couchdb_put(key, value) local a,b = db:doc(key):get(); return db:doc(key):put({ payload = value, _rev = a and a._rev }); end local st = require "util.stanza"; local handlers = {}; handlers.accounts = { get = function(self, user) return couchdb_get(self.host.."/"..user.."/account"); end; set = function(self, user, data) return couchdb_put(self.host.."/"..user.."/account", data); end; }; handlers.vcard = { get = function(self, user) return couchdb_get(self.host.."/"..user.."/vcard"); end; set = function(self, user, data) return couchdb_put(self.host.."/"..user.."/vcard", data); end; }; handlers.private = { get = function(self, user) return couchdb_get(self.host.."/"..user.."/private"); end; set = function(self, user, data) return couchdb_put(self.host.."/"..user.."/private", data); end; }; handlers.roster = { get = function(self, user) return couchdb_get(self.host.."/"..user.."/roster"); end; set = function(self, user, data) return couchdb_put(self.host.."/"..user.."/roster", data); end; }; ----------------------------- local driver = {}; function driver:open(datastore, typ) local handler = handlers[datastore]; if not handler then return nil; end local host = module.host; --local cache_key = host.." "..datastore; --if self.ds_cache[cache_key] then return self.ds_cache[cache_key]; end local instance = setmetatable({ host = host, datastore = datastore }, { __index = handler }); --for key,val in pairs(handler) do -- instance[key] = val; --end --if instance.init then instance:init(); end --self.ds_cache[cache_key] = instance; return instance; end module:provides("storage", driver);