Contents

# frozen_string_literal: true

module SalesforceStreamer
  # Models the PushTopic object for both Restforce and Streamer
  class PushTopic
    attr_accessor :id
    attr_reader :name, :description, :notify_for_fields, :query,
                :handler, :handler_constant, :api_version

    def initialize(data:)
      @handler           = data['handler']
      @static_replay     = data.dig('replay')&.to_i || -1
      @name              = data.dig('salesforce', 'name')
      @api_version       = data.dig('salesforce', 'api_version') || '41.0'
      @description       = data.dig('salesforce', 'description') || @name
      @notify_for_fields = data.dig('salesforce', 'notify_for_fields') || 'Referenced'
      @query             = strip_spaces(data.dig('salesforce', 'query'))
      validate!
    end

    def replay
      @replay ||= (ReplayPersistence.retrieve(name) || @static_replay).tap do |replayId|
        Log.info "PushTopic name=#{name} starting at replayId=#{replayId}"
      end
    end

    def to_s
      "PushTopic id=#{id} name=#{name} handler=#{handler} " \
        "replay=#{replay} notify_for_fields=#{notify_for_fields} " \
        "description=#{description} api_version=#{api_version} query=#{query}"
    end

    private

    def validate!
      raise(PushTopicNameTooLongError, @name) if @name.size > 25

      @handler_constant = Object.const_get(@handler)
      true
    rescue NameError, TypeError => e
      message = 'handler=' + @handler.to_s + ' exception=' + e.to_s
      raise(PushTopicHandlerMissingError, message)
    end

    def strip_spaces(str)
      raise(NilQueryError, @name) unless str

      str.gsub(/\s+/, ' ')
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

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