chg: [sources] user can subscribe and unsubscribe themselves..

Author: gallypette

lib/cocktailparty/catalog.ex

@@ -562,16 +562,6 @@ defmodule Cocktailparty.Catalog do
     Repo.one(query)
   end
 
-  # Check whether a used is authorized to :show a source
-  def authorized_show?(source_id, user_id) do
-    Logger.info("Checking authorization for UserID: #{user_id} @ FeedId: #{source_id}.")
-
-    (UserManagement.is_confirmed?(user_id) && is_subscribed?(source_id, user_id)) ||
-      (UserManagement.is_confirmed?(user_id) && UserManagement.can?(user_id, :access_all_sources) &&
-         UserManagement.can?(user_id, :list_all_sources)) ||
-      (UserManagement.is_confirmed?(user_id) && is_public?(source_id))
-  end
-
   defp notify_broker(%Source{} = source, msg) do
     GenServer.cast(get_broker(source), msg)
   end

lib/cocktailparty_web/access_control.ex

@@ -29,7 +29,7 @@ defmodule CocktailpartyWeb.AccessControl do
     source_id = conn.params["id"]
 
     (UserManagement.is_confirmed?(user_id) && Catalog.is_subscribed?(source_id, user_id)) ||
-      (UserManagement.is_confirmed?(user_id) && UserManagement.can?(user_id, :access_all_sources)) ||
+      (UserManagement.is_confirmed?(user_id) && (UserManagement.can?(user_id, :access_all_sources) || UserManagement.can?(user_id, :list_all_sources))) ||
       (UserManagement.is_confirmed?(user_id) && Catalog.is_public?(source_id))
   end
 

lib/cocktailparty_web/controllers/sink_controller.ex

@@ -18,9 +18,9 @@ defmodule CocktailpartyWeb.SinkController do
     changeset = SinkCatalog.change_sink(%Sink{})
     # get a receiving redis instance
     instance = Input.get_one_sink_redisinstance()
+
     case instance do
       nil ->
-
         conn
         |> put_flash(:error, "A receiving redis instance is required to create a sink.")
         |> redirect(to: ~p"/")

lib/cocktailparty_web/controllers/source_controller.ex

@@ -24,6 +24,46 @@ defmodule CocktailpartyWeb.SourceController do
   def show(conn, %{"id" => id}) do
     source = Catalog.get_source!(id)
     sample = Catalog.get_sample(id)
+
+    source =
+      source
+      |> Map.put(:subscribed, Catalog.is_subscribed?(source.id, conn.assigns.current_user.id))
+
     render(conn, :show, source: source, sample: sample)
   end
+
+  def subscribe(conn, %{"source_id" => source_id}) do
+    Logger.debug("User #{conn.assigns.current_user.id} subscribing to source #{source_id}")
+
+    case Catalog.subscribe(source_id, conn.assigns.current_user.id) do
+      {:ok, _source} ->
+        conn
+        |> put_flash(:info, "Subscribed to source #{source_id}")
+        |> redirect(to: ~p"/sources/#{source_id}")
+
+      {:error, changeset} ->
+        conn
+        |> put_flash(:error, changeset)
+        |> redirect(to: ~p"/sources/#{source_id}")
+    end
+  end
+
+  def unsubscribe(conn, %{"source_id" => source_id}) do
+    Logger.debug("User #{conn.assigns.current_user.id} unsubscribing from source #{source_id}")
+
+    case Catalog.unsubscribe(
+           String.to_integer(source_id),
+           conn.assigns.current_user.id
+         ) do
+      {1, _deleted} ->
+        conn
+        |> put_flash(:info, "Unsubscribed from source #{source_id} ")
+        |> redirect(to: ~p"/sources/#{source_id}")
+
+      {0, _deleted} ->
+        conn
+        |> put_flash(:error, "Unsubscribing from #{source_id} failed.")
+        |> redirect(to: ~p"/sources/#{source_id}")
+    end
+  end
 end

lib/cocktailparty_web/controllers/source_html/show.html.heex

@@ -5,6 +5,20 @@
     <.link :if={@is_admin} href={~p"/admin/sources/#{@source}/edit"}>
       <.button>Edit source</.button>
     </.link>
+    <.link
+      :if={!@is_admin && !@source.subscribed}
+      href={~p"/sources/subscribe/#{@source}"}
+      method="post"
+    >
+      <.button>Subscribe</.button>
+    </.link>
+    <.link
+      :if={!@is_admin && @source.subscribed}
+      href={~p"/sources/unsubscribe/#{@source}"}
+      method="delete"
+    >
+      <.button>Unsubscribe</.button>
+    </.link>
   </:actions>
 </.header>
 

lib/cocktailparty_web/router.ex

@@ -44,6 +44,8 @@ defmodule CocktailpartyWeb.Router do
     get "/", PageController, :home
     get "/sources", SourceController, :index
     get "/sources/:id", SourceController, :show
+    post "/sources/subscribe/:source_id", SourceController, :subscribe
+    delete "/sources/unsubscribe/:source_id", SourceController, :unsubscribe
     resources "/sinks", SinkController
   end