Geo: Fix geo_event_log geo_event association

Geo: Self-service framework does not associate
geo_event_log row to geo_event

ee/app/models/geo/event_log.rb

@@ -72,10 +72,10 @@ module Geo
       class_name: 'Geo::ContainerRepositoryUpdatedEvent',
       foreign_key: :container_repository_updated_event_id
 
-    belongs_to :event,
+    belongs_to :geo_event,
       class_name: 'Geo::Event',
-      foreign_key: :geo_event_id
-
+      foreign_key: :geo_event_id,
+      inverse_of: :geo_event_log
     def self.latest_event
       order(id: :desc).first
     end
@@ -95,6 +95,7 @@ module Geo
       includes(reflections.keys)
     end
 
+    # rubocop:disable Metrics/CyclomaticComplexity
     def event
       repository_created_event ||
         repository_updated_event ||
@@ -108,8 +109,10 @@ module Geo
         upload_deleted_event ||
         reset_checksum_event ||
         cache_invalidation_event ||
-        container_repository_updated_event
+        container_repository_updated_event ||
+        geo_event
     end
+    # rubocop:enable Metrics/CyclomaticComplexity
 
     def project_id
       event.try(:project_id)

ee/changelogs/unreleased/211990-geo-self-service-framework-does-not-associate-geo_event_log-row.yml

+---
+title: 'Geo: Self-service framework does not associate geo_event_log row to geo_event'
+merge_request: 28457
+author:
+type: fixed

ee/lib/gitlab/geo/replicator.rb

@@ -135,7 +135,7 @@ module Gitlab
 
         # Only works with the new geo_events at the moment because we need to
         # know which foreign key to use
-        ::Geo::EventLog.create!(geo_event_id: event)
+        ::Geo::EventLog.create!(geo_event: event)
 
         event
       rescue ActiveRecord::RecordInvalid, NoMethodError => e

ee/spec/factories/geo/event_log.rb

@@ -54,7 +54,7 @@ FactoryBot.define do
       repository_updated_event factory: :geo_design_repository_updated_event
     end
 
-    trait :event do
+    trait :geo_event do
       event factory: :geo_event
     end
   end

ee/spec/lib/gitlab/geo/log_cursor/events/event_spec.rb

@@ -5,7 +5,7 @@ require "spec_helper"
 describe Gitlab::Geo::LogCursor::Events::Event, :clean_gitlab_redis_shared_state do
   let(:logger) { Gitlab::Geo::LogCursor::Logger.new(described_class, Logger::INFO) }
   let(:event) { create(:geo_event, :package_file, event_name: "created" ) }
-  let(:event_log) { create(:geo_event_log, event: event) }
+  let(:event_log) { create(:geo_event_log, geo_event: event) }
   let(:replicable) { Packages::PackageFile.find(event.payload["model_record_id"]) }
   let!(:event_log_state) { create(:geo_event_log_state, event_id: event_log.id - 1) }
 

ee/spec/lib/gitlab/geo/replicator_spec.rb

@@ -3,6 +3,11 @@
 require 'spec_helper'
 
 describe Gitlab::Geo::Replicator do
+  include ::EE::GeoHelpers
+
+  let_it_be(:primary_node) { create(:geo_node, :primary) }
+  let_it_be(:secondary_node) { create(:geo_node) }
+
   context 'with defined events' do
     before do
       stub_const('DummyReplicator', Class.new(Gitlab::Geo::Replicator))
@@ -86,8 +91,12 @@ describe Gitlab::Geo::Replicator do
       end
 
       context 'when publishing a supported events with required params' do
-        it 'does not raise errors' do
-          expect { subject.publish(:test, other: true) }.not_to raise_error
+        it 'creates event with associated event log record' do
+          stub_current_geo_node(primary_node)
+
+          expect { subject.publish(:test, other: true) }.to change { ::Geo::EventLog.count }.from(0).to(1)
+
+          expect(::Geo::EventLog.last.event).to be_a(::Geo::Event)
         end
       end