Sync managed Arr webhooks

Co-authored-by: Copilot <223556219+Copilot@users.noreply.github.com>

Author: mjc

config/test.exs

@@ -44,6 +44,7 @@ config :phoenix_live_view,
 
 # Mark test environment so async DB tasks run synchronously
 config :reencodarr, env: :test
+config :reencodarr, auto_reconcile_managed_webhooks: false
 
 # Don't start Erlang distribution in tests — avoids duplicate_name conflicts
 # with a running dev node and unnecessary epmd registration per test run.

lib/reencodarr/application.ex

@@ -4,6 +4,7 @@ defmodule Reencodarr.Application do
   @moduledoc false
 
   use Application
+  alias Reencodarr.Services.WebhookSync
 
   @impl true
   def start(_type, _args) do
@@ -17,7 +18,11 @@ defmodule Reencodarr.Application do
     maybe_start_distribution()
 
     opts = [strategy: :one_for_one, name: Reencodarr.Supervisor]
-    Supervisor.start_link(children(), opts)
+
+    with {:ok, pid} <- Supervisor.start_link(children(), opts) do
+      maybe_start_webhook_sync()
+      {:ok, pid}
+    end
   end
 
   defp setup_file_logging do
@@ -149,6 +154,12 @@ defmodule Reencodarr.Application do
     end
   end
 
+  defp maybe_start_webhook_sync do
+    if Application.get_env(:reencodarr, :env) != :test do
+      Task.start(fn -> WebhookSync.reconcile_all() end)
+    end
+  end
+
   # Tell Phoenix to update the endpoint configuration
   # whenever the application is updated.
   @impl true

lib/reencodarr/services.ex

@@ -2,11 +2,13 @@ defmodule Reencodarr.Services do
   @moduledoc """
   This module is responsible for communicating with external services.
   """
+  require Logger
   alias Reencodarr.DbWriter
   alias Reencodarr.Repo
   alias Reencodarr.Services.Config
   alias Reencodarr.Services.Radarr
   alias Reencodarr.Services.Sonarr
+  alias Reencodarr.Services.WebhookSync
 
   @doc """
   Returns the list of configs.
@@ -80,14 +82,21 @@ defmodule Reencodarr.Services do
 
   """
   def create_config(attrs \\ %{}) do
-    DbWriter.run(
-      fn ->
-        %Config{}
-        |> Config.changeset(attrs)
-        |> Repo.insert()
-      end,
-      label: :service_config_create
-    )
+    case DbWriter.run(
+           fn ->
+             %Config{}
+             |> Config.changeset(attrs)
+             |> Repo.insert()
+           end,
+           label: :service_config_create
+         ) do
+      {:ok, config} = result ->
+        maybe_reconcile_managed_webhook(config)
+        result
+
+      error ->
+        error
+    end
   end
 
   @doc """
@@ -103,14 +112,21 @@ defmodule Reencodarr.Services do
 
   """
   def update_config(%Config{} = config, attrs) do
-    DbWriter.run(
-      fn ->
-        config
-        |> Config.changeset(attrs)
-        |> Repo.update()
-      end,
-      label: :service_config_update
-    )
+    case DbWriter.run(
+           fn ->
+             config
+             |> Config.changeset(attrs)
+             |> Repo.update()
+           end,
+           label: :service_config_update
+         ) do
+      {:ok, updated_config} = result ->
+        maybe_reconcile_managed_webhook(updated_config)
+        result
+
+      error ->
+        error
+    end
   end
 
   @doc """
@@ -157,4 +173,28 @@ defmodule Reencodarr.Services do
 
   @doc "Fetches all movie files for a given movie."
   def get_movie_files(movie_id), do: Radarr.get_movie_files(movie_id)
+
+  defp maybe_reconcile_managed_webhook(%Config{service_type: service_type})
+       when service_type in [:sonarr, :radarr] do
+    if Application.get_env(:reencodarr, :auto_reconcile_managed_webhooks, true) do
+      case WebhookSync.reconcile_for_service(service_type) do
+        :ok ->
+          :ok
+
+        :skipped ->
+          :ok
+
+        {:error, reason} ->
+          Logger.warning(
+            "Services: failed to reconcile #{service_type} webhook after config change: #{inspect(reason)}"
+          )
+
+          :ok
+      end
+    else
+      :ok
+    end
+  end
+
+  defp maybe_reconcile_managed_webhook(_config), do: :ok
 end

lib/reencodarr/services/radarr.ex

@@ -32,6 +32,26 @@ defmodule Reencodarr.Services.Radarr do
     request(url: "/api/v3/movie?includeImages=false", method: :get)
   end
 
+  @spec list_notifications() :: {:ok, Req.Response.t()} | {:error, any()}
+  def list_notifications do
+    request(url: "/api/v3/notification", method: :get)
+  end
+
+  @spec get_notification_schemas() :: {:ok, Req.Response.t()} | {:error, any()}
+  def get_notification_schemas do
+    request(url: "/api/v3/notification/schema", method: :get)
+  end
+
+  @spec create_notification(map()) :: {:ok, Req.Response.t()} | {:error, any()}
+  def create_notification(attrs) when is_map(attrs) do
+    request(url: "/api/v3/notification", method: :post, json: attrs)
+  end
+
+  @spec update_notification(integer(), map()) :: {:ok, Req.Response.t()} | {:error, any()}
+  def update_notification(id, attrs) when is_integer(id) and id > 0 and is_map(attrs) do
+    request(url: "/api/v3/notification/#{id}", method: :put, json: attrs)
+  end
+
   @spec get_movie_files(integer()) :: {:ok, Req.Response.t()} | {:error, any()}
   def get_movie_files(movie_id) do
     request(url: "/api/v3/moviefile?movieId=#{movie_id}", method: :get)

lib/reencodarr/services/sonarr.ex

@@ -36,6 +36,26 @@ defmodule Reencodarr.Services.Sonarr do
     request(url: "/api/v3/series?includeSeasonImages=false", method: :get)
   end
 
+  @spec list_notifications() :: {:ok, Req.Response.t()} | {:error, any()}
+  def list_notifications do
+    request(url: "/api/v3/notification", method: :get)
+  end
+
+  @spec get_notification_schemas() :: {:ok, Req.Response.t()} | {:error, any()}
+  def get_notification_schemas do
+    request(url: "/api/v3/notification/schema", method: :get)
+  end
+
+  @spec create_notification(map()) :: {:ok, Req.Response.t()} | {:error, any()}
+  def create_notification(attrs) when is_map(attrs) do
+    request(url: "/api/v3/notification", method: :post, json: attrs)
+  end
+
+  @spec update_notification(integer(), map()) :: {:ok, Req.Response.t()} | {:error, any()}
+  def update_notification(id, attrs) when is_integer(id) and id > 0 and is_map(attrs) do
+    request(url: "/api/v3/notification/#{id}", method: :put, json: attrs)
+  end
+
   @spec get_episode_files(integer()) :: {:ok, Req.Response.t()} | {:error, any()}
   def get_episode_files(series_id) do
     response = request(url: "/api/v3/episodefile?seriesId=#{series_id}", method: :get)