θΏ™ζ˜―indexlocζδΎ›ηš„ζœεŠ‘οΌŒδΈθ¦θΎ“ε…₯任何密码
Skip to content
Merged
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
34 changes: 32 additions & 2 deletions server/utils/AiProviders/gemini/index.js
Original file line number Diff line number Diff line change
Expand Up @@ -87,7 +87,7 @@ class GeminiLLM {
formatMessages(messages = []) {
// Gemini roles are either user || model.
// and all "content" is relabeled to "parts"
return messages
const allMessages = messages
.map((message) => {
if (message.role === "system")
return { role: "user", parts: message.content };
Expand All @@ -98,6 +98,16 @@ class GeminiLLM {
return null;
})
.filter((msg) => !!msg);

// Specifically, Google cannot have the last sent message be from a user with no assistant reply
// otherwise it will crash. So if the last item is from the user, it was not completed so pop it off
// the history.
if (
allMessages.length > 0 &&
allMessages[allMessages.length - 1].role === "user"
)
allMessages.pop();
return allMessages;
}

async sendChat(chatHistory = [], prompt, workspace = {}, rawHistory = []) {
Expand Down Expand Up @@ -210,7 +220,27 @@ class GeminiLLM {
response.on("close", handleAbort);

for await (const chunk of stream) {
fullText += chunk.text();
let chunkText;
try {
// Due to content sensitivity we cannot always get the function .text();
// https://cloud.google.com/vertex-ai/generative-ai/docs/multimodal/configure-safety-attributes#gemini-TASK-samples-nodejs
// and it is not possible to unblock or disable this safety protocol without being allowlisted by Google.
chunkText = chunk.text();
} catch (e) {
chunkText = e.message;
writeResponseChunk(response, {
uuid,
sources: [],
type: "abort",
textResponse: null,
close: true,
error: e.message,
});
resolve(e.message);
return;
}

fullText += chunkText;
writeResponseChunk(response, {
uuid,
sources: [],
Expand Down