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