Update object_created_spec to use RepositoryObjects.

refs #5014

app/models/repository_object.rb

@@ -32,7 +32,7 @@ class VersionNotOpened < StandardError; end
   scope :collections, -> { where(object_type: 'collection') }
   scope :admin_policies, -> { where(object_type: 'admin_policy') }
 
-  delegate :to_cocina, to: :head_version
+  delegate :to_cocina, :to_cocina_with_metadata, to: :head_version
 
   # NOTE: This block uses metaprogramming to create the equivalent of scopes that query the RepositoryObjectVersion table using only rows that are a `current` in the RepositoryObject table
   #

spec/services/notifications/object_created_spec.rb

@@ -13,15 +13,21 @@
   let(:channel) { instance_double(Notifications::RabbitChannel, topic:) }
   let(:topic) { instance_double(Bunny::Exchange, publish: true) }
 
+  let(:model) do
+    create(:repository_object, :with_repository_object_version, object_type) do |repo_obj|
+      repo_obj.head_version.update(created_at:, updated_at:)
+    end
+  end
+
+  let(:object_type) { :dro }
+
   context 'when RabbitMQ is enabled' do
     before do
       allow(Notifications::RabbitChannel).to receive(:instance).and_return(channel)
       allow(Settings.rabbitmq).to receive(:enabled).and_return(true)
     end
 
     context 'when called with a DRO' do
-      let(:model) { build(:ar_dro, created_at:, updated_at:) }
-
       before do
         allow(AdministrativeTags).to receive(:project).and_return(['h2'])
       end
@@ -34,7 +40,7 @@
     end
 
     context 'when called with an AdminPolicy' do
-      let(:model) { build(:ar_admin_policy, created_at:, updated_at:) }
+      let(:object_type) { :admin_policy }
 
       it 'is successful' do
         publish
@@ -49,8 +55,6 @@
     end
 
     context 'when called with a DRO' do
-      let(:model) { build(:ar_dro, created_at:, updated_at:) }
-
       it 'does not receive a message' do
         publish
         expect(topic).not_to have_received(:publish)