add env UNOAPI_MODE

Author: clairton

package.json

@@ -1,6 +1,6 @@
 {
   "name": "unoapi-cloud",
-  "version": "2.5.18",
+  "version": "2.5.19",
   "description": "Unoapi Cloud",
   "exports": "./dist/index.js",
   "types": "./dist/index.d.ts",
@@ -15,33 +15,33 @@
     "test": "node_modules/jest/bin/jest.js --coverage",
     "build": "./node_modules/typescript/bin/tsc -p .",
     "format": "prettier --ignore-path .gitignore --write \"**/*.+(js|ts|json)\"",
-    "dev": "tsx watch src/index.ts",
-    "web-dev": "tsx watch src/web.ts",
-    "waker-dev": "tsx watch src/waker.ts",
-    "standalone-dev": "tsx watch src/standalone.ts",
-    "worker-dev": "tsx watch src/worker.ts",
-    "bulker-dev": "tsx watch src/bulker.ts",
-    "broker-dev": "tsx watch src/broker.ts",
-    "bridge-dev": "tsx watch src/bridge.ts",
-    "cloud-dev": "tsx watch src/cloud.ts",
-    "start": "node dist/src/index.js",
-    "start-ts": "node --import tsx src/index.ts",
-    "cloud": "node dist/src/cloud.js",
-    "cloud-ts": "node --import tsx src/cloud.ts",
-    "standalone": "node dist/src/standalone.js",
-    "standalone-ts": "node --import tsx src/standalone.ts",
-    "web": "node dist/src/web.js",
-    "waker": "node dist/src/waker.js",
-    "waker-ts": "node --import tsx src/waker.ts",
-    "web-ts": "node --import tsx src/web.ts",
-    "worker": "node dist/src/worker.js",
-    "worker-ts": "node --import tsx src/worker.ts",
-    "bulker": "node dist/src/bulker.js",
-    "bulker-ts": "node --import tsx src/bulker.ts",
-    "broker": "node dist/src/broker.js",
-    "broker-ts": "node --import tsx src/broker.ts",
-    "bridge": "node dist/src/bridge.js",
-    "bridge-ts": "node --import tsx src/bridge.ts",
+    "dev": "UNOAPI_MODE=simple tsx watch src/index.ts",
+    "web-dev": "UNOAPI_MODE=web tsx watch src/web.ts",
+    "waker-dev": "UNOAPI_MODE=waker tsx watch src/waker.ts",
+    "standalone-dev": "UNOAPI_MODE=standalone tsx watch src/standalone.ts",
+    "worker-dev": "UNOAPI_MODE=worker tsx watch src/worker.ts",
+    "bulker-dev": "UNOAPI_MODE=bulker tsx watch src/bulker.ts",
+    "broker-dev": "UNOAPI_MODE=broker tsx watch src/broker.ts",
+    "bridge-dev": "UNOAPI_MODE=bridge tsx watch src/bridge.ts",
+    "cloud-dev": "UNOAPI_MODE=cloud tsx watch src/cloud.ts",
+    "start": "UNOAPI_MODE=simple node dist/src/index.js",
+    "start-ts": "UNOAPI_MODE=simple node --import tsx src/index.ts",
+    "cloud": "UNOAPI_MODE=cloud node dist/src/cloud.js",
+    "cloud-ts": "UNOAPI_MODE=cloud node --import tsx src/cloud.ts",
+    "standalone": "UNOAPI_MODE=standalone node dist/src/standalone.js",
+    "standalone-ts": "UNOAPI_MODE=standalone node --import tsx src/standalone.ts",
+    "web": "UNOAPI_MODE=web node dist/src/web.js",
+    "waker": "UNOAPI_MODE=waker node dist/src/waker.js",
+    "waker-ts": "UNOAPI_MODE=waker node --import tsx src/waker.ts",
+    "web-ts": "UNOAPI_MODE=web node --import tsx src/web.ts",
+    "worker": "UNOAPI_MODE=worker node dist/src/worker.js",
+    "worker-ts": "UNOAPI_MODE=worker node --import tsx src/worker.ts",
+    "bulker": "UNOAPI_MODE=bulker node dist/src/bulker.js",
+    "bulker-ts": "UNOAPI_MODE=bulker node --import tsx src/bulker.ts",
+    "broker": "UNOAPI_MODE=broker node dist/src/broker.js",
+    "broker-ts": "UNOAPI_MODE=broker node --import tsx src/broker.ts",
+    "bridge": "UNOAPI_MODE=bridge node dist/src/bridge.js",
+    "bridge-ts": "UNOAPI_MODE=bridge node --import tsx src/bridge.ts",
     "clean:data": "rm -rf ./data/medias/* ./data/sessions/* ./data/stores/*.json"
   },
   "devDependencies": {

src/cloud.ts

@@ -1,10 +1,13 @@
 import * as dotenv from 'dotenv'
 dotenv.config()
 
+process.env.UNOAPI_CLOUD = 'true'
+
 import logger from './services/logger'
 logger.info('Starting...')
 
 // eslint-disable-next-line @typescript-eslint/no-unused-vars
 import './web'
 // eslint-disable-next-line @typescript-eslint/no-unused-vars
 import './worker'
+

src/web.ts

@@ -28,6 +28,16 @@ import { BroacastJob } from './jobs/broadcast'
 import { ReloadAmqp } from './services/reload_amqp'
 import { LogoutAmqp } from './services/logout_amqp'
 import { Reload } from './services/reload'
+import ContactBaileys from './services/contact_baileys'
+import { Contact } from './services/contact'
+import { ReloadJob } from './jobs/reload'
+import Security from './services/security'
+import middleware from './services/middleware'
+import { getClientBaileys } from './services/client_baileys'
+import { ListenerBaileys } from './services/listener_baileys'
+import { Listener } from './services/listener'
+import { ContactDummy } from './services/contact_dummy'
+import injectRouteDummy from './services/inject_route_dummy'
 
 import * as Sentry from '@sentry/node'
 if (process.env.SENTRY_DSN) {
@@ -45,14 +55,19 @@ const onNewLogin = onNewLoginGenerateToken(outgoing)
 const broadcast: Broadcast = new Broadcast()
 const reloadAmqp = new ReloadAmqp(getConfigRedis)
 const logout = new LogoutAmqp(getConfigRedis)
-import { ReloadJob } from './jobs/reload'
-import Security from './services/security'
-import middleware from './services/middleware'
 const reloadJob = new ReloadJob(reloadAmqp)
 const securityVar = new Security(sessionStore)
 const middlewareVar = securityVar.run.bind(securityVar) as middleware
 
-const app: App = new App(incoming, outgoing, BASE_URL, getConfigRedis, sessionStore, onNewLogin, addToBlacklistJob, reloadAmqp, logout, middlewareVar)
+let contactType: Contact
+if (process.env.UNOAPI_MODE == 'cloud') {
+  let listener: Listener = new ListenerBaileys(outgoing, broadcast, getConfigRedis)
+  contactType = new ContactBaileys(listener, getConfigRedis, getClientBaileys, onNewLogin)
+} else {
+  contactType = new ContactDummy()
+}
+
+const app: App = new App(incoming, outgoing, BASE_URL, getConfigRedis, sessionStore, onNewLogin, addToBlacklistJob, reloadAmqp, logout, middlewareVar, injectRouteDummy, contactType!)
 broadcast.setSever(app.socket)
 
 const broadcastJob = new BroacastJob(broadcast)