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, remove_soap_tags(body, config[:soap])} %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, ""), do: {:error, body}, else: {:ok, body} end defp process_response(body, config) when is_list(config) do xml = remove_soap_tags(body, config[:soap]) if String.contains?(xml, ""), 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 remove_soap_tags(xml, config) do if config[:response_namespace] == nil do xml else IO.inspect xml ns = config[:response_namespace] attribute = String.replace(config[:soap][:attributes][:envelope], "{{namespace}}", ns) String.replace(xml, "<#{ns}:Envelope #{attribute}", "") String.replace(xml, "<#{ns}:Body>", "") String.replace(xml, "", "") String.replace(xml, "", "") String.replace(xml, "", "") end end defp build_url(url, method), do: String.replace(url, "{{NDC-method}}", Atom.to_string(method)) defp error_message(message), do: "#{message}" 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