Git of dcc - anni/blob - lib/pleroma/web/o_auth/token/strategy/revoke.ex

   1 # Pleroma: A lightweight social networking server
   2 # Copyright © 2017-2022 Pleroma Authors <https://pleroma.social/>
   3 # SPDX-License-Identifier: AGPL-3.0-only
   4
   5 defmodule Pleroma.Web.OAuth.Token.Strategy.Revoke do
   6   @moduledoc """
   7   Functions for dealing with revocation.
   8   """
   9
  10   alias Pleroma.Repo
  11   alias Pleroma.Web.OAuth.App
  12   alias Pleroma.Web.OAuth.Token
  13
  14   @doc "Finds and revokes access token for app and by token"
  15   @spec revoke(App.t(), map()) :: {:ok, Token.t()} | {:error, :not_found | Ecto.Changeset.t()}
  16   def revoke(%App{} = app, %{"token" => token} = _attrs) do
  17     with {:ok, token} <- Token.get_by_token(app, token),
  18          do: revoke(token)
  19   end
  20
  21   @doc "Revokes access token"
  22   @spec revoke(Token.t()) :: {:ok, Token.t()} | {:error, Ecto.Changeset.t()}
  23   def revoke(%Token{} = token) do
  24     with {:ok, token} <- Repo.delete(token) do
  25       Task.Supervisor.start_child(
  26         Pleroma.TaskSupervisor,
  27         Pleroma.Web.Streamer,
  28         :close_streams_by_oauth_token,
  29         [token],
  30         restart: :transient
  31       )
  32
  33       {:ok, token}
  34     else
  35       result -> result
  36     end
  37   end
  38 end