self-hosted/algora-tv
1
0
Fork 0
mirror of https://github.com/algora-io/tv.git synced 2024-11-26 01:00:20 +02:00
Code Releases Activity

cleanup unused vars and deps

Browse Source
This commit is contained in:
ty 2024-10-27 21:13:13 -04:00
parent cc6f282c37
commit 297bbcfeb2
3 changed files with 6 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
lib/algora/admin.ex
View File

@ -126,7 +126,7 @@ defmodule Algora.Admin do
{item, count}
end)
{example_stream, _} = streams |> Enum.find(&match?(manifest_name, elem(&1, 0).uri))
{example_stream, _} = streams |> Enum.find(&match?(^manifest_name, elem(&1, 0).uri))
if Enum.all?(streams, fn {x, _} -> example_stream.resolution == x.resolution && example_stream.codecs == x.codecs end) do
max_bandwidth = Enum.map(streams, fn {stream, _} -> Map.get(stream, :bandwidth) end) |> Enum.max(&Ratio.gte?/2)
@ -273,7 +273,7 @@ defmodule Algora.Admin do
|> send(:multicast_algora)
end
def download_chunks(video, chunks, dir) do
def download_chunks(chunks, dir) do
Task.async_stream(
Enum.with_index(chunks),
fn {chunk, i} ->
@ -309,7 +309,7 @@ defmodule Algora.Admin do
Map.has_key?(n, :uri),
do: n.uri
{time, _} = :timer.tc(&download_chunks/3, [video, video_chunks ++ audio_chunks, dir])
{time, _} = :timer.tc(&download_chunks/2, [video_chunks ++ audio_chunks, dir])
video_chunks
|> Enum.map(fn chunk -> "#{dir}/#{chunk}" end)

7
lib/algora/pipeline.ex
View File

@ -14,7 +14,6 @@ defmodule Algora.Pipeline do
@app "live"
@terminate_after 60_000 * 60
@reconnect_inactivity_timeout 12_000
@frame_devisor 1
defstruct [
client_ref: nil,
@ -42,7 +41,7 @@ defmodule Algora.Pipeline do
video_uuid: nil
}
{:ok, pid} = with true <- Algora.config([:resume_rtmp]),
{:ok, _pid} = with true <- Algora.config([:resume_rtmp]),
{pid, metadata} when is_pid(pid) <- :syn.lookup(:pipelines, stream_key) do
Algora.Pipeline.resume_rtmp(pid, %{ params | video_uuid: metadata[:video_uuid] })
{:ok, pid}
@ -154,7 +153,7 @@ defmodule Algora.Pipeline do
{[], %{ state | waiting_activity: false }}
end
def handle_child_notification({:track_activity, track}, _element, _ctx, state) do
def handle_child_notification({:track_activity, _track}, _element, _ctx, state) do
{[], state}
end
@ -215,7 +214,7 @@ defmodule Algora.Pipeline do
}
end
def handle_info(:link_tracks, _ctx, %{reconnect: reconnect} = state) do
def handle_info(:link_tracks, _ctx, state) do
spec = [
#
get_child(:tee_video)

5
mix.exs
View File

@ -60,11 +60,6 @@ defmodule Algora.MixProject do
{:membrane_http_adaptive_stream_plugin, "~> 0.18.5"},
{:membrane_rtmp_plugin, "~> 0.26.0"},
{:membrane_tee_plugin, "~> 0.12.0"},
{:membrane_file_plugin, "~> 0.17.2"},
{:membrane_mp4_plugin, "~> 0.35.2"},
{:membrane_funnel_plugin, "~> 0.9.1"},
{:membrane_framerate_converter_plugin, "~> 0.8.2"},
{:membrane_ffmpeg_swscale_plugin, "~> 0.15.1"},
{:syn, "~> 3.3"},
{:mint, "~> 1.0"},
{:oban, "~> 2.16"},