Sha256: 6c8a73a618bd9ad2fc39149b066aa7eba599e8d8f27edf9056b983572712272d
Contents?: true
Size: 1.36 KB
Versions: 8
Compression:
Stored size: 1.36 KB
Contents
# frozen_string_literal: true
module WaterDrop
module Contracts
# Contract with validation rules for WaterDrop configuration details
class Config < ::Karafka::Core::Contractable::Contract
configure do |config|
config.error_messages = YAML.safe_load(
File.read(
File.join(WaterDrop.gem_root, 'config', 'errors.yml')
)
).fetch('en').fetch('validations').fetch('config')
end
required(:id) { |val| val.is_a?(String) && !val.empty? }
required(:logger) { |val| !val.nil? }
required(:deliver) { |val| [true, false].include?(val) }
required(:max_payload_size) { |val| val.is_a?(Integer) && val >= 1 }
required(:max_wait_timeout) { |val| val.is_a?(Numeric) && val >= 0 }
required(:wait_timeout) { |val| val.is_a?(Numeric) && val.positive? }
required(:kafka) { |val| val.is_a?(Hash) && !val.empty? }
# rdkafka allows both symbols and strings as keys for config but then casts them to strings
# This can be confusing, so we expect all keys to be symbolized
virtual do |config, errors|
next true unless errors.empty?
errors = []
config
.fetch(:kafka)
.keys
.reject { |key| key.is_a?(Symbol) }
.each { |key| errors << [[:kafka, key], :kafka_key_must_be_a_symbol] }
errors
end
end
end
end
Version data entries
8 entries across 8 versions & 1 rubygems