mirror of
https://github.com/algora-io/tv.git
synced 2024-11-16 00:58:59 +02:00
added livestream clipping feature (#111)
This commit is contained in:
urbit-pilled
GitHub
parent
67059c630d
commit
a881fcd18c
@ -183,6 +183,8 @@ const Hooks = {
|
||||
player_type: string;
|
||||
current_time: number;
|
||||
channel_name: string;
|
||||
clip_start_time: number | undefined;
|
||||
clip_end_time: number | undefined;
|
||||
}) => {
|
||||
if (this.playerId !== opts.player_id) {
|
||||
return;
|
||||
@ -233,6 +235,14 @@ const Hooks = {
|
||||
this.player.streamType = opts.is_live ? "ll-live:dvr" : "on-demand";
|
||||
this.player.src = opts.url;
|
||||
|
||||
if (typeof(opts.clip_end_time) === "number"){
|
||||
this.player.clipEndTime = opts.clip_end_time;
|
||||
}
|
||||
if (typeof(opts.clip_start_time) === "number"){
|
||||
this.player.clipStartTime = opts.clip_start_time;
|
||||
this.player.play();
|
||||
}
|
||||
|
||||
this.player.addEventListener("provider-change", (event) => {
|
||||
const provider = event.detail;
|
||||
if (isHLSProvider(provider)) {
|
||||
|
||||
@ -85,4 +85,62 @@ defmodule Algora.Clipper do
|
||||
|
||||
"ffmpeg -i \"#{url}\" -ss #{ss} -t #{to - from} \"#{filename}.mp4\""
|
||||
end
|
||||
|
||||
def create_combined_local_clips(video, clips_params) do
|
||||
# Generate a unique filename for the combined clip
|
||||
filename = generate_combined_clip_filename(video, clips_params)
|
||||
output_path = Path.join(System.tmp_dir(), "#{filename}.mp4")
|
||||
|
||||
# Create a temporary file for the complex filter
|
||||
filter_path = Path.join(System.tmp_dir(), "#{filename}_filter.txt")
|
||||
File.write!(filter_path, create_filter_complex(clips_params))
|
||||
|
||||
# Construct the FFmpeg command
|
||||
ffmpeg_cmd = [
|
||||
"-y",
|
||||
"-i", video.url,
|
||||
"-filter_complex_script", filter_path,
|
||||
"-map", "[v]",
|
||||
"-map", "[a]",
|
||||
"-c:v", "libx264",
|
||||
"-c:a", "aac",
|
||||
output_path
|
||||
]
|
||||
|
||||
# Execute the FFmpeg command
|
||||
case System.cmd("ffmpeg", ffmpeg_cmd, stderr_to_stdout: true) do
|
||||
{_, 0} ->
|
||||
File.rm(filter_path)
|
||||
{:ok, output_path}
|
||||
{error, _} ->
|
||||
File.rm(filter_path)
|
||||
{:error, "FFmpeg error: #{error}"}
|
||||
end
|
||||
end
|
||||
|
||||
defp generate_combined_clip_filename(video, clips_params) do
|
||||
clip_count = map_size(clips_params)
|
||||
total_duration = Enum.sum(Enum.map(clips_params, fn {_, clip} ->
|
||||
Library.from_hhmmss(clip["clip_to"]) - Library.from_hhmmss(clip["clip_from"])
|
||||
end))
|
||||
Slug.slugify("#{video.title}-#{clip_count}clips-#{total_duration}s")
|
||||
end
|
||||
|
||||
defp create_filter_complex(clips_params) do
|
||||
{filter_complex, _} = clips_params
|
||||
|> Enum.sort_by(fn {key, _} -> key end)
|
||||
|> Enum.reduce({"", 0}, fn {_, clip}, {acc, index} ->
|
||||
from = Library.from_hhmmss(clip["clip_from"])
|
||||
to = Library.from_hhmmss(clip["clip_to"])
|
||||
clip_filter = "[0:v]trim=start=#{from}:end=#{to},setpts=PTS-STARTPTS[v#{index}]; " <>
|
||||
"[0:a]atrim=start=#{from}:end=#{to},asetpts=PTS-STARTPTS[a#{index}];\n"
|
||||
{acc <> clip_filter, index + 1}
|
||||
end)
|
||||
|
||||
clip_count = map_size(clips_params)
|
||||
video_concat = Enum.map_join(0..clip_count-1, "", fn i -> "[v#{i}]" end) <> "concat=n=#{clip_count}:v=1:a=0[v];\n"
|
||||
audio_concat = Enum.map_join(0..clip_count-1, "", fn i -> "[a#{i}]" end) <> "concat=n=#{clip_count}:v=0:a=1[a]"
|
||||
|
||||
filter_complex <> video_concat <> audio_concat
|
||||
end
|
||||
end
|
||||
|
||||
@ -7,7 +7,7 @@ defmodule Algora.Library do
|
||||
import Ecto.Query, warn: false
|
||||
import Ecto.Changeset
|
||||
alias Algora.Accounts.User
|
||||
alias Algora.{Repo, Accounts, Storage, Cache, ML}
|
||||
alias Algora.{Repo, Accounts, Storage, Cache, ML, Admin}
|
||||
alias Algora.Library.{Channel, Video, VideoThumbnail, Events, Subtitle, Segment}
|
||||
|
||||
@pubsub Algora.PubSub
|
||||
@ -62,7 +62,7 @@ defmodule Algora.Library do
|
||||
|> change()
|
||||
|> Video.put_video_meta(:vod, :mp4, basename)
|
||||
|
||||
dir = Path.join("/data", video.changes.uuid)
|
||||
dir = Path.join(Admin.tmp_dir(), video.changes.uuid)
|
||||
File.mkdir_p!(dir)
|
||||
local_path = Path.join(dir, video.changes.filename)
|
||||
File.cp!(tmp_path, local_path)
|
||||
@ -92,7 +92,7 @@ defmodule Algora.Library do
|
||||
|
||||
%{uuid: mp4_uuid, filename: mp4_filename, remote_path: mp4_remote_path} = mp4_video.changes
|
||||
|
||||
dir = Path.join("/data", mp4_uuid)
|
||||
dir = Path.join(Admin.tmp_dir(), mp4_uuid)
|
||||
File.mkdir_p!(dir)
|
||||
mp4_local_path = Path.join(dir, mp4_filename)
|
||||
|
||||
@ -117,20 +117,24 @@ defmodule Algora.Library do
|
||||
|
||||
hls_video =
|
||||
%Video{
|
||||
id: video.id,
|
||||
title: video.title,
|
||||
duration: duration,
|
||||
type: :vod,
|
||||
format: :hls,
|
||||
is_live: false,
|
||||
visibility: video.visibility,
|
||||
user_id: video.user_id
|
||||
user_id: video.user_id,
|
||||
channel_handle: video.channel_handle,
|
||||
channel_name: video.channel_name,
|
||||
description: video.description
|
||||
}
|
||||
|> change()
|
||||
|> Video.put_video_url(:vod, :hls)
|
||||
|
||||
%{uuid: hls_uuid, filename: hls_filename} = hls_video.changes
|
||||
|
||||
dir = Path.join("/data", hls_uuid)
|
||||
dir = Path.join(Admin.tmp_dir(), hls_uuid)
|
||||
File.mkdir_p!(dir)
|
||||
hls_local_path = Path.join(dir, hls_filename)
|
||||
|
||||
@ -166,6 +170,7 @@ defmodule Algora.Library do
|
||||
)
|
||||
end)
|
||||
|
||||
Repo.delete!(video)
|
||||
hls_video = Repo.insert!(hls_video)
|
||||
|
||||
cb.(%{stage: :generating_thumbnail, done: 1, total: 1})
|
||||
@ -175,12 +180,7 @@ defmodule Algora.Library do
|
||||
# requests from user?
|
||||
File.rm!(video.local_path)
|
||||
|
||||
Repo.delete!(video)
|
||||
|
||||
hls_video
|
||||
|> change()
|
||||
|> put_change(:id, video.id)
|
||||
|> Repo.update!()
|
||||
end
|
||||
|
||||
def get_latest_video(%User{} = user) do
|
||||
|
||||
@ -44,11 +44,13 @@ defmodule AlgoraWeb.PlayerComponent do
|
||||
player_id: assigns.id,
|
||||
id: video.id,
|
||||
url: video.url,
|
||||
title: video.title,
|
||||
title: assigns[:title] || video.title,
|
||||
poster: video.thumbnail_url,
|
||||
player_type: Library.player_type(video),
|
||||
channel_name: video.channel_name,
|
||||
current_time: assigns[:current_time] || 0
|
||||
current_time: assigns[:current_time] || 0,
|
||||
clip_start_time: assigns[:clip_start_time] || assigns[:current_time] || 0,
|
||||
clip_end_time: assigns[:end_time]
|
||||
})
|
||||
end
|
||||
|
||||
|
||||
418
lib/algora_web/live/video_clipper_live.ex
Normal file
418
lib/algora_web/live/video_clipper_live.ex
Normal file
@ -0,0 +1,418 @@
|
||||
defmodule AlgoraWeb.VideoClipperLive do
|
||||
use AlgoraWeb, :live_view
|
||||
alias Algora.{Repo, Admin, Library, Clipper}
|
||||
alias Algora.Library.Video
|
||||
alias AlgoraWeb.PlayerComponent
|
||||
require Logger
|
||||
|
||||
@impl true
|
||||
def render(assigns) do
|
||||
~H"""
|
||||
<div class="min-h-[90vh]">
|
||||
<div class="max-w-6xl mx-auto pt-2 pb-6 px-4 sm:px-6 space-y-6">
|
||||
<h1 class="text-lg font-semibold leading-8 text-gray-100 focus:outline-none">Clip editor</h1>
|
||||
<.simple_form for={@form} phx-change="update_form" phx-submit="create_video">
|
||||
<div class="grid grid-cols-1 md:grid-cols-2 gap-6">
|
||||
<div class="space-y-4">
|
||||
<div class="relative">
|
||||
<.input
|
||||
field={@form[:livestream_id]}
|
||||
type="select"
|
||||
options={Enum.map(@livestreams, &{&1.title, &1.id})}
|
||||
value={@selected_livestream && @selected_livestream.id}
|
||||
prompt="Select livestream"
|
||||
class="w-full bg-white/5 border border-white/15 rounded p-2 appearance-none"
|
||||
/>
|
||||
<.error :for={error <- @form[:livestream_id].errors}>
|
||||
<%=error %>
|
||||
</.error>
|
||||
</div>
|
||||
<div class="aspect-video bg-white/5 rounded flex items-center justify-center">
|
||||
<%= if @selected_livestream do %>
|
||||
<div id="preview-player-container" phx-update="ignore">
|
||||
<.live_component
|
||||
module={PlayerComponent}
|
||||
id="preview-player"
|
||||
video={@selected_livestream}
|
||||
current_time={@preview_clip && @preview_clip.start || 0}
|
||||
end_time={@preview_clip && @preview_clip.end || nil}
|
||||
current_user={@current_user}
|
||||
/>
|
||||
</div>
|
||||
<% else %>
|
||||
<Heroicons.play solid class="w-16 h-16" />
|
||||
<% end %>
|
||||
</div>
|
||||
<.input field={@form[:title]} type="text" label="Title" class="w-full bg-white/5 border border-white/15 rounded p-2" />
|
||||
<.input field={@form[:description]} type="textarea" label="Description" class="w-full bg-white/5 border border-white/15 rounded p-2 h-24" />
|
||||
</div>
|
||||
<div class="space-y-4 max-h-[calc(100vh-16rem)] overflow-y-auto p-2">
|
||||
<%= for {clip, index} <- Enum.with_index(@clips) do %>
|
||||
<div class="bg-white/5 rounded-lg p-4 space-y-2 ring-1 ring-white/15 relative">
|
||||
<div class="flex justify-between items-center">
|
||||
<h3 class="font-semibold">Clip <%= index + 1 %></h3>
|
||||
<button type="button" phx-click="clip_action" phx-value-action="remove"phx-value-index={index} class="absolute top-2 right-2 text-gray-400 hover:text-gray-200">
|
||||
<Heroicons.x_mark solid class="w-5 h-5" />
|
||||
</button>
|
||||
</div>
|
||||
<div class="grid grid-cols-2 gap-2">
|
||||
<div>
|
||||
<label class="block text-xs mb-1">From</label>
|
||||
<.input type="text" name={"video_clipper[clips][#{index}][clip_from]"} value={clip.clip_from} class="w-full bg-white/5 border border-white/15 rounded p-1 text-sm" phx-debounce="300" />
|
||||
<%= for error <- (clip.errors[:clip_from] || []) do %>
|
||||
<.error><%= error %></.error>
|
||||
<% end %>
|
||||
</div>
|
||||
<div>
|
||||
<label class="block text-xs mb-1">To</label>
|
||||
<.input type="text" name={"video_clipper[clips][#{index}][clip_to]"} value={clip.clip_to} class="w-full bg-white/5 border border-white/15 rounded p-1 text-sm" phx-debounce="300" />
|
||||
<%= for error <- (clip.errors[:clip_to] || []) do %>
|
||||
<.error><%= error %></.error>
|
||||
<% end %>
|
||||
</div>
|
||||
</div>
|
||||
<div class="flex py-2 space-x-2">
|
||||
<.button type="button" phx-click="preview_clip" phx-value-index={index} class="flex-grow" disabled={clip.errors != %{}}>Preview Clip <%= index + 1 %></.button>
|
||||
<div class="flex gap-2">
|
||||
<.button type="button" phx-click="clip_action" phx-value-action="move_up"phx-value-index={index}>
|
||||
<Heroicons.chevron_up solid class="w-4 h-4" />
|
||||
</.button>
|
||||
<.button type="button" phx-click="clip_action" phx-value-action="move_down" phx-value-index={index}>
|
||||
<Heroicons.chevron_down solid class="w-4 h-4" />
|
||||
</.button>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
<% end %>
|
||||
<.button type="button" phx-click="clip_action" phx-value-action="add" phx-value-index={-1} class="w-full">+ Add new clip</.button>
|
||||
</div>
|
||||
</div>
|
||||
<:actions>
|
||||
<div class="w-full">
|
||||
<.button type="submit" disabled={@processing} class="w-full rounded-xl p-3 font-semibold">
|
||||
<%= if @processing, do: "Creating video..", else: "Create video" %>
|
||||
</.button>
|
||||
|
||||
<%= if @processing do %>
|
||||
<div class="mt-4 text-center text-sm text-gray-400">
|
||||
<%= @progress.stage %> (<%= @progress.current %>/<%= @progress.total %>)
|
||||
</div>
|
||||
<div class="w-full bg-white/5 rounded-full h-2.5 mt-2">
|
||||
<div class="bg-blue-600 h-2.5 rounded-full" style={"width: #{@progress.current / @progress.total * 100}%"}></div>
|
||||
</div>
|
||||
<% end %>
|
||||
</div>
|
||||
</:actions>
|
||||
</.simple_form>
|
||||
</div>
|
||||
</div>
|
||||
"""
|
||||
end
|
||||
|
||||
@impl true
|
||||
def mount(_params, _session, socket) do
|
||||
channel = Library.get_channel!(socket.assigns.current_user)
|
||||
livestreams = Library.list_channel_videos(channel)
|
||||
changeset = change_video_clipper()
|
||||
default_video = List.first(livestreams)
|
||||
|
||||
update_player(socket, default_video, 0)
|
||||
|
||||
{:ok,
|
||||
socket
|
||||
|> assign(
|
||||
livestreams: livestreams,
|
||||
selected_livestream: default_video,
|
||||
clips: [%{clip_from: "", clip_to: "", errors: %{}}],
|
||||
processing: false,
|
||||
progress: %{stage: nil, current: 0, total: 0},
|
||||
preview_clip: nil
|
||||
)
|
||||
|> assign_form(changeset)}
|
||||
end
|
||||
|
||||
def handle_event("update_form", %{"video_clipper" => params}, socket) do
|
||||
|
||||
socket = if params["livestream_id"] && params["livestream_id"] != to_string(socket.assigns.selected_livestream.id) do
|
||||
new_livestream = Enum.find(socket.assigns.livestreams, &(&1.id == String.to_integer(params["livestream_id"])))
|
||||
|
||||
if new_livestream do
|
||||
send_update(PlayerComponent,
|
||||
id: "preview-player",
|
||||
video: new_livestream,
|
||||
current_time: 0,
|
||||
end_time: nil,
|
||||
current_user: socket.assigns.current_user
|
||||
)
|
||||
|
||||
socket
|
||||
|> assign(selected_livestream: new_livestream)
|
||||
|> assign(preview_clip: nil)
|
||||
|> assign(clips: []) # Clear the clips
|
||||
else
|
||||
socket
|
||||
end
|
||||
else
|
||||
socket
|
||||
end
|
||||
|
||||
# Update clips only if the livestream hasn't changed
|
||||
updated_clips = if params["livestream_id"] == to_string(socket.assigns.selected_livestream.id) do
|
||||
update_clips_from_params(params["clips"] || %{})
|
||||
else
|
||||
[]
|
||||
end
|
||||
|
||||
changeset = params |> change_video_clipper() |> Map.put(:action, :validate)
|
||||
|
||||
socket = socket
|
||||
|> assign(clips: updated_clips)
|
||||
|> assign_form(changeset)
|
||||
|
||||
{:noreply, socket}
|
||||
end
|
||||
|
||||
defp update_clips_from_params(clips_params) do
|
||||
clips_params
|
||||
|> Enum.sort_by(fn {key, _} -> key end)
|
||||
|> Enum.map(fn {_, clip} ->
|
||||
errors = validate_clip_times(clip["clip_from"], clip["clip_to"])
|
||||
%{
|
||||
clip_from: clip["clip_from"] || "",
|
||||
clip_to: clip["clip_to"] || "",
|
||||
errors: errors
|
||||
}
|
||||
end)
|
||||
end
|
||||
|
||||
defp change_video_clipper(attrs \\ %{}) do
|
||||
types = %{
|
||||
livestream_id: :integer,
|
||||
title: :string,
|
||||
description: :string,
|
||||
clips: :map
|
||||
}
|
||||
|
||||
{%{}, types}
|
||||
|> Ecto.Changeset.cast(attrs, Map.keys(types))
|
||||
|> Ecto.Changeset.validate_required([:livestream_id, :title])
|
||||
|> Ecto.Changeset.validate_length(:title, min: 3, max: 100)
|
||||
|> Ecto.Changeset.validate_length(:description, max: 500)
|
||||
|> validate_clips()
|
||||
end
|
||||
|
||||
defp validate_clips(changeset) do
|
||||
clips = Ecto.Changeset.get_field(changeset, :clips) || %{}
|
||||
|
||||
errors = Enum.reduce(clips, [], fn {_index, clip}, acc ->
|
||||
case validate_clip_times(clip["clip_from"], clip["clip_to"]) do
|
||||
%{} -> acc
|
||||
errors -> [errors | acc]
|
||||
end
|
||||
end)
|
||||
|
||||
case errors do
|
||||
[] -> changeset
|
||||
_ -> Ecto.Changeset.add_error(changeset, :clips, "Invalid clips", errors: errors)
|
||||
end
|
||||
end
|
||||
|
||||
defp validate_clip_times(from, to) do
|
||||
case {parse_seconds(from), parse_seconds(to)} do
|
||||
{{:ok, from_seconds}, {:ok, to_seconds}} when from_seconds < to_seconds ->
|
||||
%{}
|
||||
{{:ok, _}, {:ok, _}} ->
|
||||
%{clip_to: ["End time must be after start time"]}
|
||||
{{:error, _}, _} ->
|
||||
%{clip_from: ["Invalid time. Use HH:MM:SS"]}
|
||||
{_, {:error, _}} ->
|
||||
%{clip_to: ["Invalid time. Use HH:MM:SS"]}
|
||||
end
|
||||
end
|
||||
|
||||
defp parse_seconds(time_string) do
|
||||
time_string
|
||||
|> String.split(":")
|
||||
|> Enum.map(&String.to_integer/1)
|
||||
|> case do
|
||||
[ss] -> {:ok, ss}
|
||||
[mm, ss] -> {:ok, mm * 60 + ss}
|
||||
[hh, mm, ss] -> {:ok, hh * 3600 + mm * 60 + ss}
|
||||
_ -> {:error, :invalid_format}
|
||||
end
|
||||
rescue
|
||||
_ -> {:error, :invalid_format}
|
||||
end
|
||||
|
||||
@impl true
|
||||
def handle_event("validate", %{"video_clipper" => params}, socket) do
|
||||
changeset =
|
||||
params
|
||||
|> change_video_clipper()
|
||||
|> Map.put(:action, :validate)
|
||||
|
||||
{:noreply, assign_form(socket, changeset)}
|
||||
end
|
||||
|
||||
@impl true
|
||||
def handle_event("clip_action", %{"action" => action, "index" => index}, socket) do
|
||||
index = String.to_integer(index)
|
||||
clips = socket.assigns.clips
|
||||
|
||||
updated_clips = case action do
|
||||
"add" -> clips ++ [%{clip_from: "", clip_to: "", errors: %{}}]
|
||||
"remove" -> List.delete_at(clips, index)
|
||||
"move_up" when index > 0 ->
|
||||
{clip, clips} = List.pop_at(clips, index)
|
||||
List.insert_at(clips, index - 1, clip)
|
||||
"move_down" when index < length(clips) - 1 ->
|
||||
{clip, clips} = List.pop_at(clips, index)
|
||||
List.insert_at(clips, index + 1, clip)
|
||||
_ -> clips
|
||||
end
|
||||
|
||||
{:noreply, assign(socket, clips: updated_clips)}
|
||||
end
|
||||
|
||||
@impl true
|
||||
def handle_event("preview_clip", %{"index" => index}, socket) do
|
||||
index = String.to_integer(index)
|
||||
clip = Enum.at(socket.assigns.clips, index)
|
||||
|
||||
if clip.errors == %{} && clip.clip_to != "" && clip.clip_from != "" do
|
||||
case {parse_seconds(clip.clip_from), parse_seconds(clip.clip_to)} do
|
||||
{{:ok, start}, {:ok, end_time}} when end_time > start ->
|
||||
video = socket.assigns.selected_livestream
|
||||
update_player(socket, video, start, end_time, "Previewing Clip #{index + 1}")
|
||||
{:noreply, assign(socket, preview_clip: %{start: start, end: end_time})}
|
||||
_ ->
|
||||
{:noreply, put_flash(socket, :error, "An unexpected error occurred while previewing the clip")}
|
||||
end
|
||||
else
|
||||
{:noreply, put_flash(socket, :error, "Cannot preview an invalid clip")}
|
||||
end
|
||||
end
|
||||
|
||||
@impl true
|
||||
def handle_info({:progress_update, progress}, socket) do
|
||||
{:noreply, assign(socket, processing: true, progress: progress)}
|
||||
end
|
||||
|
||||
@impl true
|
||||
def handle_info({:processing_complete, video}, socket) do
|
||||
{:noreply, socket
|
||||
|> put_flash(:info, "Video created successfully!")
|
||||
|> assign(processing: false, progress: nil)
|
||||
|> push_redirect(to: ~p"/#{video.channel_handle}/#{video.id}")}
|
||||
end
|
||||
|
||||
@impl true
|
||||
def handle_event("create_video", %{"video_clipper" => params}, socket) do
|
||||
changeset = params |> change_video_clipper() |> Map.put(:action, :validate)
|
||||
|
||||
if changeset.valid? do
|
||||
# Set initial processing state
|
||||
socket = assign(socket,
|
||||
processing: true,
|
||||
progress: %{stage: "Initializing", current: 0, total: 100}
|
||||
)
|
||||
|
||||
# Start the video creation process in a separate process
|
||||
lv = self() # capture the LiveView PID
|
||||
Task.start(fn ->
|
||||
case create_video(params, socket, lv) do
|
||||
{:ok, video} -> send(lv, {:processing_complete, video})
|
||||
{:error, reason} -> send(lv, {:processing_error, reason})
|
||||
end
|
||||
end)
|
||||
|
||||
{:noreply, socket}
|
||||
else
|
||||
{:noreply, assign_form(socket, changeset)}
|
||||
end
|
||||
end
|
||||
|
||||
defp create_video(params, socket, lv) do
|
||||
clips = params["clips"] || %{}
|
||||
video = socket.assigns.selected_livestream
|
||||
current_user = socket.assigns.current_user
|
||||
|
||||
# Check for clip errors
|
||||
clip_errors = clips
|
||||
|> update_clips_from_params()
|
||||
|> Enum.flat_map(fn clip -> Map.to_list(clip.errors) end)
|
||||
|
||||
if Enum.empty?(clip_errors) do
|
||||
# Send initial progress update
|
||||
send(lv, {:progress_update, %{stage: "Initializing", current: 0, total: 6}})
|
||||
|
||||
case Clipper.create_combined_local_clips(video, clips) do
|
||||
{:ok, combined_clip_path} ->
|
||||
send(lv, {:progress_update, %{stage: "Creating combined clip", current: 1, total: 6}})
|
||||
|
||||
upload_entry = %Phoenix.LiveView.UploadEntry{
|
||||
client_name: Path.basename(combined_clip_path),
|
||||
client_size: File.stat!(combined_clip_path).size,
|
||||
client_type: "video/mp4"
|
||||
}
|
||||
|
||||
send(lv, {:progress_update, %{stage: "Initializing video", current: 2, total: 6}})
|
||||
new_video = Library.init_mp4!(upload_entry, combined_clip_path, current_user)
|
||||
|
||||
send(lv, {:progress_update, %{stage: "Updating video", current: 3, total: 6}})
|
||||
{:ok, updated_video} = Library.update_video(new_video, %{
|
||||
title: params["title"] || "New Video",
|
||||
description: params["description"],
|
||||
visibility: :unlisted
|
||||
})
|
||||
|
||||
# Handle transmux progress updates with all three stages
|
||||
processed_video = Library.transmux_to_hls(updated_video, fn progress_info ->
|
||||
progress = case progress_info do
|
||||
%{stage: :transmuxing, done: done, total: total} ->
|
||||
# Transmuxing is stage 4
|
||||
current = 3 + (done / total)
|
||||
%{stage: "Transmuxing", current: trunc(current), total: 6}
|
||||
|
||||
%{stage: :persisting, done: done, total: total} ->
|
||||
# Persisting is stage 5
|
||||
current = 4 + (done / total)
|
||||
%{stage: "Persisting", current: trunc(current), total: 6}
|
||||
|
||||
%{stage: :generating_thumbnail, done: done, total: total} ->
|
||||
# Generating thumbnail is stage 6
|
||||
current = 5 + (done / total)
|
||||
%{stage: "Generating thumbnail", current: trunc(current), total: 6}
|
||||
end
|
||||
send(lv, {:progress_update, progress})
|
||||
end)
|
||||
|
||||
# Clean up temporary file
|
||||
File.rm(combined_clip_path)
|
||||
|
||||
{:ok, processed_video}
|
||||
|
||||
{:error, reason} ->
|
||||
{:error, reason}
|
||||
end
|
||||
else
|
||||
error_messages = Enum.join(clip_errors, ", ")
|
||||
{:error, error_messages}
|
||||
end
|
||||
end
|
||||
|
||||
defp assign_form(socket, %Ecto.Changeset{} = changeset) do
|
||||
assign(socket, :form, to_form(changeset, as: "video_clipper"))
|
||||
end
|
||||
|
||||
defp update_player(socket, video, current_time, end_time \\ nil, title \\ nil) do
|
||||
send_update(PlayerComponent,
|
||||
id: "preview-player",
|
||||
video: video,
|
||||
current_time: current_time,
|
||||
end_time: end_time,
|
||||
title: title,
|
||||
current_user: socket.assigns.current_user
|
||||
)
|
||||
end
|
||||
end
|
||||
@ -140,6 +140,7 @@ defmodule AlgoraWeb.Router do
|
||||
live "/channel/settings", SettingsLive, :edit
|
||||
live "/channel/studio", StudioLive, :show
|
||||
live "/channel/studio/upload", StudioLive, :upload
|
||||
live "/channel/studio/clip", VideoClipperLive, :index
|
||||
live "/channel/audience", AudienceLive, :show
|
||||
live "/:channel_handle/stream", ChannelLive, :stream
|
||||
|
||||
|
||||
Loading…
Reference in New Issue
Block a user