1 # Pleroma: A lightweight social networking server
2 # Copyright © 2017-2019 Pleroma Authors <https://pleroma.social/>
3 # SPDX-License-Identifier: AGPL-3.0-only
5 defmodule Pleroma.UserInviteToken do
11 alias Pleroma.UserInviteToken
13 @type token :: String.t()
15 schema "user_invite_tokens" do
16 field(:token, :string)
17 field(:used, :boolean, default: false)
18 field(:max_use, :integer)
19 field(:expire_at, :date)
20 field(:uses, :integer, default: 0)
21 field(:invite_type, :string)
26 @spec create_invite(map()) :: UserInviteToken.t()
27 def create_invite(params \\ %{}) do
29 |> cast(params, ~w(max_use expire_at)a)
35 defp add_token(changeset) do
36 token = :crypto.strong_rand_bytes(32) |> Base.url_encode64()
37 put_change(changeset, :token, token)
40 defp assign_type(%{changes: %{max_use: _max_use, expire_at: _expire_at}} = changeset) do
41 put_change(changeset, :invite_type, "reusable_date_limited")
44 defp assign_type(%{changes: %{expire_at: _expire_at}} = changeset) do
45 put_change(changeset, :invite_type, "date_limited")
48 defp assign_type(%{changes: %{max_use: _max_use}} = changeset) do
49 put_change(changeset, :invite_type, "reusable")
52 defp assign_type(changeset), do: put_change(changeset, :invite_type, "one_time")
54 @spec list_invites() :: [UserInviteToken.t()]
56 query = from(u in UserInviteToken, order_by: u.id)
60 @spec update_invite!(UserInviteToken.t(), map()) :: UserInviteToken.t() | no_return()
61 def update_invite!(invite, changes) do
62 change(invite, changes) |> Repo.update!()
65 @spec update_invite(UserInviteToken.t(), map()) ::
66 {:ok, UserInviteToken.t()} | {:error, Changeset.t()}
67 def update_invite(invite, changes) do
68 change(invite, changes) |> Repo.update()
71 @spec find_by_token!(token()) :: UserInviteToken.t() | no_return()
72 def find_by_token!(token), do: Repo.get_by!(UserInviteToken, token: token)
74 @spec valid_invite?(UserInviteToken.t()) :: boolean()
75 def valid_invite?(%{invite_type: "one_time"} = invite) do
79 def valid_invite?(%{invite_type: "date_limited"} = invite) do
80 not_overdue_date?(invite) and not invite.used
83 def valid_invite?(%{invite_type: "reusable"} = invite) do
84 invite.uses < invite.max_use and not invite.used
87 def valid_invite?(%{invite_type: "reusable_date_limited"} = invite) do
88 not_overdue_date?(invite) and invite.uses < invite.max_use and not invite.used
91 defp not_overdue_date?(%{expire_at: expire_at} = invite) do
92 Date.compare(Date.utc_today(), expire_at) in [:lt, :eq] ||
93 (update_invite!(invite, %{used: true}) && false)
96 @spec update_usage!(UserInviteToken.t()) :: nil | UserInviteToken.t() | no_return()
97 def update_usage!(%{invite_type: "date_limited"}), do: nil
99 def update_usage!(%{invite_type: "one_time"} = invite),
100 do: update_invite!(invite, %{used: true})
102 def update_usage!(%{invite_type: invite_type} = invite)
103 when invite_type == "reusable" or invite_type == "reusable_date_limited" do
105 uses: invite.uses + 1
109 if changes.uses >= invite.max_use do
110 Map.put(changes, :used, true)
115 update_invite!(invite, changes)