eminuxandCursor
841a6a15be
Così un CPX nuovo non richiede worker Docker a mano, l'agent è nel cloud-init e gli E2E restano non in elenco. Co-authored-by: Cursor <cursoragent@cursor.com>
55 lines
1.7 KiB
Ruby
55 lines
1.7 KiB
Ruby
# frozen_string_literal: true
|
|
|
|
# Nodo streaming (MediaMTX [+ relay ffmpeg]). Fase 0: registry + assignment URL.
|
|
class StreamNode < ApplicationRecord
|
|
ROLES = %w[home cloud lab].freeze
|
|
STATUSES = %w[provisioning ready draining offline error].freeze
|
|
PROVIDERS = %w[local proxmox_lab hetzner].freeze
|
|
|
|
has_many :stream_sessions, dependent: :nullify
|
|
|
|
validates :slug, presence: true, uniqueness: true
|
|
validates :hostname, presence: true
|
|
validates :role, inclusion: { in: ROLES }
|
|
validates :status, inclusion: { in: STATUSES }
|
|
validates :provider, inclusion: { in: PROVIDERS }
|
|
validates :rtmp_base_url, :hls_base_url, :api_base_url, presence: true
|
|
validates :max_publishers, :max_relays, numericality: { greater_than: 0 }
|
|
|
|
scope :ready, -> { where(status: "ready") }
|
|
scope :allocatable, -> { ready }
|
|
|
|
# Sessioni che occupano uno slot path MediaMTX su questo nodo.
|
|
def occupying_sessions
|
|
stream_sessions.where(status: %w[idle connecting live reconnecting paused])
|
|
end
|
|
|
|
def active_publishers
|
|
occupying_sessions.count
|
|
end
|
|
|
|
def free_slots
|
|
[max_publishers - active_publishers, 0].max
|
|
end
|
|
|
|
def allocatable?
|
|
status == "ready" && free_slots.positive?
|
|
end
|
|
|
|
# Agent ffmpeg sul CPX (cloud-init :9100). Home Sidekiq lo chiama senza worker Docker per nodo.
|
|
def relay_agent_url
|
|
return unless role == "cloud"
|
|
|
|
ip = (metadata || {})["public_ip"].presence
|
|
if ip.blank?
|
|
host = URI.parse(api_base_url.to_s).host
|
|
ip = host if host.present? && host != "localhost"
|
|
end
|
|
return if ip.blank? || ip == "127.0.0.1"
|
|
|
|
"http://#{ip}:#{ENV.fetch("STREAM_NODE_AGENT_PORT", "9100")}"
|
|
rescue URI::InvalidURIError
|
|
nil
|
|
end
|
|
end
|