Global-sales/src/lib/msgUtils.js

import { cloneDeep, isEmpty } from "@/utils/utils";
import { v4 as uuid } from "uuid";

export const replaceTemplateString = (str, replacements) => {
  let result = str;
  let keys = str.match(/{{(.*?)}}/g).map(key => key.replace(/{{|}}/g, ''));

  for (let i = 0; i < keys.length; i++) {
      let replaceValue = replacements[i];
      let template = new RegExp(`{{${keys[i]}}}`, 'g');
      result = result.replace(template, replaceValue);
  }

  return result;
}
/**
 *
// +8618777396951  lyj
{
    "to": "+8613317835586",  // qqs
    "msgtype": "text",
    "msgcontent": "{\"body\":\"txtmsgtest\"}"
}
 */
export const sentMsgTypeMapped = {
  text: {
    type: 'text',
    contentToSend: (msg) => ({ action: 'message', actionId: msg.id, renderId: msg.id, to: msg.to, msgtype: 'text', msgcontent: { body: msg.text } }),
    contentToRender: (msg) => ({ ...msg, actionId: msg.id, conversationid: msg.id.split('.')[0], }),
  },
  whatsappTemplate: {
    contentToSend: (msg) => ({ action: 'message', actionId: msg.id, renderId: msg.id, to: msg.to, msgtype: 'template', msgcontent: msg.template }),
    contentToRender: (msg) => {
      console.log(msg);
      const templateDataMapped = msg.template?.components ? msg.template.components.reduce((r, v) => ({...r, [v.type]: v}), {}) : null;
      const templateParam = (templateDataMapped?.body?.parameters || []).map(e => e.text);
      const fillTemplate = templateParam.length ? replaceTemplateString(msg.template_origin.components.body?.[0]?.text || '', templateParam) : (msg.template_origin.components.body?.[0]?.text || '');
      // const footer = msg.template_origin.components?.footer?.[0]?.text || '';
      return {
        ...msg,
        actionId: msg.id,
        conversationid: msg.id.split('.')[0],
        type: 'text',
        title: msg.template_origin.components.header?.[0]?.text || '',
        text: `${fillTemplate}`, // msg.template_origin.components.body?.[0]?.text || '',
      };
    },
  },
};
const whatsappMsgMapped = {
  'whatsapp.inbound_message.received': {
    getMsg: (result) => {
      console.log('whatsapp.inbound_message.received', result);
      return isEmpty(result?.whatsappInboundMessage) ? null : { ...result.whatsappInboundMessage, conversationid: result.conversationid };
    },
    contentToRender: (contentObj) => {
      console.log('whatsapp.inbound_message.received to render', contentObj);
      // const contentObj = result?.whatsappInboundMessage || result; // debug:
      return parseRenderMessageItem(contentObj);
    },
    contentToUpdate: () => null,
  },
  'whatsapp.message.updated': {
    getMsg: (result) => {
      console.log('getMsg', result);
      return isEmpty(result?.whatsappMessage) ? null : { ...result.whatsappMessage, conversationid: result.conversationid };
    },
    contentToRender: () => null, // * 仅更新消息状态, 没有输出
    contentToUpdate: (msgcontent) => ({ ...msgcontent, id: msgcontent.wamid, status: msgStatusRenderMapped[(msgcontent?.status || 'failed')] }),
  },
};
export const msgStatusRenderMapped = {
  'accepted': 'sent',
  'sent': 'sent',
  'delivered': 'received',
  'read': 'read',
  'failed': 'failed',
};
export const receivedMsgTypeMapped = {
  ...cloneDeep(whatsappMsgMapped),
  'message': {
    // 发送消息的同步记录 status: 'accepted'
    getMsg: (result) => ({ ...result, conversationid: result.actionId.split('.')[0] }),
    contentToRender: () => null,
    contentToUpdate: (msgcontent) => ({
      ...msgcontent,
      actionId: msgcontent.actionId,
      id: msgcontent.wamid,
      status: msgStatusRenderMapped[(msgcontent?.status || 'failed')],
      conversationid: msgcontent.actionId.split('.')[0], // msgcontent.conversation.id,
    }),
  },
  'error': {
    // 发送消息的同步返回: 发送失败时
    getMsg: (result) => result,
    contentToRender: () => null,
    contentToUpdate: (msgcontent) => ({ ...msgcontent, id: msgcontent.actionId, status: msgcontent?.status || 'failed', dateString: '发送失败 ❌', conversationid: msgcontent.actionId.split('.')[0], }),
  },
};
export const whatsappMsgTypeMapped = {
  error: {
    type: (_m) => ({ type: 'system' }),
    data: (msg) => ({ id: msg.wamid, text: msg.errorCode ? msg.errorMessage : msg.text.body }),
  },
  text: {
    type: (msg) => ({ type: msg.errorCode ? 'system' : 'text' }),
    data: (msg) => ({ id: msg.wamid, text: msg.errorCode ? msg.errorMessage : msg.text.body }),
  },
  image: {
    type: 'photo',
    data: (msg) => ({
      data: { id: msg.wamid, uri: msg.image.link, width: 200, height: 200, alt: '' },
      onOpen: () => {
        console.log('Open image', msg.image.link);
      },
    }),
  },
  sticker: {
    type: 'photo',
    data: (msg) => ({
      data: { id: msg.wamid, uri: msg.sticker.link, width: 150, height: 120, alt: '' },
    }),
  },
  video: {
    type: 'video',
    data: (msg) => ({
      data: {
        id: msg.wamid,
        videoURL: msg.video.link,
        status: {
          click: true,
          loading: 0,
          download: true,
        },
      },
    }),
  },
  audio: {
    type: 'audio',
    data: (msg) => ({
      id: msg.wamid,
      data: {
        audioURL: msg.audio.link,
      },
    }),
  },
  unsupported: { type: 'system', data: (msg) => ({ text: 'Message type is currently not supported.' }) },
  reaction: {
    type: 'text',
    data: (msg) => ({ id: msg.wamid, text: msg.reaction?.emoji || msg.reaction?.text?.body || 'Reaction', reply: { message: '{content}', title: 'React from' } }),
  },
  document: {
    type: 'file',
    data: (msg) => ({ id: msg.wamid, text: msg.document.filename, data: { uri: msg.document.link, extension: 'PDF', status: { click: false, loading: 0,  } } }),
  },
  // location: 'location',
  // contact: 'contact',
  // 'contact-card': 'contact-card',
  // 'contact-card-with-photo': 'contact-card-with-photo',
  // 'contact-card-with-photo-and-label': 'contact-card-with-photo-and-label',
};
/**
 * render received msg
 */
