Skip to content

Commit

Permalink
fix: fetch instances
Browse files Browse the repository at this point in the history
  • Loading branch information
DavidsonGomes committed Oct 29, 2024
1 parent fce3e55 commit 23640a7
Show file tree
Hide file tree
Showing 3 changed files with 21 additions and 14 deletions.
4 changes: 3 additions & 1 deletion src/api/controllers/instance.controller.ts
Original file line number Diff line number Diff line change
Expand Up @@ -382,7 +382,9 @@ export class InstanceController {
return this.waMonitor.instanceInfoById(instanceId, number);
}

return this.waMonitor.instanceInfo([instanceName]);
const instanceNames = instanceName ? [instanceName] : null;

return this.waMonitor.instanceInfo(instanceNames);
}

public async setPresence({ instanceName }: InstanceDto, data: SetPresenceDto) {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -1762,7 +1762,8 @@ export class BaileysStartupService extends ChannelStartupService {
website: business?.website?.shift(),
};
} else {
const info: Instance = await waMonitor.instanceInfo([instanceName]);
const instanceNames = instanceName ? [instanceName] : null;
const info: Instance = await waMonitor.instanceInfo(instanceNames);
const business = await this.fetchBusinessProfile(jid);

return {
Expand Down
28 changes: 16 additions & 12 deletions src/api/services/monitor.service.ts
Original file line number Diff line number Diff line change
Expand Up @@ -60,23 +60,25 @@ export class WAMonitoringService {
}

public async instanceInfo(instanceNames?: string[]): Promise<any> {
const inexistentInstances = instanceNames ? instanceNames.filter((instance) => !this.waInstances[instance]) : [];
if (instanceNames && instanceNames.length > 0) {
const inexistentInstances = instanceNames ? instanceNames.filter((instance) => !this.waInstances[instance]) : [];

if (inexistentInstances.length > 0) {
throw new NotFoundException(
`Instance${inexistentInstances.length > 1 ? 's' : ''} "${inexistentInstances.join(', ')}" not found`,
);
if (inexistentInstances.length > 0) {
throw new NotFoundException(
`Instance${inexistentInstances.length > 1 ? 's' : ''} "${inexistentInstances.join(', ')}" not found`,
);
}
}

const clientName = this.configService.get<Database>('DATABASE').CONNECTION.CLIENT_NAME;

const where = instanceNames
const where = instanceNames && instanceNames.length > 0
? {
name: {
in: instanceNames,
},
clientName,
}
name: {
in: instanceNames,
},
clientName,
}
: { clientName };

const instances = await this.prismaRepository.instance.findMany({
Expand Down Expand Up @@ -123,7 +125,9 @@ export class WAMonitoringService {
throw new NotFoundException(`Instance "${instanceName}" not found`);
}

return this.instanceInfo([instanceName]);
const instanceNames = instanceName ? [instanceName] : null;

return this.instanceInfo(instanceNames);
}

public async cleaningUp(instanceName: string) {
Expand Down

0 comments on commit 23640a7

Please sign in to comment.