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/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

@@ -22,6 +22,8 @@ defmodule GroupherServer.CMS.Delegate.CitedContent do
 
   @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}))

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()

test/groupher_server/cms/cite_contents/cite_blog_test.exs

@@ -163,7 +163,6 @@ defmodule GroupherServer.Test.CMS.CiteContent.Blog do
   end
 
   describe "[cite pagi]" do
-    @tag :wip
     test "can get paged cited articles.", ~m(user community blog2 blog_attrs)a do
       {:ok, comment} =
         CMS.create_comment(