Removing comments pt 1

This commit is contained in:
Gabriel Rodrigues 2025-03-26 07:20:57 -03:00
parent 1c6b29fbf5
commit 31824d7f3f

View File

@ -943,160 +943,6 @@ export class BaileysStartupService extends ChannelStartupService {
};
private readonly messageHandle = {
'messaging-history.set': async ({
// messages,
// chats,
// contacts,
// isLatest,
// progress,
// syncType,
}: {
chats: Chat[];
contacts: Contact[];
messages: proto.IWebMessageInfo[];
isLatest?: boolean;
progress?: number;
syncType?: proto.HistorySync.HistorySyncType;
}) => {
// try {
// if (syncType === proto.HistorySync.HistorySyncType.ON_DEMAND) {
// console.log('received on-demand history sync, messages=', messages);
// }
// console.log(
// `recv ${chats.length} chats, ${contacts.length} contacts, ${messages.length} msgs (is latest: ${isLatest}, progress: ${progress}%), type: ${syncType}`,
// );
//
// const instance: InstanceDto = { instanceName: this.instance.name };
//
// let timestampLimitToImport = null;
//
// if (this.configService.get<Chatwoot>('CHATWOOT').ENABLED) {
// const daysLimitToImport = this.localChatwoot?.enabled ? this.localChatwoot.daysLimitImportMessages : 1000;
//
// const date = new Date();
// timestampLimitToImport = new Date(date.setDate(date.getDate() - daysLimitToImport)).getTime() / 1000;
//
// const maxBatchTimestamp = Math.max(...messages.map((message) => message.messageTimestamp as number));
//
// const processBatch = maxBatchTimestamp >= timestampLimitToImport;
//
// if (!processBatch) {
// return;
// }
// }
//
// const chatsRaw: { remoteJid: string; instanceId: string; name?: string }[] = [];
// const chatsRepository = new Set(
// (
// await this.prismaRepository.chat.findMany({
// where: { instanceId: this.instanceId },
// })
// ).map((chat) => chat.remoteJid),
// );
//
// for (const chat of chats) {
// if (chatsRepository?.has(chat.id)) {
// continue;
// }
//
// chatsRaw.push({
// remoteJid: chat.id,
// instanceId: this.instanceId,
// name: chat.name,
// });
// }
//
// this.sendDataWebhook(Events.CHATS_SET, chatsRaw);
//
// if (this.configService.get<Database>('DATABASE').SAVE_DATA.HISTORIC) {
// await this.prismaRepository.chat.createMany({
// data: chatsRaw,
// skipDuplicates: true,
// });
// }
//
// const messagesRaw: any[] = [];
//
// const messagesRepository: Set<string> = new Set(
// chatwootImport.getRepositoryMessagesCache(instance) ??
// (
// await this.prismaRepository.message.findMany({
// select: { key: true },
// where: { instanceId: this.instanceId },
// })
// ).map((message) => {
// const key = message.key as {
// id: string;
// };
//
// return key.id;
// }),
// );
//
// if (chatwootImport.getRepositoryMessagesCache(instance) === null) {
// chatwootImport.setRepositoryMessagesCache(instance, messagesRepository);
// }
//
// for (const m of messages) {
// if (!m.message || !m.key || !m.messageTimestamp) {
// continue;
// }
//
// if (Long.isLong(m?.messageTimestamp)) {
// m.messageTimestamp = m.messageTimestamp?.toNumber();
// }
//
// if (this.configService.get<Chatwoot>('CHATWOOT').ENABLED) {
// if (m.messageTimestamp <= timestampLimitToImport) {
// continue;
// }
// }
//
// if (messagesRepository?.has(m.key.id)) {
// continue;
// }
//
// messagesRaw.push(this.prepareMessage(m));
// }
//
// this.sendDataWebhook(Events.MESSAGES_SET, [...messagesRaw]);
//
// if (this.configService.get<Database>('DATABASE').SAVE_DATA.HISTORIC) {
// await this.prismaRepository.message.createMany({
// data: messagesRaw,
// skipDuplicates: true,
// });
// }
//
// if (
// this.configService.get<Chatwoot>('CHATWOOT').ENABLED &&
// this.localChatwoot?.enabled &&
// this.localChatwoot.importMessages &&
// messagesRaw.length > 0
// ) {
// this.chatwootService.addHistoryMessages(
// instance,
// messagesRaw.filter((msg) => !chatwootImport.isIgnorePhoneNumber(msg.key?.remoteJid)),
// );
// }
//
// await this.contactHandle['contacts.upsert'](
// contacts
// .filter((c) => !!c.notify || !!c.name)
// .map((c) => ({
// id: c.id,
// name: c.name ?? c.notify,
// })),
// );
//
// contacts = undefined;
// messages = undefined;
// chats = undefined;
// } catch (error) {
// this.logger.error(error);
// }
},
'messages.upsert': async (
{
messages,
@ -1121,28 +967,8 @@ export class BaileysStartupService extends ChannelStartupService {
} else if (requestId) {
console.log('Message received from phone, id=', requestId, received);
}
// if (text == 'onDemandHistSync') {
// const messageId = await this.client.fetchMessageHistory(50, received.key, received.messageTimestamp!);
// console.log('requested on-demand sync, id=', messageId);
// }
}
// if (received.message?.protocolMessage?.editedMessage || received.message?.editedMessage?.message) {
// const editedMessage =
// received.message?.protocolMessage || received.message?.editedMessage?.message?.protocolMessage;
// if (editedMessage) {
// if (this.configService.get<Chatwoot>('CHATWOOT').ENABLED && this.localChatwoot?.enabled)
// this.chatwootService.eventWhatsapp(
// 'messages.edit',
// { instanceName: this.instance.name, instanceId: this.instance.id },
// editedMessage,
// );
//
// await this.sendDataWebhook(Events.MESSAGES_EDITED, editedMessage);
// }
// }
if (received.messageStubParameters && received.messageStubParameters[0] === 'Message absent from node') {
this.logger.info(`Recovering message lost messageId: ${received.key.id}`);
@ -1174,33 +1000,6 @@ export class BaileysStartupService extends ChannelStartupService {
received.messageTimestamp = received.messageTimestamp?.toNumber();
}
// if (settings?.groupsIgnore && received.key.remoteJid.includes('@g.us')) {
// continue;
// }
// const existingChat = await this.prismaRepository.chat.findFirst({
// where: { instanceId: this.instanceId, remoteJid: received.key.remoteJid },
// select: { id: true, name: true },
// });
// if (
// existingChat &&
// received.pushName &&
// existingChat.name !== received.pushName &&
// received.pushName.trim().length > 0
// ) {
// this.sendDataWebhook(Events.CHATS_UPSERT, [{ ...existingChat, name: received.pushName }]);
// if (this.configService.get<Database>('DATABASE').SAVE_DATA.CHATS) {
// try {
// await this.prismaRepository.chat.update({
// where: { id: existingChat.id },
// data: { name: received.pushName },
// });
// } catch (error) {
// console.log(`Chat insert record ignored: ${received.key.remoteJid} - ${this.instanceId}`);
// }
// }
// }
const messageRaw = this.prepareMessage(received);
const isMedia =
@ -1220,108 +1019,6 @@ export class BaileysStartupService extends ChannelStartupService {
await this.client.readMessages([received.key]);
}
// if (
// this.configService.get<Chatwoot>('CHATWOOT').ENABLED &&
// this.localChatwoot?.enabled &&
// !received.key.id.includes('@broadcast')
// ) {
// const chatwootSentMessage = await this.chatwootService.eventWhatsapp(
// Events.MESSAGES_UPSERT,
// { instanceName: this.instance.name, instanceId: this.instance.id },
// messageRaw,
// );
//
// if (chatwootSentMessage?.id) {
// messageRaw.chatwootMessageId = chatwootSentMessage.id;
// messageRaw.chatwootInboxId = chatwootSentMessage.inbox_id;
// messageRaw.chatwootConversationId = chatwootSentMessage.conversation_id;
// }
// }
// if (this.configService.get<Openai>('OPENAI').ENABLED && received?.message?.audioMessage) {
// const openAiDefaultSettings = await this.prismaRepository.openaiSetting.findFirst({
// where: {
// instanceId: this.instanceId,
// },
// include: {
// OpenaiCreds: true,
// },
// });
//
// if (openAiDefaultSettings && openAiDefaultSettings.openaiCredsId && openAiDefaultSettings.speechToText) {
// messageRaw.message.speechToText = await this.openaiService.speechToText(
// openAiDefaultSettings.OpenaiCreds,
// received,
// this.client.updateMediaMessage,
// );
// }
// }
// if (this.configService.get<Database>('DATABASE').SAVE_DATA.NEW_MESSAGE) {
// const msg = await this.prismaRepository.message.create({
// data: messageRaw,
// });
//
// if (received.key.fromMe === false) {
// if (msg.status === status[3]) {
// this.logger.log(`Update not read messages ${received.key.remoteJid}`);
//
// await this.updateChatUnreadMessages(received.key.remoteJid);
// } else if (msg.status === status[4]) {
// this.logger.log(`Update readed messages ${received.key.remoteJid} - ${msg.messageTimestamp}`);
//
// await this.updateMessagesReadedByTimestamp(received.key.remoteJid, msg.messageTimestamp);
// }
// } else {
// // is send message by me
// this.logger.log(`Update readed messages ${received.key.remoteJid} - ${msg.messageTimestamp}`);
//
// await this.updateMessagesReadedByTimestamp(received.key.remoteJid, msg.messageTimestamp);
// }
//
// if (isMedia) {
// if (this.configService.get<S3>('S3').ENABLE) {
// try {
// const message: any = received;
// const media = await this.getBase64FromMediaMessage(
// {
// message,
// },
// true,
// );
//
// const { buffer, mediaType, fileName, size } = media;
// const mimetype = mimeTypes.lookup(fileName).toString();
// const fullName = join(`${this.instance.id}`, received.key.remoteJid, mediaType, fileName);
// await s3Service.uploadFile(fullName, buffer, size.fileLength?.low, {
// 'Content-Type': mimetype,
// });
//
// await this.prismaRepository.media.create({
// data: {
// messageId: msg.id,
// instanceId: this.instanceId,
// type: mediaType,
// fileName: fullName,
// mimetype,
// },
// });
//
// const mediaUrl = await s3Service.getObjectUrl(fullName);
//
// messageRaw.message.mediaUrl = mediaUrl;
//
// await this.prismaRepository.message.update({
// where: { id: msg.id },
// data: messageRaw,
// });
// } catch (error) {
// this.logger.error(['Error on upload file to minio', error?.message, error?.stack]);
// }
// }
// }
// }
if (this.localWebhook.enabled) {
if (isMedia && this.localWebhook.webhookBase64) {
try {
@ -1345,67 +1042,6 @@ export class BaileysStartupService extends ChannelStartupService {
this.logger.log(messageRaw);
this.sendDataWebhook(Events.MESSAGES_UPSERT, messageRaw);
// await chatbotController.emit({
// instance: { instanceName: this.instance.name, instanceId: this.instanceId },
// remoteJid: messageRaw.key.remoteJid,
// msg: messageRaw,
// pushName: messageRaw.pushName,
// });
//
// const contact = await this.prismaRepository.contact.findFirst({
// where: { remoteJid: received.key.remoteJid, instanceId: this.instanceId },
// });
//
// const contactRaw: { remoteJid: string; pushName: string; profilePicUrl?: string; instanceId: string } = {
// remoteJid: received.key.remoteJid,
// pushName: received.key.fromMe ? '' : received.key.fromMe == null ? '' : received.pushName,
// profilePicUrl: (await this.profilePicture(received.key.remoteJid)).profilePictureUrl,
// instanceId: this.instanceId,
// };
// if (contactRaw.remoteJid === 'status@broadcast') {
// continue;
// }
// if (contact) {
// this.sendDataWebhook(Events.CONTACTS_UPDATE, contactRaw);
//
// if (this.configService.get<Chatwoot>('CHATWOOT').ENABLED && this.localChatwoot?.enabled) {
// await this.chatwootService.eventWhatsapp(
// Events.CONTACTS_UPDATE,
// { instanceName: this.instance.name, instanceId: this.instanceId },
// contactRaw,
// );
// }
//
// if (this.configService.get<Database>('DATABASE').SAVE_DATA.CONTACTS)
// await this.prismaRepository.contact.upsert({
// where: { remoteJid_instanceId: { remoteJid: contactRaw.remoteJid, instanceId: contactRaw.instanceId } },
// create: contactRaw,
// update: contactRaw,
// });
//
// continue;
// }
// this.sendDataWebhook(Events.CONTACTS_UPSERT, contactRaw);
// if (this.configService.get<Database>('DATABASE').SAVE_DATA.CONTACTS)
// await this.prismaRepository.contact.upsert({
// where: {
// remoteJid_instanceId: {
// remoteJid: contactRaw.remoteJid,
// instanceId: contactRaw.instanceId,
// },
// },
// update: contactRaw,
// create: contactRaw,
// });
// if (contactRaw.remoteJid.includes('@s.whatsapp')) {
// await saveOnWhatsappCache([{ remoteJid: contactRaw.remoteJid }]);
// }
}
} catch (error) {
this.logger.error(error);
@ -2241,61 +1877,6 @@ export class BaileysStartupService extends ChannelStartupService {
}
}
// if (this.configService.get<Database>('DATABASE').SAVE_DATA.NEW_MESSAGE) {
// const msg = await this.prismaRepository.message.create({
// data: messageRaw,
// });
//
// if (isMedia && this.configService.get<S3>('S3').ENABLE) {
// try {
// const message: any = messageRaw;
// const media = await this.getBase64FromMediaMessage(
// {
// message,
// },
// true,
// );
//
// const { buffer, mediaType, fileName, size } = media;
//
// const mimetype = mimeTypes.lookup(fileName).toString();
//
// const fullName = join(
// `${this.instance.id}`,
// messageRaw.key.remoteJid,
// `${messageRaw.key.id}`,
// mediaType,
// fileName,
// );
//
// await s3Service.uploadFile(fullName, buffer, size.fileLength?.low, {
// 'Content-Type': mimetype,
// });
//
// await this.prismaRepository.media.create({
// data: {
// messageId: msg.id,
// instanceId: this.instanceId,
// type: mediaType,
// fileName: fullName,
// mimetype,
// },
// });
//
// const mediaUrl = await s3Service.getObjectUrl(fullName);
//
// messageRaw.message.mediaUrl = mediaUrl;
//
// await this.prismaRepository.message.update({
// where: { id: msg.id },
// data: messageRaw,
// });
// } catch (error) {
// this.logger.error(['Error on upload file to minio', error?.message, error?.stack]);
// }
// }
// }
if (this.localWebhook.enabled) {
if (isMedia && this.localWebhook.webhookBase64) {
try {