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

195 lines
5.8 KiB
TypeScript
Raw Normal View History

/*
* SPDX-FileCopyrightText: syuilo and other misskey contributors
* SPDX-License-Identifier: AGPL-3.0-only
*/
2022-09-17 20:27:08 +02:00
import { Inject, Injectable } from '@nestjs/common';
2023-04-14 06:50:05 +02:00
import * as Redis from 'ioredis';
import type { MiAntenna } from '@/models/entities/Antenna.js';
import type { MiNote } from '@/models/entities/Note.js';
import type { MiUser } from '@/models/entities/User.js';
2022-09-17 20:27:08 +02:00
import { GlobalEventService } from '@/core/GlobalEventService.js';
import * as Acct from '@/misc/acct.js';
2023-03-10 06:22:37 +01:00
import type { Packed } from '@/misc/json-schema.js';
2022-09-17 20:27:08 +02:00
import { DI } from '@/di-symbols.js';
import type { AntennasRepository, UserListJoiningsRepository } from '@/models/index.js';
2022-12-04 02:16:03 +01:00
import { UtilityService } from '@/core/UtilityService.js';
import { bindThis } from '@/decorators.js';
import { StreamMessages } from '@/server/api/stream/types.js';
import type { OnApplicationShutdown } from '@nestjs/common';
2022-09-17 20:27:08 +02:00
@Injectable()
export class AntennaService implements OnApplicationShutdown {
2022-09-18 20:11:50 +02:00
private antennasFetched: boolean;
private antennas: MiAntenna[];
2022-09-17 20:27:08 +02:00
constructor(
@Inject(DI.redis)
private redisClient: Redis.Redis,
@Inject(DI.redisForSub)
private redisForSub: Redis.Redis,
2022-09-17 20:27:08 +02:00
@Inject(DI.antennasRepository)
private antennasRepository: AntennasRepository,
@Inject(DI.userListJoiningsRepository)
private userListJoiningsRepository: UserListJoiningsRepository,
private utilityService: UtilityService,
2023-02-04 02:02:03 +01:00
private globalEventService: GlobalEventService,
2022-09-17 20:27:08 +02:00
) {
2022-09-18 20:11:50 +02:00
this.antennasFetched = false;
this.antennas = [];
2022-09-17 20:27:08 +02:00
this.redisForSub.on('message', this.onRedisMessage);
2022-09-17 20:27:08 +02:00
}
@bindThis
2022-09-23 23:45:44 +02:00
private async onRedisMessage(_: string, data: string): Promise<void> {
2022-09-17 20:27:08 +02:00
const obj = JSON.parse(data);
if (obj.channel === 'internal') {
const { type, body } = obj.message as StreamMessages['internal']['payload'];
2022-09-17 20:27:08 +02:00
switch (type) {
case 'antennaCreated':
2023-01-25 03:18:16 +01:00
this.antennas.push({
...body,
createdAt: new Date(body.createdAt),
lastUsedAt: new Date(body.lastUsedAt),
2023-01-25 03:18:16 +01:00
});
2022-09-17 20:27:08 +02:00
break;
case 'antennaUpdated':
2023-01-25 03:18:16 +01:00
this.antennas[this.antennas.findIndex(a => a.id === body.id)] = {
...body,
createdAt: new Date(body.createdAt),
lastUsedAt: new Date(body.lastUsedAt),
2023-01-25 03:18:16 +01:00
};
2022-09-17 20:27:08 +02:00
break;
case 'antennaDeleted':
2022-09-18 20:11:50 +02:00
this.antennas = this.antennas.filter(a => a.id !== body.id);
2022-09-17 20:27:08 +02:00
break;
default:
break;
}
}
}
@bindThis
public async addNoteToAntennas(note: MiNote, noteUser: { id: MiUser['id']; username: string; host: string | null; }): Promise<void> {
const antennas = await this.getAntennas();
const antennasWithMatchResult = await Promise.all(antennas.map(antenna => this.checkHitAntenna(antenna, note, noteUser).then(hit => [antenna, hit] as const)));
const matchedAntennas = antennasWithMatchResult.filter(([, hit]) => hit).map(([antenna]) => antenna);
const redisPipeline = this.redisClient.pipeline();
for (const antenna of matchedAntennas) {
redisPipeline.xadd(
`antennaTimeline:${antenna.id}`,
'MAXLEN', '~', '200',
'*',
'note', note.id);
this.globalEventService.publishAntennaStream(antenna.id, 'note', note);
}
redisPipeline.exec();
2022-09-17 20:27:08 +02:00
}
// NOTE: フォローしているユーザーのノート、リストのユーザーのノート、グループのユーザーのノート指定はパフォーマンス上の理由で無効になっている
@bindThis
public async checkHitAntenna(antenna: MiAntenna, note: (MiNote | Packed<'Note'>), noteUser: { id: MiUser['id']; username: string; host: string | null; }): Promise<boolean> {
2022-09-17 20:27:08 +02:00
if (note.visibility === 'specified') return false;
if (note.visibility === 'followers') return false;
2022-09-17 20:27:08 +02:00
if (!antenna.withReplies && note.replyId != null) return false;
2022-09-17 20:27:08 +02:00
if (antenna.src === 'home') {
// TODO
2022-09-17 20:27:08 +02:00
} else if (antenna.src === 'list') {
const listUsers = (await this.userListJoiningsRepository.findBy({
userListId: antenna.userListId!,
})).map(x => x.userId);
2022-09-17 20:27:08 +02:00
if (!listUsers.includes(note.userId)) return false;
} else if (antenna.src === 'users') {
const accts = antenna.users.map(x => {
const { username, host } = Acct.parse(x);
return this.utilityService.getFullApAccount(username, host).toLowerCase();
});
if (!accts.includes(this.utilityService.getFullApAccount(noteUser.username, noteUser.host).toLowerCase())) return false;
}
2022-09-17 20:27:08 +02:00
const keywords = antenna.keywords
// Clean up
.map(xs => xs.filter(x => x !== ''))
.filter(xs => xs.length > 0);
2022-09-17 20:27:08 +02:00
if (keywords.length > 0) {
if (note.text == null && note.cw == null) return false;
const _text = (note.text ?? '') + '\n' + (note.cw ?? '');
2022-09-17 20:27:08 +02:00
const matched = keywords.some(and =>
and.every(keyword =>
antenna.caseSensitive
? _text.includes(keyword)
: _text.toLowerCase().includes(keyword.toLowerCase()),
2022-09-17 20:27:08 +02:00
));
2022-09-17 20:27:08 +02:00
if (!matched) return false;
}
2022-09-17 20:27:08 +02:00
const excludeKeywords = antenna.excludeKeywords
// Clean up
.map(xs => xs.filter(x => x !== ''))
.filter(xs => xs.length > 0);
2022-09-17 20:27:08 +02:00
if (excludeKeywords.length > 0) {
if (note.text == null && note.cw == null) return false;
const _text = (note.text ?? '') + '\n' + (note.cw ?? '');
2022-09-17 20:27:08 +02:00
const matched = excludeKeywords.some(and =>
and.every(keyword =>
antenna.caseSensitive
? _text.includes(keyword)
: _text.toLowerCase().includes(keyword.toLowerCase()),
2022-09-17 20:27:08 +02:00
));
2022-09-17 20:27:08 +02:00
if (matched) return false;
}
2022-09-17 20:27:08 +02:00
if (antenna.withFile) {
if (note.fileIds && note.fileIds.length === 0) return false;
}
2022-09-17 20:27:08 +02:00
// TODO: eval expression
2022-09-17 20:27:08 +02:00
return true;
}
@bindThis
2022-09-17 20:27:08 +02:00
public async getAntennas() {
2022-09-18 20:11:50 +02:00
if (!this.antennasFetched) {
this.antennas = await this.antennasRepository.findBy({
isActive: true,
});
2022-09-18 20:11:50 +02:00
this.antennasFetched = true;
2022-09-17 20:27:08 +02:00
}
2022-09-18 20:11:50 +02:00
return this.antennas;
2022-09-17 20:27:08 +02:00
}
2023-05-29 06:21:26 +02:00
@bindThis
public dispose(): void {
this.redisForSub.off('message', this.onRedisMessage);
}
@bindThis
public onApplicationShutdown(signal?: string | undefined): void {
this.dispose();
}
2022-09-17 20:27:08 +02:00
}