FoundKeyGang/FoundKey
FoundKeyGang/FoundKey
7
19
Fork 22
Code Issues 37 Pull requests 4 Releases Activity

fix: missing paren, type error

Browse source
This commit is contained in:
Johann150 2023-02-01 23:35:18 +01:00
parent 4312393169
commit e584937b4f
Signed by: Johann150
GPG key ID: 9EE6577A2A06F8F1
2 changed files with 4 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
packages/backend/src/queue/index.ts
View file

@ -340,7 +340,7 @@ export default function() {
export function destroy() { export function destroy() {
deliverQueue.once('cleaned', async (jobs, status) => { deliverQueue.once('cleaned', async (jobs, status) => {
deliverLogger.succ(`Cleaned ${jobs.length} ${status} jobs`); deliverLogger.succ(`Cleaned ${jobs.length} ${status} jobs`);
await Promise.all(jobs.map(job => deletionRefCount(job)); await Promise.all(jobs.map(job => deletionRefCount(job)));
}); });
deliverQueue.clean(0, 'delayed'); deliverQueue.clean(0, 'delayed');

6
packages/backend/src/remote/activitypub/deliver-manager.ts
View file

@ -150,17 +150,17 @@ export class DeliverManager {
)), )),
); );
inboxes = inboxes.entries() const filteredInboxes = Array.from(inboxes)
.filter(inbox => !instancesToSkip.includes(new URL(inbox).host)); .filter(inbox => !instancesToSkip.includes(new URL(inbox).host));
if (deletingUserId) { if (deletingUserId) {
await Users.update(deletingUserId, { await Users.update(deletingUserId, {
// set deletion job count for reference counting before queueing jobs // set deletion job count for reference counting before queueing jobs
isDeleted: inboxes.length, isDeleted: filteredInboxes.length,
}); });
} }
inboxes.forEach(inbox => deliver(this.actor, this.activity, inbox, deletingUserId)); filteredInboxes.forEach(inbox => deliver(this.actor, this.activity, inbox, deletingUserId));
} }
} }