summaryrefslogtreecommitdiff
path: root/lib/gitlab/graphql/pagination/keyset/generic_keyset_pagination.rb
diff options
context:
space:
mode:
Diffstat (limited to 'lib/gitlab/graphql/pagination/keyset/generic_keyset_pagination.rb')
-rw-r--r--lib/gitlab/graphql/pagination/keyset/generic_keyset_pagination.rb47
1 files changed, 47 insertions, 0 deletions
diff --git a/lib/gitlab/graphql/pagination/keyset/generic_keyset_pagination.rb b/lib/gitlab/graphql/pagination/keyset/generic_keyset_pagination.rb
new file mode 100644
index 00000000000..318c6e1734f
--- /dev/null
+++ b/lib/gitlab/graphql/pagination/keyset/generic_keyset_pagination.rb
@@ -0,0 +1,47 @@
+# frozen_string_literal: true
+
+module Gitlab
+ module Graphql
+ module Pagination
+ module Keyset
+ # Use the generic keyset implementation if the given ActiveRecord scope supports it.
+ # Note: this module is temporary, at some point it will be merged with Keyset::Connection
+ module GenericKeysetPagination
+ extend ActiveSupport::Concern
+
+ def ordered_items
+ return super unless Gitlab::Pagination::Keyset::Order.keyset_aware?(items)
+
+ items
+ end
+
+ def cursor_for(node)
+ return super unless Gitlab::Pagination::Keyset::Order.keyset_aware?(items)
+
+ order = Gitlab::Pagination::Keyset::Order.extract_keyset_order_object(items)
+ encode(order.cursor_attributes_for_node(node).to_json)
+ end
+
+ def slice_nodes(sliced, encoded_cursor, before_or_after)
+ return super unless Gitlab::Pagination::Keyset::Order.keyset_aware?(sliced)
+
+ order = Gitlab::Pagination::Keyset::Order.extract_keyset_order_object(sliced)
+ order = order.reversed_order if before_or_after == :before
+
+ decoded_cursor = ordering_from_encoded_json(encoded_cursor)
+ order.apply_cursor_conditions(sliced, decoded_cursor)
+ end
+
+ def sliced_nodes
+ return super unless Gitlab::Pagination::Keyset::Order.keyset_aware?(items)
+
+ sliced = ordered_items
+ sliced = slice_nodes(sliced, before, :before) if before.present?
+ sliced = slice_nodes(sliced, after, :after) if after.present?
+ sliced
+ end
+ end
+ end
+ end
+ end
+end