mirror of
https://github.com/fly-apps/live_beats.git
synced 2024-09-27 05:50:00 +00:00
31 lines
786 B
Elixir
31 lines
786 B
Elixir
defmodule LiveBeats.SongsCleaner do
|
|
@moduledoc """
|
|
Expire user songs using a polling interval.
|
|
"""
|
|
use GenServer
|
|
|
|
alias LiveBeats.MediaLibrary
|
|
|
|
@poll_interval :timer.minutes(30)
|
|
|
|
def start_link(opts) do
|
|
GenServer.start_link(__MODULE__, opts, name: __MODULE__)
|
|
end
|
|
|
|
@impl true
|
|
def init(opts) do
|
|
{count, interval} = Keyword.fetch!(opts, :interval)
|
|
{:ok, schedule_cleanup(%{count: count, interval: interval}, 0)}
|
|
end
|
|
|
|
@impl true
|
|
def handle_info(:remove_songs, %{count: count, interval: interval} = state) do
|
|
MediaLibrary.expire_songs_older_than(count, interval)
|
|
{:noreply, schedule_cleanup(state)}
|
|
end
|
|
|
|
defp schedule_cleanup(state, after_ms \\ @poll_interval) do
|
|
Process.send_after(self(), :remove_songs, after_ms)
|
|
state
|
|
end
|
|
end
|