From bbe81bb2fa9001762df90c1a267afa0239ebb7c7 Mon Sep 17 00:00:00 2001 From: Reto Brunner Date: Mon, 10 Oct 2022 21:43:05 +0200 Subject: [PATCH] sqlite: add serialize_get --- server/plugins/messageStorage/sqlite.ts | 18 ++++++++++++++++++ 1 file changed, 18 insertions(+) diff --git a/server/plugins/messageStorage/sqlite.ts b/server/plugins/messageStorage/sqlite.ts index 6b46e8b5..ed242aea 100644 --- a/server/plugins/messageStorage/sqlite.ts +++ b/server/plugins/messageStorage/sqlite.ts @@ -284,6 +284,24 @@ class SqliteMessageStorage implements ISqliteMessageStorage { }); }); } + + private serialize_get(stmt: string, ...params: any[]): Promise { + const log_id = this.stmt_id(); + return new Promise((resolve, reject) => { + this.database.serialize(() => { + this.database.get(stmt, params, (err, row) => { + log.debug(log_id, "callback", stmt); + + if (err) { + reject(err); + return; + } + + resolve(row); + }); + }); + }); + } } // TODO: type any