Sha256: af4b65c71aa4c315d171e8942b2260bde8007a3e7b61ab701b91b305cc847dbe
Contents?: true
Size: 1.48 KB
Versions: 4
Compression:
Stored size: 1.48 KB
Contents
class SchemaSerializer class Schema attr_reader :type, :nullable, :items, :required, :properties def initialize(hash = {}) @type = hash["type"] @nullable = !hash["nullable"].nil? case type when "array" @items = self.class.new(hash.fetch("items")) when "object", nil @required = hash["required"] || [] @properties = hash.fetch("properties").each_with_object({}) {|(column, property), obj| obj[column] = self.class.new(property) } end end def serialize(object) return nil if nullable && object.nil? case type when "integer" object.to_i when "number" object.to_f when "string" object.to_s when "boolean" !object.nil? when "array" object.map {|item| items.serialize(item) } else not_enough_columns = required - properties.keys raise RequiredNotDefined, not_enough_columns.join(", ") unless not_enough_columns.empty? properties.each_with_object({}) {|(column, schema), obj| obj[column] = schema.serialize(get_value(object, column)) } end end private def get_value(object, column) return object[column] || object[column.to_sym] if object.is_a?(Hash) value = object.public_send(column) return value if !object.respond_to?(:defined_enums) || !object.defined_enums.has_key?(column) object.defined_enums[column][value] end end end
Version data entries
4 entries across 4 versions & 1 rubygems