From 90f8fe7e538bb7e52d2558152a0390e693f39b11 Mon Sep 17 00:00:00 2001
From: Akihiko Odaki <nekomanma@pixiv.co.jp>
Date: Thu, 29 Mar 2018 01:20:40 +0900
Subject: Introduce processor

---
 .../endpoints/notifications/get_unread_count.ts    | 33 ----------------------
 .../endpoints/notifications/mark_as_read_all.ts    | 32 ---------------------
 2 files changed, 65 deletions(-)
 delete mode 100644 src/api/endpoints/notifications/get_unread_count.ts
 delete mode 100644 src/api/endpoints/notifications/mark_as_read_all.ts

(limited to 'src/api/endpoints/notifications')

diff --git a/src/api/endpoints/notifications/get_unread_count.ts b/src/api/endpoints/notifications/get_unread_count.ts
deleted file mode 100644
index 845d6b29ce..0000000000
--- a/src/api/endpoints/notifications/get_unread_count.ts
+++ /dev/null
@@ -1,33 +0,0 @@
-/**
- * Module dependencies
- */
-import Notification from '../../models/notification';
-import Mute from '../../models/mute';
-
-/**
- * Get count of unread notifications
- *
- * @param {any} params
- * @param {any} user
- * @return {Promise<any>}
- */
-module.exports = (params, user) => new Promise(async (res, rej) => {
-	const mute = await Mute.find({
-		muter_id: user._id,
-		deleted_at: { $exists: false }
-	});
-	const mutedUserIds = mute.map(m => m.mutee_id);
-
-	const count = await Notification
-		.count({
-			notifiee_id: user._id,
-			notifier_id: {
-				$nin: mutedUserIds
-			},
-			is_read: false
-		});
-
-	res({
-		count: count
-	});
-});
diff --git a/src/api/endpoints/notifications/mark_as_read_all.ts b/src/api/endpoints/notifications/mark_as_read_all.ts
deleted file mode 100644
index 3550e344c4..0000000000
--- a/src/api/endpoints/notifications/mark_as_read_all.ts
+++ /dev/null
@@ -1,32 +0,0 @@
-/**
- * Module dependencies
- */
-import Notification from '../../models/notification';
-import event from '../../event';
-
-/**
- * Mark as read all notifications
- *
- * @param {any} params
- * @param {any} user
- * @return {Promise<any>}
- */
-module.exports = (params, user) => new Promise(async (res, rej) => {
-	// Update documents
-	await Notification.update({
-		notifiee_id: user._id,
-		is_read: false
-	}, {
-		$set: {
-			is_read: true
-		}
-	}, {
-		multi: true
-	});
-
-	// Response
-	res();
-
-	// 全ての通知を読みましたよというイベントを発行
-	event(user._id, 'read_all_notifications');
-});
-- 
cgit v1.2.3-freya