lamassu/lamassu-server
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

change to cached_responses; actively prune table

Browse source
This commit is contained in:
Josh Harvey 2016-05-21 17:16:27 +03:00
parent 25d782a2c5
commit 29759fe132
3 changed files with 18 additions and 11 deletions
Download patch file Download diff file Expand all files Collapse all files

19
lib/postgresql_interface.js
View file

@ -9,6 +9,8 @@ var R = require('ramda')
var logger = require('./logger')
const CACHED_SESSION_TTL = 60 * 60 * 1000
/*
function inspect(rec) {
console.log(require('util').inspect(rec, {depth: null, colors: true}))
@ -52,6 +54,8 @@ exports.init = function init (_conString) {
if (!conString) {
throw new Error('Postgres connection string is required')
}
setInterval(pruneCachedResponses, CACHED_SESSION_TTL)
}
function connect (cb) {
@ -778,12 +782,12 @@ function insertCachedRequest (session, path, method, body) {
'body'
]
const sql = getInsertQuery('cached_requests', fields)
const sql = getInsertQuery('cached_responses', fields)
return pquery(sql, [session.fingerprint, session.id, path, method, body])
}
exports.cachedResponse = function (session, path, method) {
const sql = `select body from cached_requests
const sql = `select body from cached_responses
where device_fingerprint=$1
and session_id=$2
and path=$3
@ -800,8 +804,17 @@ exports.cachedResponse = function (session, path, method) {
})
}
function pruneCachedResponses () {
const sql = `delete from cached_responses
where (EXTRACT(EPOCH FROM (now() - created))) * 1000 < $1`
const values = [CACHED_SESSION_TTL]
return pquery(sql, values)
}
exports.cacheResponse = function (session, path, method, body) {
const sql = `update cached_requests
const sql = `update cached_responses
set body=$1
where device_fingerprint=$2
and session_id=$3