iterate

Author: Betree

apps/cf_graphql/lib/resolvers/videos.ex

@@ -37,6 +37,13 @@ defmodule CF.Graphql.Resolvers.Videos do
     end
   end
 
+  def search(_root, %{url: url}, _info) do
+    case CF.Videos.get_video_by_url(url) do
+      nil -> {:ok, nil}
+      video -> {:ok, video}
+    end
+  end
+
   # Deprecated: Use paginated_list/3 instead
   # Keeping for backward compatibility with deprecated all_videos field
   def list(_root, args, _info) do
@@ -102,6 +109,27 @@ defmodule CF.Graphql.Resolvers.Videos do
     |> Enum.group_by(& &1.video_id)
   end
 
+  def create(_root, %{url: url, unlisted: unlisted}, %{
+        context: %{user: user}
+      }) do
+    case CF.Videos.get_video_by_url(url) do
+      nil ->
+        case CF.Videos.create!(user, url, unlisted: unlisted) do
+          {:ok, video} ->
+            {:ok, video}
+
+          {:error, error} when is_binary(error) ->
+            {:error, error}
+
+          {:error, _reason} ->
+            {:error, "Failed to create video"}
+        end
+
+      existing_video ->
+        {:ok, existing_video}
+    end
+  end
+
   def start_automatic_statements_extraction(_root, %{video_id: video_id}, %{
         context: %{user: user}
       }) do

apps/cf_graphql/lib/schema/schema.ex

@@ -123,6 +123,12 @@ defmodule CF.Graphql.Schema do
       arg(:statement_id, non_null(:id))
       resolve(&Resolvers.History.statement_history_actions/3)
     end
+
+    @desc "Search for a video by URL. Returns the video if it exists, null otherwise."
+    field :search_video, :video do
+      arg(:url, non_null(:string))
+      resolve(&Resolvers.Videos.search/3)
+    end
   end
 
   # Mutation API
@@ -160,6 +166,17 @@ defmodule CF.Graphql.Schema do
       resolve(&Resolvers.Videos.start_automatic_statements_extraction/3)
     end
 
+    @desc "Create a new video. If it already exists, returns the existing video."
+    field :create_video, :video do
+      middleware(Middleware.RequireAuthentication)
+      middleware(Middleware.RequireReputation, 75)
+
+      arg(:url, non_null(:string))
+      arg(:unlisted, non_null(:boolean))
+
+      resolve(&Resolvers.Videos.create/3)
+    end
+
     field :edit_video, :video do
       middleware(Middleware.RequireAuthentication)
       # MIN_REPUTATION_UPDATE_VIDEO

apps/cf_rest_api/lib/router.ex

@@ -23,10 +23,10 @@ defmodule CF.RestApi.Router do
 
     # ---- Public endpoints ----
     get("/", ApiInfoController, :get)
-    get("/videos", VideoController, :index)
-    get("/speakers/:slug_or_id", SpeakerController, :show)
-    post("/search/video", VideoController, :search)
-    get("/videos/:video_id/statements", StatementController, :get)
+    # get("/videos", VideoController, :index)
+    # get("/speakers/:slug_or_id", SpeakerController, :show)
+    # post("/search/video", VideoController, :search)
+    # get("/videos/:video_id/statements", StatementController, :get)
     get("/newsletter/unsubscribe/:token", UserController, :newsletter_unsubscribe)
 
     # ---- Authenticathed endpoints ----
@@ -43,7 +43,7 @@ defmodule CF.RestApi.Router do
       # Users
       scope "/users" do
         post("/", UserController, :create)
-        post("/request_invitation", UserController, :request_invitation)
+        # post("/request_invitation", UserController, :request_invitation)
         get("/username/:username", UserController, :show)
 
         scope "/reset_password" do
@@ -65,12 +65,12 @@ defmodule CF.RestApi.Router do
         end
       end
 
-      # Videos
-      post("/videos", VideoController, :get_or_create)
+      # # Videos
+      # post("/videos", VideoController, :get_or_create)
 
-      # Moderation
-      get("/moderation/random", ModerationController, :random)
-      post("/moderation/feedback", ModerationController, :post_feedback)
+      # # Moderation
+      # get("/moderation/random", ModerationController, :random)
+      # post("/moderation/feedback", ModerationController, :post_feedback)
     end
   end