From 0e4a111f81cceed275d9bec2695f6e401fb654d8 Mon Sep 17 00:00:00 2001 From: syuilo Date: Fri, 12 Nov 2021 02:02:25 +0900 Subject: refactoring Resolve #7779 --- src/remote/activitypub/kernel/read.ts | 27 --------------------------- 1 file changed, 27 deletions(-) delete mode 100644 src/remote/activitypub/kernel/read.ts (limited to 'src/remote/activitypub/kernel/read.ts') diff --git a/src/remote/activitypub/kernel/read.ts b/src/remote/activitypub/kernel/read.ts deleted file mode 100644 index 11a1731869..0000000000 --- a/src/remote/activitypub/kernel/read.ts +++ /dev/null @@ -1,27 +0,0 @@ -import { IRemoteUser } from '@/models/entities/user'; -import { IRead, getApId } from '../type'; -import { isSelfHost, extractDbHost } from '@/misc/convert-host'; -import { MessagingMessages } from '@/models/index'; -import { readUserMessagingMessage } from '../../../server/api/common/read-messaging-message'; - -export const performReadActivity = async (actor: IRemoteUser, activity: IRead): Promise => { - const id = await getApId(activity.object); - - if (!isSelfHost(extractDbHost(id))) { - return `skip: Read to foreign host (${id})`; - } - - const messageId = id.split('/').pop(); - - const message = await MessagingMessages.findOne(messageId); - if (message == null) { - return `skip: message not found`; - } - - if (actor.id != message.recipientId) { - return `skip: actor is not a message recipient`; - } - - await readUserMessagingMessage(message.recipientId!, message.userId, [message.id]); - return `ok: mark as read (${message.userId} => ${message.recipientId} ${message.id})`; -}; -- cgit v1.2.3-freya