增加猴狐gpt逆向接口

app/api/newbing-image/route.ts

@@ -0,0 +1,16 @@
+import { BingChat} from "../../bing-chat/build/index";
+
+export async function POST(req: Request) {
+  try {
+    let cookies = process.env.COOKIES;
+    const api = new BingChat({
+      cookie: cookies,
+    });
+    const res = await api.createImage(await req.json());
+    console.log(res)
+    return new Response();
+  } catch (e) {
+    console.error("[NewBing] ", e);
+    return new Response(JSON.stringify(e));
+  }
+}

app/api/revchat/route.ts

@@ -0,0 +1,66 @@
+import { createParser } from "eventsource-parser";
+import { NextRequest } from "next/server";
+
+async function createStream(req: NextRequest) {
+  const encoder = new TextEncoder();
+  const decoder = new TextDecoder();
+
+  const res = await fetch("http://lemurchat.anfans.cn/api/chat/conversation-trial", {
+    headers: {
+      "Content-Type": "application/json"
+    },
+    method: "POST",
+    body: req.body,
+  });
+
+  const stream = new ReadableStream({
+    async start(controller) {
+      function onParse(event: any) {
+        if (event.type === "event") {
+          const data = event.data;
+          if(event.id=="1"){
+            let text1=data.slice(data.indexOf("content"))
+            const text = text1.slice(12,text1.indexOf("index")-6)
+            const queue = encoder.encode(text);
+            controller.enqueue(queue);
+            return;
+          }
+          // https://beta.openai.com/docs/api-reference/completions/create#completions/create-stream
+          try {
+            const json = JSON.parse(data);
+            // console.log(data.indexOf("content"))
+            if (data.indexOf("content")==-1) {
+              controller.close();
+              return;
+            }
+            // console.log(event.data)
+            const text = JSON.parse(json.data.slice(5)).choices[0].delta.content;
+            const queue = encoder.encode(text);
+            controller.enqueue(queue);
+          } catch (e) {
+            controller.error(e);
+          }
+        }
+      }
+
+      const parser = createParser(onParse);
+      for await (const chunk of res.body as any) {
+        parser.feed(decoder.decode(chunk));
+      }
+    },
+  });
+  return stream;
+}
+
+export async function POST(req: NextRequest) {
+  try {
+    const stream = await createStream(req);
+    return new Response(stream);
+  } catch (error) {
+    console.error("[Chat Stream]", error);
+  }
+}
+
+export const config = {
+  runtime: "edge",
+};

app/bing-chat/build/index.d.ts

@@ -240,6 +240,7 @@ declare class BingChat {
    */
   sendMessage(text: string, opts?: SendMessageOptions): Promise<ChatMessage>;
   createConversation(): Promise<ConversationResult>;
+  createImage(message: string): Array;
 }
 
 export {

app/bing-chat/build/index.js

@@ -1,4 +1,5 @@
 // src/bing-chat.ts
+import { time } from "node:console";
 import crypto from "node:crypto";
 import WebSocket from "ws";
 
@@ -260,6 +261,45 @@ var BingChat = class {
       }
     });
   }
+  async createImage(message) {
+    // const requestId = crypto.randomUUID();
+    console.log(1)
+    const cookie = this._cookie.includes(";") ? this._cookie : `_U=${this._cookie}`;
+    let res = await fetch(`https://www.bing.com/images/create?q=${message}&rt=3&FORM=GENCRE`, {
+      headers: {
+        cookie
+      },
+      method: "GET",
+      mode: "cors"
+    })
+    console.log(res.headers)
+    if (res.status!= 302) {
+      throw new Error(
+        `unexpected HTTP error createConversation ${res.status}: ${res.statusText}`
+      );
+    }
+    console.log(2)
+    redirect_url=res.headers["Location"].replace("&nfy=1", "")
+    request_id = redirect_url.split("id=")[-1]
+    await fetch("https://www.bing.com"+redirect_url,{method:"GET"})
+    polling_url = `https://www.bing.com/images/create/async/results/${request_id}?q=${message}`
+    while (true){
+       res = await fetch(polling_url,{method:"GET"})
+      if(res.json()!=''||res.json().indexOf("errorMessage") != -1){
+        await setTimeout(()=>{console.log(123)},1000)
+        continue
+      }else{
+        break
+      }
+    }
+    console.log(3)
+    image_links = res.json().match('src="([^"]+)"')
+    normal_image_links = []
+    for(let i=0 ;i<image_links.length;i++){
+      normal_image_links.push(image_links[i].split("?w=")[0])
+    }
+    return normal_image_links
+  }
 };
 export {
   BingChat

app/requests.ts

@@ -38,6 +38,21 @@ const makeRequestParam = (
   };
 };
 
