feat: rename tasks context to operations context

swapify_api/lib/swapify_api/application.ex

@@ -2,7 +2,7 @@ defmodule SwapifyApi.Application do
   # See https://hexdocs.pm/elixir/Application.html
   # for more information on OTP Applications
   @moduledoc false
-  alias SwapifyApi.Tasks.TaskEventHandler
+  alias SwapifyApi.Operations.TaskEventHandler
 
   require Logger
   require TaskEventHandler
@@ -14,7 +14,7 @@ defmodule SwapifyApi.Application do
     # OpenTelemetry setup
     OpentelemetryBandit.setup()
     OpentelemetryPhoenix.setup(adapter: :bandit)
-    OpentelemetryEcto.setup([:swapify_api, :repo], db_statement: :enabled)
+    # OpentelemetryEcto.setup([:swapify_api, :repo], db_statement: :enabled)
     # OpentelemetryOban.setup(trace: [:jobs])
 
     # Rate limiting storage setup

swapify_api/lib/swapify_api/music_providers.ex

@@ -7,7 +7,7 @@ defmodule SwapifyApi.MusicProviders do
   alias SwapifyApi.MusicProviders.Jobs.SyncLibraryJob
   alias SwapifyApi.MusicProviders.Jobs.SyncPlatformJob
   alias SwapifyApi.MusicProviders.PlaylistRepo
-  alias SwapifyApi.Tasks.JobRepo
+  alias SwapifyApi.Operations.JobRepo
   alias SwapifyApi.Repo
 
   @doc """

swapify_api/lib/swapify_api/music_providers/apple_music.ex

@@ -2,7 +2,7 @@ defmodule SwapifyApi.MusicProviders.AppleMusic do
   @moduledoc "Interfact to talk to Apple Music"
   require Logger
 
-  alias SwapifyApi.Tasks.MatchedTrack
+  alias SwapifyApi.Operations.MatchedTrack
   alias SwapifyApi.Utils
   alias SwapifyApi.MusicProviders.Track
 

swapify_api/lib/swapify_api/music_providers/jobs/find_playlist_tracks_job.ex

@@ -27,10 +27,10 @@ defmodule SwapifyApi.MusicProviders.Jobs.FindPlaylistTracksJob do
   alias SwapifyApi.MusicProviders.Track
   alias SwapifyApi.Notifications.JobErrorNotification
   alias SwapifyApi.Notifications.JobUpdateNotification
-  alias SwapifyApi.Tasks
-  alias SwapifyApi.Tasks.MatchedTrack
-  alias SwapifyApi.Tasks.TaskEventHandler
-  alias SwapifyApi.Tasks.TransferRepo
+  alias SwapifyApi.Operations
+  alias SwapifyApi.Operations.MatchedTrack
+  alias SwapifyApi.Operations.TaskEventHandler
+  alias SwapifyApi.Operations.TransferRepo
   alias SwapifyApi.Utils
   alias SwapifyApiWeb.JobUpdateChannel
 
@@ -99,7 +99,7 @@ defmodule SwapifyApi.MusicProviders.Jobs.FindPlaylistTracksJob do
        ) do
     Task.Supervisor.start_child(Task.Supervisor, fn ->
       with {:ok, %{email: email, username: username}} <- Accounts.get_by_id(user_id),
-           {:ok, transfer} <- Tasks.get_transfer_infos(transfer_id) do
+           {:ok, transfer} <- Operations.get_transfer_infos(transfer_id) do
         SwapifyApi.Emails.transfer_ready(email, username,
           username: username,
           source_name: PlatformConnection.get_name(transfer.source),
@@ -128,9 +128,9 @@ defmodule SwapifyApi.MusicProviders.Jobs.FindPlaylistTracksJob do
       )
     )
 
-    with {:ok, _} <- Tasks.update_job_status(job_id, :error),
+    with {:ok, _} <- Operations.update_job_status(job_id, :error),
          {:ok, %{username: username}} <- Accounts.get_by_id(user_id),
-         {:ok, transfer} <- Tasks.get_transfer_infos(transfer_id) do
+         {:ok, transfer} <- Operations.get_transfer_infos(transfer_id) do
       SwapifyApi.Emails.transfer_error(transfer.email, username,
         username: username,
         source_name: PlatformConnection.get_name(transfer.source),
@@ -157,7 +157,7 @@ defmodule SwapifyApi.MusicProviders.Jobs.FindPlaylistTracksJob do
       {:error, %ErrorMessage{code: :not_found}} ->
         with {:ok, _} <- process_match_results(unsaved_tracks, transfer_id, true),
              {:ok, _} <- process_error_results(unsaved_not_found_tracks, transfer_id, true),
-             {:ok, _} <- Tasks.update_job_status(job_id, :done),
+             {:ok, _} <- Operations.update_job_status(job_id, :done),
              {:ok, _} <- on_job_success(user_id, transfer_id) do
           {:ok,
            notification:
@@ -265,7 +265,7 @@ defmodule SwapifyApi.MusicProviders.Jobs.FindPlaylistTracksJob do
       {:error, %ErrorMessage{code: :not_found}} ->
         with {:ok, _} <- process_match_results(unsaved_tracks, transfer_id, true),
              {:ok, _} <- process_error_results(unsaved_not_found_tracks, transfer_id, true),
-             {:ok, _} <- Tasks.update_job_status(job_id, :done),
+             {:ok, _} <- Operations.update_job_status(job_id, :done),
              {:ok, _} <- on_job_success(user_id, transfer_id) do
           {:ok,
            notification:

swapify_api/lib/swapify_api/music_providers/jobs/sync_library_job.ex

@@ -15,7 +15,7 @@ defmodule SwapifyApi.MusicProviders.Jobs.SyncLibraryJob do
 
   On success, returns a `{:ok, %JobUpdateNotification{}}`
   """
