[core] Fix MongoDB

Author: devlikepro

src/apps/app_sdk/services/AppsDisabledService.ts

@@ -1,5 +1,6 @@
 import { Injectable, UnprocessableEntityException } from '@nestjs/common';
 import { IAppsService } from '@waha/apps/app_sdk/services/IAppsService';
+import { DataStore } from '@waha/core/abc/DataStore';
 import { SessionManager } from '@waha/core/abc/manager.abc';
 import { WhatsappSession } from '@waha/core/abc/session.abc';
 import { Knex } from 'knex';
@@ -36,7 +37,7 @@ export class AppsDisabledService implements IAppsService {
     return;
   }
 
-  async beforeSessionStart(session: WhatsappSession, knex) {
+  async beforeSessionStart(session: WhatsappSession, store: DataStore) {
     return;
   }
 }

src/apps/app_sdk/services/AppsEnabledService.ts

@@ -3,6 +3,7 @@ import { migrate } from '@waha/apps/app_sdk/migrations';
 import { IAppService } from '@waha/apps/app_sdk/services/IAppService';
 import { IAppsService } from '@waha/apps/app_sdk/services/IAppsService';
 import { ChatWootAppService } from '@waha/apps/chatwoot/services/ChatWootAppService';
+import { DataStore } from '@waha/core/abc/DataStore';
 import { SessionManager } from '@waha/core/abc/manager.abc';
 import { WhatsappSession } from '@waha/core/abc/session.abc';
 import { generatePrefixedId } from '@waha/utils/ids';
@@ -106,7 +107,8 @@ export class AppsEnabledService implements IAppsService {
     return;
   }
 
-  async beforeSessionStart(session: WhatsappSession, knex) {
+  async beforeSessionStart(session: WhatsappSession, store: DataStore) {
+    const knex = store.getWAHADatabase();
     const repo = new AppRepository(knex);
     const apps = await repo.getAllBySession(session.name);
     for (const app of apps) {

src/apps/app_sdk/services/IAppsService.ts

@@ -1,4 +1,5 @@
 import { App } from '@waha/apps/app_sdk/dto/app.dto';
+import { DataStore } from '@waha/core/abc/DataStore';
 import { SessionManager } from '@waha/core/abc/manager.abc';
 import { WhatsappSession } from '@waha/core/abc/session.abc';
 import { Knex } from 'knex';
@@ -12,7 +13,7 @@ export interface IAppsService {
 
   delete(manager: SessionManager, appId: string): Promise<void>;
 
-  beforeSessionStart(session: WhatsappSession, knex: Knex): Promise<void>;
+  beforeSessionStart(session: WhatsappSession, store: DataStore): Promise<void>;
 
   migrate(knex: Knex): Promise<void>;
 }

src/core/abc/manager.abc.ts

@@ -103,10 +103,7 @@ export abstract class SessionManager
   }
 
   async configureApps(session: WhatsappSession) {
-    await this.appsService.beforeSessionStart(
-      session,
-      this.store.getWAHADatabase(),
-    );
+    await this.appsService.beforeSessionStart(session, this.store);
   }
 
   //