Toggle off ++ feeds for now-inactive members

config/prod.exs

@@ -72,6 +72,8 @@ config :changelog, Oban,
        {"00 3 * * *", Changelog.ObanWorkers.ZulipImporter},
        # 3:30am daily
        {"30 3 * * *", Changelog.ObanWorkers.PersonBouncer},
+       # 3:45am daily
+       {"45 3 * * *", Changelog.ObanWorkers.FeedBouncer},
        # 4am daily
        {"00 4 * * *", Changelog.ObanWorkers.EpisodeStatsProcessor},
        # 4:45am daily

lib/changelog/oban_workers/feed_bouncer.ex

@@ -0,0 +1,34 @@
+defmodule Changelog.ObanWorkers.FeedBouncer do
+  @moduledoc """
+  This module defines the Oban worker for switching inactive members'
+  feeds back to public mp3s
+  """
+  use Oban.Worker, queue: :scheduled
+
+  import Ecto.Changeset, only: [change: 2]
+
+  alias Changelog.{EventLog, Feed, Policies, Repo}
+
+  @impl Oban.Worker
+  def perform(_job) do
+    plusplus =
+      Feed
+      |> Feed.plusplus()
+      |> Feed.preload_owner()
+      |> Repo.all()
+
+      for feed = %{owner: owner} <- plusplus do
+        if !Policies.Feed.plusplus(owner) do
+          {:ok, feed} = feed |> change(%{plusplus: false}) |> Repo.update()
+          log("Turned off pluplus for feed ##{feed.id} owned by inactive member ##{owner.id} (#{owner.email})")
+          Changelog.ObanWorkers.FeedUpdater.queue(feed)
+        end
+      end
+
+      :ok
+  end
+
+  defp log(message) do
+    EventLog.insert(message, "FeedBouncer")
+  end
+end

lib/changelog/schema/feed.ex

@@ -29,6 +29,8 @@ defmodule Changelog.Feed do
 
   def get_by_slug!(slug), do: Repo.get_by!(__MODULE__, slug: slug)
 
+  def plusplus(query \\ __MODULE__), do: from(q in query, where: q.plusplus)
+
   def with_podcast_id(query \\ __MODULE__, id),
     do: from(q in query, where: fragment("? = ANY(?)", ^id, q.podcast_ids))