Add: "N available" copy to the dispatcher side.

lib/bike_brigade_web/helpers/campaign_helpers.ex

@@ -1,6 +1,10 @@
 defmodule BikeBrigadeWeb.CampaignHelpers do
   alias BikeBrigade.Delivery.Task
   alias BikeBrigade.Riders.Rider
+  alias BikeBrigade.Delivery
+  alias BikeBrigade.Utils
+
+  use BikeBrigadeWeb, :live_component
 
   alias BikeBrigade.LocalizedDateTime
 
@@ -128,4 +132,50 @@ defmodule BikeBrigadeWeb.CampaignHelpers do
   defp print_item(task_item) do
     "#{task_item.count} #{Inflex.inflect(task_item.item.name, task_item.count)}"
   end
+
+  attr :filled_tasks, :integer, required: true
+  attr :total_tasks, :integer, required: true
+  attr :campaign, :any, required: true
+
+  @doc """
+    Renders possible states of campaign "Fullness" in styled text.
+  """
+  def tasks_filled_text(assigns) do
+    {class, copy} =
+      cond do
+        assigns.filled_tasks == nil ->
+          {"text-gray-600", "N/A"}
+
+        campaign_in_past(assigns.campaign) ->
+          {"text-gray-600", "Campaign over"}
+
+        assigns.total_tasks - assigns.filled_tasks == 0 ->
+          {"text-gray-600", "Fully Assigned"}
+
+        true ->
+          {"text-red-400", "#{assigns.total_tasks - assigns.filled_tasks} Available"}
+      end
+
+    assigns =
+      assigns
+      |> assign(:class, class)
+      |> assign(:copy, copy)
+
+    ~H"""
+    <p class="flex flex-col items-center mt-0 text-sm text-gray-700 md:flex-row">
+      <Icons.maki_bicycle_share class="flex-shrink-0 mb-2 mr-1.5 h-8 w-8 md:h-5 md:w-5 md:mb-0 text-gray-500" />
+      <span class="flex space-x-2 font-bold md:font-normal">
+        <span class={@class}><%= @copy %></span>
+      </span>
+    </p>
+    """
+  end
+
+  # Use this to determine if we need to refetch data to update the liveview.
+  # ex: dispatcher changes riders/tasks, or another rider signs up -> refetch.
+  def entity_in_campaigns?(campaigns, entity_campaign_id) do
+    campaigns
+    |> Enum.flat_map(fn {_date, campaigns} -> campaigns end)
+    |> Enum.any?(fn c -> c.id == entity_campaign_id end)
+  end
 end

lib/bike_brigade_web/live/campaign_live/index.ex

@@ -7,11 +7,16 @@ defmodule BikeBrigadeWeb.CampaignLive.Index do
   alias BikeBrigade.Delivery
   alias BikeBrigade.Delivery.Campaign
   alias BikeBrigade.Messaging.SmsMessage
+  alias BikeBrigadeWeb.Components.CampaignComponents
 
   import BikeBrigadeWeb.CampaignHelpers
 
   @impl true
   def mount(_params, _session, socket) do
+    if connected?(socket) do
+      Delivery.subscribe()
+    end
+
     current_week =
       LocalizedDateTime.today()
       |> Date.beginning_of_week()
@@ -21,7 +26,8 @@ defmodule BikeBrigadeWeb.CampaignLive.Index do
      |> assign(:page, :campaigns)
      |> assign(:page_title, "Campaigns")
      |> assign(:current_week, current_week)
-     |> assign(:campaigns, fetch_campaigns(current_week))}
+     |> assign(:campaigns, fetch_campaigns(current_week))
+     |> assign(:campaign_task_counts, Delivery.get_total_tasks_and_open_tasks(current_week))}
   end
 
   @impl true
@@ -37,6 +43,27 @@ defmodule BikeBrigadeWeb.CampaignLive.Index do
     {:noreply, assign(socket, :campaigns, fetch_campaigns(socket.assigns.current_week))}
   end
 
