Extend the test worker UI with auto-scheduling

Author: solnic

test_integrations/phoenix_app/lib/phoenix_app_web/live/test_worker_live.ex

@@ -8,6 +8,7 @@ defmodule PhoenixAppWeb.TestWorkerLive do
     socket =
       assign(socket,
         form: to_form(%{"sleep_time" => 1000, "should_fail" => false, "queue" => "default"}),
+        auto_form: to_form(%{"job_count" => 5}),
         jobs: list_jobs()
       )
 
@@ -25,11 +26,7 @@ defmodule PhoenixAppWeb.TestWorkerLive do
     should_fail = params["should_fail"] == "true"
     queue = params["queue"]
 
-    case TestWorker.new(
-           %{"sleep_time" => sleep_time, "should_fail" => should_fail},
-           queue: queue
-         )
-         |> Oban.insert() do
+    case schedule_job(sleep_time, should_fail, queue) do
       {:ok, _job} ->
         {:noreply,
          socket
@@ -43,11 +40,48 @@ defmodule PhoenixAppWeb.TestWorkerLive do
     end
   end
 
+  @impl true
+  def handle_event("auto_schedule", %{"auto" => %{"job_count" => count}}, socket) do
+    job_count = String.to_integer(count)
+
+    results =
+      Enum.map(1..job_count, fn _ ->
+        sleep_time = Enum.random(500..5000)
+        should_fail = Enum.random([true, false])
+        queue = Enum.random(["default", "background"])
+
+        schedule_job(sleep_time, should_fail, queue)
+      end)
+
+    failed_count = Enum.count(results, &match?({:error, _}, &1))
+    success_count = job_count - failed_count
+
+    socket =
+      socket
+      |> put_flash(:info, "Scheduled #{success_count} jobs successfully!")
+      |> assign(jobs: list_jobs())
+
+    if failed_count > 0 do
+      socket = put_flash(socket, :error, "Failed to schedule #{failed_count} jobs")
+      {:noreply, socket}
+    else
+      {:noreply, socket}
+    end
+  end
+
   @impl true
   def handle_info(:update_jobs, socket) do
     {:noreply, assign(socket, jobs: list_jobs())}
   end
 
+  defp schedule_job(sleep_time, should_fail, queue) do
+    TestWorker.new(
+      %{"sleep_time" => sleep_time, "should_fail" => should_fail},
+      queue: queue
+    )
+    |> Oban.insert()
+  end
+
   defp list_jobs do
     import Ecto.Query
 

test_integrations/phoenix_app/lib/phoenix_app_web/live/test_worker_live.html.heex

@@ -41,6 +41,37 @@
     </div>
   </div>
 
+  <div class="mt-8 bg-white shadow sm:rounded-lg">
+    <div class="px-4 py-5 sm:p-6">
+      <h3 class="text-base font-semibold leading-6 text-gray-900">Auto Schedule Multiple Jobs</h3>
+
+      <div class="mt-5">
+        <.form for={@auto_form} phx-submit="auto_schedule" class="space-y-6">
+          <div>
+            <label class="block text-sm font-medium text-gray-700">Number of Jobs</label>
+            <div class="mt-1">
+              <input type="number"
+                     name="auto[job_count]"
+                     value="5"
+                     min="1"
+                     max="100"
+                     class="block w-full rounded-md border-gray-300 shadow-sm focus:border-indigo-500 focus:ring-indigo-500 sm:text-sm" />
+            </div>
+            <p class="mt-2 text-sm text-gray-500">
+              Jobs will be created with random sleep times (500-5000ms), random queues, and random failure states.
+            </p>
+          </div>
+
+          <div>
+            <button type="submit" class="inline-flex justify-center rounded-md bg-indigo-600 px-3 py-2 text-sm font-semibold text-white shadow-sm hover:bg-indigo-500 focus-visible:outline focus-visible:outline-2 focus-visible:outline-offset-2 focus-visible:outline-indigo-600">
+              Auto Schedule Jobs
+            </button>
+          </div>
+        </.form>
+      </div>
+    </div>
+  </div>
+
   <div class="mt-8">
     <h3 class="text-base font-semibold leading-6 text-gray-900 mb-4">Recent Jobs</h3>