Skip queueing next/prev link when there was none

server/lib/orcasite/radio/workers/link_feed_stream.ex

@@ -2,6 +2,10 @@ defmodule Orcasite.Radio.Workers.LinkFeedStream do
   use Oban.Worker, queue: :feeds, unique: [keys: [:feed_stream_id], period: 10]
 
   @impl Oban.Worker
+  def perform(%Oban.Job{args: %{"feed_stream_id" => nil} = args}) do
+    :ok
+  end
+
   def perform(%Oban.Job{args: %{"feed_stream_id" => feed_stream_id} = args}) do
     enqueue_prev_stream = Map.get(args, "enqueue_prev_stream", false)
     enqueue_next_stream = Map.get(args, "enqueue_next_stream", false)
@@ -17,7 +21,8 @@ defmodule Orcasite.Radio.Workers.LinkFeedStream do
     |> Ash.Changeset.for_update(:link_next_stream)
     |> Orcasite.Radio.update()
     |> case do
-      {:ok, %{next_feed_stream_id: next_feed_stream_id} = fs} ->
+      {:ok, %{next_feed_stream_id: next_feed_stream_id} = fs}
+      when not is_nil(next_feed_stream_id) ->
         fs
         |> Ash.Changeset.for_update(:update_end_time_and_duration)
         |> Orcasite.Radio.update()
@@ -40,7 +45,7 @@ defmodule Orcasite.Radio.Workers.LinkFeedStream do
     |> Ash.Changeset.for_update(:link_prev_stream)
     |> Orcasite.Radio.update()
     |> case do
-      {:ok, %{prev_feed_stream_id: prev_feed_stream_id}} ->
+      {:ok, %{prev_feed_stream_id: prev_feed_stream_id}} when not is_nil(prev_feed_stream_id) ->
         # If new link to previous stream, queue another link job
         if enqueue_prev_stream and prev_depth > 0 do
           %{