BulkImports: Rename "end_cursor" to "next_page"

This decouples the ExtractedData object from what type of Extractor is
being used. Using "end_cursor" is too coupled with GraphQL vocabulary.

ee/lib/ee/bulk_imports/groups/graphql/get_epic_award_emoji_query.rb

@@ -14,7 +14,7 @@ module EE
                 epic(iid: $epic_iid) {
                   award_emoji: awardEmoji(first: 100, after: $cursor) {
                     page_info: pageInfo {
-                      end_cursor: endCursor
+                      next_page: endCursor
                       has_next_page: hasNextPage
                     }
                     nodes {

ee/lib/ee/bulk_imports/groups/graphql/get_epic_events_query.rb

@@ -14,7 +14,7 @@ module EE
                 epic(iid: $epic_iid) {
                   events(first: 100, after: $cursor) {
                     page_info: pageInfo {
-                      end_cursor: endCursor
+                      next_page: endCursor
                       has_next_page: hasNextPage
                     }
                     nodes {

ee/lib/ee/bulk_imports/groups/graphql/get_epics_query.rb

@@ -17,7 +17,7 @@ module EE
                   after: $cursor
                 ) {
                   page_info: pageInfo {
-                    end_cursor: endCursor
+                    next_page: endCursor
                     has_next_page: hasNextPage
                   }
                   nodes {

ee/lib/ee/bulk_imports/groups/graphql/get_iterations_query.rb

@@ -13,7 +13,7 @@ module EE
               group(fullPath: $full_path) {
                 iterations(first: 100, after: $cursor, includeAncestors: false) {
                   page_info: pageInfo {
-                    end_cursor: endCursor
+                    next_page: endCursor
                     has_next_page: hasNextPage
                   }
                   nodes {

ee/spec/lib/ee/bulk_imports/groups/pipelines/epic_award_emoji_pipeline_spec.rb

@@ -125,7 +125,7 @@ RSpec.describe EE::BulkImports::Groups::Pipelines::EpicAwardEmojiPipeline do
 
     page_info = {
       'has_next_page' => has_next_page,
-      'end_cursor' => has_next_page ? 'cursor' : nil
+      'next_page' => has_next_page ? 'cursor' : nil
     }
 
     BulkImports::Pipeline::ExtractedData.new(data: data, page_info: page_info)

ee/spec/lib/ee/bulk_imports/groups/pipelines/epic_events_pipeline_spec.rb

@@ -171,7 +171,7 @@ RSpec.describe EE::BulkImports::Groups::Pipelines::EpicEventsPipeline do
 
     page_info = {
       'has_next_page' => has_next_page,
-      'end_cursor' => has_next_page ? 'cursor' : nil
+      'next_page' => has_next_page ? 'cursor' : nil
     }
 
     BulkImports::Pipeline::ExtractedData.new(

ee/spec/lib/ee/bulk_imports/groups/pipelines/epics_pipeline_spec.rb

@@ -146,7 +146,7 @@ RSpec.describe EE::BulkImports::Groups::Pipelines::EpicsPipeline, :clean_gitlab_
 
     page_info = {
       'has_next_page' => has_next_page,
-      'end_cursor' => has_next_page ? 'cursor' : nil
+      'next_page' => has_next_page ? 'cursor' : nil
     }
 
     BulkImports::Pipeline::ExtractedData.new(data: data, page_info: page_info)

ee/spec/lib/ee/bulk_imports/groups/pipelines/iterations_pipeline_spec.rb

@@ -112,7 +112,7 @@ RSpec.describe EE::BulkImports::Groups::Pipelines::IterationsPipeline do
   def extracted_data(title:, start_date: Date.today, has_next_page: false)
     page_info = {
       'has_next_page' => has_next_page,
-      'end_cursor' => has_next_page ? 'cursor' : nil
+      'next_page' => has_next_page ? 'cursor' : nil
     }
 
     BulkImports::Pipeline::ExtractedData.new(

lib/bulk_imports/groups/graphql/get_labels_query.rb

@@ -12,7 +12,7 @@ module BulkImports
             group(fullPath: $full_path) {
               labels(first: 100, after: $cursor, onlyGroupLabels: true) {
                 page_info: pageInfo {
-                  end_cursor: endCursor
+                  next_page: endCursor
                   has_next_page: hasNextPage
                 }
                 nodes {

lib/bulk_imports/groups/graphql/get_members_query.rb

@@ -11,7 +11,7 @@ module BulkImports
             group(fullPath: $full_path) {
               group_members: groupMembers(relations: DIRECT, first: 100, after: $cursor) {
                 page_info: pageInfo {
-                  end_cursor: endCursor
+                  next_page: endCursor
                   has_next_page: hasNextPage
                 }
                 nodes {

lib/bulk_imports/groups/graphql/get_milestones_query.rb

@@ -12,7 +12,7 @@ module BulkImports
             group(fullPath: $full_path) {
               milestones(first: 100, after: $cursor, includeDescendants: false) {
                 page_info: pageInfo {
-                  end_cursor: endCursor
+                  next_page: endCursor
                   has_next_page: hasNextPage
                 }
                 nodes {

lib/bulk_imports/pipeline/extracted_data.rb

@@ -18,7 +18,7 @@ module BulkImports
       end
 
       def next_page
-        @page_info&.dig('end_cursor')
+        @page_info&.dig('next_page')
       end
 
       def each(&block)

spec/lib/bulk_imports/groups/pipelines/labels_pipeline_spec.rb

@@ -94,7 +94,7 @@ RSpec.describe BulkImports::Groups::Pipelines::LabelsPipeline do
   def extracted_data(title:, has_next_page: false)
     page_info = {
       'has_next_page' => has_next_page,
-      'end_cursor' => has_next_page ? 'cursor' : nil
+      'next_page' => has_next_page ? 'cursor' : nil
     }
 
     BulkImports::Pipeline::ExtractedData.new(data: [label_data(title)], page_info: page_info)

spec/lib/bulk_imports/groups/pipelines/members_pipeline_spec.rb

@@ -103,7 +103,7 @@ RSpec.describe BulkImports::Groups::Pipelines::MembersPipeline do
 
     page_info = {
       'has_next_page' => has_next_page,
-      'end_cursor' => has_next_page ? 'cursor' : nil
+      'next_page' => has_next_page ? 'cursor' : nil
     }
 
     BulkImports::Pipeline::ExtractedData.new(data: data, page_info: page_info)

spec/lib/bulk_imports/groups/pipelines/milestones_pipeline_spec.rb

@@ -111,7 +111,7 @@ RSpec.describe BulkImports::Groups::Pipelines::MilestonesPipeline do
   def extracted_data(title:, has_next_page: false)
     page_info = {
       'has_next_page' => has_next_page,
-      'end_cursor' => has_next_page ? 'cursor' : nil
+      'next_page' => has_next_page ? 'cursor' : nil
     }
 
     BulkImports::Pipeline::ExtractedData.new(

spec/lib/bulk_imports/pipeline/extracted_data_spec.rb

@@ -9,7 +9,7 @@ RSpec.describe BulkImports::Pipeline::ExtractedData do
   let(:page_info) do
     {
       'has_next_page' => has_next_page,
-      'end_cursor' => cursor
+      'next_page' => cursor
     }
   end
 

spec/lib/bulk_imports/pipeline/runner_spec.rb

@@ -245,7 +245,7 @@ RSpec.describe BulkImports::Pipeline::Runner do
         data: { foo: :bar },
         page_info: {
           'has_next_page' => has_next_page,
-          'end_cursor' => has_next_page ? 'cursor' : nil
+          'next_page' => has_next_page ? 'cursor' : nil
         }
       )
     end