notfire/Iceshrimp.NET
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

[backend/core] Fix user purge failures (ISH-525)

Browse source
This commit is contained in:
Laura Hausmann 2024-10-11 19:54:04 +02:00
parent c72aa17056
commit bef7dd9855
No known key found for this signature in database
GPG key ID: D044E84C5BE01605
1 changed files with 5 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
Iceshrimp.Backend/Core/Queues/BackgroundTaskQueue.cs
View file

@ -254,7 +254,7 @@ public class BackgroundTaskQueue(int parallelism)
if (user.IsLocalUser) if (user.IsLocalUser)
{ {
var actor = renderer.RenderLite(user); var actor = renderer.RenderLite(user);
var activity = ActivityPub.ActivityRenderer.RenderDelete(actor, actor); var activity = ActivityPub.ActivityRenderer.RenderDelete(actor, actor);
await deliver.DeliverToFollowersAsync(activity, user, []); await deliver.DeliverToFollowersAsync(activity, user, []);
} }
@ -326,7 +326,10 @@ public class BackgroundTaskQueue(int parallelism)
logger.LogDebug("Removing {count} notes for user {id}", noteCnt, user.Id); logger.LogDebug("Removing {count} notes for user {id}", noteCnt, user.Id);
await foreach (var id in noteIds) await foreach (var id in noteIds)
{ {
var note = await db.Notes.AsNoTracking().FirstOrDefaultAsync(p => p.Id == id, cancellationToken: token); var note = await db.Notes.AsNoTracking()
.IncludeCommonProperties()
.FirstOrDefaultAsync(p => p.Id == id, cancellationToken: token);
if (note != null) await noteSvc.DeleteNoteAsync(note); if (note != null) await noteSvc.DeleteNoteAsync(note);
} }