Contents

module GeoWorks
  class EventsGenerator
    class GeoblacklightEventGenerator
      def record_created(record)
        publish_message(
          message("CREATED", record)
        )
      end

      def record_deleted(record)
        publish_message(
          delete_message("DELETED", record)
        )
      end

      def record_updated(record)
        publish_message(
          message("UPDATED", record)
        )
      end

      private

        def publish_message(message)
          GeoblacklightJob.perform_later(message)
        end

        def message(type, record)
          base_message(type, record).merge("doc" => generate_document(record).to_hash)
        end

        def delete_message(type, record)
          base_message(type, record).merge("id" => slug(record))
        end

        def base_message(type, record)
          {
            "id" => record.id,
            "event" => type
          }
        end

        def generate_document(record)
          Discovery::DocumentBuilder.new(record, Discovery::GeoblacklightDocument.new)
        end

        def slug(record)
          return record.id unless record.respond_to?(:provenance)
          "#{record.provenance.parameterize}-#{record.id}"
        end
    end
  end
end

Version data entries

6 entries across 6 versions & 1 rubygems

Version	Path
geo_works-0.2.0	app/services/geo_works/events_generator/geoblacklight_event_generator.rb
geo_works-0.1.4	app/services/geo_works/events_generator/geoblacklight_event_generator.rb
geo_works-0.1.3	app/services/geo_works/events_generator/geoblacklight_event_generator.rb
geo_works-0.1.2	app/services/geo_works/events_generator/geoblacklight_event_generator.rb
geo_works-0.1.1	app/services/geo_works/events_generator/geoblacklight_event_generator.rb
geo_works-0.1.0	app/services/geo_works/events_generator/geoblacklight_event_generator.rb