summaryrefslogtreecommitdiff
path: root/nodejs/database/surveys.js
diff options
context:
space:
mode:
authorJulien Dessaux2023-07-01 23:13:13 +0200
committerJulien Dessaux2023-07-01 23:13:13 +0200
commit36cc33f9e96a38ecea98ac8d26275b4828347d80 (patch)
tree653dcea7e656ec815fc0a1fa5664a6b89abccaa3 /nodejs/database/surveys.js
parentFixed prepared statements (diff)
downloadspacetraders-36cc33f9e96a38ecea98ac8d26275b4828347d80.tar.gz
spacetraders-36cc33f9e96a38ecea98ac8d26275b4828347d80.tar.bz2
spacetraders-36cc33f9e96a38ecea98ac8d26275b4828347d80.zip
Moved the nodejs agent to its own subfolder to make room for my haskell agent
Diffstat (limited to 'nodejs/database/surveys.js')
-rw-r--r--nodejs/database/surveys.js19
1 files changed, 19 insertions, 0 deletions
diff --git a/nodejs/database/surveys.js b/nodejs/database/surveys.js
new file mode 100644
index 0000000..60c85b2
--- /dev/null
+++ b/nodejs/database/surveys.js
@@ -0,0 +1,19 @@
+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));
+}