demarches-normaliennes/app/lib/api_particulier/cnaf_adapter.rb

48 lines
1.3 KiB
Ruby
Raw Normal View History

2021-10-05 14:16:07 +02:00
class APIParticulier::CnafAdapter
2021-09-21 11:46:40 +02:00
class InvalidSchemaError < ::StandardError
def initialize(errors)
super(errors.map(&:to_json).join("\n"))
end
end
2021-09-22 11:00:03 +02:00
def initialize(api_particulier_token, numero_allocataire, code_postal, requested_sources)
@api = APIParticulier::API.new(api_particulier_token)
@numero_allocataire = numero_allocataire
@code_postal = code_postal
@requested_sources = requested_sources
end
def to_params
@api.composition_familiale(@numero_allocataire, @code_postal)
2021-09-21 11:46:40 +02:00
.tap { |d| ensure_valid_schema!(d) }
2021-09-22 11:00:03 +02:00
.then { |d| extract_requested_sources(d) }
end
private
2021-09-21 11:46:40 +02:00
def ensure_valid_schema!(data)
if !schemer.valid?(data)
errors = schemer.validate(data).to_a
raise InvalidSchemaError.new(errors)
end
end
def schemer
@schemer ||= JSONSchemer.schema(Rails.root.join('app/schemas/composition-familiale.json'))
end
2021-09-22 11:00:03 +02:00
def extract_requested_sources(data)
@requested_sources['cnaf']&.map do |(scope, sources)|
case scope
when 'enfants', 'allocataires'
{ scope => data[scope].map { |s| s.slice(*sources) } }
when 'quotient_familial'
{ scope => data.slice(*sources) }
else
{ scope => data[scope].slice(*sources) }
end
end
&.reduce(&:deep_merge) || {}
end
end