Haina
/
Global-sales
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

#

Browse Source
dev/supplier-email-drawer
Lei OT 9 months ago
parent 31808bcefc
commit d05709eae4
2 changed files with 0 additions and 233 deletions
Show Stats Download Patch File Download Diff File

232
wai-server/api/messages/apiPayloadHelper.js
Unescape Escape View File

@ -1,232 +0,0 @@
/**
*
*/
'use strict';
const { objectMapper, pick } = require('../../utils/commons.util');
const mediaMsg = {
contentToSend: msg => {
const { msgtype, msgcontent, ...body } = msg;
return {
// ...body,
to: body.to,
externalId: body.actionId,
// type WAMediaUpload = Buffer | WAMediaPayloadStream | WAMediaPayloadURL;
[msgtype]: {
url: msgcontent[msgtype].link,
},
...(msgcontent[msgtype].caption ? { caption: msgcontent[msgtype].caption } : {}), // image, video, document
// mimetype: 'audio/mp4',
...(msgtype === 'document' ? { filename: msgcontent[msgtype].filename } : {}), // document
...(msgcontent.context ? { quoted: { key: msgcontent.context.message_id } } : {}),
// seconds?: number; // audio
// isAnimated?: boolean; // sticker
// jpegThumbnail?: string; // image, video
};
},
dataToDB: msg => {
const { msgtype, msgcontent, ...body } = msg;
const record = pick(msg, ['actionId', 'msgtype', 'externalId', 'from', 'to']);
return {
direction: 'outbound',
msg_status: 'ready',
createTime: Date.now(),
id: msg.actionId,
...record,
IVADS_link: msgcontent[msgtype].link,
IVADS_caption: msgcontent[msgtype].caption || '',
IVADS_filename: msgcontent[msgtype].filename || '',
...(msgcontent.context
? {
context_id: msgcontent.context.message_id,
context_from: msgcontent.message_origin.from,
}
: {}),
message_origin: JSON.stringify(msg),
};
},
};
const apiSendMsgTypeMapped = {
text: {
type: 'text',
contentToSend: msg => ({
// ...msg,
to: msg.to,
externalId: msg.actionId,
text: msg.msgcontent.body,
// linkPreview: true, // {}
...(msg.msgcontent.context ? { quoted: { key: msg.msgcontent.context.message_id } } : {}),
}),
dataToDB: msg => {
const { msgcontent } = msg;
const record = pick(msg, ['actionId', 'msgtype', 'externalId', 'from', 'to']);
return {
direction: 'outbound',
msg_status: 'ready',
createTime: Date.now(),
id: msg.actionId,
...record,
text_body: msgcontent.body,
text_preview_url: msgcontent.preview_url,
...(msgcontent.context
? {
context_id: msgcontent.context.message_id,
context_from: msgcontent.message_origin.from,
}
: {}),
message_origin: JSON.stringify(msg),
};
},
},
image: {
type: 'image',
contentToSend: msg => ({
...mediaMsg.contentToSend({ ...msg }),
}),
dataToDB: msg => mediaMsg.dataToDB(msg),
},
sticker: {
type: 'sticker',
contentToSend: msg => ({
...mediaMsg.contentToSend({ ...msg }),
}),
dataToDB: msg => mediaMsg.dataToDB(msg),
},
audio: {
type: 'audio',
contentToSend: msg => ({
...mediaMsg.contentToSend({ ...msg }),
}),
dataToDB: msg => mediaMsg.dataToDB(msg),
},
video: {
type: 'video', // todo: gif
contentToSend: msg => ({
...mediaMsg.contentToSend({ ...msg }),
}),
dataToDB: msg => mediaMsg.dataToDB(msg),
},
document: {
type: 'document',
contentToSend: msg => ({
...mediaMsg.contentToSend({ ...msg }),
}),
dataToDB: msg => mediaMsg.dataToDB(msg),
},
// 不支持
react: {
type: 'react',
contentToSend: msg => ({
// ...msg,
to: msg.to,
externalId: msg.actionId,
react: {
text: msg.msgcontent.body, // emoji | use an empty string to remove the reaction
key: msg.msgcontent.context.message_id,
},
}),
dataToDB: msg => {
const { msgtype, msgcontent, ...body } = msg;
const record = pick(msg, ['actionId', 'msgtype', 'externalId', 'from', 'to']);
return {
direction: 'outbound',
msg_status: 'ready',
createTime: Date.now(),
id: msg.actionId,
...record,
reaction_message_id: '',
reaction_emoji: '',
message_origin: JSON.stringify(msg),
};
},
},
// 不支持
location: {
type: 'location',
contentToSend: msg => ({
// ...msg,
to: msg.to,
externalId: msg.actionId,
// location: { degreesLatitude: msg.latitude, degreesLongitude: msg.longitude }, // todo:
}),
dataToDB: msg => {
const { msgtype, msgcontent, ...body } = msg;
const record = pick(msg, ['actionId', 'msgtype', 'externalId', 'from', 'to']);
return {
direction: 'outbound',
msg_status: 'ready',
createTime: Date.now(),
id: msg.actionId,
...record,
message_origin: JSON.stringify(msg),
};
},
},
// 不支持
contacts: {
type: 'contacts',
contentToSend: msg => ({
// ...msg,
to: msg.to,
externalId: msg.actionId,
// contacts: { displayName: '', contacts: msg.contacts }, // todo:
}),
dataToDB: msg => {
const { msgtype, msgcontent, ...body } = msg;
const record = pick(msg, ['actionId', 'msgtype', 'externalId', 'from', 'to']);
return {
direction: 'outbound',
msg_status: 'ready',
createTime: Date.now(),
id: msg.actionId,
...record,
message_origin: JSON.stringify(msg),
};
},
},
template: {
type: 'template',
contentToSend: msg => ({
// ...msg,
to: msg.to,
externalId: msg.actionId,
// msgcontent: {
// ...msg.template,
// components: [
// ...msg.template.components.filter(com => !['footer', 'buttons'].includes(com.type.toLowerCase())),
// ],
// },
}),
dataToDB: msg => {
const { msgtype, msgcontent, ...body } = msg;
const record = pick(msg, ['actionId', 'msgtype', 'externalId', 'from', 'to']);
return {
direction: 'outbound',
msg_status: 'ready',
createTime: Date.now(),
id: msg.actionId,
...record,
message_origin: JSON.stringify(msg),
};
},
},
};
/**
* API Payload to Send
*/
exports.ctxToSendBuilder = ctxContent => {
const { type, contentToSend } = apiSendMsgTypeMapped[ctxContent.msgtype];
const msgReady = contentToSend(ctxContent);
return msgReady;
};
/**
* API Payload to DB
*/
exports.ctxToDB = ctxContent => {
const { type, dataToDB } = apiSendMsgTypeMapped[ctxContent.msgtype];
const msgReady = dataToDB(ctxContent);
return msgReady;
};

1
wai-server/api/messages/message.controller.js
Unescape Escape View File

@ -3,7 +3,6 @@
const generateId = require('../../utils/generateId.util'); const generateId = require('../../utils/generateId.util');
const { sessionStore } = require('../../core'); const { sessionStore } = require('../../core');
const { objectMapper, pick } = require('../../utils/commons.util'); const { objectMapper, pick } = require('../../utils/commons.util');
// const { ctxToSendBuilder, ctxToDB } = require('./apiPayloadHelper');
const { createOutboundMessage, getOutboundMessage } = require('../../services/outbound_messages.service'); const { createOutboundMessage, getOutboundMessage } = require('../../services/outbound_messages.service');
const waEmitter = require('../../core/emitter'); const waEmitter = require('../../core/emitter');

Write Preview
Loading…
Cancel
Save