eminuxandCursor
5a0ca8ef1c
Senza volume stream-node i nodi Hetzner nascevano senza MediaMTX; sync live usa ora Client.for_session e rtmpconns (MediaMTX 1.20). Co-authored-by: Cursor <cursoragent@cursor.com>
60 lines
1.5 KiB
Ruby
60 lines
1.5 KiB
Ruby
module Mediamtx
|
|
# Telefono connesso al path RTMP (non solo slate alwaysAvailable).
|
|
module PublisherOnline
|
|
module_function
|
|
|
|
def active?(session)
|
|
return true if rtmp_publisher?(session)
|
|
|
|
active_path?(path_info(session))
|
|
end
|
|
|
|
def path_info(session)
|
|
Client.for_session(session).list_paths.find { |i| i["name"] == session.mediamtx_path_name }
|
|
end
|
|
|
|
# MediaMTX <=1.19: online + source.type=rtmpConn.
|
|
# MediaMTX 1.20+: online/source spesso null anche con publisher; usare rtmpconns.
|
|
def active_path?(info)
|
|
return false unless info
|
|
return true if info["online"] == true && rtmp_source?(info.dig("source", "type"))
|
|
|
|
false
|
|
end
|
|
|
|
def rtmp_publisher?(session)
|
|
path = session.mediamtx_path_name.to_s
|
|
return false if path.blank?
|
|
|
|
Client.for_session(session).list_rtmp_conns.any? do |conn|
|
|
conn_path = conn["path"].to_s.sub(%r{\A/}, "")
|
|
next false unless conn_path == path
|
|
|
|
state = conn["state"].to_s
|
|
state.empty? || state == "publish" || state == "idle"
|
|
end
|
|
rescue StandardError
|
|
false
|
|
end
|
|
|
|
def h264_video?(info)
|
|
return false unless info
|
|
|
|
(info["tracks2"] || []).any? do |track|
|
|
track["codec"] == "H264" && track.dig("codecProps", "width").to_i.positive?
|
|
end
|
|
end
|
|
|
|
def video_publishing?(session)
|
|
return false unless active?(session)
|
|
|
|
info = path_info(session)
|
|
h264_video?(info)
|
|
end
|
|
|
|
def rtmp_source?(type)
|
|
type.to_s.match?(/\Artmps?Conn\z/)
|
|
end
|
|
end
|
|
end
|