diff --git a/server/plugins/messageStorage/sqlite.ts b/server/plugins/messageStorage/sqlite.ts index dda5e814..1a9222dd 100644 --- a/server/plugins/messageStorage/sqlite.ts +++ b/server/plugins/messageStorage/sqlite.ts @@ -279,6 +279,21 @@ class SqliteMessageStorage implements ISqliteMessageStorage { }); }); } + + private serialize_fetchall(stmt: string, ...params: any[]): Promise { + return new Promise((resolve, reject) => { + this.database.serialize(() => { + this.database.all(stmt, params, (err, rows) => { + if (err) { + reject(err); + return; + } + + resolve(rows); + }); + }); + }); + } } // TODO: type any