diff --git a/src/core/storage/sqlite3/Sqlite3SessionMeRepository.ts b/src/core/storage/sqlite3/Sqlite3SessionMeRepository.ts index c9558548..1b33a5aa 100644 --- a/src/core/storage/sqlite3/Sqlite3SessionMeRepository.ts +++ b/src/core/storage/sqlite3/Sqlite3SessionMeRepository.ts @@ -36,6 +36,22 @@ export class Sqlite3SessionMeRepository return data?.me; } + async getMeBySessions( + sessionNames: string[], + ): Promise> { + const result = new Map(); + const uniqueNames = Array.from(new Set(sessionNames)); + if (uniqueNames.length === 0) { + return result; + } + const entities = await this.getEntitiesByIds(uniqueNames); + for (const sessionName of uniqueNames) { + const entity = entities.get(sessionName); + result.set(sessionName, entity?.me ?? null); + } + return result; + } + removeMe(sessionName: string): Promise { return this.deleteById(sessionName); }