Diffstat (limited to 'backend/node/src/clipperz.js') (more/less context) (ignore whitespace changes)
-rw-r--r-- | backend/node/src/clipperz.js | 37 |
1 files changed, 36 insertions, 1 deletions
diff --git a/backend/node/src/clipperz.js b/backend/node/src/clipperz.js index eebd5bf..73af0a0 100644 --- a/backend/node/src/clipperz.js +++ b/backend/node/src/clipperz.js @@ -5,2 +5,4 @@ var ASYNC = require('async'); +var express_store = require('express').session.Store; + function clipperz_hash(v) { @@ -14,2 +16,31 @@ function clipperz_random() { }; +function clipperz_store(PG) { + var rv = function(o) { express_store.call(this,o); } + rv.prototype.get = function(sid,cb) { PG.Q( + "SELECT s_data FROM clipperz.thesession WHERE s_id=$1",[sid], + function(e,r) { cb(e,(e||!r.rowCount)?null:r.rows[0].s_data); } + ) }; + rv.prototype.set = function(sid,data,cb) { PG.Q( + "UPDATE clipperz.thesession SET s_data=$1, s_mtime=current_timestamp" + +" WHERE s_id=$2",[data,sid], function(e,r) { + if(e) return cb(e); + if(r.rowCount) return cb(); + PG.Q("INSERT INTO clipperz.thesession (s_id,s_data) VALUES ($1,$2)",[sid,data],cb); + } + ) }; + rv.prototype.destroy = function(sid,cb) { PG.Q( + "DELETE FROM clipperz.thesession WHERE s_id=$1",[sid],cb + ) }; + rv.prototype.length = function(cb) { PG.Q( + "SELECT count(*) AS c FROM clipperz.thesession", function(e,r) { + cb(e,e?null:r.rows[0].c); + } + ) }; + rv.prototype.length = function(cb) { PQ.Q( + "DELETE FROM clipperz.thesession", cb + ) }; + rv.prototype.__proto__ = express_store.prototype; + return rv; +} + var srp_g = BIGNUM(2); @@ -78,3 +109,3 @@ var CLIPPERZ = module.exports = function(CONFIG) { - return { + var rv = { @@ -534,3 +565,7 @@ var CLIPPERZ = module.exports = function(CONFIG) { } + }; + rv.__defineGetter__('session_store',function(){ return function(o) { return new (clipperz_store(PG))(o) } }); + + return rv; |