Sharkey/packages/backend/src/core/UserBlockingService.ts

194 lines
6.7 KiB
TypeScript
Raw Normal View History

2022-09-17 21:27:08 +03:00
2023-04-05 07:57:22 +03:00
import { Inject, Injectable, OnModuleInit } from '@nestjs/common';
import { ModuleRef } from '@nestjs/core';
2022-09-17 21:27:08 +03:00
import { IdService } from '@/core/IdService.js';
2023-02-13 08:28:07 +02:00
import type { User } from '@/models/entities/User.js';
2022-09-17 21:27:08 +03:00
import type { Blocking } from '@/models/entities/Blocking.js';
import { QueueService } from '@/core/QueueService.js';
import { GlobalEventService } from '@/core/GlobalEventService.js';
import { DI } from '@/di-symbols.js';
2023-04-05 04:21:10 +03:00
import type { FollowRequestsRepository, BlockingsRepository, UserListsRepository, UserListJoiningsRepository } from '@/models/index.js';
2022-09-24 01:12:11 +03:00
import Logger from '@/logger.js';
2022-12-04 03:16:03 +02:00
import { UserEntityService } from '@/core/entities/UserEntityService.js';
import { ApRendererService } from '@/core/activitypub/ApRendererService.js';
import { LoggerService } from '@/core/LoggerService.js';
import { WebhookService } from '@/core/WebhookService.js';
import { bindThis } from '@/decorators.js';
2023-04-05 04:21:10 +03:00
import { CacheService } from '@/core/CacheService.js';
import { UserFollowingService } from '@/core/UserFollowingService.js';
2022-09-17 21:27:08 +03:00
@Injectable()
2023-04-05 07:57:22 +03:00
export class UserBlockingService implements OnModuleInit {
2022-09-24 01:12:11 +03:00
private logger: Logger;
2023-04-05 07:57:22 +03:00
private userFollowingService: UserFollowingService;
2022-09-24 01:12:11 +03:00
2022-09-17 21:27:08 +03:00
constructor(
2023-04-05 07:57:22 +03:00
private moduleRef: ModuleRef,
2022-09-17 21:27:08 +03:00
@Inject(DI.followRequestsRepository)
private followRequestsRepository: FollowRequestsRepository,
@Inject(DI.blockingsRepository)
private blockingsRepository: BlockingsRepository,
@Inject(DI.userListsRepository)
private userListsRepository: UserListsRepository,
@Inject(DI.userListJoiningsRepository)
private userListJoiningsRepository: UserListJoiningsRepository,
2023-04-05 04:21:10 +03:00
private cacheService: CacheService,
2022-09-17 21:27:08 +03:00
private userEntityService: UserEntityService,
private idService: IdService,
private queueService: QueueService,
2023-02-04 03:02:03 +02:00
private globalEventService: GlobalEventService,
2022-09-17 21:27:08 +03:00
private webhookService: WebhookService,
private apRendererService: ApRendererService,
2022-09-24 01:12:11 +03:00
private loggerService: LoggerService,
2022-09-17 21:27:08 +03:00
) {
2022-09-24 01:12:11 +03:00
this.logger = this.loggerService.getLogger('user-block');
2022-09-17 21:27:08 +03:00
}
2023-04-05 07:57:22 +03:00
onModuleInit() {
this.userFollowingService = this.moduleRef.get('UserFollowingService');
}
@bindThis
2022-09-17 21:27:08 +03:00
public async block(blocker: User, blockee: User) {
await Promise.all([
2022-09-18 21:11:50 +03:00
this.cancelRequest(blocker, blockee),
this.cancelRequest(blockee, blocker),
2023-04-05 04:21:10 +03:00
this.userFollowingService.unfollow(blocker, blockee),
this.userFollowingService.unfollow(blockee, blocker),
2022-09-18 21:11:50 +03:00
this.removeFromList(blockee, blocker),
2022-09-17 21:27:08 +03:00
]);
const blocking = {
id: this.idService.genId(),
createdAt: new Date(),
blocker,
blockerId: blocker.id,
blockee,
blockeeId: blockee.id,
} as Blocking;
await this.blockingsRepository.insert(blocking);
2023-04-05 04:21:10 +03:00
this.cacheService.userBlockingCache.refresh(blocker.id);
this.cacheService.userBlockedCache.refresh(blockee.id);
2023-02-04 05:40:40 +02:00
this.globalEventService.publishInternalEvent('blockingCreated', {
blockerId: blocker.id,
blockeeId: blockee.id,
});
2022-09-17 21:27:08 +03:00
if (this.userEntityService.isLocalUser(blocker) && this.userEntityService.isRemoteUser(blockee)) {
2023-02-12 11:47:30 +02:00
const content = this.apRendererService.addContext(this.apRendererService.renderBlock(blocking));
this.queueService.deliver(blocker, content, blockee.inbox, false);
2022-09-17 21:27:08 +03:00
}
}
@bindThis
2022-09-18 21:11:50 +03:00
private async cancelRequest(follower: User, followee: User) {
2022-09-17 21:27:08 +03:00
const request = await this.followRequestsRepository.findOneBy({
followeeId: followee.id,
followerId: follower.id,
});
if (request == null) {
return;
}
await this.followRequestsRepository.delete({
followeeId: followee.id,
followerId: follower.id,
});
if (this.userEntityService.isLocalUser(followee)) {
this.userEntityService.pack(followee, followee, {
detail: true,
2023-02-04 03:02:03 +02:00
}).then(packed => this.globalEventService.publishMainStream(followee.id, 'meUpdated', packed));
2022-09-17 21:27:08 +03:00
}
if (this.userEntityService.isLocalUser(follower)) {
this.userEntityService.pack(followee, follower, {
detail: true,
}).then(async packed => {
2023-02-04 03:02:03 +02:00
this.globalEventService.publishMainStream(follower.id, 'unfollow', packed);
2022-09-17 21:27:08 +03:00
const webhooks = (await this.webhookService.getActiveWebhooks()).filter(x => x.userId === follower.id && x.on.includes('unfollow'));
for (const webhook of webhooks) {
this.queueService.webhookDeliver(webhook, 'unfollow', {
user: packed,
});
}
});
}
// リモートにフォローリクエストをしていたらUndoFollow送信
if (this.userEntityService.isLocalUser(follower) && this.userEntityService.isRemoteUser(followee)) {
2023-02-12 11:47:30 +02:00
const content = this.apRendererService.addContext(this.apRendererService.renderUndo(this.apRendererService.renderFollow(follower, followee), follower));
this.queueService.deliver(follower, content, followee.inbox, false);
2022-09-17 21:27:08 +03:00
}
// リモートからフォローリクエストを受けていたらReject送信
if (this.userEntityService.isRemoteUser(follower) && this.userEntityService.isLocalUser(followee)) {
2023-02-12 11:47:30 +02:00
const content = this.apRendererService.addContext(this.apRendererService.renderReject(this.apRendererService.renderFollow(follower, followee, request.requestId!), followee));
this.queueService.deliver(followee, content, follower.inbox, false);
2022-09-17 21:27:08 +03:00
}
}
@bindThis
2022-09-18 21:11:50 +03:00
private async removeFromList(listOwner: User, user: User) {
2022-09-17 21:27:08 +03:00
const userLists = await this.userListsRepository.findBy({
userId: listOwner.id,
});
for (const userList of userLists) {
await this.userListJoiningsRepository.delete({
userListId: userList.id,
userId: user.id,
});
}
}
@bindThis
2023-02-13 08:28:07 +02:00
public async unblock(blocker: User, blockee: User) {
2022-09-17 21:27:08 +03:00
const blocking = await this.blockingsRepository.findOneBy({
blockerId: blocker.id,
blockeeId: blockee.id,
});
2022-09-17 21:27:08 +03:00
if (blocking == null) {
2022-09-24 01:12:11 +03:00
this.logger.warn('ブロック解除がリクエストされましたがブロックしていませんでした');
2022-09-17 21:27:08 +03:00
return;
}
2022-09-17 21:27:08 +03:00
// Since we already have the blocker and blockee, we do not need to fetch
// them in the query above and can just manually insert them here.
blocking.blocker = blocker;
blocking.blockee = blockee;
2022-09-17 21:27:08 +03:00
await this.blockingsRepository.delete(blocking.id);
2023-04-05 04:21:10 +03:00
this.cacheService.userBlockingCache.refresh(blocker.id);
this.cacheService.userBlockedCache.refresh(blockee.id);
2023-02-04 05:40:40 +02:00
this.globalEventService.publishInternalEvent('blockingDeleted', {
blockerId: blocker.id,
blockeeId: blockee.id,
});
2022-09-17 21:27:08 +03:00
// deliver if remote bloking
if (this.userEntityService.isLocalUser(blocker) && this.userEntityService.isRemoteUser(blockee)) {
2023-02-12 11:47:30 +02:00
const content = this.apRendererService.addContext(this.apRendererService.renderUndo(this.apRendererService.renderBlock(blocking), blocker));
this.queueService.deliver(blocker, content, blockee.inbox, false);
2022-09-17 21:27:08 +03:00
}
}
2023-02-04 05:40:40 +02:00
@bindThis
public async checkBlocked(blockerId: User['id'], blockeeId: User['id']): Promise<boolean> {
2023-04-05 04:21:10 +03:00
return (await this.cacheService.userBlockingCache.fetch(blockerId)).has(blockeeId);
2023-02-04 05:40:40 +02:00
}
2022-09-17 21:27:08 +03:00
}