gistfile1.txt

# frozen_string_literal: true

module Salesforce
  # see more error classes
  # in /gems/restforce-5-1-0/lib/restforce/error_code.rb
  # Salesforce exceptions that should be ignored in Sentry. Not much we can do about this. These errors are temporary
  # and further retries will likely fix them
  RECOVERABLE_EXCEPTIONS = [
    Restforce::ErrorCode::RequestLimitExceeded,
    Restforce::ErrorCode::QueryTimeout,
    Restforce::ErrorCode::ServerUnavailable,
    Restforce::ErrorCode::UnknownException
  ]

  class SalesforceWorker
    include Sidekiq::Worker
    # Don't have a salesforce queue so we'll put it on the intercom queue for now
    sidekiq_options queue: 'intercom', retry: Sidekiq::RETRY_24_HOURS

    # see notes on ExternalServiceWorker for why we do silly magic
    def self.inherited(subclass)
      subclass.class_eval { prepend ::ExternalServiceWorker.new(RECOVERABLE_EXCEPTIONS) }
    end

    def salesforce
      ::Salesforce.client
    end

    # Save the salesforce_id for a resource
    def store_salesforce_id(resource:, salesforce_id:)
      return unless resource.respond_to?(:salesforce_id)
      return unless resource.salesforce_id != salesforce_id
      resource.update_column(:salesforce_id, salesforce_id)
    end
  end
end



# For example:
#
# RECOVERABLE_EXCEPTIONS = [::Intercom::ServiceConnectionError, ::Intercom::BadGatewayError, ::Intercom::ServerError]
# class IntercomWorker
#   include Sidekiq::Worker
#   def self.inherited(subclass)
#     subclass.class_eval { prepend ::ExternalServiceWorker.new(RECOVERABLE_EXCEPTIONS) }
#   end
# end
#
class ExternalServiceWorker < Module
  def initialize(recoverable_exceptions = [])
    @recoverable_exceptions = recoverable_exceptions
  end

  def prepended(includer_class)
    # define a local var so the define_method closure will capture it
    recoverable_exceptions = @recoverable_exceptions
    define_method(:perform) do |*args|
      begin
        super(*args)  #calls worker perform
      rescue *recoverable_exceptions
        # SentryIgnorableError is ignored by sentry but
        # the exception correctly results in a sidekiq retry
        raise SentryIgnorableError
      end
    end
  end
end