Start on modeling

Author: cavis

app/models/stream_resource.rb

@@ -0,0 +1,46 @@
+class StreamResource < ApplicationRecord
+  BUFFER_SECONDS = 10
+
+  enum :status, %w[started created processing complete error retrying cancelled invalid].to_enum_h, prefix: true
+
+  belongs_to :stream_recording, -> { with_deleted }, touch: true, optional: true
+  has_one :podcast, through: :stream_recording
+  has_one :task, -> { order(id: :desc) }, as: :owner
+  has_many :tasks, as: :owner
+
+  validates :start_at, presence: true
+  validates :end_at, presence: true, comparison: {greater_than: :start_at}
+  validates :actual_start_at, presence: true
+  validates :actual_end_at, presence: true, comparison: {greater_than: :actual_start_at}
+  validates :original_url, presence: true
+
+  after_initialize :set_defaults
+  before_validation :set_defaults
+
+  acts_as_paranoid
+
+  # NOTE: called twice, because podcast won't be there on initialize
+  def set_defaults
+    set_default(:status, "created")
+    set_default(:guid, SecureRandom.uuid)
+    set_default(:url, published_url)
+  end
+
+  def file_name
+    File.basename(URI.parse(original_url).path) if original_url.present?
+  end
+
+  def published_path
+    "#{podcast.path}/#{stream_resource_path}" if podcast
+  end
+
+  def published_url
+    "#{podcast.base_published_url}/#{stream_resource_path}" if podcast
+  end
+
+  private
+
+  def stream_resource_path
+    "streams/#{guid}/#{file_name}"
+  end
+end

test/factories/stream_resource_factory.rb

@@ -0,0 +1,18 @@
+FactoryBot.define do
+  factory :stream_resource do
+    start_at { "2025-12-18T13:00:00Z" }
+    end_at { "2025-12-18T14:00:00Z" }
+    actual_start_at { "2025-12-18T12:59:50Z" }
+    actual_end_at { "2025-12-18T14:00:10Z" }
+
+    original_url { "s3://prx-testing/test/audio.mp3" }
+
+    status { "complete" }
+    mime_type { "audio/mpeg" }
+    file_size { 774059 }
+    bit_rate { 128 }
+    sample_rate { 44100 }
+    channels { 2 }
+    duration { 3620.0 }
+  end
+end

test/models/stream_resource_test.rb

@@ -0,0 +1,55 @@
+require "test_helper"
+
+describe StreamResource do
+  let(:podcast) { build_stubbed(:podcast) }
+  let(:resource) { build_stubbed(:stream_resource, podcast: podcast) }
+
+  describe "#set_defaults" do
+    it "sets unchanged defaults" do
+      res = StreamResource.new(podcast: podcast)
+      assert_equal "created", res.status
+      assert res.guid.present?
+      assert res.url.present?
+      refute res.changed?
+    end
+  end
+
+  describe "#file_name" do
+    it "parses the original url" do
+      assert_equal "audio.mp3", resource.file_name
+
+      resource.original_url = "http://some.where/the/file.name.here#and?other&stuff=1"
+      assert_equal "file.name.here", resource.file_name
+
+      resource.original_url = ""
+      assert_nil resource.file_name
+    end
+  end
+
+  describe "#published_path" do
+    it "includes the podcast prefix" do
+      assert_equal "#{podcast.id}/streams/#{resource.guid}/audio.mp3", resource.published_path
+    end
+  end
+
+  describe "#published_url" do
+    it "includes the podcast http url" do
+      assert_equal "https://f.prxu.org/#{resource.published_path}", resource.published_url
+    end
+
+    it "sets the url field" do
+      # NOTE: podcast is nil after_initialize
+      assert_nil resource.url
+
+      # but will be there before validation
+      assert resource.valid?
+      refute_nil resource.url
+      assert_equal resource.published_url, resource.url
+
+      resource.guid = "some-other-guid"
+      resource.original_url = "http://some/other.filename"
+      assert resource.valid?
+      refute_equal resource.published_url, resource.url
+    end
+  end
+end