+const makeRevChatRequestParam = (
+  messages: Message[]
+) => {
+  let sendMessages = messages.map((v) => ({
+    role: v.role,
+    content: v.content,
+    isSensitive: false,
+    needCheck: true
+  }));
+
+  return {
+    messages: JSON.stringify(sendMessages)
+  }
+};
+
 const makeImageRequestParam = (messages: Message[]): ChatImageRequest => {
   return {
     prompt: messages[messages.length - 1].content,
@@ -214,7 +229,7 @@ export async function requestChatStream(
       console.error("NetWork Error", err);
       options?.onMessage("请换一个问题试试吧", true);
     }
-  } else {
+  } else if(model=="万卷"){
     console.log("[Request] ", messages[messages.length - 1].content);
     const controller = new AbortController();
     const reqTimeoutId = setTimeout(() => controller.abort(), TIME_OUT_MS);
@@ -235,6 +250,95 @@ export async function requestChatStream(
       console.error("NetWork Error", err);
       options?.onMessage("请换一个问题试试吧", true);
     }
+  }else if(model=="必应绘画"){
+    console.log("[Request] ", messages[messages.length - 1].content);
+    const req = makeImageRequestParam(messages);
+    const controller = new AbortController();
+    const reqTimeoutId = setTimeout(() => controller.abort(), TIME_OUT_MS);
+    try {
+      const res = await fetch("/api/newbing-image", {
+        method: "POST",
+        headers: {
+          "Content-Type": "application/json",
+          ...getHeaders(),
+        },
+        body: JSON.stringify(req),
+      });
+
+      clearTimeout(reqTimeoutId);
+      const reg = /^['|"](.*)['|"]$/;
+      const response = (await res.json()) as ChatImagesResponse;
+      options?.onMessage(
+        JSON.stringify(response.data[0].url).replace(reg, "$1"),
+        true,
+      );
+      controller.abort();
+    } catch (err) {
+      console.error("NetWork Error", err);
+      options?.onMessage("请换一个问题试试吧", true);
+    }
+  }else{
+    const req = makeRevChatRequestParam(messages);
+
+    console.log("[Request] ", req);
+
+    const controller = new AbortController();
+    const reqTimeoutId = setTimeout(() => controller.abort(), TIME_OUT_MS);
+
+    try {
+      const res = await fetch("/api/revchat", {
+        method: "POST",
+        headers: {
+          "Content-Type": "application/json",
+          ...getHeaders(),
+        },
+        body: JSON.stringify(req),
+        signal: controller.signal,
+      });
+      clearTimeout(reqTimeoutId);
+
+      let responseText = "";
+
+      const finish = () => {
+        options?.onMessage(responseText, true);
+        controller.abort();
+      };
+
+      if (res.ok) {
+        const reader = res.body?.getReader();
+        const decoder = new TextDecoder();
+
+        options?.onController?.(controller);
+
+        while (true) {
+          // handle time out, will stop if no response in 10 secs
+          const resTimeoutId = setTimeout(() => finish(), TIME_OUT_MS);
+          const content = await reader?.read();
+          clearTimeout(resTimeoutId);
+          const text = decoder.decode(content?.value);
+          responseText += text;
+
+          const done = !content || content.done;
+          options?.onMessage(responseText, false);
+
+          if (done) {
+            break;
+          }
+        }
+
+        finish();
+      } else if (res.status === 401) {
+        console.error("Anauthorized");
+        responseText = Locale.Error.Unauthorized;
+        finish();
+      } else {
+        console.error("Stream Error");
+        options?.onError(new Error("Stream Error"));
+      }
+    } catch (err) {
+      console.error("NetWork Error", err);
+      options?.onError(err as Error);
+    }
   }
 }
 

app/store/app.ts

@@ -92,10 +92,18 @@ export const ALL_MODEL = [
     name: "AI绘画",
     available: true,
   },
+  {
+    name: "逆向Gpt",
+    available: true,
+  },
   {
     name: "必应",
     available: true,
   },
+  // {
+  //   name: "必应绘画",
+  //   available: true,
+  // },
   {
     name: "万卷",
     available: true,
@@ -139,7 +147,7 @@ export function filterConfig(config: ModelConfig): Partial<ModelConfig> {
 }
 
 const DEFAULT_CONFIG: ChatConfig = {
-  model: "聊天",
+  model: "逆向Gpt",
   historyMessageCount: 8,
   compressMessageLengthThreshold: 1000,
   sendBotMessages: true as boolean,

middleware.ts

@@ -3,7 +3,7 @@ import { ACCESS_CODES } from "./app/api/access";
 import md5 from "spark-md5";
 
 export const config = {
-  matcher: ["/api/chat", "/api/chat-stream","/api/chat-image","/api/newbing","/api/wanjuan"],
+  matcher: ["/api/chat", "/api/chat-stream","/api/chat-image","/api/revchat","/api/newbing","/api/newbing-image","/api/wanjuan"],
 };
 
 export function middleware(req: NextRequest, res: NextResponse) {