Function all

packages/core/src/query/__tests__/message-query-functions.test.ts:65–67

(sql: string, _params: unknown[] = [])

function createSyncBackedExecutor(store: Map<string, unknown[]>): AsyncSqlExecutor {
  return {
    all<T>(sql: string, _params: unknown[] = []): Promise<T[]> {
      return Promise.resolve((store.get(extractQueryKey(sql)) ?? []) as T[])
    },
    get<T>(sql: string, _params: unknown[] = []): Promise<T | undefined> {
      const rows = (store.get(extractQueryKey(sql)) ?? []) as T[]
      return Promise.resolve(rows[0])