egirlskey/src/server/api/common/read-messaging-message.ts

78 lines
2.1 KiB
TypeScript
Raw Normal View History

2017-06-12 17:12:30 +00:00
import * as mongo from 'mongodb';
2018-10-16 02:38:09 +00:00
import isObjectId from '../../../misc/is-objectid';
2018-03-29 11:32:18 +00:00
import Message from '../../../models/messaging-message';
import { IMessagingMessage as IMessage } from '../../../models/messaging-message';
import { publishMainStream } from '../../../stream';
2018-07-07 10:19:00 +00:00
import { publishMessagingStream } from '../../../stream';
import { publishMessagingIndexStream } from '../../../stream';
2018-05-28 16:22:39 +00:00
import User from '../../../models/user';
2017-06-12 17:12:30 +00:00
/**
* Mark messages as read
2017-06-12 17:12:30 +00:00
*/
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) => {
2018-10-16 02:38:09 +00:00
const userId = isObjectId(user)
2017-06-12 17:12:30 +00:00
? user
: new mongo.ObjectID(user);
2018-10-16 02:38:09 +00:00
const otherpartyId = isObjectId(otherparty)
2017-06-12 17:12:30 +00:00
? otherparty
: new mongo.ObjectID(otherparty);
const ids: mongo.ObjectID[] = Array.isArray(message)
2018-10-16 02:38:09 +00:00
? isObjectId(message[0])
2017-06-12 17:12:30 +00:00
? (message as mongo.ObjectID[])
: typeof message[0] === 'string'
? (message as string[]).map(m => new mongo.ObjectID(m))
: (message as IMessage[]).map(m => m._id)
2018-10-16 02:38:09 +00:00
: isObjectId(message)
2017-06-12 17:12:30 +00:00
? [(message as mongo.ObjectID)]
: typeof message === 'string'
? [new mongo.ObjectID(message)]
: [(message as IMessage)._id];
// Update documents
await Message.update({
_id: { $in: ids },
2018-03-29 05:48:47 +00:00
userId: otherpartyId,
recipientId: userId,
isRead: false
2017-06-12 17:12:30 +00:00
}, {
$set: {
isRead: true
}
}, {
multi: true
});
2017-06-12 17:12:30 +00:00
// Publish event
publishMessagingStream(otherpartyId, userId, 'read', ids.map(id => id.toString()));
2017-11-13 15:54:16 +00:00
publishMessagingIndexStream(userId, 'read', ids.map(id => id.toString()));
2017-06-12 17:12:30 +00:00
// Calc count of my unread messages
const count = await Message
.count({
2018-03-29 05:48:47 +00:00
recipientId: userId,
isRead: false
2018-05-14 00:24:49 +00:00
}, {
limit: 1
});
2017-06-12 17:12:30 +00:00
if (count == 0) {
2018-05-28 16:22:39 +00:00
// Update flag
User.update({ _id: userId }, {
$set: {
hasUnreadMessagingMessage: false
}
});
2017-06-12 17:12:30 +00:00
// 全ての(いままで未読だった)自分宛てのメッセージを(これで)読みましたよというイベントを発行
publishMainStream(userId, 'readAllMessagingMessages');
2017-06-12 17:12:30 +00:00
}
});