fix `Unable to submit request because it has an empty text parameter.…

…' error

closes #83

dist/main_node.mjs

@@ -1,4 +1,4 @@
-// node_modules/.deno/@[email protected].5/node_modules/@hono/node-server/dist/index.mjs
+// node_modules/.deno/@[email protected].7/node_modules/@hono/node-server/dist/index.mjs
 import { createServer as createServerHTTP } from "http";
 import { Http2ServerRequest } from "http2";
 import { Readable } from "stream";
@@ -393,6 +393,8 @@ var getRequestListener = (fetchCallback, options = {}) => {
       outgoing.on("close", () => {
         if (incoming.errored) {
           req[getAbortController]().abort(incoming.errored.toString());
+        } else if (!outgoing.writableFinished) {
+          req[getAbortController]().abort("Client connection prematurely closed.");
         }
       });
       res = fetchCallback(req, { incoming, outgoing });

package.json

@@ -18,7 +18,7 @@
     "test-cov": "deno test --coverage -A --env && deno coverage coverage --lcov --output=coverage/lcov.info"
   },
   "dependencies": {
-    "@hono/node-server": "1.13.5",
+    "@hono/node-server": "1.13.7",
     "eventsource-parser": "3.0.0",
     "itty-router": "5.0.18"
   },

src/app.ts

@@ -1,16 +1,16 @@
-import type { IRequest, IttyRouterType } from "itty-router"
+import type { IRequest } from "itty-router"
 import { Router } from "itty-router/Router"
 import { cors } from "itty-router/cors"
 import { geminiProxy } from "./gemini-proxy.ts"
 import { hello } from "./hello.ts"
-import { Logger } from "./log.ts"
+import { type Any, Logger } from "./log.ts"
 import { chatProxyHandler } from "./openai/chat/completions/ChatProxyHandler.ts"
 import { embeddingProxyHandler } from "./openai/embeddingProxyHandler.ts"
 import { modelDetail, models } from "./openai/models.ts"
 
 const { preflight, corsify } = cors({ allowHeaders: "*" })
 
-const app: IttyRouterType = Router<IRequest>({
+const app = Router<IRequest, Any[], Response>({
   before: [
     preflight,
     (req) => {

src/utils.ts

@@ -52,7 +52,7 @@ export function openAiMessageToGeminiMessage(messages: OpenAI.Chat.ChatCompletio
       if (role === "system") {
         return [
           { role: "user", parts: typeof content !== "string" ? content : [{ text: content }] },
-          { role: "model", parts: [{ text: "" }] },
+          { role: "model", parts: [{ text: "OK" }] },
         ] satisfies Content[] as Content[]
       }
 
@@ -62,7 +62,7 @@ export function openAiMessageToGeminiMessage(messages: OpenAI.Chat.ChatCompletio
           : content.map((item) => {
               if (item.type === "text") return { text: item.text }
               if (item.type === "image_url") return parseBase64(item.image_url.url)
-              return { text: "" }
+              return { text: "OK" }
             })
 
       return [{ role: "user" === role ? "user" : "model", parts: parts }]

test/chat-completion_test.ts

@@ -100,11 +100,8 @@ describe("openai to gemini test", () => {
           }),
         )
 
-        console.log(111)
-        const text = await res.text()
-        console.log(text)
-
-        const values = ReadableStream.from(text).pipeThrough(new EventSourceParserStream()).values()
+        const body = res.body ?? throws(new Error("no body"))
+        const values = body.pipeThrough(new TextDecoderStream()).pipeThrough(new EventSourceParserStream()).values()
 
         for await (const e of values) {
           if (e.data === "[DONE]") return
@@ -116,3 +113,7 @@ describe("openai to gemini test", () => {
     }
   })
 })
+
+function throws(e: Error): never {
+  throw e
+}