12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455
import { CommandCursor, WireProtocol } from "../../protocol/mod.ts";import { Document, FindOptions } from "../../types.ts";
interface FindCursorContext {  dbName: string;  collectionName: string;  protocol: WireProtocol;  options: FindOptions;  filter?: Document;}
export class FindCursor<T> extends CommandCursor<T> {  #context: FindCursorContext;
  private async executor() {    const { protocol, filter, dbName, collectionName, options } = this.#context;    const { cursor } = await protocol.commandSingle(dbName, {      find: collectionName,      filter,      batchSize: 1,      noCursorTimeout: false,      ...options,    });    return {      ...cursor,      id: cursor.id.toString(),    };  }
  constructor(context: FindCursorContext) {    super(context.protocol, () => this.executor());    this.#context = {      ...context,      options: {        ...context.options,      },    };  }
  limit(limit: number): this {    this.#context.options.limit = limit;    return this;  }
  skip(skip: number): this {    this.#context.options.skip = skip;    return this;  }
  sort(sort: Document): this {    this.#context.options.sort = sort;    return this;  }}