tmp
This commit is contained in:
@@ -79,12 +79,12 @@ export default class WebSocketServerManager {
|
|||||||
}
|
}
|
||||||
|
|
||||||
if (msg.type === 'chat' || msg.type === 'clear') {
|
if (msg.type === 'chat' || msg.type === 'clear') {
|
||||||
if (msg.agent === 'escort') {
|
if (msg.agent === 'escort-admin') {
|
||||||
|
} else {
|
||||||
const userInfo = await this.getUserInfo(msg.userId);
|
const userInfo = await this.getUserInfo(msg.userId);
|
||||||
chatTask.streamChat(userInfo, msg, (source, type, content, id) => {
|
chatTask.streamChat(userInfo, msg, (source, type, content, id) => {
|
||||||
ws.send(JSON.stringify({ source, type, content, id }));
|
ws.send(JSON.stringify({ source, type, content, id }));
|
||||||
});
|
});
|
||||||
} else if (msg.agent === 'escort-admin') {
|
|
||||||
}
|
}
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user