+  @broadcasted_infos [
+    :task_created,
+    :task_deleted,
+    :task_updated,
+    :campaign_rider_created,
+    :campaign_rider_deleted
+  ]
+
+  @impl Phoenix.LiveView
+  def handle_info({event, entity}, socket) when event in @broadcasted_infos do
+    if entity_in_campaigns?(socket.assigns.campaigns, entity.campaign_id) do
+      {:noreply, refetch_and_assign_data(socket)}
+    else
+      {:noreply, socket}
+    end
+  end
+
+  @impl Phoenix.LiveView
+  @doc "silently ignore other kinds of messages"
+  def handle_info(_, socket), do: {:noreply, socket}
+
   defp apply_action(socket, :edit, %{"id" => id}) do
     socket
     |> assign(:page_title, "Edit Campaign")
@@ -123,4 +150,12 @@ defmodule BikeBrigadeWeb.CampaignLive.Index do
   def message_info(assigns) do
     ~H""
   end
+
+  defp refetch_and_assign_data(socket) do
+    week = socket.assigns.current_week
+
+    socket
+    |> assign(:campaign_task_counts, Delivery.get_total_tasks_and_open_tasks(week))
+    |> assign(:campaigns, fetch_campaigns(week))
+  end
 end

lib/bike_brigade_web/live/campaign_live/index.html.heex

@@ -127,10 +127,15 @@
                     />
                     <%= pickup_window(c) %>
                   </p>
+
                   <p class="flex items-center mt-2 text-sm text-gray-700 sm:mt-0 sm:ml-6">
-                    <Icons.maki_bicycle_share class="flex-shrink-0 mr-1.5 h-5 w-5 text-gray-500" />
-                    <%= c.stats.signed_up_rider_count %>
+                    <.tasks_filled_text
+                      filled_tasks={@campaign_task_counts[c.id][:filled_tasks]}
+                      total_tasks={@campaign_task_counts[c.id][:total_tasks]}
+                      campaign={c}
+                    />
                   </p>
+
                   <p class="flex items-center mt-2 text-sm text-gray-700 sm:mt-0 sm:ml-6">
                     <Heroicons.shopping_bag
                       mini

lib/bike_brigade_web/live/campaign_signup_live/index.ex

@@ -75,7 +75,7 @@ defmodule BikeBrigadeWeb.CampaignSignupLive.Index do
 
   @impl Phoenix.LiveView
   def handle_info({event, entity}, socket) when event in @broadcasted_infos do
-    if entity_in_campaigns?(socket, entity.campaign_id) do
+    if entity_in_campaigns?(socket.assigns.campaigns, entity.campaign_id) do
       {:noreply, refetch_and_assign_data(socket)}
     else
       {:noreply, socket}
@@ -145,49 +145,6 @@ defmodule BikeBrigadeWeb.CampaignSignupLive.Index do
     |> assign(:campaigns, fetch_campaigns(campaign_filter))
   end
 
-  # Use this to determine if we need to refetch data to update the liveview.
-  # ex: dispatcher changes riders/tasks, or another rider signs up -> refetch.
-  defp entity_in_campaigns?(socket, entity_campaign_id) do
-    socket.assigns.campaigns
-    |> Enum.flat_map(fn {_date, campaigns} -> campaigns end)
-    |> Enum.any?(fn c -> c.id == entity_campaign_id end)
-  end
-
-  attr :filled_tasks, :integer, required: true
-  attr :total_tasks, :integer, required: true
-  attr :campaign, :any, required: true
-
-  defp tasks_filled_text(assigns) do
-    {class, copy} =
-      cond do
-        assigns.filled_tasks == nil ->
-          {"text-gray-600", "N/A"}
-
-        campaign_in_past(assigns.campaign) ->
-          {"text-gray-600", "Campaign over"}
-
-        assigns.total_tasks - assigns.filled_tasks == 0 ->
-          {"text-gray-600", "Fully Assigned"}
-
-        true ->
-          {"text-red-400", "#{assigns.total_tasks - assigns.filled_tasks} Available"}
-      end
-
-    assigns =
-      assigns
-      |> assign(:class, class)
-      |> assign(:copy, copy)
-
-    ~H"""
-    <p class="flex flex-col items-center mt-0 text-sm text-gray-700 md:flex-row">
-      <Icons.maki_bicycle_share class="flex-shrink-0 mb-2 mr-1.5 h-8 w-8 md:h-5 md:w-5 md:mb-0 text-gray-500" />
-      <span class="flex space-x-2 font-bold md:font-normal">
-        <span class={@class}><%= @copy %></span>
-      </span>
-    </p>
-    """
-  end
-
   attr :campaign, :any, required: true
   attr :rider_id, :integer, required: true
   attr :campaign_task_counts, :any, required: true