Pin and unpin feeds

Author: cruessler

lib/ex_rss_web/feed_live/index.ex

@@ -22,6 +22,7 @@ defmodule ExRssWeb.FeedLive.Index do
         join: e in Entry,
         on: f.id == e.feed_id,
         group_by: f.id,
+        order_by: [desc_nulls_last: f.position],
         select: %{
           f
           | unread_entries_count: filter(count(e.id), e.read == false),
@@ -101,6 +102,94 @@ defmodule ExRssWeb.FeedLive.Index do
     end
   end
 
+  def handle_event("pin_feed", %{"feed-id" => feed_id}, socket) do
+    update_feed_position(feed_id, 0, socket)
+  end
+
+  def handle_event("unpin_feed", %{"feed-id" => feed_id}, socket) do
+    update_feed_position(feed_id, nil, socket)
+  end
+
+  def update_feed_position(feed_id, position, socket) do
+    changeset =
+      Repo.get!(User, socket.assigns.current_user.id)
+      |> Ecto.assoc(:feeds)
+      |> Repo.get!(feed_id)
+      |> Feed.changeset(%{"position" => position})
+
+    case Repo.update(changeset) do
+      {:ok, feed} ->
+        current_user = Repo.get!(User, socket.assigns.current_user.id)
+
+        feeds_of_current_user = current_user |> Ecto.assoc(:feeds)
+
+        feeds_with_counts =
+          from(
+            f in feeds_of_current_user,
+            join: e in Entry,
+            on: f.id == e.feed_id,
+            group_by: f.id,
+            order_by: [desc_nulls_last: f.position],
+            select: %{
+              f
+              | unread_entries_count: filter(count(e.id), e.read == false),
+                read_entries_count: filter(count(e.id), e.read == true),
+                has_error: f.retries > 0
+            }
+          )
+
+        feeds =
+          feeds_with_counts
+          |> Repo.all()
+          |> Repo.preload(
+            entries: from(e in Entry, where: e.read == false, order_by: [desc: e.posted_at])
+          )
+
+        feed_with_counts_query =
+          from(
+            f in Feed,
+            join: e in Entry,
+            on: f.id == e.feed_id,
+            group_by: f.id,
+            select: %{
+              f
+              | unread_entries_count: filter(count(e.id), e.read == false),
+                read_entries_count: filter(count(e.id), e.read == true),
+                has_error: f.retries > 0
+            }
+          )
+
+        updated_feed =
+          Repo.get!(feed_with_counts_query, feed.id)
+          |> Repo.preload(
+            entries: from(e in Entry, where: e.read == false, order_by: [desc: e.posted_at])
+          )
+
+        update_broadcaster =
+          Application.get_env(:ex_rss, :update_broadcaster, ExRss.Crawler.UpdateBroadcaster)
+
+        Task.Supervisor.start_child(
+          ExRss.TaskSupervisor,
+          update_broadcaster,
+          :broadcast_update,
+          [updated_feed]
+        )
+
+        oldest_unread_entry =
+          User.oldest_unread_entry(socket.assigns.current_user.id)
+
+        socket =
+          socket
+          |> assign(:oldest_unread_entry, oldest_unread_entry)
+          |> stream(:feeds, feeds, reset: true)
+
+        {:noreply, socket}
+
+      _ ->
+        {:noreply, socket}
+    end
+  end
+
   # 2024-12-03
   # This `use` is needed for `content_tag` to be available in `elm_module`.
   use Phoenix.HTML

lib/ex_rss_web/feed_live/index.html.heex

@@ -10,17 +10,33 @@
 
 <ul id="live-feeds" phx-update="stream">
   <li :for={{dom_id, feed} <- @streams.feeds} id={dom_id}>
-    <h1 class="mb-2 font-bold"><%= feed.title %></h1>
+    <div class="flex">
+      <div>
+        <h1 class="mb-2 font-bold"><%= feed.title %></h1>
 
-    <ul class="mb-4">
-      <li class="inline-block mr-2">
-        <%= feed.read_entries_count + feed.unread_entries_count %> entries
-      </li>
-      <li class="inline-block mr-2"><%= feed.unread_entries_count %> unread</li>
-      <li class="inline-block mr-2">
-        last successful update at <%= feed.last_successful_update_at %>
-      </li>
-    </ul>
+        <ul class="mb-4">
+          <li class="inline-block mr-2">
+            <%= feed.read_entries_count + feed.unread_entries_count %> entries
+          </li>
+          <li class="inline-block mr-2"><%= feed.unread_entries_count %> unread</li>
+          <li class="inline-block mr-2">
+            last successful update at <%= feed.last_successful_update_at %>
+          </li>
+        </ul>
+      </div>
+
+      <div class="md:shrink-0 flex self-start justify-end mt-1 ml-auto space-x-4">
+        <%= if is_nil(feed.position) do %>
+          <button aria-label="Pin feed" phx-click="pin_feed" phx-value-feed-id={feed.id}>
+            <.icon name="hero-bookmark-solid" />
+          </button>
+        <% else %>
+          <button aria-label="Unpin feed" phx-click="unpin_feed" phx-value-feed-id={feed.id}>
+            <.icon name="hero-bookmark-slash-solid" />
+          </button>
+        <% end %>
+      </div>
+    </div>
 
     <.entries entries={feed.entries} />
   </li>