Merge branch 'master' of https://github.com/datacite/lupo

app/models/concerns/indexable.rb

@@ -169,7 +169,7 @@ def query(query, options={})
         from = 0
 
         # make sure we have a valid cursor
-        search_after = options.dig(:page, :cursor).is_a?(Array) || [1, "1"]
+        search_after = options.dig(:page, :cursor).is_a?(Array) ? options.dig(:page, :cursor) : [1, "1"]
 
         if self.name == "Event"
           sort = [{ created_at: "asc", uuid: "asc" }]

app/models/doi.rb

@@ -755,7 +755,7 @@ def self.query(query, options={})
       from = 0
 
       # make sure we have a valid cursor
-      search_after = options.dig(:page, :cursor).is_a?(Array) || [1, "1"]
+      search_after = options.dig(:page, :cursor).is_a?(Array) ? options.dig(:page, :cursor) : [1, "1"]
       sort = [{ created: "asc", uid: "asc" }]
     else
       from = ((options.dig(:page, :number) || 1) - 1) * (options.dig(:page, :size) || 25)

lib/tasks/event.rake

@@ -56,7 +56,7 @@ namespace :event do
 
   desc 'update registrant metadata'
   task :update_registrant => :environment do
-    cursor = ENV['CURSOR'].to_s.split(",") || [Event.minimum(:id), Event.minimum(:id)]
+    cursor = ENV["CURSOR"].present? ? Base64.urlsafe_decode64(ENV["CURSOR"]).split(",", 2) : []
 
     Event.update_registrant(cursor: cursor, size: ENV['SIZE'])
   end

spec/models/doi_spec.rb

@@ -523,23 +523,22 @@
     end
   end
 
-  # TODO issue with search_after
-  # describe "transfer", elasticsearch: true do
-  #   let(:provider)  { create(:provider) }
-  #   let(:client)  { create(:client, provider: provider) }
-  #   let(:target) { create(:client, provider: provider, symbol: provider.symbol + ".TARGET", name: "Target Client") }
-  #   let!(:dois) { create_list(:doi, 5, client: client, aasm_state: "findable") }
-
-  #   before do
-  #     Doi.import
-  #     sleep 2
-  #   end
-
-  #   it "transfer all dois" do
-  #     response = Doi.transfer(client_id: client.symbol.downcase, client_target_id: target.symbol.downcase, size: 3)
-  #     expect(response).to eq(5)
-  #   end
-  # end
+  describe "transfer", elasticsearch: true do
+    let(:provider)  { create(:provider) }
+    let(:client)  { create(:client, provider: provider) }
+    let(:target) { create(:client, provider: provider, symbol: provider.symbol + ".TARGET", name: "Target Client") }
+    let!(:dois) { create_list(:doi, 5, client: client, aasm_state: "findable") }
+
+    before do
+      Doi.import
+      sleep 2
+    end
+
+    it "transfer all dois" do
+      response = Doi.transfer(client_id: client.symbol.downcase, client_target_id: target.symbol.downcase, size: 3)
+      expect(response).to eq(5)
+    end
+  end
 
   describe "views" do
     let(:client) { create(:client) }