core: fix broadcast message

This commit is contained in:
undefined committed 2025-07-18 11:25:10 +08:00
1 parent 3d197d7d0e
commit 10d90b5ede
2 files changed
+1 -5

No files matched your search

-1
View File
@@ -305,7 +305,6 @@ export interface DomainDoc extends Record<string, any> {
// Message
export interface MessageDoc {
_id: ObjectId,
from: number,
to: number,
content: string,
+1 -4
View File
@@ -21,11 +21,8 @@ class MessageModel {
from: number, to: number | number[],
content: string, flag: number = MessageModel.FLAG_UNREAD,
) {
const _id = new ObjectId();
if (!Array.isArray(to)) to = [to];
const base = {
_id, from, content, flag,
};
const base = { from, content, flag };
if (!to.length) return base;
await MessageModel.coll.insertMany(to.map((t) => ({ ...base, to: t })));
bus.broadcast('user/message', to, base);