Paged cited contents workflow (#402)

* refactor(cite-workflow): wip

* refactor(cite-workflow): wip

* refactor(cite-workflow): wip

* refactor(cite-workflow): gq endpoint

Author: mydearxym

lib/groupher_server/accounts/delegates/upvoted_articles.ex

@@ -17,8 +17,8 @@ defmodule GroupherServer.Accounts.Delegate.UpvotedArticles do
   get paged upvoted articles
   """
   def paged_upvoted_articles(user_id, %{thread: thread} = filter) do
-    thread_upcase = thread |> to_string |> String.upcase()
-    where_query = dynamic([a], a.user_id == ^user_id and a.thread == ^thread_upcase)
+    thread = thread |> to_string |> String.upcase()
+    where_query = dynamic([a], a.user_id == ^user_id and a.thread == ^thread)
 
     load_upvoted_articles(where_query, filter)
   end

lib/groupher_server/cms/cms.ex

@@ -12,6 +12,7 @@ defmodule GroupherServer.CMS do
     ArticleCURD,
     ArticleCommunity,
     ArticleEmotion,
+    CitedContent,
     CommentCurd,
     ArticleCollect,
     ArticleUpvote,
@@ -96,6 +97,8 @@ defmodule GroupherServer.CMS do
   defdelegate sink_article(thread, id), to: ArticleCURD
   defdelegate undo_sink_article(thread, id), to: ArticleCURD
 
+  defdelegate paged_citing_contents(type, id, filter), to: CitedContent
+
   defdelegate upvote_article(thread, article_id, user), to: ArticleUpvote
   defdelegate undo_upvote_article(thread, article_id, user), to: ArticleUpvote
 

lib/groupher_server/cms/delegates/article_collect.ex

@@ -46,8 +46,8 @@ defmodule GroupherServer.CMS.Delegate.ArticleCollect do
         update_article_reaction_user_list(:collect, article, user_id, :add)
       end)
       |> Multi.run(:create_collect, fn _, _ ->
-        thread_upcase = thread |> to_string |> String.upcase()
-        args = Map.put(%{user_id: user_id, thread: thread_upcase}, info.foreign_key, article.id)
+        thread = thread |> to_string |> String.upcase()
+        args = Map.put(%{user_id: user_id, thread: thread}, info.foreign_key, article.id)
 
         ORM.create(ArticleCollect, args)
       end)
@@ -131,8 +131,8 @@ defmodule GroupherServer.CMS.Delegate.ArticleCollect do
 
   defp collection_findby_args(thread, article_id, user_id) do
     with {:ok, info} <- match(thread) do
-      thread_upcase = thread |> to_string |> String.upcase()
-      %{thread: thread_upcase, user_id: user_id} |> Map.put(info.foreign_key, article_id)
+      thread = thread |> to_string |> String.upcase()
+      %{thread: thread, user_id: user_id} |> Map.put(info.foreign_key, article_id)
     end
   end
 

lib/groupher_server/cms/delegates/article_community.ex

@@ -41,10 +41,10 @@ defmodule GroupherServer.CMS.Delegate.ArticleCommunity do
   defp pack_pin_args(thread, article_id, community_id) do
     with {:ok, info} <- match(thread),
          {:ok, community} <- ORM.find(Community, community_id) do
-      thread_upcase = thread |> to_string |> String.upcase()
+      thread = thread |> to_string |> String.upcase()
 
       Map.put(
-        %{community_id: community.id, thread: thread_upcase},
+        %{community_id: community.id, thread: thread},
         info.foreign_key,
         article_id
       )
@@ -145,12 +145,10 @@ defmodule GroupherServer.CMS.Delegate.ArticleCommunity do
 
   # check if the thread has aready enough pinned articles
   defp check_pinned_article_count(community_id, thread) do
-    thread_upcase = thread |> to_string |> String.upcase()
+    thread = thread |> to_string |> String.upcase()
 
     query =
-      from(p in PinnedArticle,
-        where: p.community_id == ^community_id and p.thread == ^thread_upcase
-      )
+      from(p in PinnedArticle, where: p.community_id == ^community_id and p.thread == ^thread)
 
     pinned_articles = query |> Repo.all()
 

lib/groupher_server/cms/delegates/article_upvote.ex

@@ -43,8 +43,8 @@ defmodule GroupherServer.CMS.Delegate.ArticleUpvote do
         Accounts.achieve(%User{id: achiever_id}, :inc, :upvote)
       end)
       |> Multi.run(:create_upvote, fn _, _ ->
-        thread_upcase = thread |> to_string |> String.upcase()
-        args = Map.put(%{user_id: user_id, thread: thread_upcase}, info.foreign_key, article.id)
+        thread = thread |> to_string |> String.upcase()
+        args = Map.put(%{user_id: user_id, thread: thread}, info.foreign_key, article.id)
 
         with {:ok, _} <- ORM.create(ArticleUpvote, args) do
           ORM.find(info.model, article.id)

lib/groupher_server/cms/delegates/cited_content.ex

@@ -0,0 +1,86 @@
+defmodule GroupherServer.CMS.Delegate.CitedContent do
+  @moduledoc """
+  CURD operation on post/job ...
+  """
+  import Ecto.Query, warn: false
+
+  import Helper.Utils, only: [done: 1, get_config: 2]
+  import ShortMaps
+
+  alias Helper.Types, as: T
+  alias GroupherServer.{CMS, Repo}
+  alias Helper.{ORM, QueryBuilder}
+
+  alias CMS.Model.CitedContent
+
+  @article_threads get_config(:article, :threads)
+
+  @article_preloads @article_threads |> Enum.map(&Keyword.new([{&1, [author: :user]}]))
+
+  @comment_article_preloads @article_threads |> Enum.map(&Keyword.new([{:comment, &1}]))
+  @cited_preloads @article_preloads ++ [[comment: :author] ++ @comment_article_preloads]
+
+  @doc "get paged citing contents"
+  def paged_citing_contents(cited_by_type, cited_by_id, %{page: page, size: size} = filter) do
+    cited_by_type = cited_by_type |> to_string |> String.upcase()
+
+    CitedContent
+    |> where([c], c.cited_by_id == ^cited_by_id and c.cited_by_type == ^cited_by_type)
+    |> QueryBuilder.filter_pack(Map.merge(filter, %{sort: :asc_inserted}))
+    |> ORM.paginater(~m(page size)a)
+    |> extract_contents
+    |> done
+  end
+
+  def extract_contents(%{entries: entries} = paged_contents) do
+    entries = entries |> Repo.preload(@cited_preloads) |> Enum.map(&shape_article(&1))
+
+    Map.put(paged_contents, :entries, entries)
+  end
+
+  defp thread_to_atom(thread), do: thread |> String.downcase() |> String.to_atom()
+
+  # shape comment cite
+  @spec shape_article(CitedContent.t()) :: T.cite_info()
+  defp shape_article(%CitedContent{comment_id: comment_id} = cited) when not is_nil(comment_id) do
+    %{
+      block_linker: block_linker,
+      cited_by_type: cited_by_type,
+      comment: comment,
+      inserted_at: inserted_at
+    } = cited
+
+    comment_thread = comment.thread |> String.downcase() |> String.to_atom()
+    article = comment |> Map.get(comment_thread)
+    user = comment.author |> Map.take([:login, :nickname, :avatar])
+
+    article
+    |> Map.take([:id, :title])
+    |> Map.merge(%{
+      inserted_at: inserted_at,
+      user: user,
+      thread: thread_to_atom(cited_by_type),
+      comment_id: comment.id,
+      block_linker: block_linker
+    })
+  end
+
+  # shape general article cite
+  defp shape_article(%CitedContent{} = cited) do
+    %{block_linker: block_linker, cited_by_type: cited_by_type, inserted_at: inserted_at} = cited
+
+    thread = thread_to_atom(cited_by_type)
+    article = Map.get(cited, thread)
+
+    user = get_in(article, [:author, :user]) |> Map.take([:login, :nickname, :avatar])
+
+    article
+    |> Map.take([:id, :title])
+    |> Map.merge(%{
+      user: user,
+      thread: thread,
+      block_linker: block_linker,
+      inserted_at: inserted_at
+    })
+  end
+end

lib/groupher_server_web/resolvers/cms_resolver.ex

@@ -102,6 +102,10 @@ defmodule GroupherServerWeb.Resolvers.CMS do
     CMS.undo_report_article(thread, id, user)
   end
 
+  def paged_citing_contents(_root, ~m(content id filter)a, _info) do
+    CMS.paged_citing_contents(content, id, filter)
+  end
+
   # #######################
   # thread reaction ..
   # #######################

lib/groupher_server_web/schema/cms/cms_metrics.ex

@@ -41,6 +41,11 @@ defmodule GroupherServerWeb.Schema.CMS.Metrics do
     value(:share)
   end
 
+  enum :content do
+    article_values()
+    value(:comment)
+  end
+
   enum :when_enum do
     value(:today)
     value(:this_week)

lib/groupher_server_web/schema/cms/cms_queries.ex

@@ -124,6 +124,15 @@ defmodule GroupherServerWeb.Schema.CMS.Queries do
       resolve(&R.CMS.paged_reports/3)
     end
 
+    @desc "paged citings list"
+    field :paged_citing_contents, :paged_citings do
+      arg(:id, non_null(:id))
+      arg(:content, :content, default_value: :post)
+      arg(:filter, :paged_filter)
+
+      resolve(&R.CMS.paged_citing_contents/3)
+    end
+
     @desc "search communities by title"
     field :search_communities, :paged_communities do
       arg(:title, non_null(:string))

lib/groupher_server_web/schema/cms/cms_types.ex

@@ -317,13 +317,29 @@ defmodule GroupherServerWeb.Schema.CMS.Types do
     timestamp_fields()
   end
 
+  object :citing do
+    field(:id, :id)
+    field(:thread, :string)
+    field(:title, :string)
+    field(:block_linker, list_of(:string))
+    field(:comment_id, :id)
+    field(:user, :common_user)
+
+    timestamp_fields()
+  end
+
   paged_article_objects()
 
   object :paged_reports do
     field(:entries, list_of(:abuse_report))
     pagination_fields()
   end
 
+  object :paged_citings do
+    field(:entries, list_of(:citing))
+    pagination_fields()
+  end
+
   object :paged_categories do
     field(:entries, list_of(:category))
     pagination_fields()