user: implement dynamic refresh of profiles (gets rid of need for fix_ap_users task)

This commit is contained in:
William Pitcock 2018-09-19 06:13:18 +00:00 committed by kaniini
parent f2727e23ee
commit c9f6eb9a41
2 changed files with 28 additions and 2 deletions

View File

@ -22,6 +22,7 @@ defmodule Pleroma.User do
field(:info, :map, default: %{}) field(:info, :map, default: %{})
field(:follower_address, :string) field(:follower_address, :string)
field(:search_distance, :float, virtual: true) field(:search_distance, :float, virtual: true)
field(:last_refreshed_at, :naive_datetime)
has_many(:notifications, Notification) has_many(:notifications, Notification)
timestamps() timestamps()
@ -112,8 +113,12 @@ def update_changeset(struct, params \\ %{}) do
end end
def upgrade_changeset(struct, params \\ %{}) do def upgrade_changeset(struct, params \\ %{}) do
params =
params
|> Map.put(:last_refreshed_at, NaiveDateTime.utc_now())
struct struct
|> cast(params, [:bio, :name, :info, :follower_address, :avatar]) |> cast(params, [:bio, :name, :info, :follower_address, :avatar, :last_refreshed_at])
|> unique_constraint(:nickname) |> unique_constraint(:nickname)
|> validate_format(:nickname, ~r/^[a-zA-Z\d]+$/) |> validate_format(:nickname, ~r/^[a-zA-Z\d]+$/)
|> validate_length(:bio, max: 5000) |> validate_length(:bio, max: 5000)
@ -169,6 +174,16 @@ def register_changeset(struct, params \\ %{}) do
end end
end end
def needs_update?(%User{local: true}), do: false
def needs_update?(%User{local: false, last_refreshed_at: nil}), do: true
def needs_update?(%User{local: false} = user) do
NaiveDateTime.diff(NaiveDateTime.utc_now(), user.last_refreshed_at) >= 86400
end
def needs_update?(_), do: true
def maybe_direct_follow(%User{} = follower, %User{info: info} = followed) do def maybe_direct_follow(%User{} = follower, %User{info: info} = followed) do
user_config = Application.get_env(:pleroma, :user) user_config = Application.get_env(:pleroma, :user)
deny_follow_blocked = Keyword.get(user_config, :deny_follow_blocked) deny_follow_blocked = Keyword.get(user_config, :deny_follow_blocked)
@ -655,7 +670,9 @@ def delete(%User{} = user) do
end end
def get_or_fetch_by_ap_id(ap_id) do def get_or_fetch_by_ap_id(ap_id) do
if user = get_by_ap_id(ap_id) do user = get_by_ap_id(ap_id)
if !is_nil(user) and !User.needs_update?(user) do
user user
else else
ap_try = ActivityPub.make_user_from_ap_id(ap_id) ap_try = ActivityPub.make_user_from_ap_id(ap_id)

View File

@ -0,0 +1,9 @@
defmodule Pleroma.Repo.Migrations.UsersAddLastRefreshedAt do
use Ecto.Migration
def change do
alter table(:users) do
add :last_refreshed_at, :naive_datetime
end
end
end