Function createPluginQueryExecutor

src/services/message/fetch.ts:24–35

(sessionId: string)

}

function createPluginQueryExecutor(sessionId: string): AsyncSqlExecutor {
  const adapter = getDataAdapter()
  return {
    all<T>(sql: string, params: unknown[] = []): Promise<T[]> {
      return adapter.pluginQuery<T>(sessionId, sql, params)
    },
    async get<T>(sql: string, params: unknown[] = []): Promise<T | undefined> {
      const rows = await adapter.pluginQuery<T>(sessionId, sql, params)
      return rows[0]
    },
  }
}

export class FetchMessageAdapter implements MessageAdapter {
  async getMessagesBefore(