Emiliano Frascaro
bba6df52c0
Rails API, app Flutter, infrastruttura Docker/MediaMTX, sito marketing e documentazione di deploy. Co-authored-by: Cursor <cursoragent@cursor.com>
51 lines
1.6 KiB
Ruby
51 lines
1.6 KiB
Ruby
namespace :streams do
|
|
desc "Termina sessioni attive non in onda su MediaMTX e rimuove path RTMP orfani"
|
|
task cleanup_stale: :environment do
|
|
client = Mediamtx::Client.new
|
|
online = client.online_path_names
|
|
stale = StreamSession.broadcasting.includes(match: :team).reject do |session|
|
|
online.include?(session.mediamtx_path_name)
|
|
end
|
|
|
|
puts "MediaMTX online: #{online.size}"
|
|
puts "Sessioni da chiudere: #{stale.size}"
|
|
|
|
stale.each do |session|
|
|
Sessions::Stop.new(session).call
|
|
puts " ended #{session.id} (#{session.match.team.name} vs #{session.match.opponent_name})"
|
|
rescue StandardError => e
|
|
session.finish! if session.may_finish?
|
|
client.delete_path(session) if session.mediamtx_path_name.present?
|
|
puts " ended #{session.id} (fallback: #{e.message})"
|
|
end
|
|
|
|
removed = cleanup_orphan_mediamtx_paths(client, online)
|
|
puts "Path MediaMTX rimossi: #{removed}"
|
|
puts "Fatto."
|
|
end
|
|
end
|
|
|
|
def cleanup_orphan_mediamtx_paths(client, online_paths)
|
|
removed = 0
|
|
|
|
client.list_paths.each do |item|
|
|
name = item["name"]
|
|
next unless name&.start_with?("match_")
|
|
|
|
session_id = name.delete_prefix("match_")
|
|
session = StreamSession.find_by(id: session_id)
|
|
should_remove = !online_paths.include?(name) &&
|
|
(session.nil? || %w[ended error].include?(session.status))
|
|
|
|
next unless should_remove
|
|
|
|
client.delete_path_name(name)
|
|
removed += 1
|
|
puts " deleted path #{name}"
|
|
rescue Mediamtx::Client::Error, Faraday::Error => e
|
|
puts " skip #{name}: #{e.message}"
|
|
end
|
|
|
|
removed
|
|
end
|