export const parseRenderMessageItem = (msg) => {
  console.log('parseRenderMessageItem', msg);
  return {
    date: msg?.sendTime || '',
    ...(whatsappMsgTypeMapped?.[msg.type]?.data(msg) || {}),
    conversationid: msg.conversationid,
    ...(typeof whatsappMsgTypeMapped[msg.type].type === 'function' ? whatsappMsgTypeMapped[msg.type].type(msg) : { type: whatsappMsgTypeMapped[msg.type].type || 'text' }),
    // type: whatsappMsgTypeMapped?.[msg.type]?.type || 'text',
    sender: msg.from,
    // status: msg?.status || 'waiting',
    // title: msg.customerProfile.name,
    // replyButton: true,
  };
};
export const parseRenderMessageList = (messages) => {
  return messages.map((msg) => {
    return {
      ...(whatsappMsgTypeMapped?.[msg.type]?.data(msg) || {}),
      ...(whatsappMsgTypeMapped?.[msg.type]?.type(msg) || { type: 'text' }), // type: whatsappMsgTypeMapped?.[msg.type]?.type || 'text',
      id: msg.id,
      sender: msg.from,
      // title: msg.customerProfile.name,
      date: msg.sendTime,
    };
  });
};

/**
 * WhatsApp Templates params
 */
export const whatsappTemplatesParamMapped = {
  'asia_highlights_has_receive_your_inquiry': [['customer_name']],
  'hello_from_asia_highlights': [['agent_name']], // todo:
};