cursorpaginator.py 1.2 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243
  1. from django.core.paginator import EmptyPage, InvalidPage
  2. class CursorPaginator:
  3. def __init__(self, queryset, order_by, per_page):
  4. self.queryset = queryset
  5. self.order_by = order_by
  6. self.per_page = int(per_page)
  7. def get_page(self, start=0):
  8. if start < 0:
  9. raise InvalidPage()
  10. object_list = self._get_slice(start)
  11. if start and not object_list:
  12. raise EmptyPage()
  13. next_cursor = None
  14. if len(object_list) > self.per_page:
  15. next_slice_first_item = object_list.pop(-1)
  16. next_cursor = getattr(next_slice_first_item, self.order_by)
  17. return Page(start, object_list, next_cursor)
  18. def _get_slice(self, start):
  19. page_len = self.per_page + 1
  20. if start:
  21. filter_name = "%s__gte" % self.order_by
  22. return self.queryset.filter(**{filter_name: start})[:page_len]
  23. return self.queryset[:page_len]
  24. class Page:
  25. def __init__(self, start, object_list, next_):
  26. self.start = start or None
  27. self.object_list = object_list
  28. self.next = next_
  29. def __len__(self):
  30. return len(self.object_list)
  31. def has_next(self):
  32. return bool(self.next)