| import { |
| IQueryStore, |
| type Checkpoint, |
| type ColumnPageQuery, |
| type IQuery, |
| type Page, |
| } from '#/persistence/interface/queryStore'; |
|
|
| export function stubQueryStore(): IQueryStore { |
| return { |
| _serviceBrand: undefined, |
| put: async (_c: string, _k: string, _v: unknown) => {}, |
| batch: async (_ops) => {}, |
| delete: async (_c: string, _k: string) => {}, |
| get: async <T>(_c: string, _k: string) => undefined as T | undefined, |
| getMany: async <T>(_c: string, _keys: readonly string[]) => new Map<string, T>(), |
| query: <T>(_c: string) => emptyQuery<T>(), |
| pageByColumn: async <T>(_c: string, _q: ColumnPageQuery) => ({ items: [] as T[] }), |
| ensureIndex: async (_c, _d) => {}, |
| listKeys: async (_c: string) => [], |
| dropCollection: async (_c: string) => {}, |
| getCheckpoint: async (_s: string) => undefined as Checkpoint | undefined, |
| setCheckpoint: async (_s: string, _c: Checkpoint) => {}, |
| storeEpoch: () => 0, |
| close: async () => {}, |
| }; |
| } |
|
|
| function emptyQuery<T>(): IQuery<T> { |
| const page: Page<T> = { items: [] }; |
| const q: IQuery<T> = { |
| where: () => q, |
| whereColumn: () => q, |
| orderBy: () => q, |
| limit: () => q, |
| cursor: () => q, |
| execute: () => Promise.resolve(page), |
| }; |
| return q; |
| } |
|
|