-  alias SwapifyApi.Tasks
+  alias SwapifyApi.Operations
   alias SwapifyApi.MusicProviders
   alias SwapifyApi.Accounts
   alias SwapifyApi.MusicProviders.AppleMusic
@@ -25,7 +25,7 @@ defmodule SwapifyApi.MusicProviders.Jobs.SyncLibraryJob do
   alias SwapifyApi.MusicProviders.Spotify
   alias SwapifyApi.Notifications.JobErrorNotification
   alias SwapifyApi.Notifications.JobUpdateNotification
-  alias SwapifyApi.Tasks.TaskEventHandler
+  alias SwapifyApi.Operations.TaskEventHandler
   alias SwapifyApi.Utils
   alias SwapifyApiWeb.JobUpdateChannel
 
@@ -80,7 +80,7 @@ defmodule SwapifyApi.MusicProviders.Jobs.SyncLibraryJob do
                   |> __MODULE__.new()
                   |> Oban.insert()
                 else
-                  Tasks.update_job_status(job_id, :done)
+                  Operations.update_job_status(job_id, :done)
                 end) do
           Logger.debug("Fetched library items",
             platform_name: platform_name,
@@ -274,7 +274,7 @@ defmodule SwapifyApi.MusicProviders.Jobs.SyncLibraryJob do
         MusicProviders.mark_playlist_transfer_as_failed(playlist_id)
       end),
       Task.async(fn ->
-        Tasks.update_job_status(job_id, :error)
+        Operations.update_job_status(job_id, :error)
       end)
     ])
   end

swapify_api/lib/swapify_api/music_providers/jobs/sync_platform_job.ex

