import db from './db.js';

const deleteExpiredSurveysStatement = db.prepare(`DELETE FROM surveys WHERE data->>'expiration' < ?;`);
const getSurveysStatement = db.prepare(`SELECT data FROM surveys WHERE data->>'symbol' = ?;`);
const setSurveysStatement = db.prepare(`INSERT INTO surveys(data) VALUES (json(?));`);

export function deleteExpired() {
	return deleteExpiredSurveysStatement.run(new Date().toISOString()).changes;
}

export function get(symbol) {
	deleteExpired();
	return getSurveysStatement.all(symbol);
}

export function set(survey) {
	deleteExpired();
	return setSurveysStatement.run(JSON.stringify(survey));
}