mirror of
https://github.com/EvolutionAPI/evolution-api.git
synced 2025-07-27 02:48:39 -06:00
import contacts with tag
This commit is contained in:
Francis Breit
GitHub
parent
256829e8a3
commit
431ee3f5a1
@ -154,78 +154,81 @@ class ChatwootImport {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
public async importHistoryContacts(instance: InstanceDto, provider: ChatwootRaw) {
|
|
||||||
|
public async importHistoryContacts(instance: InstanceDto, provider: ChatwootRaw) {
|
||||||
try {
|
try {
|
||||||
if (this.getHistoryMessagesLenght(instance) > 0) {
|
if (this.getHistoryMessagesLenght(instance) > 0) {
|
||||||
return;
|
return;
|
||||||
}
|
|
||||||
|
|
||||||
const pgClient = postgresClient.getChatwootConnection();
|
|
||||||
|
|
||||||
let totalContactsImported = 0;
|
|
||||||
|
|
||||||
const contacts = this.historyContacts.get(instance.instanceName) || [];
|
|
||||||
if (contacts.length === 0) {
|
|
||||||
return 0;
|
|
||||||
}
|
|
||||||
|
|
||||||
let contactsChunk: ContactRaw[] = this.sliceIntoChunks(contacts, 3000);
|
|
||||||
// Inserindo o label uma única vez
|
|
||||||
await this.insertLabel(instance.instanceName, Number(provider.account_id));
|
|
||||||
const tagId = await this.insertTag(instance.instanceName, contacts.length);
|
|
||||||
|
|
||||||
const contactIds: number[] = [];
|
|
||||||
|
|
||||||
while (contactsChunk.length > 0) {
|
|
||||||
// Inserindo contatos no banco de dados Chatwoot
|
|
||||||
let sqlInsert = `INSERT INTO contacts
|
|
||||||
(name, phone_number, account_id, identifier, created_at, updated_at) VALUES `;
|
|
||||||
const bindInsert = [provider.account_id];
|
|
||||||
|
|
||||||
for (const contact of contactsChunk) {
|
|
||||||
bindInsert.push(contact.pushName);
|
|
||||||
const bindName = `$${bindInsert.length}`;
|
|
||||||
|
|
||||||
bindInsert.push(`+${contact.id.split('@')[0]}`);
|
|
||||||
const bindPhoneNumber = `$${bindInsert.length}`;
|
|
||||||
|
|
||||||
bindInsert.push(contact.id);
|
|
||||||
const bindIdentifier = `$${bindInsert.length}`;
|
|
||||||
|
|
||||||
sqlInsert += `(${bindName}, ${bindPhoneNumber}, $1, ${bindIdentifier}, NOW(), NOW()),`;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
if (sqlInsert.slice(-1) === ',') {
|
const pgClient = postgresClient.getChatwootConnection();
|
||||||
sqlInsert = sqlInsert.slice(0, -1);
|
|
||||||
}
|
|
||||||
sqlInsert += ` ON CONFLICT (identifier, account_id)
|
|
||||||
DO UPDATE SET
|
|
||||||
name = EXCLUDED.name,
|
|
||||||
phone_number = EXCLUDED.phone_number,
|
|
||||||
identifier = EXCLUDED.identifier
|
|
||||||
RETURNING id`;
|
|
||||||
|
|
||||||
const result = await pgClient.query(sqlInsert, bindInsert);
|
let totalContactsImported = 0;
|
||||||
totalContactsImported += result?.rowCount ?? 0;
|
|
||||||
|
|
||||||
// Coletando os IDs dos contatos inseridos ou atualizados
|
const contacts = this.historyContacts.get(instance.instanceName) || [];
|
||||||
for (const row of result.rows) {
|
if (contacts.length === 0) {
|
||||||
contactIds.push(row.id);
|
return 0;
|
||||||
}
|
}
|
||||||
|
|
||||||
contactsChunk = this.sliceIntoChunks(contacts, 3000);
|
let contactsChunk: ContactRaw[] = this.sliceIntoChunks(contacts, 3000);
|
||||||
}
|
// Inserindo o label uma única vez
|
||||||
|
await this.insertLabel(instance.instanceName, Number(provider.account_id));
|
||||||
|
const tagId = await this.insertTag(instance.instanceName, contacts.length);
|
||||||
|
|
||||||
// Após inserir todos os contatos, inserir dados na tabela taggings
|
const contactIds: number[] = [];
|
||||||
await this.insertTaggings(instance.instanceName, tagId, contactIds);
|
|
||||||
|
|
||||||
this.deleteHistoryContacts(instance);
|
while (contactsChunk.length > 0) {
|
||||||
|
// Inserindo contatos no banco de dados Chatwoot
|
||||||
|
let sqlInsert = `INSERT INTO contacts
|
||||||
|
(name, phone_number, account_id, identifier, created_at, updated_at) VALUES `;
|
||||||
|
const bindInsert = [provider.account_id];
|
||||||
|
|
||||||
return totalContactsImported;
|
for (const contact of contactsChunk) {
|
||||||
|
bindInsert.push(contact.pushName);
|
||||||
|
const bindName = `$${bindInsert.length}`;
|
||||||
|
|
||||||
|
bindInsert.push(`+${contact.id.split('@')[0]}`);
|
||||||
|
const bindPhoneNumber = `$${bindInsert.length}`;
|
||||||
|
|
||||||
|
bindInsert.push(contact.id);
|
||||||
|
const bindIdentifier = `$${bindInsert.length}`;
|
||||||
|
|
||||||
|
sqlInsert += `(${bindName}, ${bindPhoneNumber}, $1, ${bindIdentifier}, NOW(), NOW()),`;
|
||||||
|
}
|
||||||
|
|
||||||
|
if (sqlInsert.slice(-1) === ',') {
|
||||||
|
sqlInsert = sqlInsert.slice(0, -1);
|
||||||
|
}
|
||||||
|
sqlInsert += ` ON CONFLICT (identifier, account_id)
|
||||||
|
DO UPDATE SET
|
||||||
|
name = EXCLUDED.name,
|
||||||
|
phone_number = EXCLUDED.phone_number,
|
||||||
|
identifier = EXCLUDED.identifier
|
||||||
|
RETURNING id`;
|
||||||
|
|
||||||
|
const result = await pgClient.query(sqlInsert, bindInsert);
|
||||||
|
totalContactsImported += result?.rowCount ?? 0;
|
||||||
|
|
||||||
|
// Coletando os IDs dos contatos inseridos ou atualizados
|
||||||
|
for (const row of result.rows) {
|
||||||
|
contactIds.push(row.id);
|
||||||
|
}
|
||||||
|
|
||||||
|
contactsChunk = this.sliceIntoChunks(contacts, 3000);
|
||||||
|
}
|
||||||
|
|
||||||
|
// Após inserir todos os contatos, inserir dados na tabela taggings
|
||||||
|
await this.insertTaggings(instance.instanceName, tagId, contactIds);
|
||||||
|
|
||||||
|
this.deleteHistoryContacts(instance);
|
||||||
|
|
||||||
|
return totalContactsImported;
|
||||||
} catch (error) {
|
} catch (error) {
|
||||||
this.logger.error(`Error on import history contacts: ${error.toString()}`);
|
this.logger.error(`Error on import history contacts: ${error.toString()}`);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
public async importHistoryMessages(
|
public async importHistoryMessages(
|
||||||
instance: InstanceDto,
|
instance: InstanceDto,
|
||||||
@ -250,95 +253,316 @@ class ChatwootImport {
|
|||||||
|
|
||||||
// ordering messages by number and timestamp asc
|
// ordering messages by number and timestamp asc
|
||||||
messagesOrdered.sort((a, b) => {
|
messagesOrdered.sort((a, b) => {
|
||||||
const phoneComparison = a.key.remoteJid.localeCompare(b.key.remoteJid);
|
return (
|
||||||
return phoneComparison !== 0 ? phoneComparison : a.messageTimestamp - b.messageTimestamp;
|
parseInt(a.key.remoteJid) - parseInt(b.key.remoteJid) ||
|
||||||
|
(a.messageTimestamp as number) - (b.messageTimestamp as number)
|
||||||
|
);
|
||||||
});
|
});
|
||||||
|
|
||||||
const firstLastMessageTimestampsByNumber: Map<string, firstLastTimestamp> = new Map();
|
const allMessagesMappedByPhoneNumber = this.createMessagesMapByPhoneNumber(messagesOrdered);
|
||||||
|
// Map structure: +552199999999 => { first message timestamp from number, last message timestamp from number}
|
||||||
|
const phoneNumbersWithTimestamp = new Map<string, firstLastTimestamp>();
|
||||||
|
allMessagesMappedByPhoneNumber.forEach((messages: MessageRaw[], phoneNumber: string) => {
|
||||||
|
phoneNumbersWithTimestamp.set(phoneNumber, {
|
||||||
|
first: messages[0]?.messageTimestamp as number,
|
||||||
|
last: messages[messages.length - 1]?.messageTimestamp as number,
|
||||||
|
});
|
||||||
|
});
|
||||||
|
|
||||||
for (const message of messagesOrdered) {
|
// processing messages in batch
|
||||||
const remoteJid = message.key.remoteJid;
|
const batchSize = 4000;
|
||||||
const timestamp = message.messageTimestamp;
|
let messagesChunk: MessageRaw[] = this.sliceIntoChunks(messagesOrdered, batchSize);
|
||||||
|
while (messagesChunk.length > 0) {
|
||||||
|
// Map structure: +552199999999 => MessageRaw[]
|
||||||
|
const messagesByPhoneNumber = this.createMessagesMapByPhoneNumber(messagesChunk);
|
||||||
|
|
||||||
if (!firstLastMessageTimestampsByNumber.has(remoteJid)) {
|
if (messagesByPhoneNumber.size > 0) {
|
||||||
firstLastMessageTimestampsByNumber.set(remoteJid, { first: timestamp, last: timestamp });
|
const fksByNumber = await this.selectOrCreateFksFromChatwoot(
|
||||||
} else {
|
provider,
|
||||||
const entry = firstLastMessageTimestampsByNumber.get(remoteJid);
|
inbox,
|
||||||
if (timestamp < entry.first) entry.first = timestamp;
|
phoneNumbersWithTimestamp,
|
||||||
if (timestamp > entry.last) entry.last = timestamp;
|
messagesByPhoneNumber,
|
||||||
}
|
);
|
||||||
}
|
|
||||||
|
// inserting messages in chatwoot db
|
||||||
for (const [phoneNumber, timestamps] of firstLastMessageTimestampsByNumber.entries()) {
|
let sqlInsertMsg = `INSERT INTO messages
|
||||||
const contact = await chatwootService.createContact(
|
(content, account_id, inbox_id, conversation_id, message_type, private, content_type,
|
||||||
phoneNumber,
|
sender_type, sender_id, created_at, updated_at) VALUES `;
|
||||||
provider.inbox_id,
|
const bindInsertMsg = [provider.account_id, inbox.id];
|
||||||
instance.instanceName,
|
|
||||||
);
|
messagesByPhoneNumber.forEach((messages: MessageRaw[], phoneNumber: string) => {
|
||||||
|
const fksChatwoot = fksByNumber.get(phoneNumber);
|
||||||
const conversation = await chatwootService.createConversation(
|
|
||||||
phoneNumber,
|
messages.forEach((message) => {
|
||||||
provider.inbox_id,
|
if (!message.message) {
|
||||||
provider.account_id,
|
return;
|
||||||
);
|
}
|
||||||
|
|
||||||
let chunkedMessages = this.sliceIntoChunks(
|
if (!fksChatwoot?.conversation_id || !fksChatwoot?.contact_id) {
|
||||||
messagesOrdered.filter(m => m.key.remoteJid === phoneNumber),
|
return;
|
||||||
3000,
|
}
|
||||||
);
|
|
||||||
|
const contentMessage = this.getContentMessage(chatwootService, message);
|
||||||
while (chunkedMessages.length > 0) {
|
if (!contentMessage) {
|
||||||
const chunk = chunkedMessages.shift();
|
return;
|
||||||
const sqlInsert = `
|
}
|
||||||
INSERT INTO messages (content, account_id, inbox_id, conversation_id, created_at, updated_at, source_id)
|
|
||||||
VALUES ${chunk
|
bindInsertMsg.push(contentMessage);
|
||||||
.map(
|
const bindContent = `$${bindInsertMsg.length}`;
|
||||||
_ =>
|
|
||||||
`('${_.message?.conversation || _.message?.extendedTextMessage?.text || ''}',
|
bindInsertMsg.push(fksChatwoot.conversation_id);
|
||||||
$1, $2, $3, to_timestamp($4), to_timestamp($5), $6)`,
|
const bindConversationId = `$${bindInsertMsg.length}`;
|
||||||
)
|
|
||||||
.join(',')}
|
bindInsertMsg.push(message.key.fromMe ? '1' : '0');
|
||||||
ON CONFLICT (source_id)
|
const bindMessageType = `$${bindInsertMsg.length}`;
|
||||||
DO NOTHING
|
|
||||||
`;
|
bindInsertMsg.push(message.key.fromMe ? chatwootUser.user_type : 'Contact');
|
||||||
|
const bindSenderType = `$${bindInsertMsg.length}`;
|
||||||
const bindValues = [
|
|
||||||
provider.account_id,
|
bindInsertMsg.push(message.key.fromMe ? chatwootUser.user_id : fksChatwoot.contact_id);
|
||||||
provider.inbox_id,
|
const bindSenderId = `$${bindInsertMsg.length}`;
|
||||||
conversation.id,
|
|
||||||
...chunk.flatMap(m => [m.messageTimestamp, m.messageTimestamp, m.key.id]),
|
bindInsertMsg.push(message.messageTimestamp as number);
|
||||||
];
|
const bindmessageTimestamp = `$${bindInsertMsg.length}`;
|
||||||
|
|
||||||
await pgClient.query(sqlInsert, bindValues);
|
sqlInsertMsg += `(${bindContent}, $1, $2, ${bindConversationId}, ${bindMessageType}, FALSE, 0,
|
||||||
totalMessagesImported += chunk.length;
|
${bindSenderType},${bindSenderId}, to_timestamp(${bindmessageTimestamp}), to_timestamp(${bindmessageTimestamp})),`;
|
||||||
|
});
|
||||||
|
});
|
||||||
|
if (bindInsertMsg.length > 2) {
|
||||||
|
if (sqlInsertMsg.slice(-1) === ',') {
|
||||||
|
sqlInsertMsg = sqlInsertMsg.slice(0, -1);
|
||||||
|
}
|
||||||
|
totalMessagesImported += (await pgClient.query(sqlInsertMsg, bindInsertMsg))?.rowCount ?? 0;
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
messagesChunk = this.sliceIntoChunks(messagesOrdered, batchSize);
|
||||||
}
|
}
|
||||||
|
|
||||||
this.deleteHistoryMessages(instance);
|
this.deleteHistoryMessages(instance);
|
||||||
|
this.deleteRepositoryMessagesCache(instance);
|
||||||
|
|
||||||
|
this.importHistoryContacts(instance, provider);
|
||||||
|
|
||||||
return totalMessagesImported;
|
return totalMessagesImported;
|
||||||
} catch (error) {
|
} catch (error) {
|
||||||
this.logger.error(`Error on import history messages: ${error.toString()}`);
|
this.logger.error(`Error on import history messages: ${error.toString()}`);
|
||||||
|
|
||||||
|
this.deleteHistoryMessages(instance);
|
||||||
|
this.deleteRepositoryMessagesCache(instance);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
public sliceIntoChunks<T>(arr: T[], chunkSize: number): T[] {
|
public async selectOrCreateFksFromChatwoot(
|
||||||
const res = [];
|
provider: ChatwootRaw,
|
||||||
for (let i = 0; i < arr.length; i += chunkSize) {
|
inbox: inbox,
|
||||||
const chunk = arr.slice(i, i + chunkSize);
|
phoneNumbersWithTimestamp: Map<string, firstLastTimestamp>,
|
||||||
res.push(chunk);
|
messagesByPhoneNumber: Map<string, MessageRaw[]>,
|
||||||
}
|
): Promise<Map<string, FksChatwoot>> {
|
||||||
return res;
|
|
||||||
}
|
|
||||||
|
|
||||||
private async getChatwootUser(provider: ChatwootRaw): Promise<ChatwootUser> {
|
|
||||||
const pgClient = postgresClient.getChatwootConnection();
|
const pgClient = postgresClient.getChatwootConnection();
|
||||||
const sql = `
|
|
||||||
SELECT user_id, user_type FROM users
|
const bindValues = [provider.account_id, inbox.id];
|
||||||
WHERE email = $1
|
const phoneNumberBind = Array.from(messagesByPhoneNumber.keys())
|
||||||
`;
|
.map((phoneNumber) => {
|
||||||
const result = await pgClient.query(sql, [provider.email]);
|
const phoneNumberTimestamp = phoneNumbersWithTimestamp.get(phoneNumber);
|
||||||
return result.rows[0];
|
|
||||||
|
if (phoneNumberTimestamp) {
|
||||||
|
bindValues.push(phoneNumber);
|
||||||
|
let bindStr = `($${bindValues.length},`;
|
||||||
|
|
||||||
|
bindValues.push(phoneNumberTimestamp.first);
|
||||||
|
bindStr += `$${bindValues.length},`;
|
||||||
|
|
||||||
|
bindValues.push(phoneNumberTimestamp.last);
|
||||||
|
return `${bindStr}$${bindValues.length})`;
|
||||||
|
}
|
||||||
|
})
|
||||||
|
.join(',');
|
||||||
|
|
||||||
|
// select (or insert when necessary) data from tables contacts, contact_inboxes, conversations from chatwoot db
|
||||||
|
const sqlFromChatwoot = `WITH
|
||||||
|
phone_number AS (
|
||||||
|
SELECT phone_number, created_at::INTEGER, last_activity_at::INTEGER FROM (
|
||||||
|
VALUES
|
||||||
|
${phoneNumberBind}
|
||||||
|
) as t (phone_number, created_at, last_activity_at)
|
||||||
|
),
|
||||||
|
|
||||||
|
only_new_phone_number AS (
|
||||||
|
SELECT * FROM phone_number
|
||||||
|
WHERE phone_number NOT IN (
|
||||||
|
SELECT phone_number
|
||||||
|
FROM contacts
|
||||||
|
JOIN contact_inboxes ci ON ci.contact_id = contacts.id AND ci.inbox_id = $2
|
||||||
|
JOIN conversations con ON con.contact_inbox_id = ci.id
|
||||||
|
AND con.account_id = $1
|
||||||
|
AND con.inbox_id = $2
|
||||||
|
AND con.contact_id = contacts.id
|
||||||
|
WHERE contacts.account_id = $1
|
||||||
|
)
|
||||||
|
),
|
||||||
|
|
||||||
|
new_contact AS (
|
||||||
|
INSERT INTO contacts (name, phone_number, account_id, identifier, created_at, updated_at)
|
||||||
|
SELECT REPLACE(p.phone_number, '+', ''), p.phone_number, $1, CONCAT(REPLACE(p.phone_number, '+', ''),
|
||||||
|
'@s.whatsapp.net'), to_timestamp(p.created_at), to_timestamp(p.last_activity_at)
|
||||||
|
FROM only_new_phone_number AS p
|
||||||
|
ON CONFLICT(identifier, account_id) DO UPDATE SET updated_at = EXCLUDED.updated_at
|
||||||
|
RETURNING id, phone_number, created_at, updated_at
|
||||||
|
),
|
||||||
|
|
||||||
|
new_contact_inbox AS (
|
||||||
|
INSERT INTO contact_inboxes (contact_id, inbox_id, source_id, created_at, updated_at)
|
||||||
|
SELECT new_contact.id, $2, gen_random_uuid(), new_contact.created_at, new_contact.updated_at
|
||||||
|
FROM new_contact
|
||||||
|
RETURNING id, contact_id, created_at, updated_at
|
||||||
|
),
|
||||||
|
|
||||||
|
new_conversation AS (
|
||||||
|
INSERT INTO conversations (account_id, inbox_id, status, contact_id,
|
||||||
|
contact_inbox_id, uuid, last_activity_at, created_at, updated_at)
|
||||||
|
SELECT $1, $2, 0, new_contact_inbox.contact_id, new_contact_inbox.id, gen_random_uuid(),
|
||||||
|
new_contact_inbox.updated_at, new_contact_inbox.created_at, new_contact_inbox.updated_at
|
||||||
|
FROM new_contact_inbox
|
||||||
|
RETURNING id, contact_id
|
||||||
|
)
|
||||||
|
|
||||||
|
SELECT new_contact.phone_number, new_conversation.contact_id, new_conversation.id AS conversation_id
|
||||||
|
FROM new_conversation
|
||||||
|
JOIN new_contact ON new_conversation.contact_id = new_contact.id
|
||||||
|
|
||||||
|
UNION
|
||||||
|
|
||||||
|
SELECT p.phone_number, c.id contact_id, con.id conversation_id
|
||||||
|
FROM phone_number p
|
||||||
|
JOIN contacts c ON c.phone_number = p.phone_number
|
||||||
|
JOIN contact_inboxes ci ON ci.contact_id = c.id AND ci.inbox_id = $2
|
||||||
|
JOIN conversations con ON con.contact_inbox_id = ci.id AND con.account_id = $1
|
||||||
|
AND con.inbox_id = $2 AND con.contact_id = c.id`;
|
||||||
|
|
||||||
|
const fksFromChatwoot = await pgClient.query(sqlFromChatwoot, bindValues);
|
||||||
|
|
||||||
|
return new Map(fksFromChatwoot.rows.map((item: FksChatwoot) => [item.phone_number, item]));
|
||||||
|
}
|
||||||
|
|
||||||
|
public async getChatwootUser(provider: ChatwootRaw): Promise<ChatwootUser> {
|
||||||
|
try {
|
||||||
|
const pgClient = postgresClient.getChatwootConnection();
|
||||||
|
|
||||||
|
const sqlUser = `SELECT owner_type AS user_type, owner_id AS user_id
|
||||||
|
FROM access_tokens
|
||||||
|
WHERE token = $1`;
|
||||||
|
|
||||||
|
return (await pgClient.query(sqlUser, [provider.token]))?.rows[0] || false;
|
||||||
|
} catch (error) {
|
||||||
|
this.logger.error(`Error on getChatwootUser: ${error.toString()}`);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
public createMessagesMapByPhoneNumber(messages: MessageRaw[]): Map<string, MessageRaw[]> {
|
||||||
|
return messages.reduce((acc: Map<string, MessageRaw[]>, message: MessageRaw) => {
|
||||||
|
if (!this.isIgnorePhoneNumber(message?.key?.remoteJid)) {
|
||||||
|
const phoneNumber = message?.key?.remoteJid?.split('@')[0];
|
||||||
|
if (phoneNumber) {
|
||||||
|
const phoneNumberPlus = `+${phoneNumber}`;
|
||||||
|
const messages = acc.has(phoneNumberPlus) ? acc.get(phoneNumberPlus) : [];
|
||||||
|
messages.push(message);
|
||||||
|
acc.set(phoneNumberPlus, messages);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
return acc;
|
||||||
|
}, new Map());
|
||||||
|
}
|
||||||
|
|
||||||
|
public async getContactsOrderByRecentConversations(
|
||||||
|
inbox: inbox,
|
||||||
|
provider: ChatwootRaw,
|
||||||
|
limit = 50,
|
||||||
|
): Promise<{ id: number; phone_number: string; identifier: string }[]> {
|
||||||
|
try {
|
||||||
|
const pgClient = postgresClient.getChatwootConnection();
|
||||||
|
|
||||||
|
const sql = `SELECT contacts.id, contacts.identifier, contacts.phone_number
|
||||||
|
FROM conversations
|
||||||
|
JOIN contacts ON contacts.id = conversations.contact_id
|
||||||
|
WHERE conversations.account_id = $1
|
||||||
|
AND inbox_id = $2
|
||||||
|
ORDER BY conversations.last_activity_at DESC
|
||||||
|
LIMIT $3`;
|
||||||
|
|
||||||
|
return (await pgClient.query(sql, [provider.account_id, inbox.id, limit]))?.rows;
|
||||||
|
} catch (error) {
|
||||||
|
this.logger.error(`Error on get recent conversations: ${error.toString()}`);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
public getContentMessage(chatwootService: ChatwootService, msg: IWebMessageInfo) {
|
||||||
|
const contentMessage = chatwootService.getConversationMessage(msg.message);
|
||||||
|
if (contentMessage) {
|
||||||
|
return contentMessage;
|
||||||
|
}
|
||||||
|
|
||||||
|
if (!configService.get<Chatwoot>('CHATWOOT').IMPORT.PLACEHOLDER_MEDIA_MESSAGE) {
|
||||||
|
return '';
|
||||||
|
}
|
||||||
|
|
||||||
|
const types = {
|
||||||
|
documentMessage: msg.message.documentMessage,
|
||||||
|
documentWithCaptionMessage: msg.message.documentWithCaptionMessage?.message?.documentMessage,
|
||||||
|
imageMessage: msg.message.imageMessage,
|
||||||
|
videoMessage: msg.message.videoMessage,
|
||||||
|
audioMessage: msg.message.audioMessage,
|
||||||
|
stickerMessage: msg.message.stickerMessage,
|
||||||
|
templateMessage: msg.message.templateMessage?.hydratedTemplate?.hydratedContentText,
|
||||||
|
};
|
||||||
|
const typeKey = Object.keys(types).find((key) => types[key] !== undefined);
|
||||||
|
|
||||||
|
switch (typeKey) {
|
||||||
|
case 'documentMessage':
|
||||||
|
return `_<File: ${msg.message.documentMessage.fileName}${
|
||||||
|
msg.message.documentMessage.caption ? ` ${msg.message.documentMessage.caption}` : ''
|
||||||
|
}>_`;
|
||||||
|
|
||||||
|
case 'documentWithCaptionMessage':
|
||||||
|
return `_<File: ${msg.message.documentWithCaptionMessage.message.documentMessage.fileName}${
|
||||||
|
msg.message.documentWithCaptionMessage.message.documentMessage.caption
|
||||||
|
? ` ${msg.message.documentWithCaptionMessage.message.documentMessage.caption}`
|
||||||
|
: ''
|
||||||
|
}>_`;
|
||||||
|
|
||||||
|
case 'templateMessage':
|
||||||
|
return msg.message.templateMessage.hydratedTemplate.hydratedTitleText
|
||||||
|
? `*${msg.message.templateMessage.hydratedTemplate.hydratedTitleText}*\\n`
|
||||||
|
: '' + msg.message.templateMessage.hydratedTemplate.hydratedContentText;
|
||||||
|
|
||||||
|
case 'imageMessage':
|
||||||
|
return '_<Image Message>_';
|
||||||
|
|
||||||
|
case 'videoMessage':
|
||||||
|
return '_<Video Message>_';
|
||||||
|
|
||||||
|
case 'audioMessage':
|
||||||
|
return '_<Audio Message>_';
|
||||||
|
|
||||||
|
case 'stickerMessage':
|
||||||
|
return '_<Sticker Message>_';
|
||||||
|
|
||||||
|
default:
|
||||||
|
return '';
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
public sliceIntoChunks(arr: any[], chunkSize: number) {
|
||||||
|
return arr.splice(0, chunkSize);
|
||||||
|
}
|
||||||
|
|
||||||
|
public isGroup(remoteJid: string) {
|
||||||
|
return remoteJid.includes('@g.us');
|
||||||
|
}
|
||||||
|
|
||||||
|
public isIgnorePhoneNumber(remoteJid: string) {
|
||||||
|
return this.isGroup(remoteJid) || remoteJid === 'status@broadcast' || remoteJid === '0@s.whatsapp.net';
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user