@@ -13,15 +13,15 @@ defmodule SwapifyApi.MusicProviders.Jobs.SyncPlatformJob do
 
   On success, returns a `{:ok, %JobUpdateNotification{}}`
   """
-  alias SwapifyApi.Tasks
+  alias SwapifyApi.Operations
   alias SwapifyApi.MusicProviders
   alias SwapifyApi.Utils
   alias SwapifyApi.Accounts
   alias SwapifyApi.MusicProviders.AppleMusic
   alias SwapifyApi.MusicProviders.AppleMusicTokenWorker
   alias SwapifyApi.MusicProviders.Playlist
   alias SwapifyApi.MusicProviders.Spotify
-  alias SwapifyApi.Tasks.TaskEventHandler
+  alias SwapifyApi.Operations.TaskEventHandler
   alias SwapifyApi.Notifications.JobErrorNotification
   alias SwapifyApi.Notifications.JobUpdateNotification
   alias SwapifyApiWeb.JobUpdateChannel
@@ -78,7 +78,7 @@ defmodule SwapifyApi.MusicProviders.Jobs.SyncPlatformJob do
         total = response.body["total"]
 
         with {:ok, _} <- MusicProviders.sync_playlist_metadata(:spotify, user_id, total),
-             {:ok, _} <- Tasks.update_job_status(job_id, :done) do
+             {:ok, _} <- Operations.update_job_status(job_id, :done) do
           {:ok, notification: JobUpdateNotification.new_platform_sync_update("spotify", :done)}
         end
 
@@ -122,7 +122,7 @@ defmodule SwapifyApi.MusicProviders.Jobs.SyncPlatformJob do
         total = response.body["meta"]["total"]
 
         with {:ok, _} <- MusicProviders.sync_playlist_metadata(:applemusic, user_id, total),
-             {:ok, _} <- Tasks.update_job_status(job_id, :done) do
+             {:ok, _} <- Operations.update_job_status(job_id, :done) do
           {:ok, notification: JobUpdateNotification.new_platform_sync_update("applemusic", :done)}
         end
 
@@ -152,7 +152,7 @@ defmodule SwapifyApi.MusicProviders.Jobs.SyncPlatformJob do
       service: job_args["platform_name"]
     )
 
-    Tasks.update_job_status(job_args["job_id"], :error)
+    Operations.update_job_status(job_args["job_id"], :error)
   end
 
   handle :success do
@@ -198,7 +198,7 @@ defmodule SwapifyApi.MusicProviders.Jobs.SyncPlatformJob do
     )
 
     Task.async(fn ->
-      Tasks.update_job_status(job_id, :error)
+      Operations.update_job_status(job_id, :error)
     end)
   end
 end

swapify_api/lib/swapify_api/music_providers/jobs/transfer_tracks.ex

@@ -22,9 +22,9 @@ defmodule SwapifyApi.MusicProviders.Jobs.TransferTracksJob do
   alias SwapifyApi.MusicProviders.Spotify
   alias SwapifyApi.Notifications.JobErrorNotification
   alias SwapifyApi.Notifications.JobUpdateNotification
-  alias SwapifyApi.Tasks
-  alias SwapifyApi.Tasks.TaskEventHandler
-  alias SwapifyApi.Tasks.TransferRepo
+  alias SwapifyApi.Operations
+  alias SwapifyApi.Operations.TaskEventHandler
+  alias SwapifyApi.Operations.TransferRepo
   alias SwapifyApi.Utils
   alias SwapifyApiWeb.JobUpdateChannel
 
@@ -45,7 +45,7 @@ defmodule SwapifyApi.MusicProviders.Jobs.TransferTracksJob do
   defp on_job_success(user_id, transfer_id) do
     Task.Supervisor.start_child(Task.Supervisor, fn ->
       with {:ok, %{username: username}} <- Accounts.get_by_id(user_id),
-           {:ok, transfer} <- Tasks.get_transfer_infos(transfer_id) do
+           {:ok, transfer} <- Operations.get_transfer_infos(transfer_id) do
         SwapifyApi.Emails.transfer_done(transfer.email, username,
           app_url: Application.fetch_env!(:swapify_api, :app_url),
           username: username,
@@ -67,9 +67,9 @@ defmodule SwapifyApi.MusicProviders.Jobs.TransferTracksJob do
         JobErrorNotification.new_transfer_tracks_error(transfer_id)
       )
 
-      with {:ok, _} <- Tasks.update_job_status(job_id, :error),
+      with {:ok, _} <- Operations.update_job_status(job_id, :error),
            {:ok, %{username: username}} <- Accounts.get_by_id(user_id),
-           {:ok, transfer} <- Tasks.get_transfer_infos(transfer_id) do
+           {:ok, transfer} <- Operations.get_transfer_infos(transfer_id) do
         SwapifyApi.Emails.transfer_error(transfer.email, username,
           app_url: Application.fetch_env!(:swapify_api, :app_url),
           username: username,
@@ -94,7 +94,7 @@ defmodule SwapifyApi.MusicProviders.Jobs.TransferTracksJob do
       ) do
     case TransferRepo.get_matched_tracks(transfer_id, offset, @spotify_add_limit) do
       {:ok, []} ->
-        with {:ok, _} <- Tasks.update_job_status(job_id, :done),
+        with {:ok, _} <- Operations.update_job_status(job_id, :done),
              {:ok, _} <- on_job_success(transfer_id, job_id) do
           {:ok,
            notification:
@@ -164,7 +164,7 @@ defmodule SwapifyApi.MusicProviders.Jobs.TransferTracksJob do
       ) do
     case TransferRepo.get_matched_track_by_index(transfer_id, offset) do
       {:error, %ErrorMessage{code: :not_found}} ->
-        with {:ok, _} <- Tasks.update_job_status(job_id, :done),
+        with {:ok, _} <- Operations.update_job_status(job_id, :done),
              {:ok, _} <- on_job_success(transfer_id, job_id) do
           {:ok,
            notification:
@@ -264,7 +264,7 @@ defmodule SwapifyApi.MusicProviders.Jobs.TransferTracksJob do
       service: job_args["platform_name"]
     )
 
-    Tasks.update_job_status(job_args["job_id"], :error)
+    Operations.update_job_status(job_args["job_id"], :error)
   end
 
   handle :success do

swapify_api/lib/swapify_api/music_providers/spotify.ex

@@ -2,7 +2,7 @@ defmodule SwapifyApi.MusicProviders.Spotify do
   @moduledoc "Interface to talk to Spotify"
   require Logger
 
-  alias SwapifyApi.Tasks.MatchedTrack
+  alias SwapifyApi.Operations.MatchedTrack
   alias SwapifyApi.Utils
   alias SwapifyApi.Oauth
   alias SwapifyApi.MusicProviders.Track

swapify_api/lib/swapify_api/notifications/job_update_notification.ex

@@ -1,7 +1,7 @@
 defmodule SwapifyApi.Notifications.JobUpdateNotification do
   @derive Jason.Encoder
 
-  alias SwapifyApi.Tasks.Job
+  alias SwapifyApi.Operations.Job
 
   defstruct [:name, :data, tag: "JobUpdateNotification"]
 

swapify_api/lib/swapify_api/tasks.ex → swapify_api/lib/swapify_api/operations.ex

@@ -1,4 +1,4 @@
-defmodule SwapifyApi.Tasks do
+defmodule SwapifyApi.Operations do
   @moduledoc """
   Task contexts
   """
@@ -8,10 +8,10 @@ defmodule SwapifyApi.Tasks do
   alias SwapifyApi.MusicProviders.Jobs.FindPlaylistTracksJob
   alias SwapifyApi.MusicProviders.Jobs.TransferTracksJob
   alias SwapifyApi.MusicProviders.PlaylistRepo
-  alias SwapifyApi.Tasks.Job
-  alias SwapifyApi.Tasks.JobRepo
-  alias SwapifyApi.Tasks.Transfer
-  alias SwapifyApi.Tasks.TransferRepo
+  alias SwapifyApi.Operations.Job
+  alias SwapifyApi.Operations.JobRepo
+  alias SwapifyApi.Operations.Transfer
+  alias SwapifyApi.Operations.TransferRepo
 
   @doc "Update a job status and timestamps if needed"
   @spec update_job_status(String.t(), Job.job_status()) ::

swapify_api/lib/swapify_api/tasks/job.ex → swapify_api/lib/swapify_api/operations/job.ex

@@ -1,4 +1,4 @@
-defmodule SwapifyApi.Tasks.Job do
+defmodule SwapifyApi.Operations.Job do
   use SwapifyApi.Schema
 
   alias SwapifyApi.Accounts.User

swapify_api/lib/swapify_api/tasks/job_json.ex → swapify_api/lib/swapify_api/operations/job_json.ex

@@ -1,5 +1,5 @@
-defmodule SwapifyApi.Tasks.JobJSON do
-  alias SwapifyApi.Tasks.Job
+defmodule SwapifyApi.Operations.JobJSON do
+  alias SwapifyApi.Operations.Job
 
   @fields [
     :id,

swapify_api/lib/swapify_api/tasks/job_repo.ex → swapify_api/lib/swapify_api/operations/job_repo.ex

@@ -1,6 +1,6 @@
-defmodule SwapifyApi.Tasks.JobRepo do
+defmodule SwapifyApi.Operations.JobRepo do
   alias SwapifyApi.Utils
-  alias SwapifyApi.Tasks.Job
+  alias SwapifyApi.Operations.Job
   alias SwapifyApi.Repo
 
   def create(args),

swapify_api/lib/swapify_api/tasks/matched_track.ex → swapify_api/lib/swapify_api/operations/matched_track.ex

@@ -1,4 +1,4 @@
-defmodule SwapifyApi.Tasks.MatchedTrack do
+defmodule SwapifyApi.Operations.MatchedTrack do
   @moduledoc "Business representation of a track found on another platform during a transfer"
   @derive Jason.Encoder
 

swapify_api/lib/swapify_api/tasks/task_event_handler.ex → swapify_api/lib/swapify_api/operations/task_event_handler.ex

@@ -1,9 +1,9 @@
-defmodule SwapifyApi.Tasks.TaskEventHandler do
+defmodule SwapifyApi.Operations.TaskEventHandler do
   @moduledoc """
   Macros defining events handlers
 
   ## Examples
