Keep the minimum cursor last event

ee/app/services/geo/prune_event_log_service.rb

@@ -41,7 +41,7 @@ module Geo
 
     def prune!(relation, limit)
       unless delete_all?
-        relation = relation.up_to_event(event_log_min_id)
+        relation = relation.up_to_event(event_log_min_id - 1)
       end
 
       deleted = relation.delete_with_limit(limit)

ee/changelogs/unreleased/mk-keep-last-remaining-event.yml

+---
+title: 'Geo: Keep the minimum cursor last event'
+merge_request: 8832
+author:
+type: fixed

ee/spec/services/geo/prune_event_log_service_spec.rb

@@ -61,12 +61,12 @@ describe Geo::PruneEventLogService do
   context 'with event_log_min_id' do
     let(:min_id) { events[1].id }
 
-    it 'prunes events up to the min id' do
-      expect { service.execute }.to change { Geo::EventLog.count }.by(-2)
+    it 'prunes events up to, but not including, the min id' do
+      expect { service.execute }.to change { Geo::EventLog.count }.by(-1)
     end
 
     it 'prunes all associated events' do
-      expect { service.execute }.to change { Geo::RepositoryUpdatedEvent.count }.by(-2)
+      expect { service.execute }.to change { Geo::RepositoryUpdatedEvent.count }.by(-1)
     end
   end
 

ee/spec/workers/geo/prune_event_log_worker_spec.rb

@@ -44,7 +44,7 @@ describe Geo::PruneEventLogWorker, :geo do
         create_list(:geo_event_log, 2, :updated_event)
         create(:geo_node_status, :healthy, cursor_last_event_id: Geo::EventLog.last.id, geo_node_id: secondary.id)
 
-        expect { worker.perform }.to change { Geo::RepositoryUpdatedEvent.count }.by(-2)
+        expect { worker.perform }.to change { Geo::RepositoryUpdatedEvent.count }.by(-1)
       end
 
       it 'delegates pruning to Geo::PruneEventLogService' do
@@ -118,7 +118,7 @@ describe Geo::PruneEventLogWorker, :geo do
           create(:geo_node_status, :healthy, cursor_last_event_id: events.last.id, geo_node_id: secondary2.id)
           expect(Geo::PruneEventLogService).to receive(:new).with(events[3].id).and_call_original
 
-          expect { worker.perform }.to change { Geo::EventLog.count }.by(-4)
+          expect { worker.perform }.to change { Geo::EventLog.count }.by(-3)
         end
       end
     end