mirror of
https://github.com/EvolutionAPI/evolution-api.git
synced 2025-12-24 06:07:45 -06:00
Durante o processo de logout de uma instância, as chaves associadas ao estado criptográfico não estavam sendo removidas corretamente do Redis.
Dessa forma, quando uma nova conexão era estabelecida reutilizando o mesmo instanceName, o Baileys carregava chaves antigas e inválidas, incompatíveis com o novo conjunto de credenciais (creds) gerado na reconexão. Essa inconsistência gerava o seguinte sintoma prático: A instância autenticava com sucesso; Contudo, ao tentar enviar mensagens, entrava em estado de bloqueio, exibindo o status “aguardando mensagem” indefinidamente.
This commit is contained in:
@@ -5,6 +5,7 @@ import { INSTANCE_DIR } from '@config/path.config';
|
||||
import { AuthenticationState, BufferJSON, initAuthCreds, WAProto as proto } from 'baileys';
|
||||
import fs from 'fs/promises';
|
||||
import path from 'path';
|
||||
import {Logger} from "@config/logger.config";
|
||||
|
||||
const fixFileName = (file: string): string | undefined => {
|
||||
if (!file) {
|
||||
@@ -73,12 +74,15 @@ async function fileExists(file: string): Promise<any> {
|
||||
}
|
||||
}
|
||||
|
||||
const logger = new Logger('useMultiFileAuthStatePrisma');
|
||||
|
||||
export default async function useMultiFileAuthStatePrisma(
|
||||
sessionId: string,
|
||||
cache: CacheService,
|
||||
): Promise<{
|
||||
state: AuthenticationState;
|
||||
saveCreds: () => Promise<void>;
|
||||
removeCreds: () => Promise<void>;
|
||||
}> {
|
||||
const localFolder = path.join(INSTANCE_DIR, sessionId);
|
||||
const localFile = (key: string) => path.join(localFolder, fixFileName(key) + '.json');
|
||||
@@ -142,6 +146,27 @@ export default async function useMultiFileAuthStatePrisma(
|
||||
}
|
||||
}
|
||||
|
||||
async function removeCreds(): Promise<any> {
|
||||
|
||||
const cacheConfig = configService.get<CacheConf>('CACHE');
|
||||
|
||||
// Redis
|
||||
try {
|
||||
if (cacheConfig.REDIS.ENABLED) {
|
||||
await cache.delete(sessionId);
|
||||
logger.info({ action: 'redis.delete', sessionId });
|
||||
|
||||
return
|
||||
}
|
||||
} catch (err) {
|
||||
logger.warn({ action: 'redis.delete', sessionId, err });
|
||||
}
|
||||
|
||||
logger.info({ action: 'auth.key.delete', sessionId });
|
||||
|
||||
await deleteAuthKey(sessionId);
|
||||
}
|
||||
|
||||
let creds = await readData('creds');
|
||||
if (!creds) {
|
||||
creds = initAuthCreds();
|
||||
@@ -183,5 +208,7 @@ export default async function useMultiFileAuthStatePrisma(
|
||||
saveCreds: () => {
|
||||
return writeData(creds, 'creds');
|
||||
},
|
||||
|
||||
removeCreds
|
||||
};
|
||||
}
|
||||
|
||||
@@ -39,7 +39,11 @@ import { Logger } from '@config/logger.config';
|
||||
import { AuthenticationCreds, AuthenticationState, BufferJSON, initAuthCreds, proto, SignalDataTypeMap } from 'baileys';
|
||||
import { isNotEmpty } from 'class-validator';
|
||||
|
||||
export type AuthState = { state: AuthenticationState; saveCreds: () => Promise<void> };
|
||||
export type AuthState = {
|
||||
state: AuthenticationState;
|
||||
saveCreds: () => Promise<void>
|
||||
removeCreds: () => Promise<void>;
|
||||
};
|
||||
|
||||
export class AuthStateProvider {
|
||||
constructor(private readonly providerFiles: ProviderFiles) {}
|
||||
@@ -86,6 +90,19 @@ export class AuthStateProvider {
|
||||
return response;
|
||||
};
|
||||
|
||||
const removeCreds = async () => {
|
||||
|
||||
const [response, error] = await this.providerFiles.removeSession(instance);
|
||||
if (error) {
|
||||
// this.logger.error(['removeData', error?.message, error?.stack]);
|
||||
return;
|
||||
}
|
||||
|
||||
logger.info({ action: 'remove.session', instance });
|
||||
|
||||
return;
|
||||
};
|
||||
|
||||
const creds: AuthenticationCreds = (await readData('creds')) || initAuthCreds();
|
||||
|
||||
return {
|
||||
@@ -126,6 +143,10 @@ export class AuthStateProvider {
|
||||
saveCreds: async () => {
|
||||
return await writeData(creds, 'creds');
|
||||
},
|
||||
|
||||
removeCreds
|
||||
};
|
||||
}
|
||||
}
|
||||
|
||||
const logger = new Logger('useMultiFileAuthStatePrisma');
|
||||
|
||||
@@ -8,6 +8,7 @@ export async function useMultiFileAuthStateRedisDb(
|
||||
): Promise<{
|
||||
state: AuthenticationState;
|
||||
saveCreds: () => Promise<void>;
|
||||
removeCreds: () => Promise<void>;
|
||||
}> {
|
||||
const logger = new Logger('useMultiFileAuthStateRedisDb');
|
||||
|
||||
@@ -36,6 +37,17 @@ export async function useMultiFileAuthStateRedisDb(
|
||||
}
|
||||
};
|
||||
|
||||
async function removeCreds(): Promise<any> {
|
||||
try {
|
||||
|
||||
logger.warn({ action: 'redis.delete', instanceName });
|
||||
|
||||
return await cache.delete(instanceName);
|
||||
} catch {
|
||||
return;
|
||||
}
|
||||
}
|
||||
|
||||
const creds: AuthenticationCreds = (await readData('creds')) || initAuthCreds();
|
||||
|
||||
return {
|
||||
@@ -76,5 +88,7 @@ export async function useMultiFileAuthStateRedisDb(
|
||||
saveCreds: async () => {
|
||||
return await writeData(creds, 'creds');
|
||||
},
|
||||
|
||||
removeCreds
|
||||
};
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user