Class: RazorRisk::Cassini::Applications::RouteVerbAdaptors::Portfolios::CollectionGet

Inherits:

RESTFramework::VerbHandler

• Object
• RESTFramework::VerbHandler
• RazorRisk::Cassini::Applications::RouteVerbAdaptors::Portfolios::CollectionGet

Includes:

Pantheios, Utilities::CollectionGetHelper, Utilities::Portfolios, RazorRisk::Core::Diagnostics::Logger, Razor::Connectivity::EntityConnectors::Exceptions, Razor::Connectivity::Razor3::EntityConnectors

Defined in:

lib/razor_risk/cassini/applications/route_verb_adaptors/portfolios/collection_get.rb

Overview

########################################################################## classes

Constant Summary

HTTP_VERB =

:get

HTTP_ACCEPTS =

%w{ application/xml application/json text/xml }

QUERY_PARAMETERS =

%w{

    filter-name

    page-base
    page-extent

    quick-search

    key-search

    linked-to-trade
}

Instance Method Summary

• #handle(env, params, request, response) ⇒ Object

Methods included from Utilities::Portfolios

#validate_request_body

Instance Method Details

#handle(env, params, request, response) ⇒ Object

# File 'lib/razor_risk/cassini/applications/route_verb_adaptors/portfolios/collection_get.rb', line 69

def handle env, params, request, response

    trace ParamNames[ :env, :params, :request, :response ], env, params, request, response

    # params


    filter_name     =   params['filter-name'].to_s.strip
    filter_name     =   nil if filter_name.empty?
    page_base       =   ::Xqsr3::Conversion::IntegerParser.to_integer(params['page-base'] || 0) { |x, arg|
        halt 422, {}, "invalid page specifier: 'page-base'=#{arg}"
    }
    page_extent     =   ::Xqsr3::Conversion::IntegerParser.to_integer(params['page-extent'] || 1000) { |x, arg|
        halt 422, {}, "invalid page specifier: 'page-extent'=#{arg}"
    }
    quick_search    =   params['quick-search']
    quick_search    =   nil if String === quick_search && quick_search.strip.empty?
    key_search      =   params['key-search']
    key_search      =   nil if String === key_search && key_search.strip.empty?
    linked_to_trade =   params['linked-to-trade'].to_s.strip
    linked_to_trade =   nil if linked_to_trade.empty?

    rf  =   case rf = (params['result-form'] || '').to_s
            when '', 'default'
                :body
            when 'children'
                :array
            else
                log(:warning) { "unrecognised result-form '#{rf}'" }
                :body
            end

    if page_base < 0 || page_extent < 1

        halt 416, {}, "invalid page specifier: 'page-base'=#{page_base}; 'page-extent'=#{page_extent}"
    end

    if filter_name and quick_search

        halt 422, {}, "invalid search specifier: cannot specify 'filter-name' and 'quick-search' together"
    end

    if key_search
        begin
            key_search = MultiValueConjunctionParser.new.parse_conjunction_list key_search
        rescue MultiValueConjunctionParser::SyntaxError => x
            halt 422, {'Content-Type' => 'text/plain'}, x.message
        end
    end

    rq_opts     =   {

        :filter_name => filter_name,
        :page_base => page_base,
        :page_extent => page_extent,
        :quick_search => quick_search,
        :key_search => key_search,
        :linked_to_trade => linked_to_trade,
    }

    # get credentials


    cr  =   get_required_credentials

    # get requester


    rr  =   settings.razor_requester

    # get connector


    ec  =   PortfoliosConnector.new(rr, credentials: cr, **rq_opts)

    # issue request


    begin

        qr  =   ec.get_portfolios indicate_result_by: :qualified_result, result_form: rf
    rescue EntityConnectorInternalStepException => x

        log :failure, "exception (#{x.class}): #{x}"

        headers =   {

            'Content-Type'  =>  'text/plain',
        }

        code    =   500
        msg     =   x.message

        halt(code, headers, msg)
    end

    log :debug1, "qr(#{qr.class})='#{qr}'"

    unless qr.succeeded?

        if false

            ;
        elsif :no_such_filter == qr.result

            log :debug1, "failed to retrieve portfolios: no such filter '#{filter_name}'"

            halt 422, {}, "no such filter '#{filter_name}'"
        elsif r = qr.failure_qualifier.reasons.lookup?('RZ0011')

            log :debug1, 'failed to retrieve portfolios'

            halt 404, {}, "#{r.message}: #{r.details}"
        else

            log :warning, 'failed to retrieve portfolios'

            halt 500, {}, qr.failure_qualifier.reasons.join("\n")
        end
    end

    r   =   case rf
            when :array

                xml_doc     =   ::Nokogiri.XML('<body/>')
                root_node   =   xml_doc.children.first

                qr.result.each do |pf_element|

                    root_node.add_child pf_element.to_s
                end

                xml_doc.to_s
            else

                qr.result.to_s
            end

    # return result


    status 200

    if false
    elsif request.accept?('application/xml')

        log :debug1, 'application/xml'

        content_type 'application/xml'

        r
    elsif request.accept?('application/json')

        log :debug1, 'application/json'

        content_type 'application/json'

        resp_hash   =   XmlHasher.parse(r)

        #resp_hash   =   Hash.from_xml r

        resp_json   =   resp_hash

        JSON.generate resp_json
    elsif request.accept?('text/xml')

        log :debug1, 'text/xml'

        content_type 'text/xml'

        r
    else

        log :violation, "unexpected failure to match given 'Accept' header '#{request.accept}'"

        status 500
    end
end