Create populate function for past feed_streams

server/lib/orcasite/global_setup.ex

@@ -0,0 +1,14 @@
+defmodule Orcasite.GlobalSetup do
+  def populate_feed_streams do
+    Orcasite.Radio.Feed
+    |> Ash.Query.for_read(:read)
+    |> Orcasite.Radio.read!()
+    |> Enum.map(fn feed ->
+      with {:ok, %{timestamps: timestamps}} <- Orcasite.Radio.AwsClient.list_timestamps(feed) do
+        timestamps
+        |> Enum.map(&%{feed: feed, playlist_timestamp: &1})
+        |> Orcasite.Radio.bulk_create(Orcasite.Radio.FeedStream, :create)
+      end
+    end)
+  end
+end

server/lib/orcasite/radio/feed_stream.ex

@@ -165,6 +165,15 @@ defmodule Orcasite.Radio.FeedStream do
       primary? true
       upsert? true
       upsert_identity :feed_stream_timestamp
+      upsert_fields [
+        :start_time,
+        :end_time,
+        :duration,
+        :bucket,
+        :bucket_region,
+        :cloudfront_url,
+        :playlist_timestamp
+      ]
 
       accept [
         :start_time,