feature: add endpoint to retrieve chat data by phone number

foqc · foqc · commit 68e847d10e2e · 2025-07-21T12:21:45.000-05:00
diff --git a/src/api/controllers/chat.controller.ts b/src/api/controllers/chat.controller.ts
@@ -70,6 +70,10 @@ export class ChatController {
     return await this.waMonitor.waInstances[instanceName].fetchChats(query);
   }
 
+  public async findChatByRemoteJid({ instanceName }: InstanceDto, remoteJid: string) {
+    return await this.waMonitor.waInstances[instanceName].findChatByRemoteJid(remoteJid);
+  }
+
   public async sendPresence({ instanceName }: InstanceDto, data: SendPresenceDto) {
     return await this.waMonitor.waInstances[instanceName].sendPresence(data);
   }
diff --git a/src/api/routes/chat.router.ts b/src/api/routes/chat.router.ts
@@ -191,6 +191,16 @@ export class ChatRouter extends RouterBroker {
 
         return res.status(HttpStatus.OK).json(response);
       })
+      .get(this.routerPath('findChatByRemoteJid'), ...guards, async (req, res) => {
+        const instance = req.params as unknown as InstanceDto;
+        const { remoteJid } = req.query as unknown as { remoteJid: string };
+        if (!remoteJid) {
+          return res.status(HttpStatus.BAD_REQUEST).json({ error: "remoteJid is a required query parameter" });
+        }
+        const response = await chatController.findChatByRemoteJid(instance, remoteJid);
+
+        return res.status(HttpStatus.OK).json(response);
+      })
       // Profile routes
       .post(this.routerPath('fetchBusinessProfile'), ...guards, async (req, res) => {
         const response = await this.dataValidate<ProfilePictureDto>({
diff --git a/src/api/services/channel.service.ts b/src/api/services/channel.service.ts
@@ -696,6 +696,16 @@ export class ChannelStartupService {
     });
   }
 
+  public async findChatByRemoteJid(remoteJid: string) {
+    if (!remoteJid) return null;
+    return await this.prismaRepository.chat.findFirst({
+      where: {
+        instanceId: this.instanceId,
+        remoteJid: remoteJid,
+      },
+    });
+  }
+
   public async fetchChats(query: any) {
     const remoteJid = query?.where?.remoteJid
       ? query?.where?.remoteJid.includes('@')

Original file line number	Diff line number	Diff line change
`@@ -70,6 +70,10 @@ export class ChatController {`
`70`	`70`	`return await this.waMonitor.waInstances[instanceName].fetchChats(query);`
`71`	`71`	`}`
`72`	`72`
	`73`	`+ public async findChatByRemoteJid({ instanceName }: InstanceDto, remoteJid: string) {`
	`74`	`+ return await this.waMonitor.waInstances[instanceName].findChatByRemoteJid(remoteJid);`
	`75`	`+ }`
	`76`	`+`
`73`	`77`	`public async sendPresence({ instanceName }: InstanceDto, data: SendPresenceDto) {`
`74`	`78`	`return await this.waMonitor.waInstances[instanceName].sendPresence(data);`
`75`	`79`	`}`