refactor(cited-article): wip

Author: mydearxym

lib/groupher_server/cms/delegates/block_tasks.ex

@@ -2,6 +2,7 @@ defmodule GroupherServer.CMS.Delegate.BlockTasks do
   @moduledoc """
   run tasks in every article blocks if need
   """
+  import Ecto.Query, warn: false
   import Helper.Utils, only: [get_config: 2]
   import GroupherServer.CMS.Helper.Matcher
 
@@ -48,9 +49,27 @@ defmodule GroupherServer.CMS.Delegate.BlockTasks do
 
     IO.inspect(cited_contents, label: "fuck all")
 
+    CitedContent |> Repo.insert_all(cited_contents)
+    update_citing_count(cited_contents)
+
     # CitedContent |>  ORM.create
   end
 
+  defp update_citing_count(cited_contents) do
+    Enum.each(cited_contents, fn content ->
+      count_query = from(c in CitedContent, where: c.cited_by_id == ^content.cited_by_id)
+      count = Repo.aggregate(count_query, :count)
+
+      IO.inspect(count, label: "the count")
+    end)
+
+    # count = Repo.aggregate(count_query, :count)
+    # IO.inspect cited_contents, label: "update_citing_count"
+  end
+
+  # count_query = from(s in CommunitySubscriber, where: s.user_id == ^user.id)
+  # count = Repo.aggregate(count_query, :count)
+
   @doc """
   e.g:
   [
@@ -128,6 +147,7 @@ defmodule GroupherServer.CMS.Delegate.BlockTasks do
     %{
       cited_by_id: cited_article.id,
       cited_by_type: cited_article.meta.thread,
+      # cited_article: cited_article,
       block_linker: [block_id],
       user_id: article.author.user.id
     }

lib/groupher_server/cms/helper/macros.ex

@@ -207,8 +207,8 @@ defmodule GroupherServer.CMS.Helper.Macros do
       article_comment_fields()
 
       field(:active_at, :utc_datetime_usec)
+      field(:citing_count, :integer, default: 0)
       # TODO:
-      # reference_articles
       # related_articles
       timestamps()
     end

lib/groupher_server/cms/models/cited_content.ex

@@ -11,13 +11,13 @@ defmodule GroupherServer.CMS.Model.CitedContent do
   alias GroupherServer.{Accounts, CMS}
   alias Accounts.Model.User
 
-  alias CMS.Model.{ArticleComment, Embeds}
+  alias CMS.Model.ArticleComment
 
   @timestamps_opts [type: :utc_datetime_usec]
 
   @required_fields ~w(cited_by_type cited_by_id user_id)a
   @article_cast_fields general_article_fields(:cast)
-  @optional_fields ~w(article_comment_id block_linkers)a ++ @article_cast_fields
+  @optional_fields ~w(article_comment_id block_linker)a ++ @article_cast_fields
 
   @type t :: %CitedContent{}
   schema "cited_contents" do
@@ -29,7 +29,7 @@ defmodule GroupherServer.CMS.Model.CitedContent do
 
     article_belongs_to_fields()
 
-    field(:block_linkers, {:array, :string})
+    field(:block_linker, {:array, :string})
     # content.block_linker = ["block-eee_block-bbb", "block-eee_block-bbb"]
     timestamps()
   end

lib/groupher_server/cms/models/post.ex

@@ -32,6 +32,7 @@ defmodule GroupherServer.CMS.Model.Post do
 
     # TODO: move to general_article_fields
     # embeds_one(:block_task_runner, Embeds.BlockTaskRunner, on_replace: :update)
+    # embeds_many(:citing_contents, CMS.CitedContent, on_replace: :delete)
 
     article_tags_field(:post)
     article_communities_field(:post)

priv/repo/migrations/20210611160430_add_citing_count_to_articles.exs

@@ -0,0 +1,10 @@
+defmodule GroupherServer.Repo.Migrations.AddCitingCountToArticles do
+  use Ecto.Migration
+
+  def change do
+    alter(table(:cms_posts), do: add(:citing_count, :integer))
+    alter(table(:cms_jobs), do: add(:citing_count, :integer))
+    alter(table(:cms_repos), do: add(:citing_count, :integer))
+    alter(table(:cms_blogs), do: add(:citing_count, :integer))
+  end
+end