aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorAlexander Strizhakov <alex.strizhakov@gmail.com>2020-08-12 15:15:17 +0300
committerAlexander Strizhakov <alex.strizhakov@gmail.com>2020-08-12 15:15:17 +0300
commiteec1ba232c42285fc69c26b5ccc32c504955eab5 (patch)
tree63af119ba30c82080b790edaaf2e3a4396e74152
parent57b455de5a378d661eb794c2c9d75a2684d74ef3 (diff)
downloadpleroma-eec1ba232c42285fc69c26b5ccc32c504955eab5.tar.gz
don't expire pinned posts
-rw-r--r--lib/mix/tasks/pleroma/database.ex8
1 files changed, 6 insertions, 2 deletions
diff --git a/lib/mix/tasks/pleroma/database.ex b/lib/mix/tasks/pleroma/database.ex
index 7d8f00b08..0142071a8 100644
--- a/lib/mix/tasks/pleroma/database.ex
+++ b/lib/mix/tasks/pleroma/database.ex
@@ -150,8 +150,12 @@ defmodule Mix.Tasks.Pleroma.Database do
|> Pleroma.RepoStreamer.chunk_stream(100)
|> Stream.each(fn activities ->
Enum.each(activities, fn activity ->
- expires_at = Timex.shift(activity.inserted_at, days: days)
- Pleroma.ActivityExpiration.create(activity, expires_at, false)
+ user = User.get_cached_by_ap_id(activity.actor)
+
+ if activity.id not in user.pinned_activities do
+ expires_at = Timex.shift(activity.inserted_at, days: days)
+ Pleroma.ActivityExpiration.create(activity, expires_at, false)
+ end
end)
end)
|> Stream.run()