Spaces:
Sleeping
Sleeping
File size: 2,849 Bytes
5c2ed06 |
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 |
/**
* SQL transactions for the Trivia plugin.
*/
import type { TransactionEnvironment } from '../../../lib/sql';
import type { TriviaHistory, TriviaQuestion } from './trivia';
export const transactions = {
addHistory: (
args: { history: Iterable<TriviaHistory>, gameHistoryInsertion: string, scoreHistoryInsertion: string },
env: TransactionEnvironment
) => {
const gameHistoryInsertion = env.statements.get(args.gameHistoryInsertion);
const scoreHistoryInsertion = env.statements.get(args.scoreHistoryInsertion);
if (!gameHistoryInsertion || !scoreHistoryInsertion) throw new Error('Statements not found');
for (const game of args.history) {
const { lastInsertRowid } = gameHistoryInsertion.run(
game.mode, game.length, game.category, game.startTime, game.creator, Number(game.givesPoints)
);
for (const userid in game.scores) {
scoreHistoryInsertion.run(lastInsertRowid, userid, game.scores[userid]);
}
}
return true;
},
editQuestion(
args: { oldQuestionText: string, newQuestionText?: string, newAnswers?: string[] },
env: TransactionEnvironment,
) {
// Question editing is likely to be infrequent, so I've optimized for readability and proper argument checking
// rather than performance (i.e. not passing in prepared statements).
const { oldQuestionText, newQuestionText, newAnswers } = args;
if (newAnswers) {
const questionID = (env.db
.prepare('SELECT question_id FROM trivia_questions WHERE question = ?')
.get(oldQuestionText) as AnyObject | null)?.question_id;
if (!questionID) throw new Error('Question not found');
env.db.prepare('DELETE FROM trivia_answers WHERE question_id = ?').run(questionID);
const insert = env.db.prepare('INSERT INTO trivia_answers (question_id, answer) VALUES (?, ?)');
for (const answer of newAnswers) {
insert.run([questionID, answer]);
}
}
if (newQuestionText) {
env.db
.prepare(`UPDATE trivia_questions SET question = ? WHERE question = ?`)
.run([newQuestionText, oldQuestionText]);
}
},
addQuestions: (
args: {
questions: Iterable<TriviaQuestion>,
questionInsertion: string,
answerInsertion: string,
isSubmission: boolean,
},
env: TransactionEnvironment
) => {
const questionInsertion = env.statements.get(args.questionInsertion);
const answerInsertion = env.statements.get(args.answerInsertion);
if (!questionInsertion || !answerInsertion) throw new Error('Statements not found');
const isSubmissionForSQLite = Number(args.isSubmission);
for (const question of args.questions) {
const { lastInsertRowid } = questionInsertion.run(
question.question, question.category, question.addedAt, question.user, isSubmissionForSQLite
);
for (const answer of question.answers) {
answerInsertion.run(lastInsertRowid, answer);
}
}
return true;
},
};
|