Contents

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

10 entries across 10 versions & 1 rubygems

Version	Path
salesforce_streamer-1.2.2	lib/salesforce_streamer/topic_manager.rb
salesforce_streamer-1.2.1	lib/salesforce_streamer/topic_manager.rb
salesforce_streamer-1.2.0	lib/salesforce_streamer/topic_manager.rb
salesforce_streamer-1.1.3	lib/salesforce_streamer/topic_manager.rb
salesforce_streamer-1.1.1	lib/salesforce_streamer/topic_manager.rb
salesforce_streamer-1.1.0	lib/salesforce_streamer/topic_manager.rb
salesforce_streamer-1.0.0	lib/salesforce_streamer/topic_manager.rb
salesforce_streamer-0.5.0	lib/salesforce_streamer/topic_manager.rb
salesforce_streamer-0.4.1	lib/salesforce_streamer/topic_manager.rb
salesforce_streamer-0.4.0	lib/salesforce_streamer/topic_manager.rb