Merge pull request #4894 from sul-dlss/index_on_create

app/services/create_object_service.rb

@@ -47,6 +47,7 @@ def create(cocina_request_object, assign_doi: false)
 
     # Broadcast this to a topic
     Notifications::ObjectCreated.publish(model: cocina_object_with_metadata)
+    Indexer.reindex(cocina_object: cocina_object_with_metadata)
     cocina_object_with_metadata
   end
 

app/services/ur_admin_policy_factory.rb

@@ -25,6 +25,6 @@ def self.create
     )
 
     cocina_object_with_metadata = CocinaObjectStore.store(admin_policy_cocina, skip_lock: true)
-    Notifications::ObjectCreated.publish(model: cocina_object_with_metadata)
+    Indexer.reindex(cocina_object: cocina_object_with_metadata)
   end
 end

spec/requests/create_collection_spec.rb

@@ -14,7 +14,7 @@
   before do
     allow(SuriService).to receive(:mint_id).and_return(druid)
     allow_any_instance_of(CocinaObjectStore).to receive(:find).with('druid:dd999df4567').and_return(minimal_cocina_admin_policy)
-    stub_request(:put, 'https://dor-indexing-app.example.edu/dor/reindex_from_cocina')
+    allow(Indexer).to receive(:reindex)
   end
 
   context 'when the folio instance hrid is provided and save is successful' do

spec/requests/create_object_spec.rb

@@ -25,6 +25,7 @@
   before do
     allow(SuriService).to receive(:mint_id).and_return(druid)
     allow(Catalog::MarcService).to receive(:new).and_return(marc_service)
+    allow(Indexer).to receive(:reindex)
   end
 
   context 'when a DRO is provided' do

spec/services/cocina_object_store_spec.rb

@@ -34,6 +34,7 @@
       before do
         allow(Settings.ur_admin_policy).to receive(:druid).and_return('druid:bc123df4567')
         allow(Settings.enabled_features).to receive(:create_ur_admin_policy).and_return(true)
+        allow(Indexer).to receive(:reindex)
       end
 
       it 'bootstraps' do

spec/services/create_object_service_spec.rb

@@ -19,6 +19,7 @@
     before do
       allow(Cocina::ObjectValidator).to receive(:validate)
       allow(Notifications::ObjectCreated).to receive(:publish)
+      allow(Indexer).to receive(:reindex)
       allow(store).to receive(:merge_access_for).and_return(requested_cocina_object)
       allow(store).to receive(:add_project_tag)
       allow(SuriService).to receive(:mint_id).and_return(druid)
@@ -49,6 +50,7 @@
         end.to change(Dro, :count).by(1).and change(RepositoryObject, :count).by(1)
 
         expect(Notifications::ObjectCreated).to have_received(:publish)
+        expect(Indexer).to have_received(:reindex)
         expect(Cocina::ObjectValidator).to have_received(:validate).with(requested_cocina_object)
         expect(store).to have_received(:merge_access_for).with(requested_cocina_object)
         expect(store).to have_received(:add_project_tag).with(druid, requested_cocina_object)
@@ -66,6 +68,7 @@
           expect(store.create(requested_cocina_object)).to be_a Cocina::Models::CollectionWithMetadata
         end.to change(Collection, :count).by(1)
         expect(Notifications::ObjectCreated).to have_received(:publish)
+        expect(Indexer).to have_received(:reindex)
         expect(Cocina::ObjectValidator).to have_received(:validate).with(requested_cocina_object)
         expect(store).to have_received(:merge_access_for).with(requested_cocina_object)
         expect(store).to have_received(:add_project_tag).with(druid, requested_cocina_object)

spec/services/ur_admin_policy_factory_spec.rb

@@ -8,13 +8,13 @@
   let(:druid) { Settings.ur_admin_policy.druid }
 
   before do
-    allow(Notifications::ObjectCreated).to receive(:publish)
+    allow(Indexer).to receive(:reindex)
   end
 
   it 'creates the Ur-AdminPolicy' do
     expect(AdminPolicy.exists?(external_identifier: druid)).to be false
     policy
     expect(AdminPolicy.exists?(external_identifier: druid)).to be true
-    expect(Notifications::ObjectCreated).to have_received(:publish)
+    expect(Indexer).to have_received(:reindex)
   end
 end