Sha256: 7a41dfefa9c89a0436c21eeebf9ab701cc10292af8438d0256eba93b860e7c99
Contents?: true
Size: 1.5 KB
Versions: 8
Compression:
Stored size: 1.5 KB
Contents
# frozen_string_literal: true
# This Karafka component is a Pro component under a commercial license.
# This Karafka component is NOT licensed under LGPL.
#
# All of the commercial components are present in the lib/karafka/pro directory of this
# repository and their usage requires commercial license agreement.
#
# Karafka has also commercial-friendly license, commercial support and commercial components.
#
# By sending a pull request to the pro components, you are agreeing to transfer the copyright of
# your code to Maciej Mensfeld.
module Karafka
module Web
module Pro
module Ui
module Lib
module Search
module Matchers
# Checks for phrase existence in the raw payload
#
# @note It is case sensitive
# @note Ignores encoding issues
class RawPayloadIncludes < Base
# @param message [Karafka::Messages::Message]
# @param phrase [String]
# @return [Boolean] does message raw payload contain the phrase
def call(message, phrase)
# raw payload can be nil for tombstone events
return false unless message.raw_payload
message.raw_payload.include?(phrase)
# String matching on compressed data may fail
rescue Encoding::CompatibilityError
false
end
end
end
end
end
end
end
end
end
Version data entries
8 entries across 8 versions & 1 rubygems