iterate

Author: Betree

apps/cf_graphql/lib/resolvers/comments.ex

@@ -99,13 +99,19 @@ defmodule CF.Graphql.Resolvers.Comments do
     end
   end
 
-  def flag(_root, %{comment_id: comment_id, reason: reason}, %{context: %{user: user}}) do
+  def flag(_root, %{comment_id: comment_id_str, reason: reason}, %{context: %{user: user}}) do
     # Get comment and preload statement to access video_id
-    comment = Repo.get!(Comment, comment_id) |> Repo.preload(:statement)
-    video_id = comment.statement.video_id
-
+    comment_id = String.to_integer(comment_id_str)
+    video_id =
+      Comment
+      |> join(:inner, [c], s in assoc(c, :statement))
+      |> select([c, s], s.video_id)
+      |> where([c, s], c.id == ^comment_id)
+      |> Repo.one!()
+
+    IO.inspect(%{comment_id: comment_id, reason: reason, video_id: video_id})
     Flagger.flag!(user.id, video_id, comment_id, reason)
-    {:ok, %{id: comment_id}}
+    {:ok, %{id: comment_id, video_id: video_id}}
   end
 
   # Helper function to calculate vote value diff (matches comments_channel.ex logic)

apps/cf_graphql/lib/resolvers/history.ex

@@ -15,3 +15,6 @@ defmodule CF.Graphql.Resolvers.History do
 end
 
 
+
+
+

apps/cf_graphql/lib/resolvers/moderation.ex

@@ -0,0 +1,14 @@
+defmodule CF.Graphql.Resolvers.Moderation do
+  @moduledoc """
+  Resolvers for moderation-related queries
+  """
+
+  alias CF.Moderation
+
+  def random(_root, _args, %{context: %{user: user}}) do
+    case Moderation.random!(user) do
+      nil -> {:ok, nil}
+      entry -> {:ok, entry}
+    end
+  end
+end

apps/cf_graphql/lib/resolvers/speakers.ex

@@ -187,8 +187,23 @@ defmodule CF.Graphql.Resolvers.Speakers do
     |> Repo.update()
     |> case do
       {:ok, updated_speaker} ->
-        Subscriptions.publish_speaker_updated(updated_speaker, nil)
-        CF.Algolia.SpeakersIndex.save_object(updated_speaker)
+        # Publish subscription updates asynchronously
+        Task.start(fn ->
+          speaker_video_ids =
+            Repo.all(
+              from(vs in VideoSpeaker, where: vs.speaker_id == ^speaker.id, select: vs.video_id)
+            )
+
+          Enum.each(speaker_video_ids, fn video_id ->
+            Subscriptions.publish_speaker_updated(updated_speaker, video_id)
+          end)
+        end)
+
+        # Update search index asynchronously
+        Task.start(fn ->
+          CF.Algolia.SpeakersIndex.save_object(updated_speaker)
+        end)
+
         {:ok, updated_speaker}
 
       {:error, changeset} ->

apps/cf_graphql/lib/resolvers/users.ex

@@ -89,6 +89,11 @@ defmodule CF.Graphql.Resolvers.Users do
     |> Result.ok()
   end
 
+  @spec videos_added(
+          atom() | %{:id => any(), optional(any()) => any()},
+          %{:limit => any(), :offset => any(), optional(any()) => any()},
+          any()
+        ) :: {:ok, Scrivener.Page.t()}
   @doc """
   Get videos added by this user
   """

apps/cf_graphql/lib/schema/schema.ex

@@ -8,7 +8,9 @@ defmodule CF.Graphql.Schema do
   import_types(CF.Graphql.Schema.Types.{
     AppInfo,
     Comment,
+    Flag,
     JSON,
+    ModerationEntry,
     Notification,
     Paginated,
     Source,
@@ -129,6 +131,12 @@ defmodule CF.Graphql.Schema do
       arg(:url, non_null(:string))
       resolve(&Resolvers.Videos.search/3)
     end
+
+    @desc "Get a random action requiring moderation"
+    field :random_moderation, :moderation_entry do
+      middleware(Middleware.RequireAuthentication)
+      resolve(&Resolvers.Moderation.random/3)
+    end
   end
 
   # Mutation API
@@ -291,7 +299,7 @@ defmodule CF.Graphql.Schema do
       middleware(Middleware.RequireAuthentication)
 
       arg(:comment_id, non_null(:id))
-      arg(:reason, non_null(:integer))
+      arg(:reason, non_null(:flag_reason))
 
       resolve(&Resolvers.Comments.flag/3)
     end

apps/cf_graphql/lib/schema/types/comment.ex

@@ -9,6 +9,14 @@ defmodule CF.Graphql.Schema.Types.Comment do
   import CF.Graphql.Schema.Utils
   alias CF.Graphql.Resolvers
 
+  @desc "Reason for flagging a comment"
+  enum :flag_reason do
+    value(:bad_language, description: "Personal attack or inappropriate language", as: 1)
+    value(:spam, description: "Unwanted commercial content or spam", as: 2)
+    value(:irrelevant, description: "Irrelevant", as: 3)
+    value(:not_constructive, description: "Not constructive", as: 4)
+  end
+
   @desc "A user's comment. A comment will be considered being a fact if it has a source"
   object :comment do
     field(:id, non_null(:id))

apps/cf_graphql/lib/schema/types/flag.ex

@@ -0,0 +1,22 @@
+defmodule CF.Graphql.Schema.Types.Flag do
+  @moduledoc """
+  Representation of a `DB.Schema.Flag` for Absinthe
+  """
+
+  use Absinthe.Schema.Notation
+
+  import Absinthe.Resolution.Helpers, only: [dataloader: 1]
+  import CF.Graphql.Schema.Utils
+
+  @desc "A flag on an action"
+  object :flag do
+    @desc "User who created the flag"
+    field :source_user, :user do
+      resolve(dataloader(DB.Repo))
+      complexity(join_complexity())
+    end
+
+    @desc "Reason for the flag"
+    field(:reason, :flag_reason)
+  end
+end

apps/cf_graphql/lib/schema/types/moderation_entry.ex

@@ -0,0 +1,18 @@
+defmodule CF.Graphql.Schema.Types.ModerationEntry do
+  @moduledoc """
+  Representation of a `CF.Moderation.ModerationEntry` for Absinthe
+  """
+
+  use Absinthe.Schema.Notation
+
+  import CF.Graphql.Schema.Utils
+
+  @desc "A moderation entry containing an action and its flags"
+  object :moderation_entry do
+    @desc "The action that needs moderation"
+    field(:action, non_null(:user_action))
+
+    @desc "Flags associated with this action"
+    field(:flags, non_null(list_of(:flag)))
+  end
+end

apps/cf_graphql/lib/subscriptions.ex

@@ -97,3 +97,6 @@ end
 
 
 
+
+
+