mirror of
https://github.com/danny-avila/LibreChat.git
synced 2025-12-23 03:40:14 +01:00
adding clear methods for convos
This commit is contained in:
parent
c7c50dbbab
commit
6e3f63ee46
16 changed files with 466 additions and 121 deletions
40
src/utils/handleSubmit.js
Normal file
40
src/utils/handleSubmit.js
Normal file
|
|
@ -0,0 +1,40 @@
|
|||
import { SSE } from '../../app/sse';
|
||||
|
||||
export default function handleSubmit(text, messageHandler, convo, convoHandler) {
|
||||
let payload = { text };
|
||||
if (convo.conversationId && convo.parentMessageId) {
|
||||
payload = {
|
||||
...payload,
|
||||
conversationId: convo.conversationId,
|
||||
parentMessageId: convo.parentMessageId
|
||||
};
|
||||
}
|
||||
|
||||
const events = new SSE('http://localhost:3050/ask', {
|
||||
payload: JSON.stringify(payload),
|
||||
headers: { 'Content-Type': 'application/json' }
|
||||
});
|
||||
|
||||
events.onopen = function () {
|
||||
console.log('connection is opened');
|
||||
};
|
||||
|
||||
events.onmessage = function (e) {
|
||||
const data = JSON.parse(e.data);
|
||||
if (!!data.message) {
|
||||
messageHandler(data.text.replace(/^\n/, ''));
|
||||
} else if (!data.initial) {
|
||||
console.log(data);
|
||||
convoHandler(data);
|
||||
} else {
|
||||
console.log('initial', data);
|
||||
}
|
||||
};
|
||||
|
||||
events.onerror = function (e) {
|
||||
console.log(e, 'error in opening conn.');
|
||||
events.close();
|
||||
};
|
||||
|
||||
events.stream();
|
||||
};
|
||||
Loading…
Add table
Add a link
Reference in a new issue