feat: add one piece nacha

Author: yordis

.tool-versions

@@ -1,2 +1,2 @@
-elixir 1.13.2
+elixir 1.14.0
 erlang 24.2.1

apps/one_piece_nacha/.formatter.exs

@@ -0,0 +1,4 @@
+# Used by "mix format"
+[
+  inputs: ["{mix,.formatter}.exs", "{config,lib,test}/**/*.{ex,exs}"]
+]

apps/one_piece_nacha/.gitignore

@@ -0,0 +1,26 @@
+# The directory Mix will write compiled artifacts to.
+/_build/
+
+# If you run "mix test --cover", coverage assets end up here.
+/cover/
+
+# The directory Mix downloads your dependencies sources to.
+/deps/
+
+# Where third-party dependencies like ExDoc output generated docs.
+/doc/
+
+# Ignore .fetch files in case you like to edit your project deps locally.
+/.fetch
+
+# If the VM crashes, it generates a dump, let's ignore it too.
+erl_crash.dump
+
+# Also ignore archive artifacts (built via "mix archive.build").
+*.ez
+
+# Ignore package tarball (built via "mix hex.build").
+one_piece_nacha-*.tar
+
+# Temporary files, for example, from tests.
+/tmp/

apps/one_piece_nacha/README.md

@@ -0,0 +1,21 @@
+# OnePieceNacha
+
+**TODO: Add description**
+
+## Installation
+
+If [available in Hex](https://hex.pm/docs/publish), the package can be installed
+by adding `one_piece_nacha` to your list of dependencies in `mix.exs`:
+
+```elixir
+def deps do
+  [
+    {:one_piece_nacha, "~> 0.1.0"}
+  ]
+end
+```
+
+Documentation can be generated with [ExDoc](https://github.com/elixir-lang/ex_doc)
+and published on [HexDocs](https://hexdocs.pm). Once published, the docs can
+be found at <https://hexdocs.pm/one_piece_nacha>.
+

apps/one_piece_nacha/docker-compose.yml

@@ -0,0 +1,8 @@
+version: '3.8'
+
+services:
+  moov_ach:
+    image: moov/ach:v1.21.1
+    ports:
+      - "7080:8080"
+      - "7091:9090"

apps/one_piece_nacha/lib/one_piece/batch.ex

@@ -0,0 +1,22 @@
+defmodule OnePiece.Nacha.Batch do
+  @enforce_keys [
+    :batch_header,
+    :entry_details,
+    :batch_control,
+    :__parsing_info__
+  ]
+
+  defstruct @enforce_keys
+
+  def post_traverse(rest, parsed_line, context, line, byte_offset) do
+    {rest,
+     [
+       %__MODULE__{
+         batch_header: parsed_line[:batch_header],
+         entry_details: parsed_line[:entry_details],
+         batch_control: parsed_line[:batch_control],
+         __parsing_info__: OnePiece.Nacha.ParsingInfo.new(line, byte_offset)
+       }
+     ], context}
+  end
+end

apps/one_piece_nacha/lib/one_piece/batch_control.ex

@@ -0,0 +1,52 @@
+defmodule OnePiece.Nacha.BatchControl do
+  @enforce_keys [
+    :record_type_code,
+    :service_class_code,
+    :entry_addenda_count,
+    :entry_hash,
+    :total_debit_entries,
+    :total_credit_entries,
+    :company_identification,
+    :message_authentication_code,
+    :reserved,
+    :odfi_id,
+    :batch_number,
+    :__parsing_info__
+  ]
+
+  defstruct @enforce_keys
+
+  def post_traverse(rest, parsed_line, context, line, byte_offset) do
+    {rest,
+     [
+       %__MODULE__{
+         record_type_code: Enum.at(parsed_line, 10),
+         service_class_code: Enum.at(parsed_line, 9),
+         entry_addenda_count: Enum.at(parsed_line, 8),
+         entry_hash: Enum.at(parsed_line, 7),
+         total_debit_entries: Enum.at(parsed_line, 6),
+         total_credit_entries: Enum.at(parsed_line, 5),
+         company_identification: Enum.at(parsed_line, 4),
+         message_authentication_code: Enum.at(parsed_line, 3),
+         reserved: Enum.at(parsed_line, 2),
+         odfi_id: Enum.at(parsed_line, 1),
+         batch_number: Enum.at(parsed_line, 0),
+         __parsing_info__: OnePiece.Nacha.ParsingInfo.new(line, byte_offset)
+       }
+     ], context}
+  end
+
+  def map(value, :batch_number) when is_binary(value) do
+    value
+    |> String.trim()
+    |> Integer.parse()
+    |> case do
+      :error -> :error
+      v -> elem(v, 0)
+    end
+  end
+
+  def map(value, :batch_number) when is_integer(value) do
+    value
+  end
+end

apps/one_piece_nacha/lib/one_piece/batch_header.ex

@@ -0,0 +1,56 @@
+defmodule OnePiece.Nacha.BatchHeader do
+  @enforce_keys [
+    :record_type_code,
+    :service_class_code,
+    :company_name,
+    :company_discretionary_data,
+    :company_identification,
+    :standard_entry_class,
+    :company_entry_description,
+    :company_descriptive_date,
+    :effective_entry_date,
+    :settlement_date,
+    :originator_status_code,
+    :odfi_identification,
+    :batch_number,
+    :__parsing_info__
+  ]
+
+  defstruct @enforce_keys
+
+  def post_traverse(rest, parsed_line, context, line, byte_offset) do
+    {rest,
+     [
+       %__MODULE__{
+         record_type_code: Enum.at(parsed_line, 12),
+         service_class_code: Enum.at(parsed_line, 11),
+         company_name: Enum.at(parsed_line, 10),
+         company_discretionary_data: Enum.at(parsed_line, 9),
+         company_identification: Enum.at(parsed_line, 8),
+         standard_entry_class: Enum.at(parsed_line, 7),
+         company_entry_description: Enum.at(parsed_line, 6),
+         company_descriptive_date: Enum.at(parsed_line, 5),
+         effective_entry_date: Enum.at(parsed_line, 4),
+         settlement_date: Enum.at(parsed_line, 3),
+         originator_status_code: Enum.at(parsed_line, 2),
+         odfi_identification: Enum.at(parsed_line, 1),
+         batch_number: Enum.at(parsed_line, 0),
+         __parsing_info__: OnePiece.Nacha.ParsingInfo.new(line, byte_offset)
+       }
+     ], context}
+  end
+
+  def map(value, :batch_number) when is_binary(value) do
+    value
+    |> String.trim()
+    |> Integer.parse()
+    |> case do
+         :error -> :error
+         v -> elem(v, 0)
+       end
+  end
+
+  def map(value, :batch_number) when is_integer(value) do
+    value
+  end
+end

apps/one_piece_nacha/lib/one_piece/ccd_addenda.ex

@@ -0,0 +1,26 @@
+defmodule OnePiece.Nacha.CddAddenda do
+  @enforce_keys [
+    :record_type_code,
+    :addenda_type_code,
+    :payment_related_information,
+    :addenda_sequence_number,
+    :entry_detail_sequence_number,
+    :__parsing_info__
+  ]
+
+  defstruct @enforce_keys
+
+  def post_traverse(rest, parsed_line, context, line, byte_offset) do
+    {rest,
+     [
+       %__MODULE__{
+         record_type_code: Enum.at(parsed_line, 4),
+         addenda_type_code: Enum.at(parsed_line, 3),
+         payment_related_information: Enum.at(parsed_line, 2),
+         addenda_sequence_number: Enum.at(parsed_line, 1),
+         entry_detail_sequence_number: Enum.at(parsed_line, 0),
+         __parsing_info__: OnePiece.Nacha.ParsingInfo.new(line, byte_offset)
+       }
+     ], context}
+  end
+end

apps/one_piece_nacha/lib/one_piece/ccd_entry_detail.ex

@@ -0,0 +1,38 @@
+defmodule OnePiece.Nacha.CddEntryDetail do
+  @enforce_keys [
+    :record_type_code,
+    :transaction_code,
+    :receiving_dfi_identification,
+    :check_digit,
+    :dfi_account_number,
+    :amount,
+    :identification_number,
+    :receiving_company_name,
+    :discretionary_data,
+    :addenda_record_indicator,
+    :trace_number,
+    :__parsing_info__
+  ]
+
+  defstruct @enforce_keys
+
+  def post_traverse(rest, parsed_line, context, line, byte_offset) do
+    {rest,
+     [
+       %__MODULE__{
+         record_type_code: Enum.at(parsed_line, 10),
+         transaction_code: Enum.at(parsed_line, 9),
+         receiving_dfi_identification: Enum.at(parsed_line, 8),
+         check_digit: Enum.at(parsed_line, 7),
+         dfi_account_number: Enum.at(parsed_line, 6),
+         amount: Enum.at(parsed_line, 5),
+         identification_number: Enum.at(parsed_line, 4),
+         receiving_company_name: Enum.at(parsed_line, 3),
+         discretionary_data: Enum.at(parsed_line, 2),
+         addenda_record_indicator: Enum.at(parsed_line, 1),
+         trace_number: Enum.at(parsed_line, 0),
+         __parsing_info__: OnePiece.Nacha.ParsingInfo.new(line, byte_offset)
+       }
+     ], context}
+  end
+end