ユーザーグループ

Resolve #3218

1 files changed, 8 insertions, 4 deletions

diff --git a/src/server/api/endpoints/messaging/messages/delete.ts b/src/server/api/endpoints/messaging/messages/delete.ts
index 6a896cd8d1..fb1bb42a56 100644
--- a/src/server/api/endpoints/messaging/messages/delete.ts
+++ b/src/server/api/endpoints/messaging/messages/delete.ts
@@ -1,7 +1,7 @@
 import $ from 'cafy';
 import { ID } from '../../../../../misc/cafy-id';
 import define from '../../../define';
-import { publishMessagingStream } from '../../../../../services/stream';
+import { publishMessagingStream, publishGroupMessagingStream } from '../../../../../services/stream';
 import * as ms from 'ms';
 import { ApiError } from '../../../error';
 import { MessagingMessages } from '../../../../../models';
@@ -10,7 +10,7 @@ export const meta = {
 	stability: 'stable',
 
 	desc: {
-		'ja-JP': '指定したメッセージを削除します。',
+		'ja-JP': '指定したトークメッセージを削除します。',
 		'en-US': 'Delete a message.'
 	},
 
@@ -57,6 +57,10 @@ export default define(meta, async (ps, user) => {
 
 	await MessagingMessages.delete(message.id);
 
-	publishMessagingStream(message.userId, message.recipientId, 'deleted', message.id);
-	publishMessagingStream(message.recipientId, message.userId, 'deleted', message.id);
+	if (message.recipientId) {
+		publishMessagingStream(message.userId, message.recipientId, 'deleted', message.id);
+		publishMessagingStream(message.recipientId, message.userId, 'deleted', message.id);
+	} else if (message.groupId) {
+		publishGroupMessagingStream(message.groupId, 'deleted', message.id);
+	}
 });