Contents

require "sync_machine/ensure_publication/deduper"
require "sync_machine/ensure_publication/publication_history"

module SyncMachine
  # Orchestrate logic around a change notification and whether to publish a new
  # document to the service.
  class EnsurePublication
    def initialize(enqueue_time_str:, hooks:, subject:, sync_module:)
      @enqueue_time_str = enqueue_time_str
      @hooks = hooks
      @subject = subject
      @sync_module = sync_module
    end

    def run
      dedupe { run_deduped }
    end

    private

    def call_after_publish
      return unless (after_publish_hook = hook(:after_publish))
      after_publish_hook.call(@subject)
    end

    def dedupe
      deduper = Deduper.new(
        job_class: @sync_module.const_get('EnsurePublicationWorker'),
        last_job_finished_at: publication_history.last_job_finished_at,
        subject_id: subject_id,
        enqueue_time_str: @enqueue_time_str
      )
      deduper.dedupe { yield }
    end

    def hook(hook_sym)
      @hooks[hook_sym]
    end

    def payload_body
      @payload_body ||= hook(:build).call(@subject)
    end

    def publication_history
      @publication_history ||= PublicationHistory.new(
        subject_id: subject_id, sync_module: @sync_module
      )
    end

    def publishable?
      !hook(:check_publishable) || hook(:check_publishable).call(@subject)
    end

    def run_deduped
      return unless publishable?
      if publication_history.last_publish_equals?(payload_body)
        publication_history.record_generation_time
      else
        hook(:publish).call(@subject, payload_body)
        publication_history.update(payload_body)
        call_after_publish
      end
    end

    def subject_id
      @sync_module.orm_adapter.record_id_for_job(@subject.id)
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
sync_machine-1.4.0	lib/sync_machine/ensure_publication.rb
sync_machine-1.3.0	lib/sync_machine/ensure_publication.rb