summaryrefslogtreecommitdiff
path: root/lib/plugins/alcoolog_announcer.ex
diff options
context:
space:
mode:
Diffstat (limited to 'lib/plugins/alcoolog_announcer.ex')
-rw-r--r--lib/plugins/alcoolog_announcer.ex354
1 files changed, 202 insertions, 152 deletions
diff --git a/lib/plugins/alcoolog_announcer.ex b/lib/plugins/alcoolog_announcer.ex
index f172d85..452f56c 100644
--- a/lib/plugins/alcoolog_announcer.ex
+++ b/lib/plugins/alcoolog_announcer.ex
@@ -27,19 +27,21 @@ defmodule Nola.Plugins.AlcoologAnnouncer do
def start_link(), do: GenServer.start_link(__MODULE__, [], name: __MODULE__)
def log(account) do
- dets_filename = (Nola.data_path() <> "/" <> "alcoologlog.dets") |> String.to_charlist
- {:ok, dets} = :dets.open_file(dets_filename, [{:type,:bag}])
+ dets_filename = (Nola.data_path() <> "/" <> "alcoologlog.dets") |> String.to_charlist()
+ {:ok, dets} = :dets.open_file(dets_filename, [{:type, :bag}])
from = ~U[2020-08-23 19:41:40.524154Z]
to = ~U[2020-08-24 19:41:40.524154Z]
+
select = [
- {{:"$1", :"$2", :_},
- [
- {:andalso,
- {:andalso, {:==, :"$1", {:const, account.id}},
- {:>, :"$2", {:const, DateTime.to_unix(from)}}},
- {:<, :"$2", {:const, DateTime.to_unix(to)}}}
- ], [:"$_"]}
+ {{:"$1", :"$2", :_},
+ [
+ {:andalso,
+ {:andalso, {:==, :"$1", {:const, account.id}},
+ {:>, :"$2", {:const, DateTime.to_unix(from)}}},
+ {:<, :"$2", {:const, DateTime.to_unix(to)}}}
+ ], [:"$_"]}
]
+
res = :dets.select(dets, select)
:dets.close(dets)
res
@@ -49,25 +51,30 @@ defmodule Nola.Plugins.AlcoologAnnouncer do
{:ok, _} = Registry.register(Nola.PubSub, "account", [])
stats = get_stats()
Process.send_after(self(), :stats, :timer.seconds(30))
- dets_filename = (Nola.data_path() <> "/" <> "alcoologlog.dets") |> String.to_charlist
- {:ok, dets} = :dets.open_file(dets_filename, [{:type,:bag}])
- ets = nil # :ets.new(__MODULE__.ETS, [:ordered_set, :named_table, :protected, {:read_concurrency, true}])
- {:ok, {stats, now(), dets, ets}}#, {:continue, :traverse}}
+ dets_filename = (Nola.data_path() <> "/" <> "alcoologlog.dets") |> String.to_charlist()
+ {:ok, dets} = :dets.open_file(dets_filename, [{:type, :bag}])
+
+ # :ets.new(__MODULE__.ETS, [:ordered_set, :named_table, :protected, {:read_concurrency, true}])
+ ets = nil
+ # , {:continue, :traverse}}
+ {:ok, {stats, now(), dets, ets}}
end
def handle_continue(:traverse, state = {_, _, dets, ets}) do
- traverse_fun = fn(obj, dets) ->
+ traverse_fun = fn obj, dets ->
case obj do
{nick, %DateTime{} = dt, active} ->
:dets.delete_object(dets, obj)
:dets.insert(dets, {nick, DateTime.to_unix(dt), active})
- IO.puts("ok #{inspect obj}")
+ IO.puts("ok #{inspect(obj)}")
dets
+
{nick, ts, value} ->
- :ets.insert(ets, { {nick, ts}, value })
+ :ets.insert(ets, {{nick, ts}, value})
dets
end
end
+
:dets.foldl(traverse_fun, dets, dets)
:dets.sync(dets)
IO.puts("alcoolog announcer fixed")
@@ -75,166 +82,210 @@ defmodule Nola.Plugins.AlcoologAnnouncer do
end
def alcohol_reached(old, new, level) do
- (old.active < level && new.active >= level) && (new.active5m >= level)
- end
+ old.active < level && new.active >= level && new.active5m >= level
+ end
def alcohol_below(old, new, level) do
- (old.active > level && new.active <= level) && (new.active5m <= level)
- end
-
+ old.active > level && new.active <= level && new.active5m <= level
+ end
def handle_info(:stats, {old_stats, old_now, dets, ets}) do
stats = get_stats()
now = now()
if old_now.hour < 18 && now.hour == 18 do
- apero = Enum.shuffle(@apero)
- |> Enum.random()
+ apero =
+ Enum.shuffle(@apero)
+ |> Enum.random()
case apero do
{:timed, list} ->
- spawn(fn() ->
+ spawn(fn ->
for line <- list do
Nola.Irc.Connection.broadcast_message("evolu.net", "#dmz", line)
:timer.sleep(:timer.seconds(5))
end
end)
+
string ->
Nola.Irc.Connection.broadcast_message("evolu.net", "#dmz", string)
end
-
end
- #IO.puts "newstats #{inspect stats}"
- events = for {acct, old} <- old_stats do
- new = Map.get(stats, acct, nil)
- #IO.puts "#{acct}: #{inspect(old)} -> #{inspect(new)}"
-
- now = DateTime.to_unix(DateTime.utc_now())
- if new && new[:active] do
- :dets.insert(dets, {acct, now, new[:active]})
- :ets.insert(ets, {{acct, now}, new[:active]})
- else
- :dets.insert(dets, {acct, now, 0.0})
- :ets.insert(ets, {{acct, now}, new[:active]})
- end
+ # IO.puts "newstats #{inspect stats}"
+ events =
+ for {acct, old} <- old_stats do
+ new = Map.get(stats, acct, nil)
+ # IO.puts "#{acct}: #{inspect(old)} -> #{inspect(new)}"
+
+ now = DateTime.to_unix(DateTime.utc_now())
+
+ if new && new[:active] do
+ :dets.insert(dets, {acct, now, new[:active]})
+ :ets.insert(ets, {{acct, now}, new[:active]})
+ else
+ :dets.insert(dets, {acct, now, 0.0})
+ :ets.insert(ets, {{acct, now}, new[:active]})
+ end
+
+ event =
+ cond do
+ old == nil -> nil
+ old.active > 0 && new == nil -> :sober
+ new == nil -> nil
+ alcohol_reached(old, new, 0.5) -> :stopconduire
+ alcohol_reached(old, new, 1.0) -> :g1
+ alcohol_reached(old, new, 2.0) -> :g2
+ alcohol_reached(old, new, 3.0) -> :g3
+ alcohol_reached(old, new, 4.0) -> :g4
+ alcohol_reached(old, new, 5.0) -> :g5
+ alcohol_reached(old, new, 6.0) -> :g6
+ alcohol_reached(old, new, 7.0) -> :g7
+ alcohol_reached(old, new, 10.0) -> :g10
+ alcohol_reached(old, new, 13.74) -> :record
+ alcohol_below(old, new, 0.5) -> :conduire
+ alcohol_below(old, new, 1.0) -> :fini1g
+ alcohol_below(old, new, 2.0) -> :fini2g
+ alcohol_below(old, new, 3.0) -> :fini3g
+ alcohol_below(old, new, 4.0) -> :fini4g
+ old.rising && !new.rising -> :lowering
+ true -> nil
+ end
- event = cond do
- old == nil -> nil
- (old.active > 0) && (new == nil) -> :sober
- new == nil -> nil
- alcohol_reached(old, new, 0.5) -> :stopconduire
- alcohol_reached(old, new, 1.0) -> :g1
- alcohol_reached(old, new, 2.0) -> :g2
- alcohol_reached(old, new, 3.0) -> :g3
- alcohol_reached(old, new, 4.0) -> :g4
- alcohol_reached(old, new, 5.0) -> :g5
- alcohol_reached(old, new, 6.0) -> :g6
- alcohol_reached(old, new, 7.0) -> :g7
- alcohol_reached(old, new, 10.0) -> :g10
- alcohol_reached(old, new, 13.74) -> :record
- alcohol_below(old, new, 0.5) -> :conduire
- alcohol_below(old, new, 1.0) -> :fini1g
- alcohol_below(old, new, 2.0) -> :fini2g
- alcohol_below(old, new, 3.0) -> :fini3g
- alcohol_below(old, new, 4.0) -> :fini4g
- (old.rising) && (!new.rising) -> :lowering
- true -> nil
+ {acct, event}
end
- {acct, event}
- end
for {acct, event} <- events do
- message = case event do
- :g1 -> [
- "[vigicuite jaune] LE GRAMME! LE GRAMME O/",
- "début de vigicuite jaune ! LE GRAMME ! \\O/",
- "waiiiiiiii le grammmeee",
- "bourraiiiiiiiiiiide 1 grammeeeeeeeeeee",
- ]
- :g2 -> [
- "[vigicuite orange] \\o_YAY 2 GRAMMES ! _o/",
- "PAITAIIIIIIIIII DEUX GRAMMEESSSSSSSSSSSSSSSSS",
- "bourrrrrraiiiiiiiiiiiiiiiide 2 grammeeeeeeeeeees",
- ]
- :g3 -> [
- "et un ! et deux ! et TROIS GRAMMEEESSSSSSS",
- "[vigicuite rouge] _o/ BOURRAIIDDDEEEE 3 GRAMMESSSSSSSSS \\o/ \\o/"
- ]
- :g4 -> [
- "[vigicuite écarlate] et un, et deux, et trois, ET QUATRES GRAMMEESSSSSSSSSSSSSSSSSSSssssss"
- ]
- :g5 -> "[vigicuite écarlate+] PUTAIN 5 GRAMMES !"
- :g6 -> "[vigicuite écarlate++] 6 grammes ? Vous pouvez joindre Alcool info service au 0 980 980 930"
- :g7 -> "[vigicuite c'est la merde] 7 grammes. Le SAMU, c'est le 15."
- :g10 -> "BORDLE 10 GRAMMES"
- :record -> "RECORD DU MONDE BATTU ! >13.74g/l !!"
- :fini1g -> [
- "fin d'alerte vigicuite jaune, passage en vert (<1g/l)",
- "/!\\ alerte moins de 1g/l /!\\"
- ]
- :fini2g -> [
- "t'as moins de 2 g/l, faut se reprendre là [vigicuite jaune]"
- ]
- :fini3g -> [
- "fin d'alerte vigicuite rouge, passage en orange (<3g/l)"
- ]
- :fini4g -> [
- "fin d'alerte vigicuite écarlate, passage en rouge (<4g/l)"
- ]
- :lowering -> [
- "attention ça baisse!",
- "tu vas quand même pas en rester là ?",
- "IL FAUT CONTINUER À BOIRE !",
- "t'abandonnes déjà ?",
- "!santai ?",
- "faut pas en rester là",
- "il faut se resservir",
- "coucou faut reboire",
- "encore un petit verre ?",
- "abwaaaaaaaaaaaaarrrrrrrrrrrrrr",
- "taux d'alcoolémie en chute ! agissez avant qu'il soit trop tard!",
- "ÇA BAISSE !!"
- ]
- :stopconduire -> [
- "0.5g! bientot le gramme?",
- "tu peux plus prendre la route... mais... tu peux prendre la route du gramme! !santai !",
- "fini la conduite!",
- "0.5! continues faut pas en rester là!",
- "beau début, continues !",
- "ça monte! 0.5g/l!"
- ]
- :conduire -> [
- "tu peux conduire, ou recommencer à boire! niveau critique!",
- "!santai ?",
- "tu peux reprendre la route, ou reprendre la route du gramme..",
- "attention, niveau critique!",
- "il faut boire !!",
- "trop de sang dans ton alcool, c'est mauvais pour la santé",
- "faut pas en rester là !",
- ]
- :sober -> [
- "sobre…",
- "/!\\ alerte sobriété /!\\",
- "... sobre?!?!",
- "sobre :(",
- "attention, t'es sobre :/",
- "danger, alcoolémie à 0.0 !",
- "sobre! c'était bien on recommence quand ?",
- "sobre ? Faut recommencer...",
- "T'es sobre. Ne te laisses pas abattre- ton caviste peut aider.",
- "Vous êtes sobre ? Ceci n'est pas une fatalité - resservez vous vite !"
- ]
- _ -> nil
- end
- message = case message do
- m when is_binary(m) -> m
- m when is_list(m) -> m |> Enum.shuffle() |> Enum.random()
- nil -> nil
- end
+ message =
+ case event do
+ :g1 ->
+ [
+ "[vigicuite jaune] LE GRAMME! LE GRAMME O/",
+ "début de vigicuite jaune ! LE GRAMME ! \\O/",
+ "waiiiiiiii le grammmeee",
+ "bourraiiiiiiiiiiide 1 grammeeeeeeeeeee"
+ ]
+
+ :g2 ->
+ [
+ "[vigicuite orange] \\o_YAY 2 GRAMMES ! _o/",
+ "PAITAIIIIIIIIII DEUX GRAMMEESSSSSSSSSSSSSSSSS",
+ "bourrrrrraiiiiiiiiiiiiiiiide 2 grammeeeeeeeeeees"
+ ]
+
+ :g3 ->
+ [
+ "et un ! et deux ! et TROIS GRAMMEEESSSSSSS",
+ "[vigicuite rouge] _o/ BOURRAIIDDDEEEE 3 GRAMMESSSSSSSSS \\o/ \\o/"
+ ]
+
+ :g4 ->
+ [
+ "[vigicuite écarlate] et un, et deux, et trois, ET QUATRES GRAMMEESSSSSSSSSSSSSSSSSSSssssss"
+ ]
+
+ :g5 ->
+ "[vigicuite écarlate+] PUTAIN 5 GRAMMES !"
+
+ :g6 ->
+ "[vigicuite écarlate++] 6 grammes ? Vous pouvez joindre Alcool info service au 0 980 980 930"
+
+ :g7 ->
+ "[vigicuite c'est la merde] 7 grammes. Le SAMU, c'est le 15."
+
+ :g10 ->
+ "BORDLE 10 GRAMMES"
+
+ :record ->
+ "RECORD DU MONDE BATTU ! >13.74g/l !!"
+
+ :fini1g ->
+ [
+ "fin d'alerte vigicuite jaune, passage en vert (<1g/l)",
+ "/!\\ alerte moins de 1g/l /!\\"
+ ]
+
+ :fini2g ->
+ [
+ "t'as moins de 2 g/l, faut se reprendre là [vigicuite jaune]"
+ ]
+
+ :fini3g ->
+ [
+ "fin d'alerte vigicuite rouge, passage en orange (<3g/l)"
+ ]
+
+ :fini4g ->
+ [
+ "fin d'alerte vigicuite écarlate, passage en rouge (<4g/l)"
+ ]
+
+ :lowering ->
+ [
+ "attention ça baisse!",
+ "tu vas quand même pas en rester là ?",
+ "IL FAUT CONTINUER À BOIRE !",
+ "t'abandonnes déjà ?",
+ "!santai ?",
+ "faut pas en rester là",
+ "il faut se resservir",
+ "coucou faut reboire",
+ "encore un petit verre ?",
+ "abwaaaaaaaaaaaaarrrrrrrrrrrrrr",
+ "taux d'alcoolémie en chute ! agissez avant qu'il soit trop tard!",
+ "ÇA BAISSE !!"
+ ]
+
+ :stopconduire ->
+ [
+ "0.5g! bientot le gramme?",
+ "tu peux plus prendre la route... mais... tu peux prendre la route du gramme! !santai !",
+ "fini la conduite!",
+ "0.5! continues faut pas en rester là!",
+ "beau début, continues !",
+ "ça monte! 0.5g/l!"
+ ]
+
+ :conduire ->
+ [
+ "tu peux conduire, ou recommencer à boire! niveau critique!",
+ "!santai ?",
+ "tu peux reprendre la route, ou reprendre la route du gramme..",
+ "attention, niveau critique!",
+ "il faut boire !!",
+ "trop de sang dans ton alcool, c'est mauvais pour la santé",
+ "faut pas en rester là !"
+ ]
+
+ :sober ->
+ [
+ "sobre…",
+ "/!\\ alerte sobriété /!\\",
+ "... sobre?!?!",
+ "sobre :(",
+ "attention, t'es sobre :/",
+ "danger, alcoolémie à 0.0 !",
+ "sobre! c'était bien on recommence quand ?",
+ "sobre ? Faut recommencer...",
+ "T'es sobre. Ne te laisses pas abattre- ton caviste peut aider.",
+ "Vous êtes sobre ? Ceci n'est pas une fatalité - resservez vous vite !"
+ ]
+
+ _ ->
+ nil
+ end
+
+ message =
+ case message do
+ m when is_binary(m) -> m
+ m when is_list(m) -> m |> Enum.shuffle() |> Enum.random()
+ nil -> nil
+ end
+
if message do
- #IO.puts("#{acct}: #{message}")
+ # IO.puts("#{acct}: #{message}")
account = Nola.Account.get(acct)
+
for {net, chan} <- Nola.Membership.notify_channels(account) do
user = Nola.UserTrack.find_by_account(net, account)
nick = if(user, do: user.nick, else: account.name)
@@ -245,8 +296,8 @@ defmodule Nola.Plugins.AlcoologAnnouncer do
timer()
- #IO.puts "tick stats ok"
- {:noreply, {stats,now,dets,ets}}
+ # IO.puts "tick stats ok"
+ {:noreply, {stats, now, dets, ets}}
end
def handle_info(_, state) do
@@ -265,5 +316,4 @@ defmodule Nola.Plugins.AlcoologAnnouncer do
defp timer() do
Process.send_after(self(), :stats, :timer.seconds(@seconds))
end
-
end
generated by cgit v1.2.3 (git 2.25.1) at 2025-08-31 06:39:57 +0000