require 'spec_helper'

RSpec.describe GeoWorks::EventsGenerator::GeoblacklightEventGenerator do
  subject { described_class.new }
  let(:geo_concern) { FactoryGirl.build(:public_vector_work, attributes) }
  let(:record) { GeoWorks::VectorWorkShowPresenter.new(SolrDocument.new(geo_concern.to_solr), nil) }
  let(:visibility) { Hydra::AccessControls::AccessRight::VISIBILITY_TEXT_VALUE_PUBLIC }
  let(:coverage) { GeoWorks::Coverage.new(43, -69, 42, -71) }
  let(:attributes) { { id: 'geo-work-1',
                       title: ['Geo Work'],
                       coverage: coverage.to_s,
                       description: ['geo work'],
                       temporal: ['2011'] }
  }
  let(:refs) { { "http://schema.org/url" => "http://localhost:3000/concern/vector_works/geo-work-1" } }
  let(:layer_modified) do
    datetime = record.solr_document[:system_modified_dtsi]
    DateTime.parse(datetime.to_s).utc.xmlschema
  end
  let(:discovery_doc) { { geoblacklight_version: "1.0",
                          dc_identifier_s: "geo-work-1",
                          layer_slug_s: "institution-geo-work-1",
                          uuid: "institution-geo-work-1",
                          dc_title_s: record.title.first,
                          solr_geom: "ENVELOPE(-71.0, -69.0, 43.0, 42.0)",
                          dct_provenance_s: "Institution",
                          dc_rights_s: "Public",
                          dc_description_s: "geo work",
                          dct_temporal_sm: ["2011"],
                          solr_year_i: 2011,
                          layer_id_s: 'geo-work-1',
                          layer_modified_dt: layer_modified,
                          dct_references_s: refs.to_json,
                          layer_geom_type_s: "Mixed" }
  }

  before do
    allow(record.solr_document).to receive(:visibility).and_return(visibility)
    allow(record.request).to receive_messages(host_with_port: 'localhost:3000', protocol: 'http://')
    allow(GeoblacklightJob).to receive(:perform_later)
  end

  describe "#record_created" do
    it "publishes a persistent JSON message" do
      geo_concern.save
      expected_result = {
        "id" => record.id,
        "event" => "CREATED",
        "doc" => discovery_doc
      }
      subject.record_created(record)
      expect(GeoblacklightJob).to have_received(:perform_later).with(expected_result)
    end
  end

  describe "#record_deleted" do
    it "publishes a persistent JSON message" do
      geo_concern.save
      geo_concern.destroy
      expected_result = {
        "id" => "institution-geo-work-1",
        "event" => "DELETED"
      }

      subject.record_deleted(record)
      expect(GeoblacklightJob).to have_received(:perform_later).with(expected_result)
    end
  end

  describe "#record_updated" do
    let(:title) { ['New Geo Work'] }
    it "publishes a persistent JSON message with new title" do
      geo_concern.title = ["New Geo Work"]
      geo_concern.save!
      expected_result = {
        "id" => record.id,
        "event" => "UPDATED",
        "doc" => discovery_doc
      }
      subject.record_updated(record)
      expect(GeoblacklightJob).to have_received(:perform_later).with(expected_result)
    end
  end
end