Sha256: 5271bdd70e4d4a27429c81c29860a7154dd9078078c86306f672c119e4c1702e

Contents?: true

Size: 1.25 KB

Versions: 4

Compression:

Stored size: 1.25 KB

Contents

# frozen_string_literal: true

module SalesforceStreamer
  class TopicManager
    attr_reader :push_topics

    def initialize(push_topics:)
      @push_topics = push_topics
      @client = SalesforceClient.new
    end

    def run
      Log.info 'Running Topic Manager'
      @push_topics.each do |push_topic|
        Log.debug push_topic.to_s
        upsert(push_topic) if diff?(push_topic)
      end
    end

    private

    def diff?(push_topic)
      hashie = @client.find_push_topic_by_name(push_topic.name)
      unless hashie
        Log.info "New PushTopic #{push_topic.name}"
        return true
      end
      Log.debug "Remote PushTopic found with hash=#{hashie.to_h}"
      push_topic.id = hashie.Id
      return true unless push_topic.query.eql?(hashie.Query)
      return true unless push_topic.notify_for_fields.eql?(hashie.NotifyForFields)
      return true unless push_topic.api_version.to_s.eql?(hashie.ApiVersion.to_s)

      Log.debug 'No differences detected'
      false
    end

    def upsert(push_topic)
      Log.info "Upsert PushTopic #{push_topic.name}"
      if Configuration.instance.manage_topics?
        @client.upsert_push_topic(push_topic)
      else
        Log.info 'Skipping upsert because manage topics is off'
      end
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version Path
salesforce_streamer-0.3.0 lib/salesforce_streamer/topic_manager.rb
salesforce_streamer-0.2.3 lib/salesforce_streamer/topic_manager.rb
salesforce_streamer-0.2.2 lib/salesforce_streamer/topic_manager.rb
salesforce_streamer-0.2.1 lib/salesforce_streamer/topic_manager.rb