Add uploads; next up - user authentication on post

3 files changed, 47 insertions, 5 deletions

diff --git a/lib/aggiedit_web/live/post_live/form_component.ex b/lib/aggiedit_web/live/post_live/form_component.ex
index 11ad4a1..53b19dd 100644
--- a/lib/aggiedit_web/live/post_live/form_component.ex
+++ b/lib/aggiedit_web/live/post_live/form_component.ex
@@ -2,6 +2,9 @@ defmodule AggieditWeb.PostLive.FormComponent do
   use AggieditWeb, :live_component
 
   alias Aggiedit.Rooms
+  alias Aggiedit.Rooms.Post
+  alias Aggiedit.Uploads.Upload
+  alias Aggiedit.Repo
 
   @impl true
   def update(%{post: post} = assigns, socket) do
@@ -10,7 +13,10 @@ defmodule AggieditWeb.PostLive.FormComponent do
     {:ok,
      socket
      |> assign(assigns)
-     |> assign(:changeset, changeset)}
+     |> assign(:changeset, changeset)
+     |> assign(:uploaded_files, [])
+     |> allow_upload(:upload, accept: ~w(.jpg .jpeg .png .gif), max_entries: 1)
+    }
   end
 
   @impl true
@@ -24,11 +30,35 @@ defmodule AggieditWeb.PostLive.FormComponent do
   end
 
   def handle_event("save", %{"post" => post_params}, socket) do
-    save_post(socket, socket.assigns.action, post_params)
+    socket
+    |> save_post(socket.assigns.action, post_params)
+  end
+
+  defp save_upload(socket, %Post{} = post) do
+    consume_uploaded_entries(socket, :upload, fn data, upload -> 
+      [extension | _] = MIME.extensions(upload.client_type)
+      filename = "#{upload.uuid}-#{extension}"
+      upload = %Upload{
+        file: filename,
+        size: upload.client_size,
+        mime: upload.client_type
+      }
+
+      dest = Path.join("priv/static/uploads", filename)
+      File.cp!(data.path, dest)
+
+      Repo.preload(post, :upload)
+      |> Post.change_upload(upload)
+      |> Repo.update
+      IO.puts(inspect(upload))
+
+      {:ok, upload}
+    end)
+    {:ok, post} 
   end
 
   defp save_post(socket, :edit, post_params) do
-    case Rooms.update_post(socket.assigns.post, post_params) do
+    case Rooms.update_post(socket.assigns.post, post_params, &save_upload(socket, &1)) do
       {:ok, _post} ->
         {:noreply,
          socket
@@ -41,7 +71,7 @@ defmodule AggieditWeb.PostLive.FormComponent do
   end
 
   defp save_post(socket, :new, post_params) do
-    case Rooms.create_post(post_params) do
+    case Rooms.create_post(post_params, &save_upload(socket, &1)) do
       {:ok, _post} ->
         {:noreply,
          socket
diff --git a/lib/aggiedit_web/live/post_live/form_component.html.heex b/lib/aggiedit_web/live/post_live/form_component.html.heex
index 682ec78..695a90a 100644
--- a/lib/aggiedit_web/live/post_live/form_component.html.heex
+++ b/lib/aggiedit_web/live/post_live/form_component.html.heex
@@ -16,6 +16,16 @@
     <%= label f, :body %>
     <%= textarea f, :body %>
     <%= error_tag f, :body %>
+
+    <%= live_file_input @uploads.upload %>
+
+    <%= for upload <- @uploads.upload.entries do %>
+      <div class="row">
+        <div class="column">
+          <%= live_img_preview upload, height: 80 %>
+        </div>
+      </div>
+    <% end %>
   
     <div>
       <%= submit "Save", phx_disable_with: "Saving..." %>
diff --git a/lib/aggiedit_web/live/post_live/index.ex b/lib/aggiedit_web/live/post_live/index.ex
index 1bf7bc3..1952625 100644
--- a/lib/aggiedit_web/live/post_live/index.ex
+++ b/lib/aggiedit_web/live/post_live/index.ex
@@ -3,6 +3,7 @@ defmodule AggieditWeb.PostLive.Index do
 
   alias Aggiedit.Rooms
   alias Aggiedit.Rooms.Post
+  alias Aggiedit.Repo
 
   @impl true
   def mount(_params, session, socket) do
@@ -25,9 +26,10 @@ defmodule AggieditWeb.PostLive.Index do
   end
 
   defp apply_action(socket, :new, _params) do
+    post = %Post{user_id: socket.assigns[:current_user].id}
     socket
     |> assign(:page_title, "New Post")
-    |> assign(:post, %Post{})
+    |> assign(:post, post)
   end
 
   defp apply_action(socket, :index, _params) do