1 defmodule Pleroma.Web.Push.Subscription do
4 alias Pleroma.{Repo, User}
5 alias Pleroma.Web.OAuth.Token
6 alias Pleroma.Web.Push.Subscription
8 schema "push_subscriptions" do
9 belongs_to(:user, User)
10 belongs_to(:token, Token)
11 field(:endpoint, :string)
12 field(:key_p256dh, :string)
13 field(:key_auth, :string)
14 field(:data, :map, default: %{})
19 @supported_alert_types ~w[follow favourite mention reblog]
21 defp alerts(%{"data" => %{"alerts" => alerts}}) do
22 alerts = Map.take(alerts, @supported_alert_types)
31 "endpoint" => endpoint,
32 "keys" => %{"auth" => key_auth, "p256dh" => key_p256dh}
36 Repo.insert(%Subscription{
41 key_p256dh: key_p256dh,
46 def get(%User{id: user_id}, %Token{id: token_id}) do
47 Repo.get_by(Subscription, user_id: user_id, token_id: token_id)
50 def update(user, token, params) do
52 |> change(data: alerts(params))
56 def delete(user, token) do
57 Repo.delete(get(user, token))
60 def delete_if_exists(user, token) do
61 case get(user, token) do
63 sub -> Repo.delete(sub)