import { Logger, LogProvider } from '../logger'; import { ISettingStore } from '../types/stores/settings-store'; import { Db } from './db'; const TABLE = 'settings'; export default class SettingStore implements ISettingStore { private db: Db; private logger: Logger; constructor(db: Db, getLogger: LogProvider) { this.db = db; this.logger = getLogger('settings-store.ts'); } // eslint-disable-next-line @typescript-eslint/explicit-module-boundary-types async updateRow(name: string, content: any): Promise { return this.db(TABLE) .where('name', name) .update({ content: JSON.stringify(content), }); } // eslint-disable-next-line @typescript-eslint/explicit-module-boundary-types async insertNewRow(name: string, content: any) { return this.db(TABLE).insert({ name, content }); } async exists(name: string): Promise { const result = await this.db.raw( `SELECT EXISTS (SELECT 1 FROM ${TABLE} WHERE name = ?) AS present`, [name], ); const { present } = result.rows[0]; return present; } async get(name: string): Promise { const result = await this.db.select().from(TABLE).where('name', name); if (result.length > 0) { return result[0].content; } return undefined; } // eslint-disable-next-line @typescript-eslint/explicit-module-boundary-types async insert(name: string, content: any): Promise { const exists = await this.exists(name); if (exists) { await this.updateRow(name, content); } else { await this.insertNewRow(name, content); } } async delete(name: string): Promise { await this.db(TABLE).where({ name }).del(); } async deleteAll(): Promise { await this.db(TABLE).del(); } destroy(): void {} async getAll(): Promise { const rows = await this.db(TABLE).select(); return rows.map((r) => r.content); } } module.exports = SettingStore;