Skip to content

Commit 0e358cf

Browse files
Merge pull request #1696 from foqc/foqc/develop
Preserve alias casing in chat fetch query
2 parents cdef7dc + 1ca829c commit 0e358cf

File tree

1 file changed

+34
-40
lines changed

1 file changed

+34
-40
lines changed

src/api/services/channel.service.ts

Lines changed: 34 additions & 40 deletions
Original file line numberDiff line numberDiff line change
@@ -740,21 +740,21 @@ export class ChannelStartupService {
740740
"Chat"."createdAt" + INTERVAL '24 hours' as "windowExpires",
741741
"Chat"."unreadMessages" as "unreadMessages",
742742
CASE WHEN "Chat"."createdAt" + INTERVAL '24 hours' > NOW() THEN true ELSE false END as "windowActive",
743-
"Message"."id" AS lastMessageId,
744-
"Message"."key" AS lastMessage_key,
743+
"Message"."id" AS "lastMessageId",
744+
"Message"."key" AS "lastMessage_key",
745745
CASE
746746
WHEN "Message"."key"->>'fromMe' = 'true' THEN 'Você'
747747
ELSE "Message"."pushName"
748-
END AS lastMessagePushName,
749-
"Message"."participant" AS lastMessageParticipant,
750-
"Message"."messageType" AS lastMessageMessageType,
751-
"Message"."message" AS lastMessageMessage,
752-
"Message"."contextInfo" AS lastMessageContextInfo,
753-
"Message"."source" AS lastMessageSource,
754-
"Message"."messageTimestamp" AS lastMessageMessageTimestamp,
755-
"Message"."instanceId" AS lastMessageInstanceId,
756-
"Message"."sessionId" AS lastMessageSessionId,
757-
"Message"."status" AS lastMessageStatus
748+
END AS "lastMessagePushName",
749+
"Message"."participant" AS "lastMessageParticipant",
750+
"Message"."messageType" AS "lastMessageMessageType",
751+
"Message"."message" AS "lastMessageMessage",
752+
"Message"."contextInfo" AS "lastMessageContextInfo",
753+
"Message"."source" AS "lastMessageSource",
754+
"Message"."messageTimestamp" AS "lastMessageMessageTimestamp",
755+
"Message"."instanceId" AS "lastMessageInstanceId",
756+
"Message"."sessionId" AS "lastMessageSessionId",
757+
"Message"."status" AS "lastMessageStatus"
758758
FROM "Message"
759759
LEFT JOIN "Contact" ON "Contact"."remoteJid" = "Message"."key"->>'remoteJid' AND "Contact"."instanceId" = "Message"."instanceId"
760760
LEFT JOIN "Chat" ON "Chat"."remoteJid" = "Message"."key"->>'remoteJid' AND "Chat"."instanceId" = "Message"."instanceId"
@@ -771,44 +771,38 @@ export class ChannelStartupService {
771771

772772
if (results && isArray(results) && results.length > 0) {
773773
const mappedResults = results.map((contact) => {
774-
const lastMessage = contact.lastmessageid
774+
const lastMessage = contact.lastMessageId
775775
? {
776-
id: contact.lastmessageid,
777-
key: contact.lastmessage_key,
778-
pushName: contact.lastmessagepushname,
779-
participant: contact.lastmessageparticipant,
780-
messageType: contact.lastmessagemessagetype,
781-
message: contact.lastmessagemessage,
782-
contextInfo: contact.lastmessagecontextinfo,
783-
source: contact.lastmessagesource,
784-
messageTimestamp: contact.lastmessagemessagetimestamp,
785-
instanceId: contact.lastmessageinstanceid,
786-
sessionId: contact.lastmessagesessionid,
787-
status: contact.lastmessagestatus,
776+
id: contact.lastMessageId,
777+
key: contact.lastMessage_key,
778+
pushName: contact.lastMessagePushName,
779+
participant: contact.lastMessageParticipant,
780+
messageType: contact.lastMessageMessageType,
781+
message: contact.lastMessageMessage,
782+
contextInfo: contact.lastMessageContextInfo,
783+
source: contact.lastMessageSource,
784+
messageTimestamp: contact.lastMessageMessageTimestamp,
785+
instanceId: contact.lastMessageInstanceId,
786+
sessionId: contact.lastMessageSessionId,
787+
status: contact.lastMessageStatus,
788788
}
789789
: undefined;
790790

791791
return {
792-
id: contact.contactid || null,
793-
remoteJid: contact.remotejid,
794-
pushName: contact.pushname,
795-
profilePicUrl: contact.profilepicurl,
796-
updatedAt: contact.updatedat,
797-
windowStart: contact.windowstart,
798-
windowExpires: contact.windowexpires,
799-
windowActive: contact.windowactive,
792+
id: contact.contactId || null,
793+
remoteJid: contact.remoteJid,
794+
pushName: contact.pushName,
795+
profilePicUrl: contact.profilePicUrl,
796+
updatedAt: contact.updatedAt,
797+
windowStart: contact.windowStart,
798+
windowExpires: contact.windowExpires,
799+
windowActive: contact.windowActive,
800800
lastMessage: lastMessage ? this.cleanMessageData(lastMessage) : undefined,
801801
unreadCount: contact.unreadMessages,
802-
isSaved: !!contact.contactid,
802+
isSaved: !!contact.contactId,
803803
};
804804
});
805805

806-
if (query?.take && query?.skip) {
807-
const skip = query.skip || 0;
808-
const take = query.take || 20;
809-
return mappedResults.slice(skip, skip + take);
810-
}
811-
812806
return mappedResults;
813807
}
814808

0 commit comments

Comments
 (0)