Allow searching on Postgres (#8)

* Allow searching on Postgres

This patch changes the search implementation to explicitly cast the jsonb args column
to `text` before passing it to `like/2`.

* Update lib/obanalyze/oban_jobs.ex

Co-authored-by: Aleksandr Lossenko <[email protected]>

---------

Co-authored-by: Aleksandr Lossenko <[email protected]>

Author: maltoe

lib/obanalyze/oban_jobs.ex

@@ -57,9 +57,17 @@ defmodule Obanalyze.ObanJobs do
   defp filter(query, term) do
     like = "%#{term}%"
 
-    from oj in query,
-      where: like(oj.worker, ^like),
-      or_where: like(oj.args, ^like)
+    case Oban.config() do
+      %{engine: Oban.Engines.Basic} ->
+        from oj in query,
+          where: ilike(oj.worker, ^like),
+          or_where: ilike(type(oj.args, :string), ^like)
+
+      _ ->
+        from oj in query,
+          where: like(oj.worker, ^like),
+          or_where: like(oj.args, ^like)
+    end
   end
 
   defp jobs_count_query(job_state) do

test/obanalyze/dashboard_test.exs

@@ -18,14 +18,10 @@ defmodule Obanalyze.DashboardTest do
   test "shows jobs with limit" do
     for _ <- 1..110, do: job_fixture(%{}, state: "executing", attempted_at: DateTime.utc_now())
     {:ok, live, rendered} = live(build_conn(), "/dashboard/obanalyze")
-
-    assert rendered |> :binary.matches("<td class=\"oban-jobs-executing-worker\"") |> length() ==
-             20
+    assert_count(rendered, "executing", 20)
 
     rendered = render_patch(live, "/dashboard/obanalyze?limit=100")
-
-    assert rendered |> :binary.matches("<td class=\"oban-jobs-executing-worker\"") |> length() ==
-             100
+    assert_count(rendered, "executing", 100)
   end
 
   test "shows job info modal" do
@@ -51,28 +47,23 @@ defmodule Obanalyze.DashboardTest do
     conn = build_conn()
     {:ok, live, rendered} = live(conn, "/dashboard/obanalyze")
 
-    assert rendered |> :binary.matches("<td class=\"oban-jobs-executing-worker\"") |> length() ==
-             1
+    assert_count(rendered, "executing", 1)
 
     {:ok, live, rendered} =
       live
       |> element("a", "Completed (1)")
       |> render_click()
       |> follow_redirect(conn)
 
-    assert rendered
-           |> :binary.matches("<td class=\"oban-jobs-completed-worker\"")
-           |> length() == 1
+    assert_count(rendered, "completed", 1)
 
     {:ok, _live, rendered} =
       live
       |> element("a", "Scheduled (0)")
       |> render_click()
       |> follow_redirect(conn)
 
-    assert rendered
-           |> :binary.matches("<td class=\"oban-jobs-scheduled-worker\"")
-           |> length() == 0
+    assert_count(rendered, "scheduled", 0)
   end
 
   test "run now job" do
@@ -127,24 +118,23 @@ defmodule Obanalyze.DashboardTest do
       )
 
     {:ok, _live, rendered} = live(build_conn(), "/dashboard/obanalyze?search=JsonWorker")
-
-    assert rendered |> :binary.matches("<td class=\"oban-jobs-executing-worker\"") |> length() ==
-             1
+    assert_count(rendered, 1)
 
     {:ok, _live, rendered} = live(build_conn(), "/dashboard/obanalyze?search=YamlWorker")
+    assert_count(rendered, 1)
 
-    assert rendered |> :binary.matches("<td class=\"oban-jobs-executing-worker\"") |> length() ==
-             1
+    {:ok, _live, rendered} = live(build_conn(), "/dashboard/obanalyze?search=yamlworker")
+    assert_count(rendered, 1)
 
     {:ok, _live, rendered} = live(build_conn(), "/dashboard/obanalyze?search=foo")
-
-    assert rendered |> :binary.matches("<td class=\"oban-jobs-executing-worker\"") |> length() ==
-             2
+    assert_count(rendered, 2)
 
     {:ok, _live, rendered} = live(build_conn(), "/dashboard/obanalyze?search=nothing")
+    assert_count(rendered, 0)
+  end
 
-    assert rendered |> :binary.matches("<td class=\"oban-jobs-executing-worker\"") |> length() ==
-             0
+  defp assert_count(rendered, state \\ "executing", n) do
+    assert length(:binary.matches(rendered, "<td class=\"oban-jobs-#{state}-worker\"")) == n
   end
 
   defp job_fixture(args, opts) do