summaryrefslogtreecommitdiff
path: root/packages/backend/src/core/NoteCreateService.ts
diff options
context:
space:
mode:
Diffstat (limited to 'packages/backend/src/core/NoteCreateService.ts')
-rw-r--r--packages/backend/src/core/NoteCreateService.ts304
1 files changed, 22 insertions, 282 deletions
diff --git a/packages/backend/src/core/NoteCreateService.ts b/packages/backend/src/core/NoteCreateService.ts
index 41efa76f3f..c252336f99 100644
--- a/packages/backend/src/core/NoteCreateService.ts
+++ b/packages/backend/src/core/NoteCreateService.ts
@@ -38,7 +38,7 @@ import InstanceChart from '@/core/chart/charts/instance.js';
import ActiveUsersChart from '@/core/chart/charts/active-users.js';
import { GlobalEventService } from '@/core/GlobalEventService.js';
import { NotificationService } from '@/core/NotificationService.js';
-import { WebhookService } from '@/core/WebhookService.js';
+import { UserWebhookService } from '@/core/UserWebhookService.js';
import { HashtagService } from '@/core/HashtagService.js';
import { AntennaService } from '@/core/AntennaService.js';
import { QueueService } from '@/core/QueueService.js';
@@ -61,7 +61,6 @@ import { CacheService } from '@/core/CacheService.js';
import { isReply } from '@/misc/is-reply.js';
import { trackPromise } from '@/misc/promise-tracker.js';
import { isUserRelated } from '@/misc/is-user-related.js';
-import { isNotNull } from '@/misc/is-not-null.js';
import { IdentifiableError } from '@/misc/identifiable-error.js';
type NotificationType = 'reply' | 'renote' | 'quote' | 'mention';
@@ -207,7 +206,7 @@ export class NoteCreateService implements OnApplicationShutdown {
private federatedInstanceService: FederatedInstanceService,
private hashtagService: HashtagService,
private antennaService: AntennaService,
- private webhookService: WebhookService,
+ private webhookService: UserWebhookService,
private featuredService: FeaturedService,
private remoteUserResolveService: RemoteUserResolveService,
private apDeliverManagerService: ApDeliverManagerService,
@@ -282,7 +281,7 @@ export class NoteCreateService implements OnApplicationShutdown {
data.visibility = 'home';
}
- if (this.isRenote(data)) {
+ if (data.renote) {
switch (data.renote.visibility) {
case 'public':
// public noteは無条件にrenote可能
@@ -368,6 +367,9 @@ export class NoteCreateService implements OnApplicationShutdown {
mentionedUsers = data.apMentions ?? await this.extractMentionedUsers(user, combinedTokens);
}
+ // if the host is media-silenced, custom emojis are not allowed
+ if (this.utilityService.isMediaSilencedHost(meta.mediaSilencedHosts, user.host)) emojis = [];
+
tags = tags.filter(tag => Array.from(tag).length <= 128).splice(0, 32);
if (data.reply && (user.id !== data.reply.userId) && !mentionedUsers.some(u => u.id === data.reply!.userId)) {
@@ -417,175 +419,8 @@ export class NoteCreateService implements OnApplicationShutdown {
host: MiUser['host'];
isBot: MiUser['isBot'];
noindex: MiUser['noindex'];
- }, data: Option, silent = false): Promise<MiNote> {
- // チャンネル外にリプライしたら対象のスコープに合わせる
- // (クライアントサイドでやっても良い処理だと思うけどとりあえずサーバーサイドで)
- if (data.reply && data.channel && data.reply.channelId !== data.channel.id) {
- if (data.reply.channelId) {
- data.channel = await this.channelsRepository.findOneBy({ id: data.reply.channelId });
- } else {
- data.channel = null;
- }
- }
-
- // チャンネル内にリプライしたら対象のスコープに合わせる
- // (クライアントサイドでやっても良い処理だと思うけどとりあえずサーバーサイドで)
- if (data.reply && (data.channel == null) && data.reply.channelId) {
- data.channel = await this.channelsRepository.findOneBy({ id: data.reply.channelId });
- }
-
- if (data.createdAt == null) data.createdAt = new Date();
- if (data.visibility == null) data.visibility = 'public';
- if (data.localOnly == null) data.localOnly = false;
- if (data.channel != null) data.visibility = 'public';
- if (data.channel != null) data.visibleUsers = [];
- if (data.channel != null) data.localOnly = true;
-
- const meta = await this.metaService.fetch();
-
- if (data.visibility === 'public' && data.channel == null) {
- const sensitiveWords = meta.sensitiveWords;
- if (this.utilityService.isKeyWordIncluded(data.cw ?? data.text ?? '', sensitiveWords)) {
- data.visibility = 'home';
- } else if ((await this.roleService.getUserPolicies(user.id)).canPublicNote === false) {
- data.visibility = 'home';
- }
- }
-
- const hasProhibitedWords = await this.checkProhibitedWordsContain({
- cw: data.cw,
- text: data.text,
- pollChoices: data.poll?.choices,
- }, meta.prohibitedWords);
-
- if (hasProhibitedWords) {
- throw new IdentifiableError('689ee33f-f97c-479a-ac49-1b9f8140af99', 'Note contains prohibited words');
- }
-
- const inSilencedInstance = this.utilityService.isSilencedHost(meta.silencedHosts, user.host);
-
- if (data.visibility === 'public' && inSilencedInstance && user.host !== null) {
- data.visibility = 'home';
- }
-
- if (data.renote) {
- switch (data.renote.visibility) {
- case 'public':
- // public noteは無条件にrenote可能
- break;
- case 'home':
- // home noteはhome以下にrenote可能
- if (data.visibility === 'public') {
- data.visibility = 'home';
- }
- break;
- case 'followers':
- // 他人のfollowers noteはreject
- if (data.renote.userId !== user.id) {
- throw new Error('Renote target is not public or home');
- }
-
- // Renote対象がfollowersならfollowersにする
- data.visibility = 'followers';
- break;
- case 'specified':
- // specified / direct noteはreject
- throw new Error('Renote target is not public or home');
- }
- }
-
- // Check blocking
- if (this.isRenote(data) && !this.isQuote(data)) {
- if (data.renote.userHost === null) {
- if (data.renote.userId !== user.id) {
- const blocked = await this.userBlockingService.checkBlocked(data.renote.userId, user.id);
- if (blocked) {
- throw new Error('blocked');
- }
- }
- }
- }
-
- // 返信対象がpublicではないならhomeにする
- if (data.reply && data.reply.visibility !== 'public' && data.visibility === 'public') {
- data.visibility = 'home';
- }
-
- // ローカルのみをRenoteしたらローカルのみにする
- if (data.renote && data.renote.localOnly && data.channel == null) {
- data.localOnly = true;
- }
-
- // ローカルのみにリプライしたらローカルのみにする
- if (data.reply && data.reply.localOnly && data.channel == null) {
- data.localOnly = true;
- }
-
- if (data.text) {
- if (data.text.length > DB_MAX_NOTE_TEXT_LENGTH) {
- data.text = data.text.slice(0, DB_MAX_NOTE_TEXT_LENGTH);
- }
- data.text = data.text.trim();
- if (data.text === '') {
- data.text = null;
- }
- } else {
- data.text = null;
- }
-
- let tags = data.apHashtags;
- let emojis = data.apEmojis;
- let mentionedUsers = data.apMentions;
-
- // Parse MFM if needed
- if (!tags || !emojis || !mentionedUsers) {
- const tokens = (data.text ? mfm.parse(data.text)! : []);
- const cwTokens = data.cw ? mfm.parse(data.cw)! : [];
- const choiceTokens = data.poll && data.poll.choices
- ? concat(data.poll.choices.map(choice => mfm.parse(choice)!))
- : [];
-
- const combinedTokens = tokens.concat(cwTokens).concat(choiceTokens);
-
- tags = data.apHashtags ?? extractHashtags(combinedTokens);
-
- emojis = data.apEmojis ?? extractCustomEmojisFromMfm(combinedTokens);
-
- mentionedUsers = data.apMentions ?? await this.extractMentionedUsers(user, combinedTokens);
- }
-
- tags = tags.filter(tag => Array.from(tag).length <= 128).splice(0, 32);
-
- if (data.reply && (user.id !== data.reply.userId) && !mentionedUsers.some(u => u.id === data.reply!.userId)) {
- mentionedUsers.push(await this.usersRepository.findOneByOrFail({ id: data.reply!.userId }));
- }
-
- if (data.visibility === 'specified') {
- if (data.visibleUsers == null) throw new Error('invalid param');
-
- for (const u of data.visibleUsers) {
- if (!mentionedUsers.some(x => x.id === u.id)) {
- mentionedUsers.push(u);
- }
- }
-
- if (data.reply && !data.visibleUsers.some(x => x.id === data.reply!.userId)) {
- data.visibleUsers.push(await this.usersRepository.findOneByOrFail({ id: data.reply!.userId }));
- }
- }
-
- if (mentionedUsers.length > 0 && mentionedUsers.length > (await this.roleService.getUserPolicies(user.id)).mentionLimit) {
- throw new IdentifiableError('9f466dab-c856-48cd-9e65-ff90ff750580', 'Note contains too many mentions');
- }
-
- const note = await this.insertNote(user, data, tags, emojis, mentionedUsers);
-
- setImmediate('post created', { signal: this.#shutdownController.signal }).then(
- () => this.postNoteImported(note, user, data, silent, tags!, mentionedUsers!),
- () => { /* aborted, ignore this */ },
- );
-
- return note;
+ }, data: Option): Promise<MiNote> {
+ return this.create(user, data, true);
}
@bindThis
@@ -705,7 +540,7 @@ export class NoteCreateService implements OnApplicationShutdown {
const meta = await this.metaService.fetch();
this.notesChart.update(note, true);
- if (meta.enableChartsForRemoteUser || (user.host == null)) {
+ if (note.visibility !== 'specified' && (meta.enableChartsForRemoteUser || (user.host == null))) {
this.perUserNotesChart.update(user, note, true);
}
@@ -817,7 +652,7 @@ export class NoteCreateService implements OnApplicationShutdown {
this.webhookService.getActiveWebhooks().then(webhooks => {
webhooks = webhooks.filter(x => x.userId === user.id && x.on.includes('note'));
for (const webhook of webhooks) {
- this.queueService.webhookDeliver(webhook, 'note', {
+ this.queueService.userWebhookDeliver(webhook, 'note', {
note: noteObj,
});
}
@@ -831,6 +666,7 @@ export class NoteCreateService implements OnApplicationShutdown {
if (data.reply) {
this.globalEventService.publishNoteStream(data.reply.id, 'replied', {
id: note.id,
+ userId: user.id,
});
// 通知
if (data.reply.userHost === null) {
@@ -855,7 +691,7 @@ export class NoteCreateService implements OnApplicationShutdown {
const webhooks = (await this.webhookService.getActiveWebhooks()).filter(x => x.userId === data.reply!.userId && x.on.includes('reply'));
for (const webhook of webhooks) {
- this.queueService.webhookDeliver(webhook, 'reply', {
+ this.queueService.userWebhookDeliver(webhook, 'reply', {
note: noteObj,
});
}
@@ -895,7 +731,7 @@ export class NoteCreateService implements OnApplicationShutdown {
const webhooks = (await this.webhookService.getActiveWebhooks()).filter(x => x.userId === data.renote!.userId && x.on.includes('renote'));
for (const webhook of webhooks) {
- this.queueService.webhookDeliver(webhook, 'renote', {
+ this.queueService.userWebhookDeliver(webhook, 'renote', {
note: noteObj,
});
}
@@ -965,105 +801,6 @@ export class NoteCreateService implements OnApplicationShutdown {
}
@bindThis
- private async postNoteImported(note: MiNote, user: {
- id: MiUser['id'];
- username: MiUser['username'];
- host: MiUser['host'];
- isBot: MiUser['isBot'];
- noindex: MiUser['noindex'];
- }, data: Option, silent: boolean, tags: string[], mentionedUsers: MinimumUser[]) {
- const meta = await this.metaService.fetch();
-
- this.notesChart.update(note, true);
- if (meta.enableChartsForRemoteUser || (user.host == null)) {
- this.perUserNotesChart.update(user, note, true);
- }
-
- // Register host
- if (this.userEntityService.isRemoteUser(user)) {
- this.federatedInstanceService.fetch(user.host).then(async i => {
- if (note.renote && note.text) {
- this.instancesRepository.increment({ id: i.id }, 'notesCount', 1);
- } else if (!note.renote) {
- this.instancesRepository.increment({ id: i.id }, 'notesCount', 1);
- }
- if ((await this.metaService.fetch()).enableChartsForFederatedInstances) {
- this.instanceChart.updateNote(i.host, note, true);
- }
- });
- }
-
- if (data.renote && data.text) {
- // Increment notes count (user)
- this.incNotesCountOfUser(user);
- } else if (!data.renote) {
- // Increment notes count (user)
- this.incNotesCountOfUser(user);
- }
-
- this.pushToTl(note, user);
-
- this.antennaService.addNoteToAntennas(note, user);
-
- if (data.reply) {
- this.saveReply(data.reply, note);
- }
-
- if (data.reply == null) {
- // TODO: キャッシュ
- this.followingsRepository.findBy({
- followeeId: user.id,
- notify: 'normal',
- }).then(followings => {
- for (const following of followings) {
- // TODO: ワードミュート考慮
- this.notificationService.createNotification(following.followerId, 'note', {
- noteId: note.id,
- }, user.id);
- }
- });
- }
-
- if (data.renote && data.text == null && data.renote.userId !== user.id && !user.isBot) {
- this.incRenoteCount(data.renote);
- }
-
- if (data.poll && data.poll.expiresAt) {
- const delay = data.poll.expiresAt.getTime() - Date.now();
- this.queueService.endedPollNotificationQueue.add(note.id, {
- noteId: note.id,
- }, {
- delay,
- removeOnComplete: true,
- });
- }
-
- // Pack the note
- const noteObj = await this.noteEntityService.pack(note, null, { skipHide: true, withReactionAndUserPairCache: true });
-
- if (data.channel) {
- this.channelsRepository.increment({ id: data.channel.id }, 'notesCount', 1);
- this.channelsRepository.update(data.channel.id, {
- lastNotedAt: new Date(),
- });
-
- this.notesRepository.countBy({
- userId: user.id,
- channelId: data.channel.id,
- }).then(count => {
- // この処理が行われるのはノート作成後なので、ノートが一つしかなかったら最初の投稿だと判断できる
- // TODO: とはいえノートを削除して何回も投稿すればその分だけインクリメントされる雑さもあるのでどうにかしたい
- if (count === 1) {
- this.channelsRepository.increment({ id: data.channel!.id }, 'usersCount', 1);
- }
- });
- }
-
- // Register to search database
- if (!user.noindex) this.index(note);
- }
-
- @bindThis
private isRenote(note: Option): note is Option & { renote: MiNote } {
return note.renote != null;
}
@@ -1134,7 +871,7 @@ export class NoteCreateService implements OnApplicationShutdown {
const webhooks = (await this.webhookService.getActiveWebhooks()).filter(x => x.userId === u.id && x.on.includes('mention'));
for (const webhook of webhooks) {
- this.queueService.webhookDeliver(webhook, 'mention', {
+ this.queueService.userWebhookDeliver(webhook, 'mention', {
note: detailPackedNote,
});
}
@@ -1185,7 +922,7 @@ export class NoteCreateService implements OnApplicationShutdown {
const mentions = extractMentions(tokens);
let mentionedUsers = (await Promise.all(mentions.map(m =>
this.remoteUserResolveService.resolveUser(m.username, m.host ?? user.host).catch(() => null),
- ))).filter(isNotNull);
+ ))).filter(x => x != null);
// Drop duplicate users
mentionedUsers = mentionedUsers.filter((u, i, self) =>
@@ -1280,10 +1017,13 @@ export class NoteCreateService implements OnApplicationShutdown {
}
}
- if (note.visibility !== 'specified' || !note.visibleUserIds.some(v => v === user.id)) { // 自分自身のHTL
- this.fanoutTimelineService.push(`homeTimeline:${user.id}`, note.id, meta.perUserHomeTimelineCacheMax, r);
- if (note.fileIds.length > 0) {
- this.fanoutTimelineService.push(`homeTimelineWithFiles:${user.id}`, note.id, meta.perUserHomeTimelineCacheMax / 2, r);
+ // 自分自身のHTL
+ if (note.userHost == null) {
+ if (note.visibility !== 'specified' || !note.visibleUserIds.some(v => v === user.id)) {
+ this.fanoutTimelineService.push(`homeTimeline:${user.id}`, note.id, meta.perUserHomeTimelineCacheMax, r);
+ if (note.fileIds.length > 0) {
+ this.fanoutTimelineService.push(`homeTimelineWithFiles:${user.id}`, note.id, meta.perUserHomeTimelineCacheMax / 2, r);
+ }
}
}
generated by cgit v1.2.3-freya (git 2.53.0.84.g453e7b744a) at 2026-03-04 10:08:33 +0000