Sharkey/src/server/api/common/read-notification.ts

72 lines
1.8 KiB
TypeScript
Raw Normal View History

import * as mongo from 'mongodb';
2018-03-29 14:32:18 +03:00
import { default as Notification, INotification } from '../../../models/notification';
2018-07-07 13:19:00 +03:00
import publishUserStream from '../../../stream';
2018-05-22 05:45:49 +03:00
import Mute from '../../../models/mute';
2018-05-28 19:22:39 +03:00
import User from '../../../models/user';
/**
* Mark as read notification(s)
*/
export default (
user: string | mongo.ObjectID,
message: string | string[] | INotification | INotification[] | mongo.ObjectID | mongo.ObjectID[]
) => new Promise<any>(async (resolve, reject) => {
const userId = mongo.ObjectID.prototype.isPrototypeOf(user)
? user
: new mongo.ObjectID(user);
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 INotification[]).map(m => m._id)
: mongo.ObjectID.prototype.isPrototypeOf(message)
? [(message as mongo.ObjectID)]
: typeof message === 'string'
? [new mongo.ObjectID(message)]
: [(message as INotification)._id];
2018-05-22 05:45:49 +03:00
const mute = await Mute.find({
muterId: userId
});
const mutedUserIds = mute.map(m => m.muteeId);
// Update documents
await Notification.update({
_id: { $in: ids },
2018-03-29 08:48:47 +03:00
isRead: false
}, {
$set: {
2018-03-29 08:48:47 +03:00
isRead: true
}
}, {
multi: true
});
// Calc count of my unread notifications
const count = await Notification
.count({
2018-03-29 08:48:47 +03:00
notifieeId: userId,
2018-05-22 05:45:49 +03:00
notifierId: {
$nin: mutedUserIds
},
2018-03-29 08:48:47 +03:00
isRead: false
2018-05-14 03:24:49 +03:00
}, {
limit: 1
});
if (count == 0) {
2018-05-28 19:22:39 +03:00
// Update flag
User.update({ _id: userId }, {
$set: {
hasUnreadNotification: false
}
});
// 全ての(いままで未読だった)通知を(これで)読みましたよというイベントを発行
publishUserStream(userId, 'read_all_notifications');
}
});