NeoAnd/evolution-api
1
0
Fork 0
mirror of https://github.com/EvolutionAPI/evolution-api.git synced 2025-07-23 04:22:02 -06:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

Fix conversationId when is dify agent

Browse Source
This commit is contained in:
Renan Cesar 2024-08-08 16:28:40 -03:00
parent d0a723b8ef
commit 0e4034ffac
1 changed files with 8 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/api/integrations/dify/services/dify.service.ts
View File

@ -1179,6 +1179,7 @@ export class DifyService {
}); });
let completeMessage = ''; let completeMessage = '';
let conversationId
const stream = response.data; const stream = response.data;
const reader = new Readable().wrap(stream); const reader = new Readable().wrap(stream);
@ -1190,6 +1191,7 @@ export class DifyService {
const event = JSON.parse(data); const event = JSON.parse(data);
if (event.event === 'agent_message') { if (event.event === 'agent_message') {
completeMessage += event.answer; completeMessage += event.answer;
conversationId = conversationId ?? event?.conversation_id
console.log('completeMessage:', completeMessage); console.log('completeMessage:', completeMessage);
} }
@ -1219,8 +1221,8 @@ export class DifyService {
data: { data: {
status: 'opened', status: 'opened',
awaitUser: true, awaitUser: true,
sessionId: response?.data?.conversation_id, sessionId: conversationId
}, }
}); });
sendTelemetry('/message/sendText'); sendTelemetry('/message/sendText');
@ -1511,6 +1513,7 @@ export class DifyService {
}); });
let completeMessage = ''; let completeMessage = '';
let conversationId
const stream = response.data; const stream = response.data;
const reader = new Readable().wrap(stream); const reader = new Readable().wrap(stream);
@ -1526,6 +1529,7 @@ export class DifyService {
const event = JSON.parse(jsonString); const event = JSON.parse(jsonString);
if (event.event === 'agent_message') { if (event.event === 'agent_message') {
completeMessage += event.answer; completeMessage += event.answer;
conversationId = conversationId ?? event?.conversation_id
} }
} catch (error) { } catch (error) {
console.error('Error parsing stream data:', error); console.error('Error parsing stream data:', error);
@ -1553,8 +1557,8 @@ export class DifyService {
data: { data: {
status: 'opened', status: 'opened',
awaitUser: true, awaitUser: true,
sessionId: response?.data?.conversation_id, sessionId: conversationId
}, }
}); });
sendTelemetry('/message/sendText'); sendTelemetry('/message/sendText');