You've already forked algora-tv
							
							
				mirror of
				https://github.com/algora-io/tv.git
				synced 2025-10-30 23:07:56 +02:00 
			
		
		
		
	cleanup unused vars and deps
This commit is contained in:
		| @@ -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) | ||||
|   | ||||
| @@ -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
									
									
									
									
									
								
							
							
						
						
									
										5
									
								
								mix.exs
									
									
									
									
									
								
							| @@ -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"}, | ||||
|   | ||||
		Reference in New Issue
	
	Block a user