ex_szamlazz_hu

defmodule ExSzamlazzHu.CreateInvoice do
  @moduledoc false

  alias Tesla.Multipart
  alias ExSzamlazzHu.CreateInvoice.InvoiceData
  alias ExSzamlazzHu.CreateInvoice.Result
  alias ExSzamlazzHu.Utils.TemporaryFile

  @url "https://www.szamlazz.hu/szamla/"

  @spec run(params :: map()) :: {:ok, Result.t()} | {:error, :cannot_save_temporary_file} | {:error, any()}
  def run(params) do
    with invoice_data <- InvoiceData.parse(params),
         xml <- InvoiceData.to_xml(invoice_data),
         {:ok, file_path} <- save_temporary_file(xml),
         {:ok, response} <- send_request(file_path),
         {:ok, success, data} <- handle_response(response, invoice_data),
         result <- compile_result(success, data, response) do
      {:ok, result}
    end
  end

  defp save_temporary_file(xml) do
    random_chars = for _ <- 1..5, into: "", do: <<Enum.random(?a..?z)>>
    timestamp = DateTime.utc_now() |> DateTime.to_iso8601()
    filename = "#{timestamp}_#{random_chars}.xml"

    TemporaryFile.save(filename, xml)
  end

  defp send_request(file_path) do
    body =
      Multipart.new()
      |> Multipart.add_content_type_param("charset=utf-8")
      |> Multipart.add_file(file_path, name: "action-xmlagentxmlfile")

    Tesla.post(@url, body)
  end

  defp handle_response(%Tesla.Env{} = response, invoice_data) do
    header_map = Map.new(response.headers)

    cond do
      header_map["szlahu_down"] == "true" -> {:ok, false, %{szlahu_down: true}}
      header_map["szlahu_error_code"] == nil -> handle_success_response(response, invoice_data)
      true -> handle_error_response(response)
    end
  end

  defp handle_error_response(%Tesla.Env{} = response) do
    header_map = Map.new(response.headers)

    result = %{
      szlahu_error: header_map["szlahu_error"],
      szlahu_error_code: header_map["szlahu_error_code"]
    }

    {:ok, false, result}
  end

  defp handle_success_response(%Tesla.Env{} = response, invoice_data) do
    header_map = Map.new(response.headers)

    szlahu_vevoifiokurl = URI.decode(header_map["szlahu_vevoifiokurl"])

    params = %{
      szlahu_id: header_map["szlahu_id"],
      szlahu_nettovegosszeg: header_map["szlahu_nettovegosszeg"],
      szlahu_szamlaszam: header_map["szlahu_szamlaszam"],
      szlahu_bruttovegosszeg: header_map["szlahu_bruttovegosszeg"],
      szlahu_kintlevoseg: header_map["szlahu_kintlevoseg"],
      szlahu_vevoifiokurl: szlahu_vevoifiokurl
    }

    result = maybe_add_invoice_path_info(params, response, invoice_data)

    {:ok, true, result}
  end

  defp maybe_add_invoice_path_info(
         info,
         %Tesla.Env{} = response,
         %InvoiceData{beallitasok: %{szamlaLetoltes: true}} = invoice_data
       ) do
    random_chars = for _ <- 1..5, into: "", do: <<Enum.random(?a..?z)>>
    timestamp = DateTime.utc_now() |> DateTime.to_iso8601()
    filename = "#{timestamp}_#{random_chars}.pdf"
    pdf = get_invoice_pdf_data(response, invoice_data)

    case TemporaryFile.save(filename, pdf) do
      {:ok, path} -> Map.put(info, :invoice_file_path, path)
      {:error, _} -> info
    end
  end

  defp maybe_add_invoice_path_info(info, _, _), do: info

  defp get_invoice_pdf_data(
         %Tesla.Env{} = response,
         %InvoiceData{beallitasok: %{szamlaLetoltes: true, valaszVerzio: 1}}
       ) do
    response.body
  end

  defp get_invoice_pdf_data(
         %Tesla.Env{} = response,
         %InvoiceData{beallitasok: %{szamlaLetoltes: true, valaszVerzio: 2}}
       ) do
    [pdf_tag] = Regex.run(~r/<pdf>(.*)<\/pdf>/ims, response.body, capture: :first)
    [_, base64_pdf] = String.split(pdf_tag, "<pdf>")
    [base64_pdf, _] = String.split(base64_pdf, "</pdf>")

    base64_pdf =
      base64_pdf
      |> String.trim()
      |> String.replace("\n", "")

    Base.decode64!(base64_pdf)
  end

  defp compile_result(success, data, response) do
    %Result{
      success: success,
      raw_response: response,
      szlahu_id: data[:szlahu_id],
      szlahu_nettovegosszeg: data[:szlahu_nettovegosszeg],
      szlahu_szamlaszam: data[:szlahu_szamlaszam],
      szlahu_bruttovegosszeg: data[:szlahu_bruttovegosszeg],
      szlahu_kintlevoseg: data[:szlahu_kintlevoseg],
      szlahu_vevoifiokurl: data[:szlahu_vevoifiokurl],
      path_to_pdf_invoice: data[:invoice_file_path],
      szlahu_error: data[:szlahu_error],
      szlahu_error_code: data[:szlahu_error_code],
      szlahu_down: data[:szlahu_down] == true
    }
  end
end