perf: websocket 使用console.log日志

dev/emitter
Lei OT 10 months ago
parent b5693182da
commit 971d92cfa6

@ -284,11 +284,11 @@ export const sentMsgTypeMapped = {
const whatsappMsgMapped = { const whatsappMsgMapped = {
'whatsapp.inbound_message.received': { 'whatsapp.inbound_message.received': {
getMsg: (result) => { getMsg: (result) => {
console.log('whatsapp.inbound_message.received', result); // console.log('whatsapp.inbound_message.received', result);
return isEmpty(result?.whatsappInboundMessage) ? null : { ...result.whatsappInboundMessage, conversationid: result.conversationid, messageorigin: result.messageorigin, msg_source: 'WABA', msg_direction: 'inbound' }; return isEmpty(result?.whatsappInboundMessage) ? null : { ...result.whatsappInboundMessage, conversationid: result.conversationid, messageorigin: result.messageorigin, msg_source: 'WABA', msg_direction: 'inbound' };
}, },
contentToRender: (contentObj) => { contentToRender: (contentObj) => {
console.log('whatsapp.inbound_message.received to render', contentObj); // console.log('whatsapp.inbound_message.received to render', contentObj);
return parseRenderMessageItem(contentObj); return parseRenderMessageItem(contentObj);
}, },
contentToUpdate: () => null, contentToUpdate: () => null,
@ -325,7 +325,7 @@ const whatsappMsgMapped = {
const emailMsgMapped = { const emailMsgMapped = {
'email.inbound.received': { 'email.inbound.received': {
getMsg: (result) => { getMsg: (result) => {
console.log('email.inbound.received', result); // console.log('email.inbound.received', result);
const data1 = pick(result, ['conversationid', 'opi_sn', 'coli_sn', 'coli_id']); const data1 = pick(result, ['conversationid', 'opi_sn', 'coli_sn', 'coli_id']);
return isEmpty(result?.emailMessage) ? null : { ...result.emailMessage, ...data1, msg_source: 'email', msg_direction: 'inbound' }; return isEmpty(result?.emailMessage) ? null : { ...result.emailMessage, ...data1, msg_source: 'email', msg_direction: 'inbound' };
}, },
@ -337,7 +337,7 @@ const emailMsgMapped = {
}, },
'email.updated': { 'email.updated': {
getMsg: (result) => { getMsg: (result) => {
console.log('email.updated', result); // console.log('email.updated', result);
const { emailMessage } = result; const { emailMessage } = result;
const data1 = pick(result, ['conversationid', 'opi_sn', 'coli_sn', 'coli_id']); const data1 = pick(result, ['conversationid', 'opi_sn', 'coli_sn', 'coli_id']);
return isEmpty(result?.emailMessage) ? null : { ...emailMessage, ...data1, msg_source: 'email', msg_direction: 'outbound' }; return isEmpty(result?.emailMessage) ? null : { ...emailMessage, ...data1, msg_source: 'email', msg_direction: 'outbound' };

@ -104,6 +104,11 @@ export class RealTimeAPI {
} }
sendMessage(messageObject) { sendMessage(messageObject) {
console.log(
`%c websocket Message OUT ⬆`,
'background:#41b883 ; padding: 1px; border-radius: 3px; color: #fff',
JSON.stringify(messageObject),
);
this.webSocket.next(messageObject); this.webSocket.next(messageObject);
} }

@ -154,7 +154,8 @@ const websocketSlice = (set, get) => ({
}, 500); }, 500);
}, },
handleMessage: (data) => { handleMessage: (data) => {
olog('handleMessage------------------', data); olog('websocket Message IN ⬇', JSON.stringify(data));
// olog('websocket Messages ----', data);
// console.log(data); // console.log(data);
const { updateMessageItem, sentOrReceivedNewMessage, addGlobalNotify } = get(); const { updateMessageItem, sentOrReceivedNewMessage, addGlobalNotify } = get();
const { errcode, errmsg, result } = data; const { errcode, errmsg, result } = data;
@ -167,11 +168,11 @@ const websocketSlice = (set, get) => ({
// addError('Error Connecting to Server'); // addError('Error Connecting to Server');
resultType = 'error'; resultType = 'error';
} }
console.log(resultType, 'result.type'); // console.log(resultType, 'result.type');
const msgObj = receivedMsgTypeMapped[resultType].getMsg(result); const msgObj = receivedMsgTypeMapped[resultType].getMsg(result);
const msgRender = receivedMsgTypeMapped[resultType].contentToRender(msgObj); const msgRender = receivedMsgTypeMapped[resultType].contentToRender(msgObj);
const msgUpdate = receivedMsgTypeMapped[resultType].contentToUpdate(msgObj); const msgUpdate = receivedMsgTypeMapped[resultType].contentToUpdate(msgObj);
console.log('msgRender msgUpdate', msgRender, msgUpdate); // console.log('msgRender msgUpdate', msgRender, msgUpdate);
if ([ if ([
'whatsapp.message.updated', 'message', 'error', 'whatsapp.message.updated', 'message', 'error',
'email.updated', 'email.updated',
@ -192,7 +193,7 @@ const websocketSlice = (set, get) => ({
const msgNotify = receivedMsgTypeMapped[resultType].contentToNotify(msgObj); const msgNotify = receivedMsgTypeMapped[resultType].contentToNotify(msgObj);
addGlobalNotify(msgNotify); addGlobalNotify(msgNotify);
} }
console.log('handleMessage*******************'); // console.log('handleMessage*******************');
}, },
}); });

Loading…
Cancel
Save