import { BasePaginator } from './BasePaginator';
import type {
  PaginationQueryParams,
  PaginationQueryReturnValue,
  PaginatorOptions,
} from './BasePaginator';
import type { ReminderFilters, ReminderResponse, ReminderSort } from '../types';
import type { StreamChat } from '../client';

export class ReminderPaginator extends BasePaginator<ReminderResponse> {
  private client: StreamChat;
  protected _filters: ReminderFilters | undefined;
  protected _sort: ReminderSort | undefined;

  get filters(): ReminderFilters | undefined {
    return this._filters;
  }

  get sort(): ReminderSort | undefined {
    return this._sort;
  }

  set filters(filters: ReminderFilters | undefined) {
    this._filters = filters;
    this.resetState();
  }

  set sort(sort: ReminderSort | undefined) {
    this._sort = sort;
    this.resetState();
  }

  constructor(client: StreamChat, options?: PaginatorOptions) {
    super(options);
    this.client = client;
  }

  query = async ({
    direction,
  }: PaginationQueryParams): Promise<PaginationQueryReturnValue<ReminderResponse>> => {
    const cursor = this.cursor?.[direction];
    const {
      reminders: items,
      next,
      prev,
    } = await this.client.queryReminders({
      filter: this.filters,
      sort: this.sort,
      limit: this.pageSize,
      [direction]: cursor,
    });
    return { items, next, prev };
  };

  filterQueryResults = (items: ReminderResponse[]) => items;
}