bdef6c75bb
* Ensure channel detail lookup doesn't download the video - oops * Ran the needful migrations for replacing channels with sources * got media source test back working * channel tasks test * Media indexing worker test * media tests * Got all tests working except controller tests * got all tests working * Renamed Channel struct to Source * renamed ChannelTasks * More renaming; renamed channel details module * Removed Channel yt-dlp module, instead throwing things in the VideoCollection module * Renamed what looks like the last of the outstanding data
110 lines
3.8 KiB
Elixir
110 lines
3.8 KiB
Elixir
defmodule Pinchflat.Workers.MediaIndexingWorkerTest do
|
|
use Pinchflat.DataCase
|
|
|
|
import Mox
|
|
import Pinchflat.MediaFixtures
|
|
import Pinchflat.MediaSourceFixtures
|
|
|
|
alias Pinchflat.Tasks
|
|
alias Pinchflat.Workers.MediaIndexingWorker
|
|
alias Pinchflat.Workers.VideoDownloadWorker
|
|
|
|
setup :verify_on_exit!
|
|
|
|
describe "perform/1" do
|
|
test "it does not do any indexing if the source shouldn't be indexed" do
|
|
expect(YtDlpRunnerMock, :run, 0, fn _url, _opts, _ot -> {:ok, ""} end)
|
|
|
|
source = source_fixture(index_frequency_minutes: -1)
|
|
|
|
perform_job(MediaIndexingWorker, %{id: source.id})
|
|
end
|
|
|
|
test "it does not reschedule if the source shouldn't be indexed" do
|
|
expect(YtDlpRunnerMock, :run, 0, fn _url, _opts, _ot -> {:ok, ""} end)
|
|
|
|
source = source_fixture(index_frequency_minutes: -1)
|
|
perform_job(MediaIndexingWorker, %{id: source.id})
|
|
|
|
refute_enqueued(worker: MediaIndexingWorker, args: %{"id" => source.id})
|
|
end
|
|
|
|
test "it indexes the source if it should be indexed" do
|
|
expect(YtDlpRunnerMock, :run, fn _url, _opts, _ot -> {:ok, ""} end)
|
|
|
|
source = source_fixture(index_frequency_minutes: 10)
|
|
|
|
perform_job(MediaIndexingWorker, %{id: source.id})
|
|
end
|
|
|
|
test "it kicks off a download job for each pending media item" do
|
|
expect(YtDlpRunnerMock, :run, fn _url, _opts, _ot -> {:ok, "video1"} end)
|
|
|
|
source = source_fixture(index_frequency_minutes: 10)
|
|
perform_job(MediaIndexingWorker, %{id: source.id})
|
|
|
|
assert [_] = all_enqueued(worker: VideoDownloadWorker)
|
|
end
|
|
|
|
test "it starts a job for any pending media item even if it's from another run" do
|
|
expect(YtDlpRunnerMock, :run, fn _url, _opts, _ot -> {:ok, "video1"} end)
|
|
|
|
source = source_fixture(index_frequency_minutes: 10)
|
|
media_item_fixture(%{source_id: source.id, media_filepath: nil})
|
|
perform_job(MediaIndexingWorker, %{id: source.id})
|
|
|
|
assert [_, _] = all_enqueued(worker: VideoDownloadWorker)
|
|
end
|
|
|
|
test "it does not kick off a job for media items that could not be saved" do
|
|
expect(YtDlpRunnerMock, :run, fn _url, _opts, _ot -> {:ok, "video1\nvideo1"} end)
|
|
|
|
source = source_fixture(index_frequency_minutes: 10)
|
|
perform_job(MediaIndexingWorker, %{id: source.id})
|
|
|
|
# Only one job should be enqueued, since the second video is a duplicate
|
|
assert [_] = all_enqueued(worker: VideoDownloadWorker)
|
|
end
|
|
|
|
test "it reschedules the job based on the index frequency" do
|
|
expect(YtDlpRunnerMock, :run, fn _url, _opts, _ot -> {:ok, ""} end)
|
|
|
|
source = source_fixture(index_frequency_minutes: 10)
|
|
perform_job(MediaIndexingWorker, %{id: source.id})
|
|
|
|
assert_enqueued(
|
|
worker: MediaIndexingWorker,
|
|
args: %{"id" => source.id},
|
|
scheduled_at: now_plus(source.index_frequency_minutes, :minutes)
|
|
)
|
|
end
|
|
|
|
test "it creates a task for the rescheduled job" do
|
|
expect(YtDlpRunnerMock, :run, fn _url, _opts, _ot -> {:ok, ""} end)
|
|
|
|
source = source_fixture(index_frequency_minutes: 10)
|
|
task_count_fetcher = fn -> Enum.count(Tasks.list_tasks()) end
|
|
|
|
assert_changed([from: 0, to: 1], task_count_fetcher, fn ->
|
|
perform_job(MediaIndexingWorker, %{id: source.id})
|
|
end)
|
|
end
|
|
|
|
test "it creates the basic media_item records" do
|
|
expect(YtDlpRunnerMock, :run, fn _url, _opts, _ot -> {:ok, "video1\nvideo2"} end)
|
|
|
|
source = source_fixture(index_frequency_minutes: 10)
|
|
|
|
media_item_fetcher = fn ->
|
|
source
|
|
|> Repo.preload(:media_items)
|
|
|> Map.get(:media_items)
|
|
|> Enum.map(fn media_item -> media_item.media_id end)
|
|
end
|
|
|
|
assert_changed([from: [], to: ["video1", "video2"]], media_item_fetcher, fn ->
|
|
perform_job(MediaIndexingWorker, %{id: source.id})
|
|
end)
|
|
end
|
|
end
|
|
end
|