-
Notifications
You must be signed in to change notification settings - Fork 0
/
Depricated-gemini-api.js
66 lines (59 loc) · 1.96 KB
/
Depricated-gemini-api.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
//Depricated
// // Function to stream data to a Gemini API endpoint
// export function streamGemini(data) {
// return fetch('http://127.0.0.1:5000', {
// method: 'POST',
// headers: {
// 'Content-Type': 'application/json'
// },
// body: JSON.stringify(data)
// });
// }
// /**
// * A helper function that streams text output chunks from a fetch() response.
// */
// async function* streamResponseChunks(response) {
// let buffer = '';
// const CHUNK_SEPARATOR = '\n\n';
// // Function to process the buffer and yield chunks
// let processBuffer = async function* (streamDone = false) {
// while (true) {
// let flush = false;
// let chunkSeparatorIndex = buffer.indexOf(CHUNK_SEPARATOR);
// if (streamDone && chunkSeparatorIndex < 0) {
// flush = true;
// chunkSeparatorIndex = buffer.length;
// }
// if (chunkSeparatorIndex < 0) {
// break;
// }
// let chunk = buffer.substring(0, chunkSeparatorIndex);
// buffer = buffer.substring(chunkSeparatorIndex + CHUNK_SEPARATOR.length);
// chunk = chunk.replace(/^data:\s*/, '').trim();
// if (!chunk) {
// if (flush) break;
// continue;
// }
// let { error, text } = JSON.parse(chunk);
// if (error) {
// console.error(error);
// throw new Error(error?.message || JSON.stringify(error));
// }
// yield text;
// if (flush) break;
// }
// };
// const reader = response.body.getReader();
// try {
// while (true) {
// const { done, value } = await reader.read()
// if (done) break;
// buffer += new TextDecoder().decode(value);
// console.log(new TextDecoder().decode(value));
// yield* processBuffer();
// }
// } finally {
// reader.releaseLock();
// }
// yield* processBuffer(true);
// }