mirror of
https://github.com/EvolutionAPI/evolution-api.git
synced 2025-07-24 17:38:40 -06:00
Merge branch 'release/1.7.3'
This commit is contained in:
commit
371ec9b8d5
12
CHANGELOG.md
12
CHANGELOG.md
@ -1,3 +1,15 @@
|
|||||||
|
# 1.7.3 (2024-04-18 12:07)
|
||||||
|
|
||||||
|
### Fixed
|
||||||
|
* Revert fix audio encoding
|
||||||
|
* Recovering messages lost with redis cache
|
||||||
|
* Adjusts in redis for save instances
|
||||||
|
* Adjusts in proxy
|
||||||
|
* Revert pull request #523
|
||||||
|
* Added instance name on logs
|
||||||
|
* Added support for Spanish
|
||||||
|
* Fix error: invalid operator. The allowed operators for identifier are equal_to,not_equal_to in chatwoot
|
||||||
|
|
||||||
# 1.7.2 (2024-04-12 17:31)
|
# 1.7.2 (2024-04-12 17:31)
|
||||||
|
|
||||||
### Feature
|
### Feature
|
||||||
|
@ -33,7 +33,10 @@ CLEAN_STORE_CHATS=true
|
|||||||
|
|
||||||
# Permanent data storage
|
# Permanent data storage
|
||||||
DATABASE_ENABLED=false
|
DATABASE_ENABLED=false
|
||||||
DATABASE_CONNECTION_URI=mongodb://root:root@mongodb:27017/?authSource=admin&readPreference=primary&ssl=false&directConnection=true
|
DATABASE_CONNECTION_URI=mongodb://root:root@mongodb:27017/?authSource=admin &
|
||||||
|
readPreference=primary &
|
||||||
|
ssl=false &
|
||||||
|
directConnection=true
|
||||||
DATABASE_CONNECTION_DB_PREFIX_NAME=evdocker
|
DATABASE_CONNECTION_DB_PREFIX_NAME=evdocker
|
||||||
|
|
||||||
# Choose the data you want to save in the application's database or store
|
# Choose the data you want to save in the application's database or store
|
||||||
@ -43,10 +46,6 @@ DATABASE_SAVE_MESSAGE_UPDATE=false
|
|||||||
DATABASE_SAVE_DATA_CONTACTS=false
|
DATABASE_SAVE_DATA_CONTACTS=false
|
||||||
DATABASE_SAVE_DATA_CHATS=false
|
DATABASE_SAVE_DATA_CHATS=false
|
||||||
|
|
||||||
REDIS_ENABLED=false
|
|
||||||
REDIS_URI=redis://redis:6379
|
|
||||||
REDIS_PREFIX_KEY=evdocker
|
|
||||||
|
|
||||||
RABBITMQ_ENABLED=false
|
RABBITMQ_ENABLED=false
|
||||||
RABBITMQ_RABBITMQ_MODE=global
|
RABBITMQ_RABBITMQ_MODE=global
|
||||||
RABBITMQ_EXCHANGE_NAME=evolution_exchange
|
RABBITMQ_EXCHANGE_NAME=evolution_exchange
|
||||||
@ -73,7 +72,7 @@ WEBHOOK_GLOBAL_URL=''
|
|||||||
WEBHOOK_GLOBAL_ENABLED=false
|
WEBHOOK_GLOBAL_ENABLED=false
|
||||||
# With this option activated, you work with a url per webhook event, respecting the global url and the name of each event
|
# With this option activated, you work with a url per webhook event, respecting the global url and the name of each event
|
||||||
WEBHOOK_GLOBAL_WEBHOOK_BY_EVENTS=false
|
WEBHOOK_GLOBAL_WEBHOOK_BY_EVENTS=false
|
||||||
## Set the events you want to hear
|
## Set the events you want to hear
|
||||||
WEBHOOK_EVENTS_APPLICATION_STARTUP=false
|
WEBHOOK_EVENTS_APPLICATION_STARTUP=false
|
||||||
WEBHOOK_EVENTS_QRCODE_UPDATED=true
|
WEBHOOK_EVENTS_QRCODE_UPDATED=true
|
||||||
WEBHOOK_EVENTS_MESSAGES_SET=true
|
WEBHOOK_EVENTS_MESSAGES_SET=true
|
||||||
@ -129,6 +128,14 @@ CHATWOOT_MESSAGE_READ=false # false | true
|
|||||||
CHATWOOT_IMPORT_DATABASE_CONNECTION_URI=postgres://user:password@hostname:port/dbname
|
CHATWOOT_IMPORT_DATABASE_CONNECTION_URI=postgres://user:password@hostname:port/dbname
|
||||||
CHATWOOT_IMPORT_DATABASE_PLACEHOLDER_MEDIA_MESSAGE=true
|
CHATWOOT_IMPORT_DATABASE_PLACEHOLDER_MEDIA_MESSAGE=true
|
||||||
|
|
||||||
|
CACHE_REDIS_ENABLED=false
|
||||||
|
CACHE_REDIS_URI=redis://redis:6379
|
||||||
|
CACHE_REDIS_PREFIX_KEY=evolution
|
||||||
|
CACHE_REDIS_TTL=604800
|
||||||
|
CACHE_REDIS_SAVE_INSTANCES=false
|
||||||
|
CACHE_LOCAL_ENABLED=false
|
||||||
|
CACHE_LOCAL_TTL=604800
|
||||||
|
|
||||||
# Defines an authentication type for the api
|
# Defines an authentication type for the api
|
||||||
# We recommend using the apikey because it will allow you to use a custom token,
|
# We recommend using the apikey because it will allow you to use a custom token,
|
||||||
# if you use jwt, a random token will be generated and may be expired and you will have to generate a new token
|
# if you use jwt, a random token will be generated and may be expired and you will have to generate a new token
|
||||||
@ -143,4 +150,4 @@ AUTHENTICATION_EXPOSE_IN_FETCH_INSTANCES=true
|
|||||||
AUTHENTICATION_JWT_EXPIRIN_IN=0
|
AUTHENTICATION_JWT_EXPIRIN_IN=0
|
||||||
AUTHENTICATION_JWT_SECRET='L=0YWt]b2w[WF>#>:&E`'
|
AUTHENTICATION_JWT_SECRET='L=0YWt]b2w[WF>#>:&E`'
|
||||||
|
|
||||||
LANGUAGE=en # pt-BR, en
|
LANGUAGE=en # pt-BR, en
|
||||||
|
@ -33,7 +33,10 @@ CLEAN_STORE_CHATS=true
|
|||||||
|
|
||||||
# Permanent data storage
|
# Permanent data storage
|
||||||
DATABASE_ENABLED=true
|
DATABASE_ENABLED=true
|
||||||
DATABASE_CONNECTION_URI=mongodb://root:root@mongodb:27017/?authSource=admin&readPreference=primary&ssl=false&directConnection=true
|
DATABASE_CONNECTION_URI=mongodb://root:root@mongodb:27017/?authSource=admin &
|
||||||
|
readPreference=primary &
|
||||||
|
ssl=false &
|
||||||
|
directConnection=true
|
||||||
DATABASE_CONNECTION_DB_PREFIX_NAME=evolution
|
DATABASE_CONNECTION_DB_PREFIX_NAME=evolution
|
||||||
|
|
||||||
# Choose the data you want to save in the application's database or store
|
# Choose the data you want to save in the application's database or store
|
||||||
@ -43,10 +46,6 @@ DATABASE_SAVE_MESSAGE_UPDATE=false
|
|||||||
DATABASE_SAVE_DATA_CONTACTS=false
|
DATABASE_SAVE_DATA_CONTACTS=false
|
||||||
DATABASE_SAVE_DATA_CHATS=false
|
DATABASE_SAVE_DATA_CHATS=false
|
||||||
|
|
||||||
REDIS_ENABLED=true
|
|
||||||
REDIS_URI=redis://redis:6379
|
|
||||||
REDIS_PREFIX_KEY=evolution
|
|
||||||
|
|
||||||
# Global Webhook Settings
|
# Global Webhook Settings
|
||||||
# Each instance's Webhook URL and events will be requested at the time it is created
|
# Each instance's Webhook URL and events will be requested at the time it is created
|
||||||
## Define a global webhook that will listen for enabled events from all instances
|
## Define a global webhook that will listen for enabled events from all instances
|
||||||
@ -54,7 +53,7 @@ WEBHOOK_GLOBAL_URL=''
|
|||||||
WEBHOOK_GLOBAL_ENABLED=false
|
WEBHOOK_GLOBAL_ENABLED=false
|
||||||
# With this option activated, you work with a url per webhook event, respecting the global url and the name of each event
|
# With this option activated, you work with a url per webhook event, respecting the global url and the name of each event
|
||||||
WEBHOOK_GLOBAL_WEBHOOK_BY_EVENTS=false
|
WEBHOOK_GLOBAL_WEBHOOK_BY_EVENTS=false
|
||||||
## Set the events you want to hear
|
## Set the events you want to hear
|
||||||
WEBHOOK_EVENTS_APPLICATION_STARTUP=false
|
WEBHOOK_EVENTS_APPLICATION_STARTUP=false
|
||||||
WEBHOOK_EVENTS_QRCODE_UPDATED=true
|
WEBHOOK_EVENTS_QRCODE_UPDATED=true
|
||||||
WEBHOOK_EVENTS_MESSAGES_SET=true
|
WEBHOOK_EVENTS_MESSAGES_SET=true
|
||||||
@ -87,6 +86,14 @@ CONFIG_SESSION_PHONE_NAME=chrome
|
|||||||
# Set qrcode display limit
|
# Set qrcode display limit
|
||||||
QRCODE_LIMIT=30
|
QRCODE_LIMIT=30
|
||||||
|
|
||||||
|
CACHE_REDIS_ENABLED=false
|
||||||
|
CACHE_REDIS_URI=redis://redis:6379
|
||||||
|
CACHE_REDIS_PREFIX_KEY=evolution
|
||||||
|
CACHE_REDIS_TTL=604800
|
||||||
|
CACHE_REDIS_SAVE_INSTANCES=false
|
||||||
|
CACHE_LOCAL_ENABLED=false
|
||||||
|
CACHE_LOCAL_TTL=604800
|
||||||
|
|
||||||
# Defines an authentication type for the api
|
# Defines an authentication type for the api
|
||||||
# We recommend using the apikey because it will allow you to use a custom token,
|
# We recommend using the apikey because it will allow you to use a custom token,
|
||||||
# if you use jwt, a random token will be generated and may be expired and you will have to generate a new token
|
# if you use jwt, a random token will be generated and may be expired and you will have to generate a new token
|
||||||
@ -109,4 +116,4 @@ AUTHENTICATION_INSTANCE_NAME=evolution
|
|||||||
AUTHENTICATION_INSTANCE_WEBHOOK_URL=''
|
AUTHENTICATION_INSTANCE_WEBHOOK_URL=''
|
||||||
AUTHENTICATION_INSTANCE_CHATWOOT_ACCOUNT_ID=1
|
AUTHENTICATION_INSTANCE_CHATWOOT_ACCOUNT_ID=1
|
||||||
AUTHENTICATION_INSTANCE_CHATWOOT_TOKEN=123456
|
AUTHENTICATION_INSTANCE_CHATWOOT_TOKEN=123456
|
||||||
AUTHENTICATION_INSTANCE_CHATWOOT_URL=''
|
AUTHENTICATION_INSTANCE_CHATWOOT_URL=''
|
||||||
|
14
Dockerfile
14
Dockerfile
@ -1,6 +1,6 @@
|
|||||||
FROM node:20.7.0-alpine AS builder
|
FROM node:20.7.0-alpine AS builder
|
||||||
|
|
||||||
LABEL version="1.7.2" description="Api to control whatsapp features through http requests."
|
LABEL version="1.7.3" description="Api to control whatsapp features through http requests."
|
||||||
LABEL maintainer="Davidson Gomes" git="https://github.com/DavidsonGomes"
|
LABEL maintainer="Davidson Gomes" git="https://github.com/DavidsonGomes"
|
||||||
LABEL contact="contato@agenciadgcode.com"
|
LABEL contact="contato@agenciadgcode.com"
|
||||||
|
|
||||||
@ -58,10 +58,6 @@ ENV DATABASE_SAVE_MESSAGE_UPDATE=false
|
|||||||
ENV DATABASE_SAVE_DATA_CONTACTS=false
|
ENV DATABASE_SAVE_DATA_CONTACTS=false
|
||||||
ENV DATABASE_SAVE_DATA_CHATS=false
|
ENV DATABASE_SAVE_DATA_CHATS=false
|
||||||
|
|
||||||
ENV REDIS_ENABLED=false
|
|
||||||
ENV REDIS_URI=redis://redis:6379
|
|
||||||
ENV REDIS_PREFIX_KEY=evolution
|
|
||||||
|
|
||||||
ENV RABBITMQ_ENABLED=false
|
ENV RABBITMQ_ENABLED=false
|
||||||
ENV RABBITMQ_MODE=global
|
ENV RABBITMQ_MODE=global
|
||||||
ENV RABBITMQ_EXCHANGE_NAME=evolution_exchange
|
ENV RABBITMQ_EXCHANGE_NAME=evolution_exchange
|
||||||
@ -129,6 +125,14 @@ ENV QRCODE_COLOR=#198754
|
|||||||
|
|
||||||
ENV TYPEBOT_API_VERSION=latest
|
ENV TYPEBOT_API_VERSION=latest
|
||||||
|
|
||||||
|
ENV CACHE_REDIS_ENABLED=false
|
||||||
|
ENV CACHE_REDIS_URI=redis://redis:6379
|
||||||
|
ENV CACHE_REDIS_PREFIX_KEY=evolution
|
||||||
|
ENV CACHE_REDIS_TTL=604800
|
||||||
|
ENV CACHE_REDIS_SAVE_INSTANCES=false
|
||||||
|
ENV CACHE_LOCAL_ENABLED=false
|
||||||
|
ENV CACHE_LOCAL_TTL=604800
|
||||||
|
|
||||||
ENV AUTHENTICATION_TYPE=apikey
|
ENV AUTHENTICATION_TYPE=apikey
|
||||||
|
|
||||||
ENV AUTHENTICATION_API_KEY=B6D711FCDE4D4FD5936544120E713976
|
ENV AUTHENTICATION_API_KEY=B6D711FCDE4D4FD5936544120E713976
|
||||||
|
@ -1,6 +1,6 @@
|
|||||||
{
|
{
|
||||||
"name": "evolution-api",
|
"name": "evolution-api",
|
||||||
"version": "1.7.2",
|
"version": "1.7.3",
|
||||||
"description": "Rest api for communication with WhatsApp",
|
"description": "Rest api for communication with WhatsApp",
|
||||||
"main": "./dist/src/main.js",
|
"main": "./dist/src/main.js",
|
||||||
"scripts": {
|
"scripts": {
|
||||||
|
@ -1,13 +1,19 @@
|
|||||||
export interface ICache {
|
export interface ICache {
|
||||||
get(key: string): Promise<any>;
|
get(key: string): Promise<any>;
|
||||||
|
|
||||||
|
hGet(key: string, field: string): Promise<any>;
|
||||||
|
|
||||||
set(key: string, value: any, ttl?: number): void;
|
set(key: string, value: any, ttl?: number): void;
|
||||||
|
|
||||||
|
hSet(key: string, field: string, value: any): Promise<void>;
|
||||||
|
|
||||||
has(key: string): Promise<boolean>;
|
has(key: string): Promise<boolean>;
|
||||||
|
|
||||||
keys(appendCriteria?: string): Promise<string[]>;
|
keys(appendCriteria?: string): Promise<string[]>;
|
||||||
|
|
||||||
delete(key: string | string[]): Promise<number>;
|
delete(key: string | string[]): Promise<number>;
|
||||||
|
|
||||||
|
hDelete(key: string, field: string): Promise<any>;
|
||||||
|
|
||||||
deleteAll(appendCriteria?: string): Promise<number>;
|
deleteAll(appendCriteria?: string): Promise<number>;
|
||||||
}
|
}
|
||||||
|
@ -6,7 +6,6 @@ import { v4 } from 'uuid';
|
|||||||
import { ConfigService, HttpServer, WaBusiness } from '../../config/env.config';
|
import { ConfigService, HttpServer, WaBusiness } from '../../config/env.config';
|
||||||
import { Logger } from '../../config/logger.config';
|
import { Logger } from '../../config/logger.config';
|
||||||
import { BadRequestException, InternalServerErrorException } from '../../exceptions';
|
import { BadRequestException, InternalServerErrorException } from '../../exceptions';
|
||||||
import { RedisCache } from '../../libs/redis.client';
|
|
||||||
import { InstanceDto, SetPresenceDto } from '../dto/instance.dto';
|
import { InstanceDto, SetPresenceDto } from '../dto/instance.dto';
|
||||||
import { ChatwootService } from '../integrations/chatwoot/services/chatwoot.service';
|
import { ChatwootService } from '../integrations/chatwoot/services/chatwoot.service';
|
||||||
import { RabbitmqService } from '../integrations/rabbitmq/services/rabbitmq.service';
|
import { RabbitmqService } from '../integrations/rabbitmq/services/rabbitmq.service';
|
||||||
@ -41,8 +40,9 @@ export class InstanceController {
|
|||||||
private readonly typebotService: TypebotService,
|
private readonly typebotService: TypebotService,
|
||||||
private readonly integrationService: IntegrationService,
|
private readonly integrationService: IntegrationService,
|
||||||
private readonly proxyService: ProxyController,
|
private readonly proxyService: ProxyController,
|
||||||
private readonly cache: RedisCache,
|
private readonly cache: CacheService,
|
||||||
private readonly chatwootCache: CacheService,
|
private readonly chatwootCache: CacheService,
|
||||||
|
private readonly messagesLostCache: CacheService,
|
||||||
) {}
|
) {}
|
||||||
|
|
||||||
private readonly logger = new Logger(InstanceController.name);
|
private readonly logger = new Logger(InstanceController.name);
|
||||||
@ -108,6 +108,7 @@ export class InstanceController {
|
|||||||
this.repository,
|
this.repository,
|
||||||
this.cache,
|
this.cache,
|
||||||
this.chatwootCache,
|
this.chatwootCache,
|
||||||
|
this.messagesLostCache,
|
||||||
);
|
);
|
||||||
} else {
|
} else {
|
||||||
instance = new BaileysStartupService(
|
instance = new BaileysStartupService(
|
||||||
@ -116,6 +117,7 @@ export class InstanceController {
|
|||||||
this.repository,
|
this.repository,
|
||||||
this.cache,
|
this.cache,
|
||||||
this.chatwootCache,
|
this.chatwootCache,
|
||||||
|
this.messagesLostCache,
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -2,7 +2,7 @@ import { NextFunction, Request, Response } from 'express';
|
|||||||
import { existsSync } from 'fs';
|
import { existsSync } from 'fs';
|
||||||
import { join } from 'path';
|
import { join } from 'path';
|
||||||
|
|
||||||
import { configService, Database, Redis } from '../../config/env.config';
|
import { CacheConf, configService, Database } from '../../config/env.config';
|
||||||
import { INSTANCE_DIR } from '../../config/path.config';
|
import { INSTANCE_DIR } from '../../config/path.config';
|
||||||
import {
|
import {
|
||||||
BadRequestException,
|
BadRequestException,
|
||||||
@ -17,12 +17,13 @@ import { cache, waMonitor } from '../server.module';
|
|||||||
async function getInstance(instanceName: string) {
|
async function getInstance(instanceName: string) {
|
||||||
try {
|
try {
|
||||||
const db = configService.get<Database>('DATABASE');
|
const db = configService.get<Database>('DATABASE');
|
||||||
const redisConf = configService.get<Redis>('REDIS');
|
const cacheConf = configService.get<CacheConf>('CACHE');
|
||||||
|
|
||||||
const exists = !!waMonitor.waInstances[instanceName];
|
const exists = !!waMonitor.waInstances[instanceName];
|
||||||
|
|
||||||
if (redisConf.ENABLED) {
|
if (cacheConf.REDIS.ENABLED && cacheConf.REDIS.SAVE_INSTANCES) {
|
||||||
const keyExists = await cache.keyExists();
|
const keyExists = await cache.has(instanceName);
|
||||||
|
|
||||||
return exists || keyExists;
|
return exists || keyExists;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -1,5 +1,6 @@
|
|||||||
import { isURL } from 'class-validator';
|
import { isURL } from 'class-validator';
|
||||||
|
|
||||||
|
import { CacheEngine } from '../../../../cache/cacheengine';
|
||||||
import { ConfigService, HttpServer } from '../../../../config/env.config';
|
import { ConfigService, HttpServer } from '../../../../config/env.config';
|
||||||
import { Logger } from '../../../../config/logger.config';
|
import { Logger } from '../../../../config/logger.config';
|
||||||
import { BadRequestException } from '../../../../exceptions';
|
import { BadRequestException } from '../../../../exceptions';
|
||||||
@ -7,7 +8,6 @@ import { InstanceDto } from '../../../dto/instance.dto';
|
|||||||
import { RepositoryBroker } from '../../../repository/repository.manager';
|
import { RepositoryBroker } from '../../../repository/repository.manager';
|
||||||
import { waMonitor } from '../../../server.module';
|
import { waMonitor } from '../../../server.module';
|
||||||
import { CacheService } from '../../../services/cache.service';
|
import { CacheService } from '../../../services/cache.service';
|
||||||
import { CacheEngine } from '../cache/cacheengine';
|
|
||||||
import { ChatwootDto } from '../dto/chatwoot.dto';
|
import { ChatwootDto } from '../dto/chatwoot.dto';
|
||||||
import { ChatwootService } from '../services/chatwoot.service';
|
import { ChatwootService } from '../services/chatwoot.service';
|
||||||
|
|
||||||
|
@ -461,7 +461,7 @@ export class ChatwootService {
|
|||||||
const queryOperator = fieldsToSearch.length - 1 === index1 && numbers.length - 1 === index2 ? null : 'OR';
|
const queryOperator = fieldsToSearch.length - 1 === index1 && numbers.length - 1 === index2 ? null : 'OR';
|
||||||
filterPayload.push({
|
filterPayload.push({
|
||||||
attribute_key: field,
|
attribute_key: field,
|
||||||
filter_operator: field == 'phone_number' ? 'equal_to' : 'contains',
|
filter_operator: ['phone_number', 'identifier'].includes(field) ? 'equal_to' : 'contains',
|
||||||
values: [number.replace('+', '')],
|
values: [number.replace('+', '')],
|
||||||
query_operator: queryOperator,
|
query_operator: queryOperator,
|
||||||
});
|
});
|
||||||
|
@ -57,7 +57,7 @@ export class TypebotService {
|
|||||||
|
|
||||||
if (session) {
|
if (session) {
|
||||||
if (status === 'closed') {
|
if (status === 'closed') {
|
||||||
const found_session: Session[] = findData.sessions.splice(findData.sessions.indexOf(session), 1);
|
findData.sessions.splice(findData.sessions.indexOf(session), 1);
|
||||||
|
|
||||||
const typebotData = {
|
const typebotData = {
|
||||||
enabled: findData.enabled,
|
enabled: findData.enabled,
|
||||||
@ -68,7 +68,7 @@ export class TypebotService {
|
|||||||
delay_message: findData.delay_message,
|
delay_message: findData.delay_message,
|
||||||
unknown_message: findData.unknown_message,
|
unknown_message: findData.unknown_message,
|
||||||
listening_from_me: findData.listening_from_me,
|
listening_from_me: findData.listening_from_me,
|
||||||
sessions: found_session,
|
sessions: findData.sessions,
|
||||||
};
|
};
|
||||||
|
|
||||||
this.create(instance, typebotData);
|
this.create(instance, typebotData);
|
||||||
@ -106,7 +106,7 @@ export class TypebotService {
|
|||||||
delay_message: findData.delay_message,
|
delay_message: findData.delay_message,
|
||||||
unknown_message: findData.unknown_message,
|
unknown_message: findData.unknown_message,
|
||||||
listening_from_me: findData.listening_from_me,
|
listening_from_me: findData.listening_from_me,
|
||||||
sessions: findData.sessions.splice(findData.sessions.indexOf(session), 1),
|
sessions: findData.sessions,
|
||||||
};
|
};
|
||||||
|
|
||||||
this.create(instance, typebotData);
|
this.create(instance, typebotData);
|
||||||
|
@ -1,8 +1,8 @@
|
|||||||
|
import { CacheEngine } from '../cache/cacheengine';
|
||||||
import { configService } from '../config/env.config';
|
import { configService } from '../config/env.config';
|
||||||
import { eventEmitter } from '../config/event.config';
|
import { eventEmitter } from '../config/event.config';
|
||||||
import { Logger } from '../config/logger.config';
|
import { Logger } from '../config/logger.config';
|
||||||
import { dbserver } from '../libs/db.connect';
|
import { dbserver } from '../libs/db.connect';
|
||||||
import { RedisCache } from '../libs/redis.client';
|
|
||||||
import { ChatController } from './controllers/chat.controller';
|
import { ChatController } from './controllers/chat.controller';
|
||||||
import { GroupController } from './controllers/group.controller';
|
import { GroupController } from './controllers/group.controller';
|
||||||
import { InstanceController } from './controllers/instance.controller';
|
import { InstanceController } from './controllers/instance.controller';
|
||||||
@ -14,7 +14,6 @@ import { WebhookController } from './controllers/webhook.controller';
|
|||||||
import { ChamaaiController } from './integrations/chamaai/controllers/chamaai.controller';
|
import { ChamaaiController } from './integrations/chamaai/controllers/chamaai.controller';
|
||||||
import { ChamaaiRepository } from './integrations/chamaai/repository/chamaai.repository';
|
import { ChamaaiRepository } from './integrations/chamaai/repository/chamaai.repository';
|
||||||
import { ChamaaiService } from './integrations/chamaai/services/chamaai.service';
|
import { ChamaaiService } from './integrations/chamaai/services/chamaai.service';
|
||||||
import { CacheEngine } from './integrations/chatwoot/cache/cacheengine';
|
|
||||||
import { ChatwootController } from './integrations/chatwoot/controllers/chatwoot.controller';
|
import { ChatwootController } from './integrations/chatwoot/controllers/chatwoot.controller';
|
||||||
import { ChatwootRepository } from './integrations/chatwoot/repository/chatwoot.repository';
|
import { ChatwootRepository } from './integrations/chatwoot/repository/chatwoot.repository';
|
||||||
import { ChatwootService } from './integrations/chatwoot/services/chatwoot.service';
|
import { ChatwootService } from './integrations/chatwoot/services/chatwoot.service';
|
||||||
@ -107,10 +106,18 @@ export const repository = new RepositoryBroker(
|
|||||||
dbserver?.getClient(),
|
dbserver?.getClient(),
|
||||||
);
|
);
|
||||||
|
|
||||||
export const cache = new RedisCache();
|
export const cache = new CacheService(new CacheEngine(configService, 'instance').getEngine());
|
||||||
const chatwootCache = new CacheService(new CacheEngine(configService, ChatwootService.name).getEngine());
|
const chatwootCache = new CacheService(new CacheEngine(configService, ChatwootService.name).getEngine());
|
||||||
|
const messagesLostCache = new CacheService(new CacheEngine(configService, 'baileys').getEngine());
|
||||||
|
|
||||||
export const waMonitor = new WAMonitoringService(eventEmitter, configService, repository, cache, chatwootCache);
|
export const waMonitor = new WAMonitoringService(
|
||||||
|
eventEmitter,
|
||||||
|
configService,
|
||||||
|
repository,
|
||||||
|
cache,
|
||||||
|
chatwootCache,
|
||||||
|
messagesLostCache,
|
||||||
|
);
|
||||||
|
|
||||||
const authService = new AuthService(configService, waMonitor, repository);
|
const authService = new AuthService(configService, waMonitor, repository);
|
||||||
|
|
||||||
@ -160,6 +167,7 @@ export const instanceController = new InstanceController(
|
|||||||
proxyController,
|
proxyController,
|
||||||
cache,
|
cache,
|
||||||
chatwootCache,
|
chatwootCache,
|
||||||
|
messagesLostCache,
|
||||||
);
|
);
|
||||||
export const sendMessageController = new SendMessageController(waMonitor);
|
export const sendMessageController = new SendMessageController(waMonitor);
|
||||||
export const chatController = new ChatController(waMonitor);
|
export const chatController = new ChatController(waMonitor);
|
||||||
|
@ -1,3 +1,5 @@
|
|||||||
|
import { BufferJSON } from '@whiskeysockets/baileys';
|
||||||
|
|
||||||
import { Logger } from '../../config/logger.config';
|
import { Logger } from '../../config/logger.config';
|
||||||
import { ICache } from '../abstract/abstract.cache';
|
import { ICache } from '../abstract/abstract.cache';
|
||||||
|
|
||||||
@ -20,6 +22,21 @@ export class CacheService {
|
|||||||
return this.cache.get(key);
|
return this.cache.get(key);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public async hGet(key: string, field: string) {
|
||||||
|
try {
|
||||||
|
const data = await this.cache.hGet(key, field);
|
||||||
|
|
||||||
|
if (data) {
|
||||||
|
return JSON.parse(data, BufferJSON.reviver);
|
||||||
|
}
|
||||||
|
|
||||||
|
return null;
|
||||||
|
} catch (error) {
|
||||||
|
this.logger.error(error);
|
||||||
|
return null;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
async set(key: string, value: any) {
|
async set(key: string, value: any) {
|
||||||
if (!this.cache) {
|
if (!this.cache) {
|
||||||
return;
|
return;
|
||||||
@ -28,6 +45,16 @@ export class CacheService {
|
|||||||
this.cache.set(key, value);
|
this.cache.set(key, value);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public async hSet(key: string, field: string, value: any) {
|
||||||
|
try {
|
||||||
|
const json = JSON.stringify(value, BufferJSON.replacer);
|
||||||
|
|
||||||
|
await this.cache.hSet(key, field, json);
|
||||||
|
} catch (error) {
|
||||||
|
this.logger.error(error);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
async has(key: string) {
|
async has(key: string) {
|
||||||
if (!this.cache) {
|
if (!this.cache) {
|
||||||
return;
|
return;
|
||||||
@ -44,6 +71,16 @@ export class CacheService {
|
|||||||
return this.cache.delete(key);
|
return this.cache.delete(key);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
async hDelete(key: string, field: string) {
|
||||||
|
try {
|
||||||
|
await this.cache.hDelete(key, field);
|
||||||
|
return true;
|
||||||
|
} catch (error) {
|
||||||
|
this.logger.error(error);
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
async deleteAll(appendCriteria?: string) {
|
async deleteAll(appendCriteria?: string) {
|
||||||
if (!this.cache) {
|
if (!this.cache) {
|
||||||
return;
|
return;
|
||||||
|
@ -5,11 +5,10 @@ import { Db } from 'mongodb';
|
|||||||
import { Collection } from 'mongoose';
|
import { Collection } from 'mongoose';
|
||||||
import { join } from 'path';
|
import { join } from 'path';
|
||||||
|
|
||||||
import { Auth, ConfigService, Database, DelInstance, HttpServer, Redis } from '../../config/env.config';
|
import { Auth, CacheConf, ConfigService, Database, DelInstance, HttpServer } from '../../config/env.config';
|
||||||
import { Logger } from '../../config/logger.config';
|
import { Logger } from '../../config/logger.config';
|
||||||
import { INSTANCE_DIR, STORE_DIR } from '../../config/path.config';
|
import { INSTANCE_DIR, STORE_DIR } from '../../config/path.config';
|
||||||
import { NotFoundException } from '../../exceptions';
|
import { NotFoundException } from '../../exceptions';
|
||||||
import { RedisCache } from '../../libs/redis.client';
|
|
||||||
import {
|
import {
|
||||||
AuthModel,
|
AuthModel,
|
||||||
ChamaaiModel,
|
ChamaaiModel,
|
||||||
@ -34,8 +33,9 @@ export class WAMonitoringService {
|
|||||||
private readonly eventEmitter: EventEmitter2,
|
private readonly eventEmitter: EventEmitter2,
|
||||||
private readonly configService: ConfigService,
|
private readonly configService: ConfigService,
|
||||||
private readonly repository: RepositoryBroker,
|
private readonly repository: RepositoryBroker,
|
||||||
private readonly cache: RedisCache,
|
private readonly cache: CacheService,
|
||||||
private readonly chatwootCache: CacheService,
|
private readonly chatwootCache: CacheService,
|
||||||
|
private readonly messagesLostCache: CacheService,
|
||||||
) {
|
) {
|
||||||
this.logger.verbose('instance created');
|
this.logger.verbose('instance created');
|
||||||
|
|
||||||
@ -43,7 +43,7 @@ export class WAMonitoringService {
|
|||||||
this.noConnection();
|
this.noConnection();
|
||||||
|
|
||||||
Object.assign(this.db, configService.get<Database>('DATABASE'));
|
Object.assign(this.db, configService.get<Database>('DATABASE'));
|
||||||
Object.assign(this.redis, configService.get<Redis>('REDIS'));
|
Object.assign(this.redis, configService.get<CacheConf>('CACHE'));
|
||||||
|
|
||||||
this.dbInstance = this.db.ENABLED
|
this.dbInstance = this.db.ENABLED
|
||||||
? this.repository.dbServer?.db(this.db.CONNECTION.DB_PREFIX_NAME + '-instances')
|
? this.repository.dbServer?.db(this.db.CONNECTION.DB_PREFIX_NAME + '-instances')
|
||||||
@ -51,7 +51,7 @@ export class WAMonitoringService {
|
|||||||
}
|
}
|
||||||
|
|
||||||
private readonly db: Partial<Database> = {};
|
private readonly db: Partial<Database> = {};
|
||||||
private readonly redis: Partial<Redis> = {};
|
private readonly redis: Partial<CacheConf> = {};
|
||||||
|
|
||||||
private dbInstance: Db;
|
private dbInstance: Db;
|
||||||
|
|
||||||
@ -212,7 +212,7 @@ export class WAMonitoringService {
|
|||||||
});
|
});
|
||||||
this.logger.verbose('instance files deleted: ' + name);
|
this.logger.verbose('instance files deleted: ' + name);
|
||||||
});
|
});
|
||||||
} else if (!this.redis.ENABLED) {
|
} else if (!this.redis.REDIS.ENABLED && !this.redis.REDIS.SAVE_INSTANCES) {
|
||||||
const dir = opendirSync(INSTANCE_DIR, { encoding: 'utf-8' });
|
const dir = opendirSync(INSTANCE_DIR, { encoding: 'utf-8' });
|
||||||
for await (const dirent of dir) {
|
for await (const dirent of dir) {
|
||||||
if (dirent.isDirectory()) {
|
if (dirent.isDirectory()) {
|
||||||
@ -247,10 +247,9 @@ export class WAMonitoringService {
|
|||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
if (this.redis.ENABLED) {
|
if (this.redis.REDIS.ENABLED && this.redis.REDIS.SAVE_INSTANCES) {
|
||||||
this.logger.verbose('cleaning up instance in redis: ' + instanceName);
|
this.logger.verbose('cleaning up instance in redis: ' + instanceName);
|
||||||
this.cache.reference = instanceName;
|
await this.cache.delete(instanceName);
|
||||||
await this.cache.delAll();
|
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -303,7 +302,7 @@ export class WAMonitoringService {
|
|||||||
this.logger.verbose('Loading instances');
|
this.logger.verbose('Loading instances');
|
||||||
|
|
||||||
try {
|
try {
|
||||||
if (this.redis.ENABLED) {
|
if (this.redis.REDIS.ENABLED && this.redis.REDIS.SAVE_INSTANCES) {
|
||||||
await this.loadInstancesFromRedis();
|
await this.loadInstancesFromRedis();
|
||||||
} else if (this.db.ENABLED && this.db.SAVE_DATA.INSTANCE) {
|
} else if (this.db.ENABLED && this.db.SAVE_DATA.INSTANCE) {
|
||||||
await this.loadInstancesFromDatabase();
|
await this.loadInstancesFromDatabase();
|
||||||
@ -346,6 +345,7 @@ export class WAMonitoringService {
|
|||||||
this.repository,
|
this.repository,
|
||||||
this.cache,
|
this.cache,
|
||||||
this.chatwootCache,
|
this.chatwootCache,
|
||||||
|
this.messagesLostCache,
|
||||||
);
|
);
|
||||||
|
|
||||||
instance.instanceName = name;
|
instance.instanceName = name;
|
||||||
@ -356,6 +356,7 @@ export class WAMonitoringService {
|
|||||||
this.repository,
|
this.repository,
|
||||||
this.cache,
|
this.cache,
|
||||||
this.chatwootCache,
|
this.chatwootCache,
|
||||||
|
this.messagesLostCache,
|
||||||
);
|
);
|
||||||
|
|
||||||
instance.instanceName = name;
|
instance.instanceName = name;
|
||||||
@ -374,12 +375,11 @@ export class WAMonitoringService {
|
|||||||
|
|
||||||
private async loadInstancesFromRedis() {
|
private async loadInstancesFromRedis() {
|
||||||
this.logger.verbose('Redis enabled');
|
this.logger.verbose('Redis enabled');
|
||||||
await this.cache.connect(this.redis as Redis);
|
const keys = await this.cache.keys();
|
||||||
const keys = await this.cache.getInstanceKeys();
|
|
||||||
|
|
||||||
if (keys?.length > 0) {
|
if (keys?.length > 0) {
|
||||||
this.logger.verbose('Reading instance keys and setting instances');
|
this.logger.verbose('Reading instance keys and setting instances');
|
||||||
await Promise.all(keys.map((k) => this.setInstance(k.split(':')[1])));
|
await Promise.all(keys.map((k) => this.setInstance(k.split(':')[2])));
|
||||||
} else {
|
} else {
|
||||||
this.logger.verbose('No instance keys found');
|
this.logger.verbose('No instance keys found');
|
||||||
}
|
}
|
||||||
|
@ -71,6 +71,8 @@ export class WAStartupService {
|
|||||||
public chamaaiService = new ChamaaiService(waMonitor, this.configService);
|
public chamaaiService = new ChamaaiService(waMonitor, this.configService);
|
||||||
|
|
||||||
public set instanceName(name: string) {
|
public set instanceName(name: string) {
|
||||||
|
this.logger.setInstance(name);
|
||||||
|
|
||||||
this.logger.verbose(`Initializing instance '${name}'`);
|
this.logger.verbose(`Initializing instance '${name}'`);
|
||||||
if (!name) {
|
if (!name) {
|
||||||
this.logger.verbose('Instance name not found, generating random name with uuid');
|
this.logger.verbose('Instance name not found, generating random name with uuid');
|
||||||
@ -583,7 +585,7 @@ export class WAStartupService {
|
|||||||
this.logger.verbose(`Proxy enabled: ${this.localProxy.enabled}`);
|
this.logger.verbose(`Proxy enabled: ${this.localProxy.enabled}`);
|
||||||
|
|
||||||
this.localProxy.proxy = data?.proxy;
|
this.localProxy.proxy = data?.proxy;
|
||||||
this.logger.verbose(`Proxy proxy: ${this.localProxy.proxy.host}`);
|
this.logger.verbose(`Proxy proxy: ${this.localProxy.proxy?.host}`);
|
||||||
|
|
||||||
this.logger.verbose('Proxy loaded');
|
this.logger.verbose('Proxy loaded');
|
||||||
}
|
}
|
||||||
|
@ -39,9 +39,10 @@ import makeWASocket, {
|
|||||||
import { Label } from '@whiskeysockets/baileys/lib/Types/Label';
|
import { Label } from '@whiskeysockets/baileys/lib/Types/Label';
|
||||||
import { LabelAssociation } from '@whiskeysockets/baileys/lib/Types/LabelAssociation';
|
import { LabelAssociation } from '@whiskeysockets/baileys/lib/Types/LabelAssociation';
|
||||||
import axios from 'axios';
|
import axios from 'axios';
|
||||||
|
import { exec } from 'child_process';
|
||||||
import { arrayUnique, isBase64, isURL } from 'class-validator';
|
import { arrayUnique, isBase64, isURL } from 'class-validator';
|
||||||
import EventEmitter2 from 'eventemitter2';
|
import EventEmitter2 from 'eventemitter2';
|
||||||
import ffmpeg from 'fluent-ffmpeg';
|
// import ffmpeg from 'fluent-ffmpeg';
|
||||||
import fs, { existsSync, readFileSync } from 'fs';
|
import fs, { existsSync, readFileSync } from 'fs';
|
||||||
import { parsePhoneNumber } from 'libphonenumber-js';
|
import { parsePhoneNumber } from 'libphonenumber-js';
|
||||||
import Long from 'long';
|
import Long from 'long';
|
||||||
@ -54,11 +55,10 @@ import qrcode, { QRCodeToDataURLOptions } from 'qrcode';
|
|||||||
import qrcodeTerminal from 'qrcode-terminal';
|
import qrcodeTerminal from 'qrcode-terminal';
|
||||||
import sharp from 'sharp';
|
import sharp from 'sharp';
|
||||||
|
|
||||||
import { ConfigService, ConfigSessionPhone, Database, Log, QrCode, Redis } from '../../../config/env.config';
|
import { CacheConf, ConfigService, ConfigSessionPhone, Database, Log, QrCode } from '../../../config/env.config';
|
||||||
import { INSTANCE_DIR } from '../../../config/path.config';
|
import { INSTANCE_DIR } from '../../../config/path.config';
|
||||||
import { BadRequestException, InternalServerErrorException, NotFoundException } from '../../../exceptions';
|
import { BadRequestException, InternalServerErrorException, NotFoundException } from '../../../exceptions';
|
||||||
import { dbserver } from '../../../libs/db.connect';
|
import { dbserver } from '../../../libs/db.connect';
|
||||||
import { RedisCache } from '../../../libs/redis.client';
|
|
||||||
import { makeProxyAgent } from '../../../utils/makeProxyAgent';
|
import { makeProxyAgent } from '../../../utils/makeProxyAgent';
|
||||||
import { useMultiFileAuthStateDb } from '../../../utils/use-multi-file-auth-state-db';
|
import { useMultiFileAuthStateDb } from '../../../utils/use-multi-file-auth-state-db';
|
||||||
import { useMultiFileAuthStateRedisDb } from '../../../utils/use-multi-file-auth-state-redis-db';
|
import { useMultiFileAuthStateRedisDb } from '../../../utils/use-multi-file-auth-state-redis-db';
|
||||||
@ -120,21 +120,21 @@ import { Events, MessageSubtype, TypeMediaMessage, wa } from '../../types/wa.typ
|
|||||||
import { CacheService } from './../cache.service';
|
import { CacheService } from './../cache.service';
|
||||||
import { WAStartupService } from './../whatsapp.service';
|
import { WAStartupService } from './../whatsapp.service';
|
||||||
|
|
||||||
// const retryCache = {};
|
|
||||||
|
|
||||||
export class BaileysStartupService extends WAStartupService {
|
export class BaileysStartupService extends WAStartupService {
|
||||||
constructor(
|
constructor(
|
||||||
public readonly configService: ConfigService,
|
public readonly configService: ConfigService,
|
||||||
public readonly eventEmitter: EventEmitter2,
|
public readonly eventEmitter: EventEmitter2,
|
||||||
public readonly repository: RepositoryBroker,
|
public readonly repository: RepositoryBroker,
|
||||||
public readonly cache: RedisCache,
|
public readonly cache: CacheService,
|
||||||
public readonly chatwootCache: CacheService,
|
public readonly chatwootCache: CacheService,
|
||||||
|
public readonly messagesLostCache: CacheService,
|
||||||
) {
|
) {
|
||||||
super(configService, eventEmitter, repository, chatwootCache);
|
super(configService, eventEmitter, repository, chatwootCache);
|
||||||
this.logger.verbose('BaileysStartupService initialized');
|
this.logger.verbose('BaileysStartupService initialized');
|
||||||
this.cleanStore();
|
this.cleanStore();
|
||||||
this.instance.qrcode = { count: 0 };
|
this.instance.qrcode = { count: 0 };
|
||||||
this.mobile = false;
|
this.mobile = false;
|
||||||
|
this.recoveringMessages();
|
||||||
}
|
}
|
||||||
|
|
||||||
private readonly msgRetryCounterCache: CacheStore = new NodeCache();
|
private readonly msgRetryCounterCache: CacheStore = new NodeCache();
|
||||||
@ -147,6 +147,26 @@ export class BaileysStartupService extends WAStartupService {
|
|||||||
public phoneNumber: string;
|
public phoneNumber: string;
|
||||||
public mobile: boolean;
|
public mobile: boolean;
|
||||||
|
|
||||||
|
private async recoveringMessages() {
|
||||||
|
const cacheConf = this.configService.get<CacheConf>('CACHE');
|
||||||
|
|
||||||
|
if ((cacheConf?.REDIS?.ENABLED && cacheConf?.REDIS?.URI !== '') || cacheConf?.LOCAL?.ENABLED) {
|
||||||
|
setTimeout(async () => {
|
||||||
|
this.logger.info('Recovering messages');
|
||||||
|
this.messagesLostCache.keys().then((keys) => {
|
||||||
|
keys.forEach(async (key) => {
|
||||||
|
const message = await this.messagesLostCache.get(key.split(':')[2]);
|
||||||
|
|
||||||
|
if (message.messageStubParameters && message.messageStubParameters[0] === 'Message absent from node') {
|
||||||
|
this.logger.verbose('Message absent from node, retrying to send, key: ' + key.split(':')[2]);
|
||||||
|
await this.client.sendMessageAck(JSON.parse(message.messageStubParameters[1], BufferJSON.reviver));
|
||||||
|
}
|
||||||
|
});
|
||||||
|
});
|
||||||
|
}, 30000);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
public get connectionStatus() {
|
public get connectionStatus() {
|
||||||
this.logger.verbose('Getting connection status');
|
this.logger.verbose('Getting connection status');
|
||||||
return this.stateConnection;
|
return this.stateConnection;
|
||||||
@ -377,10 +397,12 @@ export class BaileysStartupService extends WAStartupService {
|
|||||||
│ CONNECTED TO WHATSAPP │
|
│ CONNECTED TO WHATSAPP │
|
||||||
└──────────────────────────────┘`.replace(/^ +/gm, ' '),
|
└──────────────────────────────┘`.replace(/^ +/gm, ' '),
|
||||||
);
|
);
|
||||||
this.logger.info(`
|
this.logger.info(
|
||||||
|
`
|
||||||
wuid: ${formattedWuid}
|
wuid: ${formattedWuid}
|
||||||
name: ${formattedName}
|
name: ${formattedName}
|
||||||
`);
|
`,
|
||||||
|
);
|
||||||
|
|
||||||
if (this.localChatwoot.enabled) {
|
if (this.localChatwoot.enabled) {
|
||||||
this.chatwootService.eventWhatsapp(
|
this.chatwootService.eventWhatsapp(
|
||||||
@ -437,12 +459,11 @@ export class BaileysStartupService extends WAStartupService {
|
|||||||
private async defineAuthState() {
|
private async defineAuthState() {
|
||||||
this.logger.verbose('Defining auth state');
|
this.logger.verbose('Defining auth state');
|
||||||
const db = this.configService.get<Database>('DATABASE');
|
const db = this.configService.get<Database>('DATABASE');
|
||||||
const redis = this.configService.get<Redis>('REDIS');
|
const cache = this.configService.get<CacheConf>('CACHE');
|
||||||
|
|
||||||
if (redis?.ENABLED) {
|
if (cache?.REDIS.ENABLED && cache?.REDIS.SAVE_INSTANCES) {
|
||||||
this.logger.verbose('Redis enabled');
|
this.logger.info('Redis enabled');
|
||||||
this.cache.reference = this.instance.name;
|
return await useMultiFileAuthStateRedisDb(this.instance.name, this.cache);
|
||||||
return await useMultiFileAuthStateRedisDb(this.cache);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
if (db.SAVE_DATA.INSTANCE && db.ENABLED) {
|
if (db.SAVE_DATA.INSTANCE && db.ENABLED) {
|
||||||
@ -485,11 +506,11 @@ export class BaileysStartupService extends WAStartupService {
|
|||||||
let options;
|
let options;
|
||||||
|
|
||||||
if (this.localProxy.enabled) {
|
if (this.localProxy.enabled) {
|
||||||
this.logger.info('Proxy enabled: ' + this.localProxy.proxy.host);
|
this.logger.info('Proxy enabled: ' + this.localProxy.proxy?.host);
|
||||||
|
|
||||||
if (this.localProxy?.proxy?.host?.includes('proxyscrape')) {
|
if (this.localProxy?.proxy?.host?.includes('proxyscrape')) {
|
||||||
try {
|
try {
|
||||||
const response = await axios.get(this.localProxy.proxy.host);
|
const response = await axios.get(this.localProxy.proxy?.host);
|
||||||
const text = response.data;
|
const text = response.data;
|
||||||
const proxyUrls = text.split('\r\n');
|
const proxyUrls = text.split('\r\n');
|
||||||
const rand = Math.floor(Math.random() * Math.floor(proxyUrls.length));
|
const rand = Math.floor(Math.random() * Math.floor(proxyUrls.length));
|
||||||
@ -655,11 +676,11 @@ export class BaileysStartupService extends WAStartupService {
|
|||||||
let options;
|
let options;
|
||||||
|
|
||||||
if (this.localProxy.enabled) {
|
if (this.localProxy.enabled) {
|
||||||
this.logger.info('Proxy enabled: ' + this.localProxy.proxy.host);
|
this.logger.info('Proxy enabled: ' + this.localProxy.proxy?.host);
|
||||||
|
|
||||||
if (this.localProxy?.proxy?.host?.includes('proxyscrape')) {
|
if (this.localProxy?.proxy?.host?.includes('proxyscrape')) {
|
||||||
try {
|
try {
|
||||||
const response = await axios.get(this.localProxy.proxy.host);
|
const response = await axios.get(this.localProxy.proxy?.host);
|
||||||
const text = response.data;
|
const text = response.data;
|
||||||
const proxyUrls = text.split('\r\n');
|
const proxyUrls = text.split('\r\n');
|
||||||
const rand = Math.floor(Math.random() * Math.floor(proxyUrls.length));
|
const rand = Math.floor(Math.random() * Math.floor(proxyUrls.length));
|
||||||
@ -1043,6 +1064,20 @@ export class BaileysStartupService extends WAStartupService {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if (received.messageStubParameters && received.messageStubParameters[0] === 'Message absent from node') {
|
||||||
|
this.logger.info('Recovering message lost');
|
||||||
|
|
||||||
|
await this.messagesLostCache.set(received.key.id, received);
|
||||||
|
continue;
|
||||||
|
}
|
||||||
|
|
||||||
|
const retryCache = (await this.messagesLostCache.get(received.key.id)) || null;
|
||||||
|
|
||||||
|
if (retryCache) {
|
||||||
|
this.logger.info('Recovered message lost');
|
||||||
|
await this.messagesLostCache.delete(received.key.id);
|
||||||
|
}
|
||||||
|
|
||||||
if (
|
if (
|
||||||
(type !== 'notify' && type !== 'append') ||
|
(type !== 'notify' && type !== 'append') ||
|
||||||
received.message?.protocolMessage ||
|
received.message?.protocolMessage ||
|
||||||
@ -1241,7 +1276,6 @@ export class BaileysStartupService extends WAStartupService {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// if (key.remoteJid !== 'status@broadcast' && !key?.remoteJid?.match(/(:\d+)/)) {
|
|
||||||
if (key.remoteJid !== 'status@broadcast') {
|
if (key.remoteJid !== 'status@broadcast') {
|
||||||
this.logger.verbose('Message update is valid');
|
this.logger.verbose('Message update is valid');
|
||||||
|
|
||||||
@ -1472,27 +1506,12 @@ export class BaileysStartupService extends WAStartupService {
|
|||||||
if (events['messages.upsert']) {
|
if (events['messages.upsert']) {
|
||||||
this.logger.verbose('Listening event: messages.upsert');
|
this.logger.verbose('Listening event: messages.upsert');
|
||||||
const payload = events['messages.upsert'];
|
const payload = events['messages.upsert'];
|
||||||
// if (payload.messages.find((a) => a?.messageStubType === 2)) {
|
|
||||||
// const msg = payload.messages[0];
|
|
||||||
// retryCache[msg.key.id] = msg;
|
|
||||||
// return;
|
|
||||||
// }
|
|
||||||
this.messageHandle['messages.upsert'](payload, database, settings);
|
this.messageHandle['messages.upsert'](payload, database, settings);
|
||||||
}
|
}
|
||||||
|
|
||||||
if (events['messages.update']) {
|
if (events['messages.update']) {
|
||||||
this.logger.verbose('Listening event: messages.update');
|
this.logger.verbose('Listening event: messages.update');
|
||||||
const payload = events['messages.update'];
|
const payload = events['messages.update'];
|
||||||
// payload.forEach((message) => {
|
|
||||||
// if (retryCache[message.key.id]) {
|
|
||||||
// this.client.ev.emit('messages.upsert', {
|
|
||||||
// messages: [message],
|
|
||||||
// type: 'notify',
|
|
||||||
// });
|
|
||||||
// delete retryCache[message.key.id];
|
|
||||||
// return;
|
|
||||||
// }
|
|
||||||
// });
|
|
||||||
this.messageHandle['messages.update'](payload, database, settings);
|
this.messageHandle['messages.update'](payload, database, settings);
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -2297,6 +2316,82 @@ export class BaileysStartupService extends WAStartupService {
|
|||||||
return await this.sendMessageWithTyping(data.number, { ...generate.message }, data?.options, isChatwoot);
|
return await this.sendMessageWithTyping(data.number, { ...generate.message }, data?.options, isChatwoot);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// public async processAudio(audio: string, number: string) {
|
||||||
|
// this.logger.verbose('Processing audio');
|
||||||
|
// let tempAudioPath: string;
|
||||||
|
// let outputAudio: string;
|
||||||
|
|
||||||
|
// number = number.replace(/\D/g, '');
|
||||||
|
// const hash = `${number}-${new Date().getTime()}`;
|
||||||
|
// this.logger.verbose('Hash to audio name: ' + hash);
|
||||||
|
|
||||||
|
// if (isURL(audio)) {
|
||||||
|
// this.logger.verbose('Audio is url');
|
||||||
|
|
||||||
|
// outputAudio = `${join(this.storePath, 'temp', `${hash}.ogg`)}`;
|
||||||
|
// tempAudioPath = `${join(this.storePath, 'temp', `temp-${hash}.mp3`)}`;
|
||||||
|
|
||||||
|
// this.logger.verbose('Output audio path: ' + outputAudio);
|
||||||
|
// this.logger.verbose('Temp audio path: ' + tempAudioPath);
|
||||||
|
|
||||||
|
// const timestamp = new Date().getTime();
|
||||||
|
// const url = `${audio}?timestamp=${timestamp}`;
|
||||||
|
|
||||||
|
// this.logger.verbose('Including timestamp in url: ' + url);
|
||||||
|
|
||||||
|
// let config: any = {
|
||||||
|
// responseType: 'arraybuffer',
|
||||||
|
// };
|
||||||
|
|
||||||
|
// if (this.localProxy.enabled) {
|
||||||
|
// config = {
|
||||||
|
// ...config,
|
||||||
|
// httpsAgent: makeProxyAgent(this.localProxy.proxy),
|
||||||
|
// };
|
||||||
|
// }
|
||||||
|
|
||||||
|
// const response = await axios.get(url, config);
|
||||||
|
// this.logger.verbose('Getting audio from url');
|
||||||
|
|
||||||
|
// fs.writeFileSync(tempAudioPath, response.data);
|
||||||
|
// } else {
|
||||||
|
// this.logger.verbose('Audio is base64');
|
||||||
|
|
||||||
|
// outputAudio = `${join(this.storePath, 'temp', `${hash}.ogg`)}`;
|
||||||
|
// tempAudioPath = `${join(this.storePath, 'temp', `temp-${hash}.mp3`)}`;
|
||||||
|
|
||||||
|
// this.logger.verbose('Output audio path: ' + outputAudio);
|
||||||
|
// this.logger.verbose('Temp audio path: ' + tempAudioPath);
|
||||||
|
|
||||||
|
// const audioBuffer = Buffer.from(audio, 'base64');
|
||||||
|
// fs.writeFileSync(tempAudioPath, audioBuffer);
|
||||||
|
// this.logger.verbose('Temp audio created');
|
||||||
|
// }
|
||||||
|
|
||||||
|
// this.logger.verbose('Converting audio to mp4');
|
||||||
|
// return new Promise((resolve, reject) => {
|
||||||
|
// // This fix was suggested by @PurpShell
|
||||||
|
// ffmpeg.setFfmpegPath(ffmpegPath.path);
|
||||||
|
|
||||||
|
// ffmpeg()
|
||||||
|
// .input(tempAudioPath)
|
||||||
|
// .outputFormat('ogg')
|
||||||
|
// .noVideo()
|
||||||
|
// .audioCodec('libopus')
|
||||||
|
// .save(outputAudio)
|
||||||
|
// .on('error', function (error) {
|
||||||
|
// console.log('error', error);
|
||||||
|
// fs.unlinkSync(tempAudioPath);
|
||||||
|
// if (error) reject(error);
|
||||||
|
// })
|
||||||
|
// .on('end', async function () {
|
||||||
|
// fs.unlinkSync(tempAudioPath);
|
||||||
|
// resolve(outputAudio);
|
||||||
|
// })
|
||||||
|
// .run();
|
||||||
|
// });
|
||||||
|
// }
|
||||||
|
|
||||||
public async processAudio(audio: string, number: string) {
|
public async processAudio(audio: string, number: string) {
|
||||||
this.logger.verbose('Processing audio');
|
this.logger.verbose('Processing audio');
|
||||||
let tempAudioPath: string;
|
let tempAudioPath: string;
|
||||||
@ -2309,7 +2404,7 @@ export class BaileysStartupService extends WAStartupService {
|
|||||||
if (isURL(audio)) {
|
if (isURL(audio)) {
|
||||||
this.logger.verbose('Audio is url');
|
this.logger.verbose('Audio is url');
|
||||||
|
|
||||||
outputAudio = `${join(this.storePath, 'temp', `${hash}.ogg`)}`;
|
outputAudio = `${join(this.storePath, 'temp', `${hash}.mp4`)}`;
|
||||||
tempAudioPath = `${join(this.storePath, 'temp', `temp-${hash}.mp3`)}`;
|
tempAudioPath = `${join(this.storePath, 'temp', `temp-${hash}.mp3`)}`;
|
||||||
|
|
||||||
this.logger.verbose('Output audio path: ' + outputAudio);
|
this.logger.verbose('Output audio path: ' + outputAudio);
|
||||||
@ -2320,25 +2415,14 @@ export class BaileysStartupService extends WAStartupService {
|
|||||||
|
|
||||||
this.logger.verbose('Including timestamp in url: ' + url);
|
this.logger.verbose('Including timestamp in url: ' + url);
|
||||||
|
|
||||||
let config: any = {
|
const response = await axios.get(url, { responseType: 'arraybuffer' });
|
||||||
responseType: 'arraybuffer',
|
|
||||||
};
|
|
||||||
|
|
||||||
if (this.localProxy.enabled) {
|
|
||||||
config = {
|
|
||||||
...config,
|
|
||||||
httpsAgent: makeProxyAgent(this.localProxy.proxy),
|
|
||||||
};
|
|
||||||
}
|
|
||||||
|
|
||||||
const response = await axios.get(url, config);
|
|
||||||
this.logger.verbose('Getting audio from url');
|
this.logger.verbose('Getting audio from url');
|
||||||
|
|
||||||
fs.writeFileSync(tempAudioPath, response.data);
|
fs.writeFileSync(tempAudioPath, response.data);
|
||||||
} else {
|
} else {
|
||||||
this.logger.verbose('Audio is base64');
|
this.logger.verbose('Audio is base64');
|
||||||
|
|
||||||
outputAudio = `${join(this.storePath, 'temp', `${hash}.ogg`)}`;
|
outputAudio = `${join(this.storePath, 'temp', `${hash}.mp4`)}`;
|
||||||
tempAudioPath = `${join(this.storePath, 'temp', `temp-${hash}.mp3`)}`;
|
tempAudioPath = `${join(this.storePath, 'temp', `temp-${hash}.mp3`)}`;
|
||||||
|
|
||||||
this.logger.verbose('Output audio path: ' + outputAudio);
|
this.logger.verbose('Output audio path: ' + outputAudio);
|
||||||
@ -2351,25 +2435,15 @@ export class BaileysStartupService extends WAStartupService {
|
|||||||
|
|
||||||
this.logger.verbose('Converting audio to mp4');
|
this.logger.verbose('Converting audio to mp4');
|
||||||
return new Promise((resolve, reject) => {
|
return new Promise((resolve, reject) => {
|
||||||
// This fix was suggested by @PurpShell
|
exec(`${ffmpegPath.path} -i ${tempAudioPath} -vn -ab 128k -ar 44100 -f ipod ${outputAudio} -y`, (error) => {
|
||||||
ffmpeg.setFfmpegPath(ffmpegPath.path);
|
fs.unlinkSync(tempAudioPath);
|
||||||
|
this.logger.verbose('Temp audio deleted');
|
||||||
|
|
||||||
ffmpeg()
|
if (error) reject(error);
|
||||||
.input(tempAudioPath)
|
|
||||||
.outputFormat('ogg')
|
this.logger.verbose('Audio converted to mp4');
|
||||||
.noVideo()
|
resolve(outputAudio);
|
||||||
.audioCodec('libopus')
|
});
|
||||||
.save(outputAudio)
|
|
||||||
.on('error', function (error) {
|
|
||||||
console.log('error', error);
|
|
||||||
fs.unlinkSync(tempAudioPath);
|
|
||||||
if (error) reject(error);
|
|
||||||
})
|
|
||||||
.on('end', async function () {
|
|
||||||
fs.unlinkSync(tempAudioPath);
|
|
||||||
resolve(outputAudio);
|
|
||||||
})
|
|
||||||
.run();
|
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -2389,7 +2463,7 @@ export class BaileysStartupService extends WAStartupService {
|
|||||||
{
|
{
|
||||||
audio: Buffer.from(audio, 'base64'),
|
audio: Buffer.from(audio, 'base64'),
|
||||||
ptt: true,
|
ptt: true,
|
||||||
mimetype: 'audio/ogg; codecs=opus',
|
mimetype: 'audio/mp4',
|
||||||
},
|
},
|
||||||
{ presence: 'recording', delay: data?.options?.delay },
|
{ presence: 'recording', delay: data?.options?.delay },
|
||||||
isChatwoot,
|
isChatwoot,
|
||||||
|
@ -7,7 +7,6 @@ import { getMIMEType } from 'node-mime-types';
|
|||||||
|
|
||||||
import { ConfigService, Database, WaBusiness } from '../../../config/env.config';
|
import { ConfigService, Database, WaBusiness } from '../../../config/env.config';
|
||||||
import { BadRequestException, InternalServerErrorException } from '../../../exceptions';
|
import { BadRequestException, InternalServerErrorException } from '../../../exceptions';
|
||||||
import { RedisCache } from '../../../libs/redis.client';
|
|
||||||
import { NumberBusiness } from '../../dto/chat.dto';
|
import { NumberBusiness } from '../../dto/chat.dto';
|
||||||
import {
|
import {
|
||||||
ContactMessage,
|
ContactMessage,
|
||||||
@ -34,8 +33,9 @@ export class BusinessStartupService extends WAStartupService {
|
|||||||
public readonly configService: ConfigService,
|
public readonly configService: ConfigService,
|
||||||
public readonly eventEmitter: EventEmitter2,
|
public readonly eventEmitter: EventEmitter2,
|
||||||
public readonly repository: RepositoryBroker,
|
public readonly repository: RepositoryBroker,
|
||||||
public readonly cache: RedisCache,
|
public readonly cache: CacheService,
|
||||||
public readonly chatwootCache: CacheService,
|
public readonly chatwootCache: CacheService,
|
||||||
|
public readonly messagesLostCache: CacheService,
|
||||||
) {
|
) {
|
||||||
super(configService, eventEmitter, repository, chatwootCache);
|
super(configService, eventEmitter, repository, chatwootCache);
|
||||||
this.logger.verbose('BusinessStartupService initialized');
|
this.logger.verbose('BusinessStartupService initialized');
|
||||||
|
@ -1,5 +1,5 @@
|
|||||||
import { CacheConf, ConfigService } from '../../../../config/env.config';
|
import { ICache } from '../api/abstract/abstract.cache';
|
||||||
import { ICache } from '../../../abstract/abstract.cache';
|
import { CacheConf, ConfigService } from '../config/env.config';
|
||||||
import { LocalCache } from './localcache';
|
import { LocalCache } from './localcache';
|
||||||
import { RedisCache } from './rediscache';
|
import { RedisCache } from './rediscache';
|
||||||
|
|
@ -1,7 +1,7 @@
|
|||||||
import NodeCache from 'node-cache';
|
import NodeCache from 'node-cache';
|
||||||
|
|
||||||
import { CacheConf, CacheConfLocal, ConfigService } from '../../../../config/env.config';
|
import { ICache } from '../api/abstract/abstract.cache';
|
||||||
import { ICache } from '../../../abstract/abstract.cache';
|
import { CacheConf, CacheConfLocal, ConfigService } from '../config/env.config';
|
||||||
|
|
||||||
export class LocalCache implements ICache {
|
export class LocalCache implements ICache {
|
||||||
private conf: CacheConfLocal;
|
private conf: CacheConfLocal;
|
||||||
@ -45,4 +45,17 @@ export class LocalCache implements ICache {
|
|||||||
buildKey(key: string) {
|
buildKey(key: string) {
|
||||||
return `${this.module}:${key}`;
|
return `${this.module}:${key}`;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
async hGet() {
|
||||||
|
console.log('hGet not implemented');
|
||||||
|
}
|
||||||
|
|
||||||
|
async hSet() {
|
||||||
|
console.log('hSet not implemented');
|
||||||
|
}
|
||||||
|
|
||||||
|
async hDelete() {
|
||||||
|
console.log('hDelete not implemented');
|
||||||
|
return 0;
|
||||||
|
}
|
||||||
}
|
}
|
@ -1,7 +1,7 @@
|
|||||||
import { createClient, RedisClientType } from 'redis';
|
import { createClient, RedisClientType } from 'redis';
|
||||||
|
|
||||||
import { CacheConf, CacheConfRedis, configService } from '../../../../config/env.config';
|
import { CacheConf, CacheConfRedis, configService } from '../config/env.config';
|
||||||
import { Logger } from '../../../../config/logger.config';
|
import { Logger } from '../config/logger.config';
|
||||||
|
|
||||||
class Redis {
|
class Redis {
|
||||||
private logger = new Logger(Redis.name);
|
private logger = new Logger(Redis.name);
|
@ -1,8 +1,9 @@
|
|||||||
|
import { BufferJSON } from '@whiskeysockets/baileys';
|
||||||
import { RedisClientType } from 'redis';
|
import { RedisClientType } from 'redis';
|
||||||
|
|
||||||
import { CacheConf, CacheConfRedis, ConfigService } from '../../../../config/env.config';
|
import { ICache } from '../api/abstract/abstract.cache';
|
||||||
import { Logger } from '../../../../config/logger.config';
|
import { CacheConf, CacheConfRedis, ConfigService } from '../config/env.config';
|
||||||
import { ICache } from '../../../abstract/abstract.cache';
|
import { Logger } from '../config/logger.config';
|
||||||
import { redisClient } from './rediscache.client';
|
import { redisClient } from './rediscache.client';
|
||||||
|
|
||||||
export class RedisCache implements ICache {
|
export class RedisCache implements ICache {
|
||||||
@ -14,7 +15,6 @@ export class RedisCache implements ICache {
|
|||||||
this.conf = this.configService.get<CacheConf>('CACHE')?.REDIS;
|
this.conf = this.configService.get<CacheConf>('CACHE')?.REDIS;
|
||||||
this.client = redisClient.getConnection();
|
this.client = redisClient.getConnection();
|
||||||
}
|
}
|
||||||
|
|
||||||
async get(key: string): Promise<any> {
|
async get(key: string): Promise<any> {
|
||||||
try {
|
try {
|
||||||
return JSON.parse(await this.client.get(this.buildKey(key)));
|
return JSON.parse(await this.client.get(this.buildKey(key)));
|
||||||
@ -23,6 +23,20 @@ export class RedisCache implements ICache {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
async hGet(key: string, field: string) {
|
||||||
|
try {
|
||||||
|
const data = await this.client.hGet(this.buildKey(key), field);
|
||||||
|
|
||||||
|
if (data) {
|
||||||
|
return JSON.parse(data, BufferJSON.reviver);
|
||||||
|
}
|
||||||
|
|
||||||
|
return null;
|
||||||
|
} catch (error) {
|
||||||
|
this.logger.error(error);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
async set(key: string, value: any, ttl?: number) {
|
async set(key: string, value: any, ttl?: number) {
|
||||||
try {
|
try {
|
||||||
await this.client.setEx(this.buildKey(key), ttl || this.conf?.TTL, JSON.stringify(value));
|
await this.client.setEx(this.buildKey(key), ttl || this.conf?.TTL, JSON.stringify(value));
|
||||||
@ -31,6 +45,16 @@ export class RedisCache implements ICache {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
async hSet(key: string, field: string, value: any) {
|
||||||
|
try {
|
||||||
|
const json = JSON.stringify(value, BufferJSON.replacer);
|
||||||
|
|
||||||
|
await this.client.hSet(this.buildKey(key), field, json);
|
||||||
|
} catch (error) {
|
||||||
|
this.logger.error(error);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
async has(key: string) {
|
async has(key: string) {
|
||||||
try {
|
try {
|
||||||
return (await this.client.exists(this.buildKey(key))) > 0;
|
return (await this.client.exists(this.buildKey(key))) > 0;
|
||||||
@ -47,6 +71,14 @@ export class RedisCache implements ICache {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
async hDelete(key: string, field: string) {
|
||||||
|
try {
|
||||||
|
return await this.client.hDel(this.buildKey(key), field);
|
||||||
|
} catch (error) {
|
||||||
|
this.logger.error(error);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
async deleteAll(appendCriteria?: string) {
|
async deleteAll(appendCriteria?: string) {
|
||||||
try {
|
try {
|
||||||
const keys = await this.keys(appendCriteria);
|
const keys = await this.keys(appendCriteria);
|
@ -63,12 +63,6 @@ export type Database = {
|
|||||||
SAVE_DATA: SaveData;
|
SAVE_DATA: SaveData;
|
||||||
};
|
};
|
||||||
|
|
||||||
export type Redis = {
|
|
||||||
ENABLED: boolean;
|
|
||||||
URI: string;
|
|
||||||
PREFIX_KEY: string;
|
|
||||||
};
|
|
||||||
|
|
||||||
export type Rabbitmq = {
|
export type Rabbitmq = {
|
||||||
ENABLED: boolean;
|
ENABLED: boolean;
|
||||||
MODE: string; // global, single, isolated
|
MODE: string; // global, single, isolated
|
||||||
@ -153,6 +147,7 @@ export type CacheConfRedis = {
|
|||||||
URI: string;
|
URI: string;
|
||||||
PREFIX_KEY: string;
|
PREFIX_KEY: string;
|
||||||
TTL: number;
|
TTL: number;
|
||||||
|
SAVE_INSTANCES: boolean;
|
||||||
};
|
};
|
||||||
export type CacheConfLocal = {
|
export type CacheConfLocal = {
|
||||||
ENABLED: boolean;
|
ENABLED: boolean;
|
||||||
@ -186,7 +181,6 @@ export interface Env {
|
|||||||
STORE: StoreConf;
|
STORE: StoreConf;
|
||||||
CLEAN_STORE: CleanStoreConf;
|
CLEAN_STORE: CleanStoreConf;
|
||||||
DATABASE: Database;
|
DATABASE: Database;
|
||||||
REDIS: Redis;
|
|
||||||
RABBITMQ: Rabbitmq;
|
RABBITMQ: Rabbitmq;
|
||||||
SQS: Sqs;
|
SQS: Sqs;
|
||||||
WEBSOCKET: Websocket;
|
WEBSOCKET: Websocket;
|
||||||
@ -280,11 +274,6 @@ export class ConfigService {
|
|||||||
LABELS: process.env?.DATABASE_SAVE_DATA_LABELS === 'true',
|
LABELS: process.env?.DATABASE_SAVE_DATA_LABELS === 'true',
|
||||||
},
|
},
|
||||||
},
|
},
|
||||||
REDIS: {
|
|
||||||
ENABLED: process.env?.REDIS_ENABLED === 'true',
|
|
||||||
URI: process.env.REDIS_URI || '',
|
|
||||||
PREFIX_KEY: process.env.REDIS_PREFIX_KEY || 'evolution',
|
|
||||||
},
|
|
||||||
RABBITMQ: {
|
RABBITMQ: {
|
||||||
ENABLED: process.env?.RABBITMQ_ENABLED === 'true',
|
ENABLED: process.env?.RABBITMQ_ENABLED === 'true',
|
||||||
MODE: process.env?.RABBITMQ_MODE || 'isolated',
|
MODE: process.env?.RABBITMQ_MODE || 'isolated',
|
||||||
@ -398,6 +387,7 @@ export class ConfigService {
|
|||||||
URI: process.env?.CACHE_REDIS_URI || '',
|
URI: process.env?.CACHE_REDIS_URI || '',
|
||||||
PREFIX_KEY: process.env?.CACHE_REDIS_PREFIX_KEY || 'evolution-cache',
|
PREFIX_KEY: process.env?.CACHE_REDIS_PREFIX_KEY || 'evolution-cache',
|
||||||
TTL: Number.parseInt(process.env?.CACHE_REDIS_TTL) || 604800,
|
TTL: Number.parseInt(process.env?.CACHE_REDIS_TTL) || 604800,
|
||||||
|
SAVE_INSTANCES: process.env?.CACHE_REDIS_SAVE_INSTANCES === 'true',
|
||||||
},
|
},
|
||||||
LOCAL: {
|
LOCAL: {
|
||||||
ENABLED: process.env?.CACHE_LOCAL_ENABLED === 'true',
|
ENABLED: process.env?.CACHE_LOCAL_ENABLED === 'true',
|
||||||
|
@ -60,10 +60,16 @@ export class Logger {
|
|||||||
private readonly configService = configService;
|
private readonly configService = configService;
|
||||||
constructor(private context = 'Logger') {}
|
constructor(private context = 'Logger') {}
|
||||||
|
|
||||||
|
private instance = null;
|
||||||
|
|
||||||
public setContext(value: string) {
|
public setContext(value: string) {
|
||||||
this.context = value;
|
this.context = value;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public setInstance(value: string) {
|
||||||
|
this.instance = value;
|
||||||
|
}
|
||||||
|
|
||||||
private console(value: any, type: Type) {
|
private console(value: any, type: Type) {
|
||||||
const types: Type[] = [];
|
const types: Type[] = [];
|
||||||
|
|
||||||
@ -76,6 +82,8 @@ export class Logger {
|
|||||||
/*Command.UNDERSCORE +*/ Command.BRIGHT + Level[type],
|
/*Command.UNDERSCORE +*/ Command.BRIGHT + Level[type],
|
||||||
'[Evolution API]',
|
'[Evolution API]',
|
||||||
Command.BRIGHT + Color[type],
|
Command.BRIGHT + Color[type],
|
||||||
|
this.instance ? `[${this.instance}]` : '',
|
||||||
|
Command.BRIGHT + Color[type],
|
||||||
`v${packageJson.version}`,
|
`v${packageJson.version}`,
|
||||||
Command.BRIGHT + Color[type],
|
Command.BRIGHT + Color[type],
|
||||||
process.pid.toString(),
|
process.pid.toString(),
|
||||||
@ -99,6 +107,7 @@ export class Logger {
|
|||||||
} else {
|
} else {
|
||||||
console.log(
|
console.log(
|
||||||
'[Evolution API]',
|
'[Evolution API]',
|
||||||
|
this.instance ? `[${this.instance}]` : '',
|
||||||
process.pid.toString(),
|
process.pid.toString(),
|
||||||
'-',
|
'-',
|
||||||
`${formatDateLog(Date.now())} `,
|
`${formatDateLog(Date.now())} `,
|
||||||
|
@ -77,11 +77,6 @@ DATABASE:
|
|||||||
CONTACTS: false
|
CONTACTS: false
|
||||||
CHATS: false
|
CHATS: false
|
||||||
|
|
||||||
REDIS:
|
|
||||||
ENABLED: false
|
|
||||||
URI: "redis://localhost:6379"
|
|
||||||
PREFIX_KEY: "evolution"
|
|
||||||
|
|
||||||
RABBITMQ:
|
RABBITMQ:
|
||||||
ENABLED: false
|
ENABLED: false
|
||||||
MODE: "global"
|
MODE: "global"
|
||||||
@ -181,8 +176,9 @@ CACHE:
|
|||||||
REDIS:
|
REDIS:
|
||||||
ENABLED: false
|
ENABLED: false
|
||||||
URI: "redis://localhost:6379"
|
URI: "redis://localhost:6379"
|
||||||
PREFIX_KEY: "evolution-cache"
|
PREFIX_KEY: "evolution"
|
||||||
TTL: 604800
|
TTL: 604800
|
||||||
|
SAVE_INSTANCES: false
|
||||||
LOCAL:
|
LOCAL:
|
||||||
ENABLED: false
|
ENABLED: false
|
||||||
TTL: 86400
|
TTL: 86400
|
||||||
|
@ -25,7 +25,7 @@ info:
|
|||||||
</font>
|
</font>
|
||||||
|
|
||||||
[](https://god.gw.postman.com/run-collection/26869335-5546d063-156b-4529-915f-909dd628c090?action=collection%2Ffork&source=rip_markdown&collection-url=entityId%3D26869335-5546d063-156b-4529-915f-909dd628c090%26entityType%3Dcollection%26workspaceId%3D339a4ee7-378b-45c9-b5b8-fd2c0a9c2442)
|
[](https://god.gw.postman.com/run-collection/26869335-5546d063-156b-4529-915f-909dd628c090?action=collection%2Ffork&source=rip_markdown&collection-url=entityId%3D26869335-5546d063-156b-4529-915f-909dd628c090%26entityType%3Dcollection%26workspaceId%3D339a4ee7-378b-45c9-b5b8-fd2c0a9c2442)
|
||||||
version: 1.7.2
|
version: 1.7.3
|
||||||
contact:
|
contact:
|
||||||
name: DavidsonGomes
|
name: DavidsonGomes
|
||||||
email: contato@agenciadgcode.com
|
email: contato@agenciadgcode.com
|
||||||
|
@ -1,123 +0,0 @@
|
|||||||
import { createClient, RedisClientType } from '@redis/client';
|
|
||||||
import { BufferJSON } from '@whiskeysockets/baileys';
|
|
||||||
|
|
||||||
import { Redis } from '../config/env.config';
|
|
||||||
import { Logger } from '../config/logger.config';
|
|
||||||
|
|
||||||
export class RedisCache {
|
|
||||||
private readonly logger = new Logger(RedisCache.name);
|
|
||||||
private client: RedisClientType;
|
|
||||||
private statusConnection = false;
|
|
||||||
private instanceName: string;
|
|
||||||
private redisEnv: Redis;
|
|
||||||
|
|
||||||
constructor() {
|
|
||||||
this.logger.verbose('RedisCache instance created');
|
|
||||||
process.on('beforeExit', () => {
|
|
||||||
this.logger.verbose('RedisCache instance destroyed');
|
|
||||||
this.disconnect();
|
|
||||||
});
|
|
||||||
}
|
|
||||||
|
|
||||||
public set reference(reference: string) {
|
|
||||||
this.logger.verbose('set reference: ' + reference);
|
|
||||||
this.instanceName = reference;
|
|
||||||
}
|
|
||||||
|
|
||||||
public async connect(redisEnv: Redis) {
|
|
||||||
this.logger.verbose('Connecting to Redis...');
|
|
||||||
this.client = createClient({ url: redisEnv.URI });
|
|
||||||
this.client.on('error', (err) => this.logger.error('Redis Client Error ' + err));
|
|
||||||
|
|
||||||
await this.client.connect();
|
|
||||||
this.statusConnection = true;
|
|
||||||
this.redisEnv = redisEnv;
|
|
||||||
this.logger.verbose(`Connected to ${redisEnv.URI}`);
|
|
||||||
}
|
|
||||||
|
|
||||||
public async disconnect() {
|
|
||||||
if (this.statusConnection) {
|
|
||||||
await this.client.disconnect();
|
|
||||||
this.statusConnection = false;
|
|
||||||
this.logger.verbose('Redis client disconnected');
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
public async getInstanceKeys(): Promise<string[]> {
|
|
||||||
const keys: string[] = [];
|
|
||||||
try {
|
|
||||||
this.logger.verbose('Fetching instance keys');
|
|
||||||
for await (const key of this.client.scanIterator({ MATCH: `${this.redisEnv.PREFIX_KEY}:*` })) {
|
|
||||||
keys.push(key);
|
|
||||||
}
|
|
||||||
return keys;
|
|
||||||
} catch (error) {
|
|
||||||
this.logger.error('Error fetching instance keys ' + error);
|
|
||||||
throw error;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
public async keyExists(key?: string) {
|
|
||||||
try {
|
|
||||||
const keys = await this.getInstanceKeys();
|
|
||||||
const targetKey = key || this.instanceName;
|
|
||||||
this.logger.verbose('keyExists: ' + targetKey);
|
|
||||||
return keys.includes(targetKey);
|
|
||||||
} catch (error) {
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
public async setData(field: string, data: any) {
|
|
||||||
try {
|
|
||||||
this.logger.verbose('setData: ' + field);
|
|
||||||
const json = JSON.stringify(data, BufferJSON.replacer);
|
|
||||||
await this.client.hSet(this.redisEnv.PREFIX_KEY + ':' + this.instanceName, field, json);
|
|
||||||
return true;
|
|
||||||
} catch (error) {
|
|
||||||
this.logger.error(error);
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
public async getData(field: string): Promise<any | null> {
|
|
||||||
try {
|
|
||||||
this.logger.verbose('getData: ' + field);
|
|
||||||
const data = await this.client.hGet(this.redisEnv.PREFIX_KEY + ':' + this.instanceName, field);
|
|
||||||
|
|
||||||
if (data) {
|
|
||||||
this.logger.verbose('getData: ' + field + ' success');
|
|
||||||
return JSON.parse(data, BufferJSON.reviver);
|
|
||||||
}
|
|
||||||
|
|
||||||
this.logger.verbose('getData: ' + field + ' not found');
|
|
||||||
return null;
|
|
||||||
} catch (error) {
|
|
||||||
this.logger.error(error);
|
|
||||||
return null;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
public async removeData(field: string): Promise<boolean> {
|
|
||||||
try {
|
|
||||||
this.logger.verbose('removeData: ' + field);
|
|
||||||
await this.client.hDel(this.redisEnv.PREFIX_KEY + ':' + this.instanceName, field);
|
|
||||||
return true;
|
|
||||||
} catch (error) {
|
|
||||||
this.logger.error(error);
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
public async delAll(hash?: string): Promise<boolean> {
|
|
||||||
try {
|
|
||||||
const targetHash = hash || this.redisEnv.PREFIX_KEY + ':' + this.instanceName;
|
|
||||||
this.logger.verbose('instance delAll: ' + targetHash);
|
|
||||||
const result = await this.client.del(targetHash);
|
|
||||||
return !!result;
|
|
||||||
} catch (error) {
|
|
||||||
this.logger.error(error);
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
@ -4,7 +4,7 @@ import path from 'path';
|
|||||||
|
|
||||||
import { ConfigService, Language } from '../config/env.config';
|
import { ConfigService, Language } from '../config/env.config';
|
||||||
|
|
||||||
const languages = ['en', 'pt-BR'];
|
const languages = ['en', 'pt-BR', 'es'];
|
||||||
const translationsPath = path.join(__dirname, 'translations');
|
const translationsPath = path.join(__dirname, 'translations');
|
||||||
const configService: ConfigService = new ConfigService();
|
const configService: ConfigService = new ConfigService();
|
||||||
|
|
||||||
|
26
src/utils/translations/es.json
Normal file
26
src/utils/translations/es.json
Normal file
@ -0,0 +1,26 @@
|
|||||||
|
{
|
||||||
|
"qrgeneratedsuccesfully": "Código QR generado exitosamente!",
|
||||||
|
"scanqr": "Escanea este código QR en los próximos 40 segundos.",
|
||||||
|
"qrlimitreached": "🚨 Se alcanzó el límite de generación de QRCode. Para generar un nuevo QRCode, envíe el mensaje 'init' nuevamente.",
|
||||||
|
"numbernotinwhatsapp": "⚠️ El mensaje no fue enviado porque el contacto no es un número de Whatsapp válido..",
|
||||||
|
"cw.inbox.connected": "🚀 ¡Conexión establecida exitosamente!",
|
||||||
|
"cw.inbox.disconnect": "🚨 Instancia *{{inboxName}}* desconectado de Whatsapp.",
|
||||||
|
"cw.inbox.alreadyConnected": "🚨 La instancia {{inboxName}} está conectada.",
|
||||||
|
"cw.inbox.clearCache": "✅ Caché de la instancia {{inboxName}} borrada.",
|
||||||
|
"cw.inbox.notFound": "⚠️ Instancia {{inboxName}} no encontrada.",
|
||||||
|
"cw.inbox.status": "⚠️ Estado de la instancia {{inboxName}}: *{{state}}*.",
|
||||||
|
"cw.import.startImport": "💬 Empezando a importar mensajes. Espere por favor...",
|
||||||
|
"cw.import.importingMessages": "💬 Importando mensajes. mas un momento...",
|
||||||
|
"cw.import.messagesImported": "💬 {{totalMessagesImported}} mensajes importados. Actualiza la página para ver los nuevos mensajes..",
|
||||||
|
"cw.import.messagesException": "⚠️ Algo salió mal al importar mensajes..",
|
||||||
|
"cw.locationMessage.location": "Ubicación",
|
||||||
|
"cw.locationMessage.latitude": "Latitude",
|
||||||
|
"cw.locationMessage.longitude": "Longitude",
|
||||||
|
"cw.locationMessage.locationName": "Nombre",
|
||||||
|
"cw.locationMessage.locationAddress": "Direccion",
|
||||||
|
"cw.locationMessage.locationUrl": "URL",
|
||||||
|
"cw.contactMessage.contact": "Contacto",
|
||||||
|
"cw.contactMessage.name": "Nombre",
|
||||||
|
"cw.contactMessage.number": "Numero",
|
||||||
|
"cw.message.edited": "Mensaje editado"
|
||||||
|
}
|
@ -6,10 +6,13 @@ import {
|
|||||||
SignalDataTypeMap,
|
SignalDataTypeMap,
|
||||||
} from '@whiskeysockets/baileys';
|
} from '@whiskeysockets/baileys';
|
||||||
|
|
||||||
|
import { CacheService } from '../api/services/cache.service';
|
||||||
import { Logger } from '../config/logger.config';
|
import { Logger } from '../config/logger.config';
|
||||||
import { RedisCache } from '../libs/redis.client';
|
|
||||||
|
|
||||||
export async function useMultiFileAuthStateRedisDb(cache: RedisCache): Promise<{
|
export async function useMultiFileAuthStateRedisDb(
|
||||||
|
instanceName: string,
|
||||||
|
cache: CacheService,
|
||||||
|
): Promise<{
|
||||||
state: AuthenticationState;
|
state: AuthenticationState;
|
||||||
saveCreds: () => Promise<void>;
|
saveCreds: () => Promise<void>;
|
||||||
}> {
|
}> {
|
||||||
@ -17,7 +20,7 @@ export async function useMultiFileAuthStateRedisDb(cache: RedisCache): Promise<{
|
|||||||
|
|
||||||
const writeData = async (data: any, key: string): Promise<any> => {
|
const writeData = async (data: any, key: string): Promise<any> => {
|
||||||
try {
|
try {
|
||||||
return await cache.setData(key, data);
|
return await cache.hSet(instanceName, key, data);
|
||||||
} catch (error) {
|
} catch (error) {
|
||||||
return logger.error({ localError: 'writeData', error });
|
return logger.error({ localError: 'writeData', error });
|
||||||
}
|
}
|
||||||
@ -25,7 +28,7 @@ export async function useMultiFileAuthStateRedisDb(cache: RedisCache): Promise<{
|
|||||||
|
|
||||||
const readData = async (key: string): Promise<any> => {
|
const readData = async (key: string): Promise<any> => {
|
||||||
try {
|
try {
|
||||||
return await cache.getData(key);
|
return await cache.hGet(instanceName, key);
|
||||||
} catch (error) {
|
} catch (error) {
|
||||||
logger.error({ localError: 'readData', error });
|
logger.error({ localError: 'readData', error });
|
||||||
return;
|
return;
|
||||||
@ -34,7 +37,7 @@ export async function useMultiFileAuthStateRedisDb(cache: RedisCache): Promise<{
|
|||||||
|
|
||||||
const removeData = async (key: string) => {
|
const removeData = async (key: string) => {
|
||||||
try {
|
try {
|
||||||
return await cache.removeData(key);
|
return await cache.hDelete(instanceName, key);
|
||||||
} catch (error) {
|
} catch (error) {
|
||||||
logger.error({ readData: 'removeData', error });
|
logger.error({ readData: 'removeData', error });
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user