Weishen/Hydro
2
0 Fork 0
mirror of https://gitcode.com/gh_mirrors/hy/Hydro.git synced 2026-10-20 01:38:19 +08:00
Code Issues Packages Projects Releases Wiki Activity

core: message: support richtext

Browse Source
This commit is contained in:
undefined committed 2022-01-14 01:19:10 +08:00
1 parent b6910e574b
commit 55a95b97ea
1 file changed
+8 -3
Download Patch File Download Diff File Expand all files Collapse all files
packages/hydrooj/src/model/message.ts
+8 -3
View File
@@ -4,6 +4,7 @@ import * as bus from '../service/bus';
import db from '../service/db'; import db from '../service/db';
import { ArgMethod } from '../utils'; import { ArgMethod } from '../utils';
import { PRIV } from './builtin'; import { PRIV } from './builtin';
import * as system from './system';
import user from './user'; import user from './user';
const coll = db.collection('message'); const coll = db.collection('message');
@@ -66,9 +67,13 @@ class MessageModel {
return coll.find({ $or: [{ from: uid }, { to: uid }] }); return coll.find({ $or: [{ from: uid }, { to: uid }] });
} }
static async sendNotification(message: string) { static async sendNotification(message: string, ...args: any[]) {
const targets = await user.getMulti({ priv: { $bitsAllSet: PRIV.PRIV_VIEW_SYSTEM_NOTIFICATION } }).project({ _id: 1 }).toArray(); const targets = await user.getMulti({ priv: { $bitsAllSet: PRIV.PRIV_VIEW_SYSTEM_NOTIFICATION } })
return Promise.all(targets.map(({ _id }) => MessageModel.send(1, _id, message))); .project({ _id: 1, viewLang: 1 }).toArray();
return Promise.all(targets.map(({ _id, viewLang }) => {
const msg = message.translate(viewLang || system.get('server.language')).format(...args);
return MessageModel.send(1, _id, msg, MessageModel.FLAG_RICHTEXT);
}));
} }
} }