Sha256: e02334e2dd9d7ab8ff41bc195ec74aae74d592e47d920d00ec28a2e263b633d1
Contents?: true
Size: 1.91 KB
Versions: 5
Compression:
Stored size: 1.91 KB
Contents
# frozen_string_literal: true
require 'avromatic/model/types/abstract_type'
module Avromatic
module Model
module Types
class CustomType < AbstractType
IDENTITY_PROC = Proc.new { |value| value }
attr_reader :custom_type_configuration, :value_classes, :default_type
def initialize(custom_type_configuration:, default_type:)
@custom_type_configuration = custom_type_configuration
@default_type = default_type
@deserializer = custom_type_configuration.deserializer || IDENTITY_PROC
@serializer = custom_type_configuration.serializer || IDENTITY_PROC
@value_classes = if custom_type_configuration.value_class
[custom_type_configuration.value_class].freeze
else
default_type.value_classes
end
end
def input_classes
# We don't know the valid input classes for a custom type
end
def name
custom_type_configuration.value_class ? custom_type_configuration.value_class.name.to_s.freeze : default_type.name
end
def coerce(input)
if input.nil?
input
else
@deserializer.call(input)
end
rescue StandardError => e
# TODO: Don't swallow this
raise ArgumentError.new("Could not coerce '#{input.inspect}' to #{name}: #{e.message}")
end
def coercible?(input)
# TODO: Delegate this to optional configuration
input.nil? || !coerce(input).nil?
rescue ArgumentError
false
end
def coerced?(value)
# TODO: Delegate this to optional configuration
coerce(value) == value
rescue ArgumentError
false
end
def serialize(value, **)
@serializer.call(value)
end
end
end
end
end
Version data entries
5 entries across 5 versions & 1 rubygems