-    use SwapifyApi.Tasks.TaskEventHandler, job_module: "Swapify.MyObanJob"
+    use SwapifyApi.Operations.TaskEventHandler, job_module: "Swapify.MyObanJob"
 
     handle :success do
       # do something with the `args` variable
@@ -15,7 +15,7 @@ defmodule SwapifyApi.Tasks.TaskEventHandler do
   """
   defmacro __using__(opts) do
     quote do
-      import SwapifyApi.Tasks.TaskEventHandler
+      import SwapifyApi.Operations.TaskEventHandler
       @jobname unquote(opts[:job_module])
     end
   end

swapify_api/lib/swapify_api/tasks/transfer.ex → swapify_api/lib/swapify_api/operations/transfer.ex

@@ -1,13 +1,13 @@
-defmodule SwapifyApi.Tasks.Transfer do
+defmodule SwapifyApi.Operations.Transfer do
   @moduledoc "Business a representation of a playlist transfer"
   use SwapifyApi.Schema
 
   alias SwapifyApi.Accounts.PlatformConnection
   alias SwapifyApi.Accounts.User
   alias SwapifyApi.MusicProviders.Playlist
   alias SwapifyApi.MusicProviders.Track
-  alias SwapifyApi.Tasks.Job
-  alias SwapifyApi.Tasks.MatchedTrack
+  alias SwapifyApi.Operations.Job
+  alias SwapifyApi.Operations.MatchedTrack
 
   @type t :: %__MODULE__{
           id: String.t(),

swapify_api/lib/swapify_api/tasks/transfer_json.ex → swapify_api/lib/swapify_api/operations/transfer_json.ex

@@ -1,7 +1,7 @@
-defmodule SwapifyApi.Tasks.TransferJSON do
-  alias SwapifyApi.Tasks.JobJSON
+defmodule SwapifyApi.Operations.TransferJSON do
+  alias SwapifyApi.Operations.JobJSON
   alias SwapifyApi.MusicProviders.PlaylistJSON
-  alias SwapifyApi.Tasks.Transfer
+  alias SwapifyApi.Operations.Transfer
 
   def show(%Transfer{} = t) do
     %{

swapify_api/lib/swapify_api/tasks/transfer_repo.ex → swapify_api/lib/swapify_api/operations/transfer_repo.ex

@@ -1,4 +1,4 @@
-defmodule SwapifyApi.Tasks.TransferRepo do
+defmodule SwapifyApi.Operations.TransferRepo do
   @doc "Transfer table repository"
   use OpenTelemetryDecorator
 
@@ -7,8 +7,8 @@ defmodule SwapifyApi.Tasks.TransferRepo do
   alias SwapifyApi.MusicProviders.Playlist
   alias SwapifyApi.MusicProviders.Track
   alias SwapifyApi.Repo
-  alias SwapifyApi.Tasks.MatchedTrack
-  alias SwapifyApi.Tasks.Transfer
+  alias SwapifyApi.Operations.MatchedTrack
+  alias SwapifyApi.Operations.Transfer
   alias SwapifyApi.Utils
 
   @spec create(map()) :: {:ok, Transfer.t()} | {:error, Ecto.Changeset.t()}

swapify_api/lib/swapify_api_web/controllers/admin_dashboard_controller.ex

@@ -1,14 +1,14 @@
 defmodule SwapifyApiWeb.AdminDashboardController do
   use SwapifyApiWeb, :controller
 
-  alias SwapifyApi.Tasks
+  alias SwapifyApi.Operations
   alias SwapifyApi.Accounts
 
   plug :put_layout, {SwapifyApiWeb.Layouts, :admin}
 
   def index(conn, _) do
     with {:ok, user_count} <- Accounts.count_users(),
-         {:ok, transfer_count} <- Tasks.count_transfers() do
+         {:ok, transfer_count} <- Operations.count_transfers() do
       conn |> render(:index, user_count: user_count, transfer_count: transfer_count)
     end
   end