Merge pull request #101 from epochtalk/watch-thread

Watch thread
epochtalk · Aug 7, 2024 · 5944cda · 5944cda
2 parents 36bb0b5 + e84987b
commit 5944cda
Show file tree

Hide file tree

Showing 6 changed files with 311 additions and 7 deletions.
diff --git a/lib/epochtalk_server/models/watch_thread.ex b/lib/epochtalk_server/models/watch_thread.ex
@@ -54,7 +54,7 @@ defmodule EpochtalkServer.Models.WatchThread do
 
     case Repo.insert(watch_thread_cs) do
       {:ok, db_watch_thread} ->
-        db_watch_thread
+        {:ok, db_watch_thread}
 
       {:error,
        %Ecto.Changeset{
@@ -75,7 +75,7 @@ defmodule EpochtalkServer.Models.WatchThread do
   """
   @spec delete(user :: User.t(), thread_id :: non_neg_integer) ::
           {non_neg_integer(), nil | [term()]}
-  def delete(%User{} = user, thread_id) do
+  def delete(%{} = user, thread_id) do
     query =
       from w in WatchThread,
         where: w.user_id == ^user.id and w.thread_id == ^thread_id

diff --git a/lib/epochtalk_server_web/controllers/thread.ex b/lib/epochtalk_server_web/controllers/thread.ex
@@ -20,6 +20,7 @@ defmodule EpochtalkServerWeb.Controllers.Thread do
   alias EpochtalkServer.Models.UserThreadView
   alias EpochtalkServer.Models.MetadataThread
   alias EpochtalkServer.Models.ModerationLog
+  alias EpochtalkServer.Models.WatchThread
   alias EpochtalkServer.Models.WatchBoard
   alias EpochtalkServer.Models.AutoModeration
   alias EpochtalkServer.Models.UserActivity
@@ -222,6 +223,80 @@ defmodule EpochtalkServerWeb.Controllers.Thread do
     end
   end
 
+  @doc """
+  Used to watch `Thread`
+  """
+  def watch(conn, attrs) do
+    with user <- Guardian.Plug.current_resource(conn),
+         thread_id <- Validate.cast(attrs, "thread_id", :integer, required: true),
+         :ok <- ACL.allow!(conn, "watchlist.watchThread"),
+         user_priority <- ACL.get_user_priority(conn),
+         {:can_read, {:ok, true}} <-
+           {:can_read, Board.get_read_access_by_thread_id(thread_id, user_priority)},
+         {:is_active, true} <-
+           {:is_active, User.is_active?(user.id)},
+         {:ok, watch_thread} <- WatchThread.create(user, thread_id) do
+      render(conn, :watch, thread: watch_thread)
+    else
+      {:can_read, {:ok, false}} ->
+        ErrorHelpers.render_json_error(
+          conn,
+          403,
+          "Unauthorized, you do not have permission to read"
+        )
+
+      {:is_active, false} ->
+        ErrorHelpers.render_json_error(
+          conn,
+          400,
+          "Account must be active to watch thread"
+        )
+
+      {:error, data} ->
+        ErrorHelpers.render_json_error(conn, 400, data)
+
+      _ ->
+        ErrorHelpers.render_json_error(conn, 400, "Error, cannot watch thread")
+    end
+  end
+
+  @doc """
+  Used to unwatch `Thread`
+  """
+  def unwatch(conn, attrs) do
+    with user <- Guardian.Plug.current_resource(conn),
+         thread_id <- Validate.cast(attrs, "thread_id", :integer, required: true),
+         :ok <- ACL.allow!(conn, "watchlist.unwatchThread"),
+         user_priority <- ACL.get_user_priority(conn),
+         {:can_read, {:ok, true}} <-
+           {:can_read, Board.get_read_access_by_thread_id(thread_id, user_priority)},
+         {:is_active, true} <-
+           {:is_active, User.is_active?(user.id)},
+         {1, nil} <- WatchThread.delete(user, thread_id) do
+      render(conn, :watch, thread: %{thread_id: thread_id, user_id: user.id})
+    else
+      {:can_read, {:ok, false}} ->
+        ErrorHelpers.render_json_error(
+          conn,
+          403,
+          "Unauthorized, you do not have permission to read"
+        )
+
+      {:is_active, false} ->
+        ErrorHelpers.render_json_error(
+          conn,
+          400,
+          "Account must be active to unwatch thread"
+        )
+
+      {:error, data} ->
+        ErrorHelpers.render_json_error(conn, 400, data)
+
+      _ ->
+        ErrorHelpers.render_json_error(conn, 400, "Error, cannot unwatch thread")
+    end
+  end
+
   @doc """
   Used to lock `Thread`
   """

diff --git a/lib/epochtalk_server_web/json/thread_json.ex b/lib/epochtalk_server_web/json/thread_json.ex
@@ -115,6 +115,19 @@ defmodule EpochtalkServerWeb.Controllers.ThreadJSON do
   def lock(%{thread: %{thread_id: thread_id, locked: locked}}),
     do: %{thread_id: thread_id, locked: locked}
 
+  @doc """
+  Renders watched `Thread`.
+
+    iex> thread = %{
+    iex>   thread_id: 2,
+    iex>   user_id: 1
+    iex> }
+    iex> EpochtalkServerWeb.Controllers.ThreadJSON.watch(%{thread: thread})
+    thread
+  """
+  def watch(%{thread: %{thread_id: thread_id, user_id: user_id}}),
+    do: %{thread_id: thread_id, user_id: user_id}
+
   @doc """
   Renders purge `Thread`.
 

diff --git a/lib/epochtalk_server_web/plugs/prepare_parse.ex b/lib/epochtalk_server_web/plugs/prepare_parse.ex
@@ -34,9 +34,15 @@ defmodule EpochtalkServerWeb.Plugs.PrepareParse do
   end
 
   defp try_decode(conn, body) do
-    case Jason.decode(body) do
-      {:ok, _result} -> update_in(conn.assigns[:raw_body], &[body | &1 || []])
-      {:error, _reason} -> raise MalformedPayload
+    %{method: method} = conn
+
+    if method in @methods and @env != :test do
+      case Jason.decode(body) do
+        {:ok, _result} -> update_in(conn.assigns[:raw_body], &[body | &1 || []])
+        {:error, _reason} -> raise MalformedPayload
+      end
+    else
+      conn
     end
   end
 end
diff --git a/lib/epochtalk_server_web/router.ex b/lib/epochtalk_server_web/router.ex
@@ -54,6 +54,8 @@ defmodule EpochtalkServerWeb.Router do
     post "/threads/:thread_id/polls/lock", Poll, :lock
     put "/threads/:thread_id/polls", Poll, :update
     post "/threads/:thread_id/polls", Poll, :create
+    post "/watchlist/threads/:thread_id", Thread, :watch
+    delete "/watchlist/threads/:thread_id", Thread, :unwatch
     get "/posts/draft", PostDraft, :by_user_id
     put "/posts/draft", PostDraft, :upsert
     post "/posts", Post, :create