Current section

Files

Jump to
ndc_ex_sdk lib ndc_ex.ex
Raw

lib/ndc_ex.ex

defmodule NDCEx do
require HTTPotion
require Logger
def request(method, data, config) do
NDCEx.Message.Base.build_document(method, data, config)
|> rest_call_with_message(config, method)
end
def rest_call_with_message(xml, config, method) do
Logger.debug xml
url = NDCEx.Message.Base.build_url(config[:server][:url], method)
headers = get_headers(config[:rest][:headers], method)
case HTTPotion.post(url, [body: xml, headers: headers, timeout: 30000 ]) do
%HTTPotion.Response{body: body, headers: _headers, status_code: 200 } ->
FileLogger.log(xml, body, config)
process_response(body, config[:soap])
%HTTPotion.Response{body: body, headers: _headers, status_code: _status_code } ->
FileLogger.log(xml, body, config)
{:error, NDCNormalize.remove_soap_tags(body, config)}
%HTTPotion.Response{status_code: 404} ->
{:error, error_message("Request does not exist")}
_ ->
{:error, error_message("Unknown Error")}
end
end
defp process_response(body, config) when config == nil do
if String.contains?(body, "<error>"), do: {:error, body}, else: {:ok, body}
end
defp process_response(body, config) when is_list(config) do
xml = NDCNormalize.remove_soap_tags(body, config)
if String.contains?(xml, "<error>"), do: {:error, xml}, else: {:ok, xml}
end
defp get_headers(headers, method) do
Enum.map(headers, fn ({key, value}) ->
{key, String.replace(value, "{{NDC-method}}", Atom.to_string(method))}
end)
end
defp build_url(url, method), do: String.replace(url, "{{NDC-method}}", Atom.to_string(method))
defp error_message(message), do: "<error><message>#{message}</message></error>"
defp remove_tag(doc, tag), do: String.replace(doc, tag, "")
def get_mix_config(key) when is_atom(key), do: Application.get_env(:ndc_ex_sdk, key)
end