|
|
@@ -0,0 +1,199 @@
|
|
|
+import { Google, REQUEST_TIMEOUT_MS } from "@/app/constant";
|
|
|
+import { ChatOptions, getHeaders, LLMApi, LLMModel, LLMUsage } from "../api";
|
|
|
+import { useAccessStore, useAppConfig, useChatStore } from "@/app/store";
|
|
|
+import {
|
|
|
+ EventStreamContentType,
|
|
|
+ fetchEventSource,
|
|
|
+} from "@fortaine/fetch-event-source";
|
|
|
+import { prettyObject } from "@/app/utils/format";
|
|
|
+import { getClientConfig } from "@/app/config/client";
|
|
|
+import Locale from "../../locales";
|
|
|
+export class GeminiApi implements LLMApi {
|
|
|
+ extractMessage(res: any) {
|
|
|
+ console.log("[Response] gemini response: ", res);
|
|
|
+ return (
|
|
|
+ res?.candidates?.at(0)?.content?.parts.at(0)?.text ||
|
|
|
+ res?.error?.message ||
|
|
|
+ ""
|
|
|
+ );
|
|
|
+ }
|
|
|
+ async chat(options: ChatOptions): Promise<void> {
|
|
|
+ const messages = options.messages.map((v) => ({
|
|
|
+ role: v.role.replace("assistant", "model").replace("system", "model"),
|
|
|
+ parts: [{ text: v.content }],
|
|
|
+ }));
|
|
|
+
|
|
|
+ const modelConfig = {
|
|
|
+ ...useAppConfig.getState().modelConfig,
|
|
|
+ ...useChatStore.getState().currentSession().mask.modelConfig,
|
|
|
+ ...{
|
|
|
+ model: options.config.model,
|
|
|
+ },
|
|
|
+ };
|
|
|
+ const accessStore = useAccessStore.getState();
|
|
|
+
|
|
|
+ const requestPayload = {
|
|
|
+ contents: messages,
|
|
|
+ // stream: options.config.stream,
|
|
|
+ // model: modelConfig.model,
|
|
|
+ // temperature: modelConfig.temperature,
|
|
|
+ // presence_penalty: modelConfig.presence_penalty,
|
|
|
+ // frequency_penalty: modelConfig.frequency_penalty,
|
|
|
+ // top_p: modelConfig.top_p,
|
|
|
+ // max_tokens: Math.max(modelConfig.max_tokens, 1024),
|
|
|
+ // Please do not ask me why not send max_tokens, no reason, this param is just shit, I dont want to explain anymore.
|
|
|
+ };
|
|
|
+
|
|
|
+ console.log("[Request] openai payload: ", requestPayload);
|
|
|
+
|
|
|
+ // todo: support stream later
|
|
|
+ const shouldStream = false;
|
|
|
+ const controller = new AbortController();
|
|
|
+ options.onController?.(controller);
|
|
|
+
|
|
|
+ try {
|
|
|
+ const chatPath =
|
|
|
+ this.path(Google.ChatPath) + `?key=${accessStore.googleApiKey}`;
|
|
|
+ const chatPayload = {
|
|
|
+ method: "POST",
|
|
|
+ body: JSON.stringify(requestPayload),
|
|
|
+ signal: controller.signal,
|
|
|
+ headers: getHeaders(),
|
|
|
+ };
|
|
|
+
|
|
|
+ // make a fetch request
|
|
|
+ const requestTimeoutId = setTimeout(
|
|
|
+ () => controller.abort(),
|
|
|
+ REQUEST_TIMEOUT_MS,
|
|
|
+ );
|
|
|
+ if (shouldStream) {
|
|
|
+ let responseText = "";
|
|
|
+ let remainText = "";
|
|
|
+ let finished = false;
|
|
|
+
|
|
|
+ // animate response to make it looks smooth
|
|
|
+ function animateResponseText() {
|
|
|
+ if (finished || controller.signal.aborted) {
|
|
|
+ responseText += remainText;
|
|
|
+ console.log("[Response Animation] finished");
|
|
|
+ return;
|
|
|
+ }
|
|
|
+
|
|
|
+ if (remainText.length > 0) {
|
|
|
+ const fetchCount = Math.max(1, Math.round(remainText.length / 60));
|
|
|
+ const fetchText = remainText.slice(0, fetchCount);
|
|
|
+ responseText += fetchText;
|
|
|
+ remainText = remainText.slice(fetchCount);
|
|
|
+ options.onUpdate?.(responseText, fetchText);
|
|
|
+ }
|
|
|
+
|
|
|
+ requestAnimationFrame(animateResponseText);
|
|
|
+ }
|
|
|
+
|
|
|
+ // start animaion
|
|
|
+ animateResponseText();
|
|
|
+
|
|
|
+ const finish = () => {
|
|
|
+ if (!finished) {
|
|
|
+ finished = true;
|
|
|
+ options.onFinish(responseText + remainText);
|
|
|
+ }
|
|
|
+ };
|
|
|
+
|
|
|
+ controller.signal.onabort = finish;
|
|
|
+
|
|
|
+ fetchEventSource(chatPath, {
|
|
|
+ ...chatPayload,
|
|
|
+ async onopen(res) {
|
|
|
+ clearTimeout(requestTimeoutId);
|
|
|
+ const contentType = res.headers.get("content-type");
|
|
|
+ console.log(
|
|
|
+ "[OpenAI] request response content type: ",
|
|
|
+ contentType,
|
|
|
+ );
|
|
|
+
|
|
|
+ if (contentType?.startsWith("text/plain")) {
|
|
|
+ responseText = await res.clone().text();
|
|
|
+ return finish();
|
|
|
+ }
|
|
|
+
|
|
|
+ if (
|
|
|
+ !res.ok ||
|
|
|
+ !res.headers
|
|
|
+ .get("content-type")
|
|
|
+ ?.startsWith(EventStreamContentType) ||
|
|
|
+ res.status !== 200
|
|
|
+ ) {
|
|
|
+ const responseTexts = [responseText];
|
|
|
+ let extraInfo = await res.clone().text();
|
|
|
+ try {
|
|
|
+ const resJson = await res.clone().json();
|
|
|
+ extraInfo = prettyObject(resJson);
|
|
|
+ } catch {}
|
|
|
+
|
|
|
+ if (res.status === 401) {
|
|
|
+ responseTexts.push(Locale.Error.Unauthorized);
|
|
|
+ }
|
|
|
+
|
|
|
+ if (extraInfo) {
|
|
|
+ responseTexts.push(extraInfo);
|
|
|
+ }
|
|
|
+
|
|
|
+ responseText = responseTexts.join("\n\n");
|
|
|
+
|
|
|
+ return finish();
|
|
|
+ }
|
|
|
+ },
|
|
|
+ onmessage(msg) {
|
|
|
+ if (msg.data === "[DONE]" || finished) {
|
|
|
+ return finish();
|
|
|
+ }
|
|
|
+ const text = msg.data;
|
|
|
+ try {
|
|
|
+ const json = JSON.parse(text) as {
|
|
|
+ choices: Array<{
|
|
|
+ delta: {
|
|
|
+ content: string;
|
|
|
+ };
|
|
|
+ }>;
|
|
|
+ };
|
|
|
+ const delta = json.choices[0]?.delta?.content;
|
|
|
+ if (delta) {
|
|
|
+ remainText += delta;
|
|
|
+ }
|
|
|
+ } catch (e) {
|
|
|
+ console.error("[Request] parse error", text);
|
|
|
+ }
|
|
|
+ },
|
|
|
+ onclose() {
|
|
|
+ finish();
|
|
|
+ },
|
|
|
+ onerror(e) {
|
|
|
+ options.onError?.(e);
|
|
|
+ throw e;
|
|
|
+ },
|
|
|
+ openWhenHidden: true,
|
|
|
+ });
|
|
|
+ } else {
|
|
|
+ const res = await fetch(chatPath, chatPayload);
|
|
|
+ clearTimeout(requestTimeoutId);
|
|
|
+
|
|
|
+ const resJson = await res.json();
|
|
|
+ const message = this.extractMessage(resJson);
|
|
|
+ options.onFinish(message);
|
|
|
+ }
|
|
|
+ } catch (e) {
|
|
|
+ console.log("[Request] failed to make a chat request", e);
|
|
|
+ options.onError?.(e as Error);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ usage(): Promise<LLMUsage> {
|
|
|
+ throw new Error("Method not implemented.");
|
|
|
+ }
|
|
|
+ async models(): Promise<LLMModel[]> {
|
|
|
+ return [];
|
|
|
+ }
|
|
|
+ path(path: string): string {
|
|
|
+ return "/api/google/" + path;
|
|
|
+ }
|
|
|
+}
|