Page MenuHomePhabricator
Files F59410

No OneTemporary
Actions

View Options

diff --git a/lib/lsg_irc/radio_france_plugin.ex b/lib/lsg_irc/radio_france_plugin.ex
new file mode 100644
index 0000000..34935ca
--- /dev/null
+++ b/lib/lsg_irc/radio_france_plugin.ex
@@ -0,0 +1,133 @@
+defmodule LSG.IRC.RadioFrancePlugin do
+ require Logger
+
+ def irc_doc() do
+ """
+ # radio france
+
+ Qu'est ce qu'on écoute sur radio france ?
+
+ * **!radiofrance `[station]`, !rf `[station]`**
+ * **!fip, !inter, !info, !bleu, !culture, !musique, !fip `[sous-station]`, !bleu `[région]`**
+ """
+ end
+
+ def start_link() do
+ GenServer.start_link(__MODULE__, [], name: __MODULE__)
+ end
+
+ @trigger "radiofrance"
+ @shortcuts ~w(fip inter info bleu culture musique)
+
+ def init(_) do
+ regopts = [plugin: __MODULE__]
+ {:ok, _} = Registry.register(IRC.PubSub, "trigger:radiofrance", regopts)
+ {:ok, _} = Registry.register(IRC.PubSub, "trigger:rf", regopts)
+ for s <- @shortcuts do
+ {:ok, _} = Registry.register(IRC.PubSub, "trigger:#{s}", regopts)
+ end
+ {:ok, nil}
+ end
+
+ def handle_info({:irc, :trigger, "rf", m = %IRC.Message{trigger: %IRC.Trigger{type: :bang}}}, state) do
+ handle_info({:irc, :trigger, "radiofrance", m}, state)
+ end
+
+ def handle_info({:irc, :trigger, @trigger, m = %IRC.Message{trigger: %IRC.Trigger{type: :bang, args: []}}}, state) do
+ m.replyfun.("radiofrance: précisez la station!")
+ {:noreply, state}
+ end
+
+ def handle_info({:irc, :trigger, @trigger, m = %IRC.Message{trigger: %IRC.Trigger{type: :bang, args: args}}}, state) do
+ now(args_to_station(args), m)
+ {:noreply, state}
+ end
+
+ def handle_info({:irc, :trigger, trigger, m = %IRC.Message{trigger: %IRC.Trigger{type: :bang, args: args}}}, state) when trigger in @shortcuts do
+ now(args_to_station([trigger | args]), m)
+ {:noreply, state}
+ end
+
+ defp args_to_station(args) do
+ args
+ |> Enum.map(&unalias/1)
+ |> Enum.map(&String.downcase/1)
+ |> Enum.join("_")
+ end
+
+ def handle_info(info, state) do
+ Logger.debug("unhandled info: #{inspect info}")
+ {:noreply, state}
+ end
+
+ defp now(station, m) when is_binary(station) do
+ case HTTPoison.get(np_url(station), [], []) do
+ {:ok, %HTTPoison.Response{status_code: 200, body: body}} ->
+ json = Poison.decode!(body)
+ song? = !!get_in(json, ["now", "song"])
+ station = reformat_station_name(get_in(json, ["now", "stationName"]))
+ now_title = get_in(json, ["now", "firstLine", "title"])
+ now_subtitle = get_in(json, ["now", "secondLine", "title"])
+ next_title = get_in(json, ["next", "firstLine", "title"])
+ next_subtitle = get_in(json, ["next", "secondLine", "title"])
+ next_song? = !!get_in(json, ["next", "song"])
+ next_at = get_in(json, ["next", "startTime"])
+
+ now = format_title(song?, now_title, now_subtitle)
+ prefix = if song?, do: "🎶", else: "🎤"
+ m.replyfun.("#{prefix} #{station}: #{now}")
+
+ next = format_title(song?, next_title, next_subtitle)
+ if next do
+ next_prefix = if next_at do
+ next_date = DateTime.from_unix!(next_at)
+ in_seconds = DateTime.diff(next_date, DateTime.utc_now())
+ in_minutes = ceil(in_seconds / 60)
+ if in_minutes >= 5 do
+ if next_song?, do: "#{in_minutes}m 🔜", else: "dans #{in_minutes} minutes:"
+ else
+ if next_song?, do: "🔜", else: "suivi de:"
+ end
+ else
+ if next_song?, do: "🔜", else: "à suivre:"
+ end
+ m.replyfun.("#{next_prefix} #{next}")
+ end
+
+ {:error, %HTTPoison.Response{status_code: 404}} ->
+ m.replyfun.("radiofrance: la radio \"#{station}\" n'existe pas")
+
+ {:error, %HTTPoison.Response{status_code: code}} ->
+ m.replyfun.("radiofrance: erreur http #{code}")
+
+ _ ->
+ m.replyfun.("radiofrance: ça n'a pas marché, rip")
+ end
+ end
+
+ defp np_url(station), do: "https://www.radiofrance.fr/api/v2.0/stations/#{station}/live"
+
+ defp unalias("inter"), do: "franceinter"
+ defp unalias("info"), do: "franceinfo"
+ defp unalias("bleu"), do: "francebleu"
+ defp unalias("culture"), do: "franceculture"
+ defp unalias("musique"), do: "francemusique"
+ defp unalias(station), do: station
+
+ defp format_title(_, nil, nil) do
+ nil
+ end
+ defp format_title(true, title, artist) do
+ [artist, title] |> Enum.filter(& &1) |> Enum.join(" - ")
+ end
+ defp format_title(false, show, section) do
+ [show, section] |> Enum.filter(& &1) |> Enum.join(": ")
+ end
+
+ defp reformat_station_name(station) do
+ station
+ |> String.replace("france", "france ")
+ |> String.replace("_", " ")
+ end
+
+end

File Metadata

Mime Type
text/x-diff
Expires
Sun, Apr 27, 12:17 PM (14 h, 22 m)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
38851
Default Alt Text
(4 KB)

Event Timeline