misty.cafe/mistykey
1
0
Fork 0
Code Issues Pull requests 1 Projects Releases Packages Wiki Activity Actions

run account move steps 1-at-a-time

Browse source
This commit is contained in:
Hazelnoot 2025-09-14 10:23:11 -04:00
parent 958ce72249
commit be3c911e48
1 changed files with 12 additions and 20 deletions
Download patch file Download diff file Expand all files Collapse all files

32
packages/backend/src/core/AccountMoveService.ts
View file

@ -136,26 +136,18 @@ export class AccountMoveService {
@bindThis @bindThis
public async postMoveProcess(src: MiUser, dst: MiUser): Promise<void> { public async postMoveProcess(src: MiUser, dst: MiUser): Promise<void> {
// Copy blockings and mutings, and update lists // Copy blockings and mutings, and update lists
try { await this.copyBlocking(src, dst)
const results = await Promise.allSettled([ .catch(err => this.logger.warn(`Error copying blockings in migration ${src.id} (@${src.usernameLower}@${src.host}) to ${dst.id} (@${dst.usernameLower}@${dst.host}): ${renderInlineError(err)}`));
this.copyBlocking(src, dst), await this.copyMutings(src, dst)
this.copyMutings(src, dst), .catch(err => this.logger.warn(`Error copying mutings in migration ${src.id} (@${src.usernameLower}@${src.host}) to ${dst.id} (@${dst.usernameLower}@${dst.host}): ${renderInlineError(err)}`));
this.deleteScheduledNotes(src), await this.deleteScheduledNotes(src)
this.copyRoles(src, dst), .catch(err => this.logger.warn(`Error deleting scheduled notes in migration ${src.id} (@${src.usernameLower}@${src.host}) to ${dst.id} (@${dst.usernameLower}@${dst.host}): ${renderInlineError(err)}`));
this.updateLists(src, dst), await this.copyRoles(src, dst)
this.antennaService.onMoveAccount(src, dst), .catch(err => this.logger.warn(`Error copying roles in migration ${src.id} (@${src.usernameLower}@${src.host}) to ${dst.id} (@${dst.usernameLower}@${dst.host}): ${renderInlineError(err)}`));
]); await this.updateLists(src, dst)
.catch(err => this.logger.warn(`Error updating lists in migration ${src.id} (@${src.usernameLower}@${src.host}) to ${dst.id} (@${dst.usernameLower}@${dst.host}): ${renderInlineError(err)}`));
// Log errors, but keep moving await this.antennaService.onMoveAccount(src, dst)
for (const result of results) { .catch(err => this.logger.warn(`Error updating antennas in migration ${src.id} (@${src.usernameLower}@${src.host}) to ${dst.id} (@${dst.usernameLower}@${dst.host}): ${renderInlineError(err)}`));
if (result.status === 'rejected') {
this.logger.warn(`Non-fatal exception in migration from ${src.id} (@${src.usernameLower}@${src.host}) to ${dst.id} (@${dst.usernameLower}@${dst.host}): ${renderInlineError(result.reason)}`);
}
}
} catch (err) {
/* skip if any error happens */
this.logger.warn(`Non-fatal exception in migration from ${src.id} (@${src.usernameLower}@${src.host}) to ${dst.id} (@${dst.usernameLower}@${dst.host}): ${renderInlineError(err)}`);
}
// follow the new account // follow the new account
const proxy = await this.systemAccountService.fetch('proxy'); const proxy = await this.systemAccountService.fetch('proxy');