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,