sashman / birin_api Goto Github PK

  def create_ring_numbers_from_series(ring_series_list, user_id) do
    {:ok,
     ring_series_list
     |> Enum.map(fn %{type: type, size: size, start_number: start_number, end_number: end_number} ->
       {:ok, %{id: ring_series_id}} =
         {:ok, _} =
         create_ring_series(%{
           type: type,
           size: size,
           start_number: start_number,
           end_number: end_number,
           received_at: NaiveDateTime.utc_now(),
           allocated_at: nil
         })

       RingSerial.ring_number_stream(start_number, end_number)
       |> Stream.map(fn ring_number ->
         {:ok, _} =
           %{
             type: type,
             number: ring_number,
             user_id: user_id,
             ring_series_id: ring_series_id
           }
           |> create_ring_number()
       end)
       |> Enum.count()
     end)
     |> Enum.sum()}
  end