Add pubsub

2 files changed, 32 insertions, 34 deletions

diff --git a/lib/aggiedit_web/live/post_live/index.ex b/lib/aggiedit_web/live/post_live/index.ex
index 57ae727..6b2be56 100644
--- a/lib/aggiedit_web/live/post_live/index.ex
+++ b/lib/aggiedit_web/live/post_live/index.ex
@@ -10,7 +10,9 @@ defmodule AggieditWeb.PostLive.Index do
   def mount(%{"room_id" => _room_id} = params, session, socket) do
     {:ok, socket} = assign_socket_room_and_user_or_error(params, session, socket)
     case socket.assigns do
-      %{:room => room} -> {:ok, assign(socket, %{:posts => room |> Repo.preload(posts: [:user, :upload]) |> Map.get(:posts)})}
+      %{:room => room} -> 
+        if connected?(socket), do: Rooms.subscribe(socket.assigns.room)
+        {:ok, assign(socket, %{:posts => room |> Repo.preload(posts: [:user, :upload]) |> Map.get(:posts)}), temporary_assigns: [posts: []]}
       _ -> {:ok, socket}
     end
   end
@@ -59,4 +61,11 @@ defmodule AggieditWeb.PostLive.Index do
       {:noreply, socket |> put_flash(:error, "You do not have permission to delete this post.") |> redirect(to: Routes.post_index_path(socket, :index, socket.assigns.room))}
     end
   end
+
+  @impl true
+  def handle_info({action, post}, socket) when action in [:post_created, :post_updated, :post_deleted] do
+    {:noreply, update(socket, :posts, fn posts -> 
+      [posts | post]
+    end)}
+  end
 end
diff --git a/lib/aggiedit_web/live/post_live/index.html.heex b/lib/aggiedit_web/live/post_live/index.html.heex
index 7532685..efb42cb 100644
--- a/lib/aggiedit_web/live/post_live/index.html.heex
+++ b/lib/aggiedit_web/live/post_live/index.html.heex
@@ -15,39 +15,28 @@
 <% end %>
 
 <span><%= live_patch "New Post", to: Routes.post_index_path(@socket, :new, @room) %></span>
-<%= for post <- @posts do %>
-  <div class="card d-flex flex-row align-items-center p-2 m-2 shadow">
-    <%= if !is_nil(post.upload) do %>
-      <%= live_redirect to: Routes.post_show_path(@socket, :show, @room, post) do %>
-        <div class="card-image d-flex justify-content-center" style="width: 100px">
-          <img class="fluid-img thumbnail" src={Routes.static_path(@socket, "/uploads/#{post.upload.file}")} />
-        </div>
+<div id="posts" phx-update="prepend">
+  <%= for post <- @posts do %>
+    <div id={"post-#{post.id}"} class="card d-flex flex-row align-items-center p-2 m-2 shadow">
+      <%= if !is_nil(post.upload) do %>
+        <%= live_redirect to: Routes.post_show_path(@socket, :show, @room, post) do %>
+          <div class="card-image d-flex justify-content-center" style="width: 100px">
+            <img class="fluid-img thumbnail" src={Routes.static_path(@socket, "/uploads/#{post.upload.file}")} />
+          </div>
+        <% end %>
       <% end %>
-    <% end %>
-    <div class="card-body">
-      <%= live_redirect to: Routes.post_show_path(@socket, :show, @room, post) do %>
-        <h4 class="card-title"><%= post.title %></h4>
-      <% end %>
-      <h6 class="card-subtitle mb-2"><span class="text-muted">aggie/</span><%= post.user.username %></h6>
-      <p class="card-text"><%= post.body %></p>
+      <div class="card-body">
+        <%= live_redirect to: Routes.post_show_path(@socket, :show, @room, post) do %>
+          <h4 class="card-title"><%= post.title %></h4>
+        <% end %>
+        <h6 class="card-subtitle mb-2"><span class="text-muted">aggie/</span><%= post.user.username %></h6>
+        <p class="card-text"><%= post.body %></p>
 
-      <%= if Aggiedit.Roles.guard?(@current_user, :edit, post) && Aggiedit.Roles.guard?(@current_user, :edit, post) do %>
-        <span><%= live_patch "Edit", to: Routes.post_index_path(@socket, :edit, @room, post) %></span>
-        <span><%= link "Delete", to: "#", phx_click: "delete", phx_value_id: post.id %></span>
-      <% end %>
+        <%= if Aggiedit.Roles.guard?(@current_user, :edit, post) && Aggiedit.Roles.guard?(@current_user, :edit, post) do %>
+          <span><%= live_patch "Edit", to: Routes.post_index_path(@socket, :edit, @room, post) %></span>
+          <span><%= link "Delete", to: "#", phx_click: "delete", phx_value_id: post.id %></span>
+        <% end %>
+      </div>
     </div>
-  </div>
-<!--
-  <div class=>
-  </div>
-  <tr id={"post-#{post.id}"}>
-    <td><%= post.title %></td>
-    <td><%= post.body %></td>
-
-    <td>
-      <span></span>
-    </td>
-  </tr>
-  -->
-<% end %>
-
+  <% end %>
+</div>