call

in lib/aws/rails/middleware/ebs_sqs_active_job_middleware.rb [16:33]

• 10 lines of code
• 4 McCabe index (conditional complexity)

      def call(env)
        request = ActionDispatch::Request.new(env)

        
        return @app.call(env) unless from_sqs_daemon?(request)

        @logger.debug('aws-sdk-rails middleware detected call from Elastic Beanstalk SQS Daemon.')

        
        unless request.local? || sent_from_docker_host?(request)
          @logger.warn("SQSD request detected from untrusted address #{request.remote_ip}; returning 403 forbidden.")
          return FORBIDDEN_RESPONSE
        end

        
        periodic_task?(request) ? execute_periodic_task(request) : execute_job(request)
      end