renamed ChannelTasks

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

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.
   """

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