subscribe the MetadataIndexListener in config/initializers/listeners.…

…rb; add on_object_metadata_created

app/services/hyrax/listeners/metadata_index_listener.rb

@@ -16,7 +16,17 @@ class MetadataIndexListener
       #
       # @param event [Dry::Event]
       def on_object_metadata_updated(event)
-        Hyrax.index_adapter.save(resource: event[:object])
+        Hyrax.index_adapter.save(resource:
+          Hyrax::ValkyrieIndexer.for(resource: event[:object]).resource)
+      end
+
+      ##
+      # Index the resource.
+      #
+      # @param event [Dry::Event]
+      def on_object_metadata_created(event)
+        Hyrax.index_adapter.save(resource: 
+          Hyrax::ValkyrieIndexer.for(resource: event[:object]).resource)
       end
     end
   end

config/initializers/listeners.rb

@@ -1,6 +1,7 @@
 # frozen_string_literal: true
 
 Hyrax.publisher.subscribe(Hyrax::Listeners::AclIndexListener.new)
+Hyrax.publisher.subscribe(Hyrax::Listeners::MetadataIndexListener.new)
 Hyrax.publisher.subscribe(Hyrax::Listeners::BatchNotificationListener.new)
 Hyrax.publisher.subscribe(Hyrax::Listeners::ObjectLifecycleListener.new)
 Hyrax.publisher.subscribe(Hyrax::Listeners::FileSetLifecycleListener.new)
@@ -10,6 +11,7 @@
 # When callbacks are removed and replaced with direct event publication, drop these blocks
 Hyrax.config.callback.set(:after_create_concern, warn: false) do |curation_concern, user|
   Hyrax.publisher.publish('object.deposited', object: curation_concern, user: user)
+  Hyrax.publisher.publish('object.metadata.created', object: curation_concern, user: user)
 end
 
 Hyrax.config.callback.set(:after_create_fileset, warn: false) do |file_set, user|

lib/hyrax/publisher.rb

@@ -58,6 +58,7 @@ class Publisher
     register_event('object.deleted')
     register_event('object.deposited')
     register_event('object.acl.updated')
+    register_event('object.metadata.created')
     register_event('object.metadata.updated')
   end
 end

lib/hyrax/specs/spy_listener.rb

@@ -5,7 +5,7 @@ module Specs
     class SpyListener
       attr_reader :file_set_attached, :file_set_url_imported, :object_deleted,
                   :object_deposited, :object_acl_updated,
-                  :object_metadata_updated
+                  :object_metadata_created, :object_metadata_updated
 
       def on_object_deleted(event)
         @object_deleted = event
@@ -19,6 +19,10 @@ def on_object_acl_updated(event)
         @object_acl_updated = event
       end
 
+      def on_object_metadata_created(event)
+        @object_metadata_created = event
+      end
+
       def on_object_metadata_updated(event)
         @object_metadata_updated = event
       end

spec/actors/hyrax/actors/generic_work_actor_spec.rb

@@ -63,6 +63,12 @@
           .to change { listener.object_deposited&.payload }
           .to eq object: curation_concern, user: user
       end
+
+      it 'publishes an object.metadata.created event' do
+        expect { middleware.create(env) }
+          .to change { listener.object_metadata_created&.payload }
+          .to eq object: curation_concern, user: user
+      end
     end
 
     context 'valid attributes', perform_enqueued: [AttachFilesToWorkJob, IngestJob] do

spec/services/hyrax/listeners/metadata_index_listener_spec.rb

@@ -21,4 +21,14 @@
         .to contain_exactly(resource)
     end
   end
+
+  describe '#on_object_metadata_created' do
+    let(:event_type) { :on_object_metadata_created }
+
+    it 'indexes the object on the configured adapter' do
+      expect { listener.on_object_metadata_created(event) }
+        .to change { fake_adapter.saved_resources }
+        .to contain_exactly(resource)
+    end
+  end
 end