location_component.ex 3.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107
  1. defmodule VaccinsWeb.LocationComponent do
  2. use VaccinsWeb, :live_component
  3. alias Vaccins.{LocationStore, Search}
  4. @impl true
  5. def mount(socket),
  6. do:
  7. {:ok,
  8. socket
  9. |> assign(
  10. has_availabilities: false,
  11. slots_after: [],
  12. slots_before: [],
  13. loading: false,
  14. last_refresh_date: nil
  15. )}
  16. @impl true
  17. def update(assigns, socket) do
  18. {force_refresh, assigns} = assigns |> Map.pop(:force_refresh)
  19. assigns = assigns |> integrate_availabilities
  20. if is_nil(force_refresh) do
  21. {:ok, socket |> assign(assigns) |> assign(loading: false)}
  22. else
  23. trigger_and_signal_query(
  24. assigns |> Map.get(:location, socket.assigns.location),
  25. assigns.id
  26. )
  27. {:ok,
  28. socket |> assign(assigns) |> assign(loading: true, last_refresh_date: get_refresh_time())}
  29. end
  30. end
  31. @impl true
  32. def handle_event("trigger_query", _, socket = %{assigns: %{id: id, location: location}}) do
  33. trigger_and_signal_query(location, id)
  34. {:noreply, socket |> assign(loading: true, last_refresh_date: get_refresh_time())}
  35. end
  36. @impl true
  37. def render(assigns) do
  38. ~L"""
  39. <dl class="location">
  40. <dt>id</dt>
  41. <dd><%= @location.id %></dd>
  42. <dt>Status (<%= if @last_refresh_date, do: @last_refresh_date |> Time.to_string() %>) </dt>
  43. <dd>
  44. <%= cond do %>
  45. <%= @loading -> %>...
  46. <%= not has_slots?(assigns) -> %>Pas de créneau
  47. <%= has_slots?(assigns) -> %>Des dispos !
  48. <% end %>
  49. </dd>
  50. <dt>booking page</dt>
  51. <dd><%= link @location.booking_page, to: @location.booking_page %></dd>
  52. <%= if has_slots?(assigns) do %>
  53. <dt>Avant 24h</dt>
  54. <dd>
  55. <ul><%= for d <- @slots_before do %><li><%= d |> DateTime.to_string %></li><% end %></ul>
  56. </dd>
  57. <dt>Après 24h</dt>
  58. <dd>
  59. <ul><%= for d <- @slots_after do %><li><%= d |> DateTime.to_string %></li><% end %></ul>
  60. </dd>
  61. <% end %>
  62. <dt>test availability</dt>
  63. <dd><button phx-click="trigger_query" phx-target="<%= @myself %>">Trigger</button></dd>
  64. </dl>
  65. """
  66. end
  67. defp integrate_availabilities(assigns = %{availabilities: {:error, reason}}),
  68. do: assigns |> Map.put(:has_availabilities, false)
  69. defp integrate_availabilities(assigns = %{availabilities: {:ok, after_slots}})
  70. when is_list(after_slots),
  71. do:
  72. assigns
  73. |> Map.put(:has_availabilities, true)
  74. |> Map.put(:slots_after, after_slots |> Enum.take(5))
  75. defp integrate_availabilities(assigns = %{availabilities: {:ok, before_slots, after_slots}})
  76. when is_list(before_slots),
  77. do:
  78. assigns
  79. |> Map.put(:has_availabilities, true)
  80. |> Map.put(:slots_after, after_slots |> Enum.take(5))
  81. |> Map.put(:slots_before, before_slots)
  82. defp integrate_availabilities(assigns), do: assigns
  83. defp has_slots?(assigns = %{slots_before: before, slots_after: after_}),
  84. do: not (before |> Enum.empty?() and after_ |> Enum.empty?())
  85. defp trigger_and_signal_query(location, id) do
  86. ref = Search.async_trigger_query(location)
  87. send(self(), {:query_sent, id, ref})
  88. end
  89. defp get_refresh_time() do
  90. with {:ok, now} <-
  91. DateTime.utc_now() |> DateTime.shift_zone("Europe/Paris", Tzdata.TimeZoneDatabase),
  92. do: now |> DateTime.to_time() |> Time.truncate(:second)
  93. end
  94. end