Contents

# frozen_string_literal: true

require "anycable/rpc/rpc_pb"

module AnyCable
  module Handler # :nodoc:
    # Handle app-level errors.
    #
    # NOTE: this functionality couldn't be implemeted
    # as middleware, 'cause interceptors do not support
    # aborting the call and returning a data
    module CaptureExceptions
      RESPONSE_CLASS = {
        command: AnyCable::CommandResponse,
        connect: AnyCable::ConnectionResponse,
        disconnect: AnyCable::DisconnectResponse
      }.freeze

      RESPONSE_CLASS.keys.each do |mid|
        module_eval <<~CODE, __FILE__, __LINE__ + 1
          def #{mid}(*)
            capture_exceptions(:#{mid}) { super }
          end
        CODE
      end

      def capture_exceptions(method_name)
        yield
      rescue StandardError => exp
        AnyCable::ExceptionsHandling.notify(exp)

        RESPONSE_CLASS.fetch(method_name).new(
          status: AnyCable::Status::ERROR,
          error_msg: exp.message
        )
      end
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
anycable-0.6.1	lib/anycable/handler/capture_exceptions.rb
anycable-0.6.0	lib/anycable/handler/capture_exceptions.rb
anycable-0.6.0.rc1	lib/anycable/handler/capture_exceptions.rb