File size: 1,262 Bytes
f0634fb | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 | 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;
}
|