1 # Pleroma: A lightweight social networking server
2 # Copyright © 2017-2020 Pleroma Authors <https://pleroma.social/>
3 # SPDX-License-Identifier: AGPL-3.0-only
5 defmodule Pleroma.Web.OAuth.App do
11 @type t :: %__MODULE__{}
14 field(:client_name, :string)
15 field(:redirect_uris, :string)
16 field(:scopes, {:array, :string}, default: [])
17 field(:website, :string)
18 field(:client_id, :string)
19 field(:client_secret, :string)
20 field(:trusted, :boolean, default: false)
22 has_many(:oauth_authorizations, Pleroma.Web.OAuth.Authorization, on_delete: :delete_all)
23 has_many(:oauth_tokens, Pleroma.Web.OAuth.Token, on_delete: :delete_all)
28 @spec changeset(App.t(), map()) :: Ecto.Changeset.t()
29 def changeset(struct, params) do
30 cast(struct, params, [:client_name, :redirect_uris, :scopes, :website, :trusted])
33 @spec register_changeset(App.t(), map()) :: Ecto.Changeset.t()
34 def register_changeset(struct, params \\ %{}) do
38 |> validate_required([:client_name, :redirect_uris, :scopes])
40 if changeset.valid? do
44 :crypto.strong_rand_bytes(32) |> Base.url_encode64(padding: false)
48 :crypto.strong_rand_bytes(32) |> Base.url_encode64(padding: false)
55 @spec create(map()) :: {:ok, App.t()} | {:error, Ecto.Changeset.t()}
57 with changeset <- __MODULE__.register_changeset(%__MODULE__{}, params) do
58 Repo.insert(changeset)
62 @spec update(map()) :: {:ok, App.t()} | {:error, Ecto.Changeset.t()}
64 with %__MODULE__{} = app <- Repo.get(__MODULE__, params["id"]),
65 changeset <- changeset(app, params) do
66 Repo.update(changeset)
71 Gets app by attrs or create new with attrs.
72 And updates the scopes if need.
74 @spec get_or_make(map(), list(String.t())) :: {:ok, App.t()} | {:error, Ecto.Changeset.t()}
75 def get_or_make(attrs, scopes) do
76 with %__MODULE__{} = app <- Repo.get_by(__MODULE__, attrs) do
77 update_scopes(app, scopes)
81 |> register_changeset(Map.put(attrs, :scopes, scopes))
86 defp update_scopes(%__MODULE__{} = app, []), do: {:ok, app}
87 defp update_scopes(%__MODULE__{scopes: scopes} = app, scopes), do: {:ok, app}
89 defp update_scopes(%__MODULE__{} = app, scopes) do
91 |> change(%{scopes: scopes})
95 @spec search(map()) :: {:ok, [App.t()], non_neg_integer()}
97 query = from(a in __MODULE__)
100 if params[:client_name] do
101 from(a in query, where: a.client_name == ^params[:client_name])
107 if params[:client_id] do
108 from(a in query, where: a.client_id == ^params[:client_id])
114 if Map.has_key?(params, :trusted) do
115 from(a in query, where: a.trusted == ^params[:trusted])
122 limit: ^params[:page_size],
123 offset: ^((params[:page] - 1) * params[:page_size])
126 count = Repo.aggregate(__MODULE__, :count, :id)
128 {:ok, Repo.all(query), count}
131 @spec destroy(pos_integer()) :: {:ok, App.t()} | {:error, Ecto.Changeset.t()}
133 with %__MODULE__{} = app <- Repo.get(__MODULE__, id) do
138 @spec errors(Ecto.Changeset.t()) :: map()
139 def errors(changeset) do
140 Enum.reduce(changeset.errors, %{}, fn
141 {:client_name, {error, _}}, acc ->
142 Map.put(acc, :name, error)
144 {key, {error, _}}, acc ->
145 Map.put(acc, key, error)