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

---
 src/api/common/read-messaging-message.ts | 66 --------------------------------
 1 file changed, 66 deletions(-)
 delete mode 100644 src/api/common/read-messaging-message.ts

(limited to 'src/api/common/read-messaging-message.ts')

diff --git a/src/api/common/read-messaging-message.ts b/src/api/common/read-messaging-message.ts
deleted file mode 100644
index 8e5e5b2b68..0000000000
--- a/src/api/common/read-messaging-message.ts
+++ /dev/null
@@ -1,66 +0,0 @@
-import * as mongo from 'mongodb';
-import Message from '../models/messaging-message';
-import { IMessagingMessage as IMessage } from '../models/messaging-message';
-import publishUserStream from '../event';
-import { publishMessagingStream } from '../event';
-import { publishMessagingIndexStream } from '../event';
-
-/**
- * Mark as read message(s)
- */
-export default (
-	user: string | mongo.ObjectID,
-	otherparty: string | mongo.ObjectID,
-	message: string | string[] | IMessage | IMessage[] | mongo.ObjectID | mongo.ObjectID[]
-) => new Promise<any>(async (resolve, reject) => {
-
-	const userId = mongo.ObjectID.prototype.isPrototypeOf(user)
-		? user
-		: new mongo.ObjectID(user);
-
-	const otherpartyId = mongo.ObjectID.prototype.isPrototypeOf(otherparty)
-		? otherparty
-		: new mongo.ObjectID(otherparty);
-
-	const ids: mongo.ObjectID[] = Array.isArray(message)
-		? mongo.ObjectID.prototype.isPrototypeOf(message[0])
-			? (message as mongo.ObjectID[])
-			: typeof message[0] === 'string'
-				? (message as string[]).map(m => new mongo.ObjectID(m))
-				: (message as IMessage[]).map(m => m._id)
-		: mongo.ObjectID.prototype.isPrototypeOf(message)
-			? [(message as mongo.ObjectID)]
-			: typeof message === 'string'
-				? [new mongo.ObjectID(message)]
-				: [(message as IMessage)._id];
-
-	// Update documents
-	await Message.update({
-		_id: { $in: ids },
-		user_id: otherpartyId,
-		recipient_id: userId,
-		is_read: false
-	}, {
-		$set: {
-			is_read: true
-		}
-	}, {
-		multi: true
-	});
-
-	// Publish event
-	publishMessagingStream(otherpartyId, userId, 'read', ids.map(id => id.toString()));
-	publishMessagingIndexStream(userId, 'read', ids.map(id => id.toString()));
-
-	// Calc count of my unread messages
-	const count = await Message
-		.count({
-			recipient_id: userId,
-			is_read: false
-		});
-
-	if (count == 0) {
-		// 全ての(いままで未読だった)自分宛てのメッセージを(これで)読みましたよというイベントを発行
-		publishUserStream(userId, 'read_all_messaging_messages');
-	}
-});
-- 
cgit v1.2.3-freya