feat: Upload captions

Author: Betree

apps/cf/lib/actions/action_creator.ex

@@ -10,6 +10,7 @@ defmodule CF.Actions.ActionCreator do
   alias DB.Schema.Speaker
   alias DB.Schema.Statement
   alias DB.Schema.Comment
+  alias DB.Schema.VideoCaption
   alias CF.Actions.ReputationChange
 
   # Create
@@ -175,6 +176,19 @@ defmodule CF.Actions.ActionCreator do
     )
   end
 
+  def action_upload_video_captions(user_id, video_id, caption = %VideoCaption{}) do
+    action(
+      user_id,
+      :video_caption,
+      :upload,
+      video_id: video_id,
+      changes: %{
+        "format" => caption.format,
+        "parsed" => caption.parsed
+      }
+    )
+  end
+
   def action_revert_vote(user_id, video_id, vote_type, comment = %Comment{})
       when vote_type in [:revert_vote_up, :revert_vote_down, :revert_self_vote] do
     action(

apps/cf_graphql/lib/resolvers/videos.ex

@@ -115,6 +115,7 @@ defmodule CF.Graphql.Resolvers.Videos do
     {:ok, video}
   end
 
+
   def edit(_root, %{id: id, unlisted: unlisted}, %{
         context: %{user: user}
       }) do
@@ -136,5 +137,32 @@ defmodule CF.Graphql.Resolvers.Videos do
       {:error, _} ->
         {:error, "Failed to update video"}
     end
+
+  def set_captions(_root, %{video_id: video_id, captions: captions_input}, %{
+        context: %{user: user}
+      }) do
+    video = DB.Repo.get!(DB.Schema.Video, video_id)
+
+    Multi.new()
+    |> Multi.insert(
+      :caption,
+      VideoCaption.changeset(%VideoCaption{
+        video_id: video.id,
+        raw: captions_input,
+        parsed: captions_input,
+        format: "user-provided"
+      })
+    )
+    |> Multi.run(
+      :action,
+      fn _repo, %{caption: caption} ->
+        CF.Actions.ActionCreator.action_upload_video_captions(user.id, video.id, caption)
+        |> DB.Repo.insert!()
+
+        {:ok, caption}
+      end
+    )
+
+    {:ok, video}
   end
 end

apps/cf_graphql/lib/schema/input_objects.ex

@@ -3,6 +3,7 @@ defmodule CF.Graphql.Schema.InputObjects do
 
   import_types(CF.Graphql.Schema.InputObjects.{
     VideoFilter,
-    StatementFilter
+    StatementFilter,
+    VideoCaption
   })
 end

apps/cf_graphql/lib/schema/input_objects/video_caption.ex

@@ -0,0 +1,10 @@
+defmodule CF.Graphql.Schema.InputObjects.VideoCaption do
+  use Absinthe.Schema.Notation
+  use Absinthe.Ecto, repo: DB.Repo
+
+  input_object :video_caption_input do
+    field(:text, non_null(:string))
+    field(:start, non_null(:float))
+    field(:duration, :float)
+  end
+end

apps/cf_graphql/lib/schema/schema.ex

@@ -109,6 +109,16 @@ defmodule CF.Graphql.Schema do
       arg(:unlisted, non_null(:boolean))
 
       resolve(&Resolvers.Videos.edit/3)
-    end
+         end
+
+    field :set_video_captions, :video do
+      middleware(Middleware.RequireAuthentication)
+      middleware(Middleware.RequireReputation, 450)
+
+      arg(:video_id, non_null(:id))
+      arg(:captions, non_null(list_of(:video_caption_input)))
+
+      resolve(&Resolvers.Videos.set_captions/3)
+
   end
 end

apps/cf_jobs/config/config.exs

@@ -38,11 +38,9 @@ config :cf_jobs, CF.Jobs.Scheduler,
       schedule: {:extended, "*/5"},
       task: {CF.Jobs.CreateNotifications, :update, []},
       overlap: false
-    ]
     # Captions
     # download_captions: [
-    #   # every minute
-    #   schedule: "*/1 * * * *",
+    #   schedule: "@daily",
     #   task: {CF.Jobs.DownloadCaptions, :update, []},
     #   overlap: false
     # ]