Remove unnecessary code
This commit is contained in:
@@ -19,7 +19,6 @@ defmodule MusicLibrary.ScrobbleRules.Worker do
|
|||||||
case ScrobbleRules.apply_all_rules() do
|
case ScrobbleRules.apply_all_rules() do
|
||||||
{:ok, results} ->
|
{:ok, results} ->
|
||||||
log_results(results)
|
log_results(results)
|
||||||
:ok
|
|
||||||
|
|
||||||
{:error, reason} ->
|
{:error, reason} ->
|
||||||
Logger.error("Failed to apply scrobble rules: #{inspect(reason)}")
|
Logger.error("Failed to apply scrobble rules: #{inspect(reason)}")
|
||||||
@@ -64,26 +63,4 @@ defmodule MusicLibrary.ScrobbleRules.Worker do
|
|||||||
})
|
})
|
||||||
end)
|
end)
|
||||||
end
|
end
|
||||||
|
|
||||||
@doc """
|
|
||||||
Schedules the worker to run periodically.
|
|
||||||
|
|
||||||
This should be called during application startup to ensure
|
|
||||||
the worker runs automatically.
|
|
||||||
"""
|
|
||||||
def schedule_periodic do
|
|
||||||
# Schedule to run every 30 minutes
|
|
||||||
__MODULE__.new(%{})
|
|
||||||
|> Oban.insert(schedule_in: {30, :minute})
|
|
||||||
end
|
|
||||||
|
|
||||||
@doc """
|
|
||||||
Triggers the worker to run immediately.
|
|
||||||
|
|
||||||
Useful for manual rule application or testing.
|
|
||||||
"""
|
|
||||||
def run_now do
|
|
||||||
__MODULE__.new(%{})
|
|
||||||
|> Oban.insert()
|
|
||||||
end
|
|
||||||
end
|
end
|
||||||
|
|||||||
@@ -86,10 +86,4 @@ defmodule MusicLibrary.ScrobbleRules.WorkerTest do
|
|||||||
assert :ok = Worker.perform(%Oban.Job{args: %{}})
|
assert :ok = Worker.perform(%Oban.Job{args: %{}})
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
describe "run_now/0" do
|
|
||||||
test "enqueues job for immediate execution" do
|
|
||||||
assert {:ok, %Oban.Job{}} = Worker.run_now()
|
|
||||||
end
|
|
||||||
end
|
|
||||||
end
|
end
|
||||||
|
|||||||
Reference in New Issue
Block a user