diff --git a/lib/putzplan/pub_sub.ex b/lib/putzplan/pub_sub.ex
new file mode 100644
index 0000000..d7bcbd6
--- /dev/null
+++ b/lib/putzplan/pub_sub.ex
@@ -0,0 +1,43 @@
+defmodule Putzplan.PubSub do
+ @tasks_topic "tasks"
+
+ def subscribe_completed(id) do
+ Phoenix.PubSub.subscribe(__MODULE__, get_topic(id))
+ end
+
+ def subscribe_tasks do
+ Phoenix.PubSub.subscribe(__MODULE__, @tasks_topic)
+ end
+
+ def upsert_task(task) do
+ Phoenix.PubSub.broadcast!(__MODULE__, @tasks_topic, {:upsert, task})
+ end
+
+ def delete_task(task) do
+ Phoenix.PubSub.broadcast!(__MODULE__, @tasks_topic, {:delete, task})
+ end
+
+ def update_task_by_id(id) do
+ Phoenix.PubSub.broadcast!(__MODULE__, @tasks_topic, {:update, id})
+ end
+
+ def upsert_completed_task(completed_task) do
+ Phoenix.PubSub.broadcast!(
+ __MODULE__,
+ get_topic(completed_task.tasks.id),
+ {:upsert, completed_task}
+ )
+ end
+
+ def delete_completed_task(completed_task) do
+ Phoenix.PubSub.broadcast!(
+ __MODULE__,
+ get_topic(completed_task.tasks.id),
+ {:delete, completed_task}
+ )
+ end
+
+ defp get_topic(id) do
+ "completed:" <> id
+ end
+end
diff --git a/lib/putzplan_web/live/task_live/index.ex b/lib/putzplan_web/live/task_live/index.ex
index fbf9907..70cf5dc 100644
--- a/lib/putzplan_web/live/task_live/index.ex
+++ b/lib/putzplan_web/live/task_live/index.ex
@@ -1,13 +1,6 @@
defmodule PutzplanWeb.TaskLive.Index do
use PutzplanWeb, :live_view
- @pubsub_name Putzplan.PubSub
- @pubsub_topic "tasks"
-
- defp get_topic(id) do
- "completed:" <> id
- end
-
@impl true
def render(assigns) do
~H"""
@@ -23,7 +16,7 @@ defmodule PutzplanWeb.TaskLive.Index do
<%= for {id, task} <- @streams.tasks do %>
@@ -81,7 +74,7 @@ defmodule PutzplanWeb.TaskLive.Index do
<.link
- phx-click={JS.push("delete", value: %{id: task.id}) |> hide("#task-#{id}")}
+ phx-click={JS.push("delete", value: %{id: task.id}) |> hide(id)}
data-confirm="Are you sure?"
class="text-red-600 hover:text-red-800 p-1 rounded-full hover:bg-red-100"
phx-click-stop-propagation="true"
@@ -123,7 +116,7 @@ defmodule PutzplanWeb.TaskLive.Index do
@impl true
def mount(_params, _session, socket) do
- if connected?(socket), do: Phoenix.PubSub.subscribe(@pubsub_name, @pubsub_topic)
+ if connected?(socket), do: Putzplan.PubSub.subscribe_tasks()
{:ok,
socket
@@ -180,9 +173,9 @@ defmodule PutzplanWeb.TaskLive.Index do
def handle_event("delete", %{"id" => id}, socket) do
task = Ash.get!(Putzplan.Tasks.Task, id, actor: socket.assigns.current_user)
Ash.destroy!(task, actor: socket.assigns.current_user)
- Phoenix.PubSub.broadcast(@pubsub_name, @pubsub_topic, {:delete, task})
+ Putzplan.PubSub.delete_task(task)
- {:noreply, task}
+ {:noreply, socket}
end
@impl true
@@ -193,8 +186,8 @@ defmodule PutzplanWeb.TaskLive.Index do
|> Ash.create!(actor: socket.assigns.current_user)
task = Ash.get!(Putzplan.Tasks.Task, id, load: [:due])
- Phoenix.PubSub.broadcast(@pubsub_name, @pubsub_topic, {:upsert, task})
- Phoenix.PubSub.broadcast(@pubsub_name, get_topic(id), {:upsert, completed_task})
+ Putzplan.PubSub.upsert_task(task)
+ Putzplan.PubSub.upsert_completed_task(completed_task)
{:noreply, socket}
end
diff --git a/lib/putzplan_web/live/task_live/show.ex b/lib/putzplan_web/live/task_live/show.ex
index daa59c2..68d0f2f 100644
--- a/lib/putzplan_web/live/task_live/show.ex
+++ b/lib/putzplan_web/live/task_live/show.ex
@@ -2,17 +2,11 @@ defmodule PutzplanWeb.TaskLive.Show do
require Ash.Query
use PutzplanWeb, :live_view
- @pubsub_name Putzplan.PubSub
-
- defp get_topic(id) do
- "completed:" <> id
- end
-
@impl true
def render(assigns) do
~H"""
<.header>
- Task {@task.description}
+ {@task.description}
<:actions>
<.link patch={~p"/tasks/#{@task}/show/edit"} phx-click={JS.push_focus()}>
<.button>Edit task
@@ -87,7 +81,7 @@ defmodule PutzplanWeb.TaskLive.Show do
current_user={@current_user}
action={@live_action}
task={@task}
- patch={~p"/"}
+ patch={~p"/tasks/#{@task}"}
/>
@@ -97,7 +91,7 @@ defmodule PutzplanWeb.TaskLive.Show do
@impl true
def mount(%{"id" => id}, _session, socket) do
- if connected?(socket), do: Phoenix.PubSub.subscribe(@pubsub_name, get_topic(id))
+ if connected?(socket), do: Putzplan.PubSub.subscribe_completed(id)
{:ok, socket}
end
@@ -127,8 +121,8 @@ defmodule PutzplanWeb.TaskLive.Show do
Ash.destroy!(completed_task, actor: socket.assigns.current_user)
- Phoenix.PubSub.broadcast!(@pubsub_name, get_topic(id), {:delete, completed_task})
- Phoenix.PubSub.broadcast!(@pubsub_name, "tasks", {:update, completed_task.tasks.id})
+ Putzplan.PubSub.delete_completed_task(completed_task)
+ Putzplan.PubSub.update_task_by_id(completed_task.tasks.id)
{:noreply, socket}
end