Skip to content

Commit 5239e43

Browse files
committed
feat: update server and monitor services
Updated server.module.ts and monitor.service.ts to improve service initialization and monitoring logic. Modified main.ts to integrate changes. This enhances the application's performance and reliability.
1 parent 53cc613 commit 5239e43

File tree

3 files changed

+16
-7
lines changed

3 files changed

+16
-7
lines changed

src/api/server.module.ts

Lines changed: 7 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
import { CacheEngine } from '../cache/cacheengine';
2-
import { configService } from '../config/env.config';
2+
import { configService, ProviderSession } from '../config/env.config';
33
import { eventEmitter } from '../config/event.config';
44
import { Logger } from '../config/logger.config';
55
import { dbserver } from '../libs/db.connect';
@@ -110,7 +110,12 @@ export const repository = new RepositoryBroker(
110110
export const cache = new CacheService(new CacheEngine(configService, 'instance').getEngine());
111111
const chatwootCache = new CacheService(new CacheEngine(configService, ChatwootService.name).getEngine());
112112
const baileysCache = new CacheService(new CacheEngine(configService, 'baileys').getEngine());
113-
const providerFiles = new ProviderFiles(configService);
113+
114+
let providerFiles: ProviderFiles = null;
115+
116+
if (configService.get<ProviderSession>('PROVIDER')?.ENABLED) {
117+
providerFiles = new ProviderFiles(configService);
118+
}
114119

115120
export const waMonitor = new WAMonitoringService(
116121
eventEmitter,

src/api/services/monitor.service.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -323,7 +323,7 @@ export class WAMonitoringService {
323323
this.logger.verbose('Loading instances');
324324

325325
try {
326-
if (this.providerSession.ENABLED) {
326+
if (this.providerSession?.ENABLED) {
327327
await this.loadInstancesFromProvider();
328328
} else if (this.redis.REDIS.ENABLED && this.redis.REDIS.SAVE_INSTANCES) {
329329
await this.loadInstancesFromRedis();

src/main.ts

Lines changed: 8 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,7 @@ import { initIO } from './api/integrations/websocket/libs/socket.server';
1212
import { ProviderFiles } from './api/provider/sessions';
1313
import { HttpStatus, router } from './api/routes/index.router';
1414
import { waMonitor } from './api/server.module';
15-
import { Auth, configService, Cors, HttpServer, Rabbitmq, Sqs, Webhook } from './config/env.config';
15+
import { Auth, configService, Cors, HttpServer, ProviderSession, Rabbitmq, Sqs, Webhook } from './config/env.config';
1616
import { onUnexpectedError } from './config/error.config';
1717
import { Logger } from './config/logger.config';
1818
import { ROOT_DIR } from './config/path.config';
@@ -27,9 +27,13 @@ async function bootstrap() {
2727
const logger = new Logger('SERVER');
2828
const app = express();
2929

30-
const providerFiles = new ProviderFiles(configService);
31-
await providerFiles.onModuleInit();
32-
logger.info('Provider:Files - ON');
30+
let providerFiles: ProviderFiles = null;
31+
32+
if (configService.get<ProviderSession>('PROVIDER')?.ENABLED) {
33+
providerFiles = new ProviderFiles(configService);
34+
await providerFiles.onModuleInit();
35+
logger.info('Provider:Files - ON');
36+
}
3337

3438
app.use(
3539
cors({

0 commit comments

Comments
 (0)