summaryrefslogtreecommitdiff
path: root/packages/backend/src/server/api/endpoints/i
diff options
context:
space:
mode:
authorsyuilo <Syuilotan@yahoo.co.jp>2023-02-15 13:06:06 +0900
committerGitHub <noreply@github.com>2023-02-15 13:06:06 +0900
commit8f2049bcd261c3fb10afdc8c15cf4edffe1baa71 (patch)
treedc5aa1cefc24d3f6eb36bb1723d7433f8a19e5a2 /packages/backend/src/server/api/endpoints/i
parentMerge branch 'develop' of https://github.com/misskey-dev/misskey into develop (diff)
downloadsharkey-8f2049bcd261c3fb10afdc8c15cf4edffe1baa71.tar.gz
sharkey-8f2049bcd261c3fb10afdc8c15cf4edffe1baa71.tar.bz2
sharkey-8f2049bcd261c3fb10afdc8c15cf4edffe1baa71.zip
drop messaging (#9919)
* drop messaging (from backend) * wip
Diffstat (limited to 'packages/backend/src/server/api/endpoints/i')
-rw-r--r--packages/backend/src/server/api/endpoints/i/read-all-messaging-messages.ts56
1 files changed, 0 insertions, 56 deletions
diff --git a/packages/backend/src/server/api/endpoints/i/read-all-messaging-messages.ts b/packages/backend/src/server/api/endpoints/i/read-all-messaging-messages.ts
deleted file mode 100644
index 109d6d1068..0000000000
--- a/packages/backend/src/server/api/endpoints/i/read-all-messaging-messages.ts
+++ /dev/null
@@ -1,56 +0,0 @@
-import { Inject, Injectable } from '@nestjs/common';
-import { Endpoint } from '@/server/api/endpoint-base.js';
-import type { MessagingMessagesRepository, UserGroupJoiningsRepository } from '@/models/index.js';
-import { GlobalEventService } from '@/core/GlobalEventService.js';
-import { DI } from '@/di-symbols.js';
-
-export const meta = {
- tags: ['account', 'messaging'],
-
- requireCredential: true,
-
- kind: 'write:account',
-} as const;
-
-export const paramDef = {
- type: 'object',
- properties: {},
- required: [],
-} as const;
-
-// eslint-disable-next-line import/no-default-export
-@Injectable()
-export default class extends Endpoint<typeof meta, typeof paramDef> {
- constructor(
- @Inject(DI.messagingMessagesRepository)
- private messagingMessagesRepository: MessagingMessagesRepository,
-
- @Inject(DI.userGroupJoiningsRepository)
- private userGroupJoiningsRepository: UserGroupJoiningsRepository,
-
- private globalEventService: GlobalEventService,
- ) {
- super(meta, paramDef, async (ps, me) => {
- // Update documents
- await this.messagingMessagesRepository.update({
- recipientId: me.id,
- isRead: false,
- }, {
- isRead: true,
- });
-
- const joinings = await this.userGroupJoiningsRepository.findBy({ userId: me.id });
-
- await Promise.all(joinings.map(j => this.messagingMessagesRepository.createQueryBuilder().update()
- .set({
- reads: (() => `array_append("reads", '${me.id}')`) as any,
- })
- .where('groupId = :groupId', { groupId: j.userGroupId })
- .andWhere('userId != :userId', { userId: me.id })
- .andWhere('NOT (:userId = ANY(reads))', { userId: me.id })
- .execute()));
-
- this.globalEventService.publishMainStream(me.id, 'readAllMessagingMessages');
- });
- }
-}