(sessionId: string)
| 118 | const avatarCheckedSessions = new Set<string>() |
| 119 | |
| 120 | function ensureAliasesColumn(sessionId: string): void { |
| 121 | if (aliasesCheckedSessions.has(sessionId)) return |
| 122 | const dbPath = getDbPath(sessionId) |
| 123 | if (!fs.existsSync(dbPath)) return |
| 124 | closeDatabase(sessionId) |
| 125 | const db = new Database(dbPath) |
| 126 | db.pragma('journal_mode = WAL') |
| 127 | try { |
| 128 | const adapter = new BetterSqliteAdapter(db) |
| 129 | if (coreEnsureAliasesColumn(adapter)) { |
| 130 | console.log(`[Worker] Added aliases column to member table in session ${sessionId}`) |
| 131 | } |
| 132 | aliasesCheckedSessions.add(sessionId) |
| 133 | } finally { |
| 134 | db.close() |
| 135 | } |
| 136 | } |
| 137 | |
| 138 | export function ensureAvatarColumn(sessionId: string): void { |
| 139 | if (avatarCheckedSessions.has(sessionId)) return |
nothing calls this directly
no test coverage detected