This commit is contained in:
mattyatea 2024-04-02 22:44:12 +09:00
parent b1c751fa3a
commit 103c4190eb
3 changed files with 4 additions and 3 deletions

View file

@ -28,6 +28,7 @@ export class AccountUpdateService {
@bindThis
public async publishToFollowers(userId: MiUser['id']) {
console.time('AccountUpdateService.publishToFollowers');
const user = await this.usersRepository.findOneBy({ id: userId });
if (user == null) throw new Error('user not found');
@ -37,5 +38,6 @@ export class AccountUpdateService {
this.apDeliverManagerService.deliverToFollowers(user, content);
this.relayService.deliverToRelays(user, content);
}
console.timeEnd('AccountUpdateService.publishToFollowers');
}
}

View file

@ -344,7 +344,9 @@ export class GlobalEventService {
@bindThis
public publishMainStream<K extends keyof MainEventTypes>(userId: MiUser['id'], type: K, value?: MainEventTypes[K]): void {
console.time('GlobalEventService.publishMainStream');
this.publish(`mainStream:${userId}`, type, typeof value === 'undefined' ? null : value);
console.time('GlobalEventService.publishMainStream');
}
@bindThis