Sha256: a289e5de5b2bd8f13927fceac917431b3202b6b89a0aca80e905cc1655d93cd6
Contents?: true
Size: 1.42 KB
Versions: 7
Compression:
Stored size: 1.42 KB
Contents
# frozen_string_literal: true
require "dry-struct"
require "dry-transformer"
require "json"
module DjiMqttConnect
module Thing::Product
class RequestsMarshal < MessageMarshal
include Utils::MessageParsing
# Rename pesky `method` argument to `_method` and makes a copy of the raw data
class AttributeTransformer < Dry::Transformer::Pipe
import Dry::Transformer::HashTransformations
define! do
symbolize_keys
copy_keys data: :_data
rename_keys method: :_method
end
end
# Attempts to look a the method attribute, and builds a specific Message class for the message
def load(raw_message)
# Parse the message from JSON
parsed_message = JSON.parse(raw_message)
# Transform the message
transformed_message = attribute_transformer.call(parsed_message)
# Build an instance of the class, or a generic message from the current class
message_class = message_class_for_parsed_message(parsed_message, RequestsMessage)
message_class.new transformed_message
rescue JSON::ParserError => e
raise ParseError.new(e, "Unable to parse message as JSON")
rescue Dry::Struct::Error => e
raise ParseError.new(e, "Unexpected #{message_class} payload")
end
private
def attribute_transformer
@attribute_transformer ||= AttributeTransformer.new
end
end
end
end
Version data entries
7 entries across 7 versions & 1 rubygems