From d822aaa899dd0452612198770562971075451847 Mon Sep 17 00:00:00 2001
From: Kieran Eglin <kieran.eglin@gmail.com>
Date: Fri, 2 Feb 2024 10:14:20 -0800
Subject: [PATCH] renamed ChannelTasks

---
 lib/pinchflat/media_source.ex                        |  8 ++++----
 .../tasks/{channel_tasks.ex => source_tasks.ex}      |  2 +-
 ...{channel_tasks_test.exs => source_tasks_test.exs} | 12 ++++++------
 3 files changed, 11 insertions(+), 11 deletions(-)
 rename lib/pinchflat/tasks/{channel_tasks.ex => source_tasks.ex} (95%)
 rename test/pinchflat/tasks/{channel_tasks_test.exs => source_tasks_test.exs} (73%)

diff --git a/lib/pinchflat/media_source.ex b/lib/pinchflat/media_source.ex
index e218723..750a932 100644
--- a/lib/pinchflat/media_source.ex
+++ b/lib/pinchflat/media_source.ex
@@ -8,7 +8,7 @@ defmodule Pinchflat.MediaSource do
 
   alias Pinchflat.Tasks
   alias Pinchflat.Media
-  alias Pinchflat.Tasks.ChannelTasks
+  alias Pinchflat.Tasks.SourceTasks
   alias Pinchflat.MediaSource.Source
   alias Pinchflat.MediaClient.ChannelDetails
 
@@ -65,7 +65,7 @@ defmodule Pinchflat.MediaSource do
   media if the indexing frequency has been changed.
 
   Existing indexing tasks will be cancelled if the indexing frequency has been
-  changed (logic in `ChannelTasks.kickoff_indexing_task`)
+  changed (logic in `SourceTasks.kickoff_indexing_task`)
 
   Returns {:ok, %Source{}} | {:error, %Ecto.Changeset{}}
   """
@@ -150,13 +150,13 @@ defmodule Pinchflat.MediaSource do
     case changeset.data do
       # If the changeset is new (not persisted), attempt indexing no matter what
       %{__meta__: %{state: :built}} ->
-        ChannelTasks.kickoff_indexing_task(channel)
+        SourceTasks.kickoff_indexing_task(channel)
 
       # If the record has been persisted, only attempt indexing if the
       # indexing frequency has been changed
       %{__meta__: %{state: :loaded}} ->
         if Map.has_key?(changeset.changes, :index_frequency_minutes) do
-          ChannelTasks.kickoff_indexing_task(channel)
+          SourceTasks.kickoff_indexing_task(channel)
         end
     end
   end
diff --git a/lib/pinchflat/tasks/channel_tasks.ex b/lib/pinchflat/tasks/source_tasks.ex
similarity index 95%
rename from lib/pinchflat/tasks/channel_tasks.ex
rename to lib/pinchflat/tasks/source_tasks.ex
index 18b7304..b28bc07 100644
--- a/lib/pinchflat/tasks/channel_tasks.ex
+++ b/lib/pinchflat/tasks/source_tasks.ex
@@ -1,4 +1,4 @@
-defmodule Pinchflat.Tasks.ChannelTasks do
+defmodule Pinchflat.Tasks.SourceTasks do
   @moduledoc """
   This module contains methods for managing tasks (workers) related to channels.
   """
diff --git a/test/pinchflat/tasks/channel_tasks_test.exs b/test/pinchflat/tasks/source_tasks_test.exs
similarity index 73%
rename from test/pinchflat/tasks/channel_tasks_test.exs
rename to test/pinchflat/tasks/source_tasks_test.exs
index d5a3f4c..1e9c38f 100644
--- a/test/pinchflat/tasks/channel_tasks_test.exs
+++ b/test/pinchflat/tasks/source_tasks_test.exs
@@ -1,18 +1,18 @@
-defmodule Pinchflat.Tasks.ChannelTasksTest do
+defmodule Pinchflat.Tasks.SourceTasksTest do
   use Pinchflat.DataCase
 
   import Pinchflat.TasksFixtures
   import Pinchflat.MediaSourceFixtures
 
   alias Pinchflat.Tasks.Task
-  alias Pinchflat.Tasks.ChannelTasks
+  alias Pinchflat.Tasks.SourceTasks
   alias Pinchflat.Workers.MediaIndexingWorker
 
   describe "kickoff_indexing_task/1" do
     test "it does not schedule a job if the interval is <= 0" do
       source = source_fixture(index_frequency_minutes: -1)
 
-      assert {:ok, :should_not_index} = ChannelTasks.kickoff_indexing_task(source)
+      assert {:ok, :should_not_index} = SourceTasks.kickoff_indexing_task(source)
 
       refute_enqueued(worker: MediaIndexingWorker, args: %{"id" => source.id})
     end
@@ -20,7 +20,7 @@ defmodule Pinchflat.Tasks.ChannelTasksTest do
     test "it schedules a job if the interval is > 0" do
       source = source_fixture(index_frequency_minutes: 1)
 
-      assert {:ok, _} = ChannelTasks.kickoff_indexing_task(source)
+      assert {:ok, _} = SourceTasks.kickoff_indexing_task(source)
 
       assert_enqueued(worker: MediaIndexingWorker, args: %{"id" => source.id})
     end
@@ -28,7 +28,7 @@ defmodule Pinchflat.Tasks.ChannelTasksTest do
     test "it creates and attaches a task if the interval is > 0" do
       source = source_fixture(index_frequency_minutes: 1)
 
-      assert {:ok, %Task{} = task} = ChannelTasks.kickoff_indexing_task(source)
+      assert {:ok, %Task{} = task} = SourceTasks.kickoff_indexing_task(source)
 
       assert task.source_id == source.id
     end
@@ -37,7 +37,7 @@ defmodule Pinchflat.Tasks.ChannelTasksTest do
       source = source_fixture()
       task = task_fixture(source_id: source.id)
 
-      assert {:ok, _} = ChannelTasks.kickoff_indexing_task(source)
+      assert {:ok, _} = SourceTasks.kickoff_indexing_task(source)
 
       assert_raise Ecto.NoResultsError, fn -> Repo.reload!(task) end
     end