mirror of
https://github.com/EvolutionAPI/evolution-api.git
synced 2025-07-24 17:38:40 -06:00
Merge pull request #744 from rcesar/v2.0.0
Fix conversationId when is dify agent
This commit is contained in:
commit
9329330297
@ -1199,6 +1199,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);
|
||||||
@ -1210,6 +1211,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);
|
||||||
}
|
}
|
||||||
@ -1239,8 +1241,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');
|
||||||
@ -1554,6 +1556,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);
|
||||||
@ -1569,6 +1572,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);
|
||||||
@ -1596,8 +1600,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');
|
||||||
|
Loading…
Reference in New Issue
Block a user