修补一些请求特征

docs: add deploy to Zeabur guide

.github/workflows/docker-image.yml

@@ -0,0 +1,46 @@
+name: Build and Push Docker Image
+
+on:
+  release:
+    types: [created]
+  workflow_dispatch:
+    inputs:
+      tag:
+        description: 'Tag Name'
+        required: true
+
+jobs:
+  build-and-push:
+    runs-on: ubuntu-latest
+    steps:
+    - uses: actions/checkout@v2
+
+    - name: Set up Docker Buildx
+      uses: docker/setup-buildx-action@v1
+
+    - name: Login to Docker Hub
+      uses: docker/login-action@v1
+      with:
+        username: ${{ secrets.DOCKERHUB_USERNAME }}
+        password: ${{ secrets.DOCKERHUB_PASSWORD }}
+
+    - name: Set tag name
+      id: tag_name
+      run: |
+        if [ "${{ github.event_name }}" = "release" ]; then
+          echo "::set-output name=tag::${GITHUB_REF#refs/tags/}"
+        elif [ "${{ github.event_name }}" = "workflow_dispatch" ]; then
+          echo "::set-output name=tag::${{ github.event.inputs.tag }}"
+        fi
+
+    - name: Build and push Docker image with Release tag
+      uses: docker/build-push-action@v2
+      with:
+        context: .
+        file: ./Dockerfile
+        push: true
+        tags: |
+          vinlic/kimi-free-api:${{ steps.tag_name.outputs.tag }}
+          vinlic/kimi-free-api:latest
+        platforms: linux/amd64,linux/arm64
+        build-args: TARGETPLATFORM=${{ matrix.platform }}

.gitignore

@@ -1,3 +1,4 @@
 dist/
 node_modules/
-logs/
+logs/
+.vercel

Dockerfile

@@ -4,14 +4,15 @@ WORKDIR /app
 
 COPY . /app
 
-RUN npm i --registry http://registry.npmmirror.com && npm run build
+RUN yarn install --registry https://registry.npmmirror.com/ && yarn run build
 
 FROM node:lts-alpine
 
-COPY --from=BUILD_IMAGE /app/configs ./configs
-COPY --from=BUILD_IMAGE /app/package.json ./package.json
-COPY --from=BUILD_IMAGE /app/dist ./dist
-COPY --from=BUILD_IMAGE /app/node_modules ./node_modules
+COPY --from=BUILD_IMAGE /app/public /app/public
+COPY --from=BUILD_IMAGE /app/configs /app/configs
+COPY --from=BUILD_IMAGE /app/package.json /app/package.json
+COPY --from=BUILD_IMAGE /app/dist /app/dist
+COPY --from=BUILD_IMAGE /app/node_modules /app/node_modules
 
 WORKDIR /app
 

README.md

@@ -1,5 +1,11 @@
 # KIMI AI Free 服务
 
+
+<hr>
+
+<span>[ 中文 | <a href="README_EN.md">English</a> ]</span>
+
+
 ![](https://img.shields.io/github/license/llm-red-team/kimi-free-api.svg)
 ![](https://img.shields.io/github/stars/llm-red-team/kimi-free-api.svg)
 ![](https://img.shields.io/github/forks/llm-red-team/kimi-free-api.svg)
@@ -9,30 +15,47 @@
 
 与ChatGPT接口完全兼容。
 
+还有以下五个free-api欢迎关注：
+
+阶跃星辰 (跃问StepChat) 接口转API [step-free-api](https://github.com/LLM-Red-Team/step-free-api)
+
+阿里通义 (Qwen) 接口转API [qwen-free-api](https://github.com/LLM-Red-Team/qwen-free-api)
+
+ZhipuAI (智谱清言) 接口转API [glm-free-api](https://github.com/LLM-Red-Team/glm-free-api)
+
+秘塔AI (metaso) 接口转API [metaso-free-api](https://github.com/LLM-Red-Team/metaso-free-api)
+
+聆心智能 (Emohaa) 接口转API [emohaa-free-api](https://github.com/LLM-Red-Team/emohaa-free-api)
+
 ## 目录
 
-* [声明](#声明)
+* [免责声明](#免责声明)
 * [在线体验](#在线体验)
 * [效果示例](#效果示例)
 * [接入准备](#接入准备)
   * [多账号接入](#多账号接入)
 * [Docker部署](#Docker部署)
   * [Docker-compose部署](#Docker-compose部署)
+* [Render部署](#Render部署)
+* [Vercel部署](#Vercel部署)
 * [原生部署](#原生部署)
 * [接口列表](#接口列表)
   * [对话补全](#对话补全)
   * [文档解读](#文档解读)
   * [图像解析](#图像解析)
+  * [refresh_token存活检测](#refresh_token存活检测)
 * [注意事项](#注意事项)
   * [Nginx反代优化](#Nginx反代优化)
 
-## 声明
+## 免责声明
 
-仅限自用，禁止对外提供服务或商用，避免对官方造成服务压力，否则风险自担！
+**本组织和个人不接受任何资金捐助和交易，此项目是纯粹研究交流学习性质！**
 
-仅限自用，禁止对外提供服务或商用，避免对官方造成服务压力，否则风险自担！
+**仅限自用，禁止对外提供服务或商用，避免对官方造成服务压力，否则风险自担！**
 
-仅限自用，禁止对外提供服务或商用，避免对官方造成服务压力，否则风险自担！
+**仅限自用，禁止对外提供服务或商用，避免对官方造成服务压力，否则风险自担！**
+
+**仅限自用，禁止对外提供服务或商用，避免对官方造成服务压力，否则风险自担！**
 
 ## 在线体验
 
@@ -42,23 +65,23 @@ https://udify.app/chat/Po0F6BMJ15q5vu2P
 
 ## 效果示例
 
-### 验明正身
+### 验明正身Demo
 
 ![验明正身](./doc/example-1.png)
 
-### 多轮对话
+### 多轮对话Demo
 
 ![多轮对话](./doc/example-6.png)
 
-### 联网搜索
+### 联网搜索Demo
 
 ![联网搜索](./doc/example-2.png)
 
-### 长文档解读
+### 长文档解读Demo
 
 ![长文档解读](./doc/example-5.png)
 
-### 图像解析
+### 图像解析Demo
 
 ![图像解析](./doc/example-3.png)
 
@@ -70,13 +93,17 @@ https://udify.app/chat/Po0F6BMJ15q5vu2P
 
 从 [kimi.moonshot.cn](https://kimi.moonshot.cn) 获取refresh_token
 
-进入kimi随便发起一个对话，然后F12打开开发者工具，从Application > Local Storage中找到refresh_token的值，这将作为Authorization的Bearer Token值：`Authorization: Bearer TOKEN`
+进入kimi随便发起一个对话，然后F12打开开发者工具，从Application > Local Storage中找到`refresh_token`的值，这将作为Authorization的Bearer Token值：`Authorization: Bearer TOKEN`
 
 ![example0](./doc/example-0.png)
 
+如果你看到的`refresh_token`是一个数组，请使用`.`拼接起来再使用。
+
+![example8](./doc/example-8.jpg)
+
 ### 多账号接入
 
-目前kimi限制普通账号每3小时内只能进行30轮长文本的问答，你可以通过提供多个账号的refresh_token并使用`,`拼接提供：
+目前kimi限制普通账号每3小时内只能进行30轮长文本的问答（短文本不限），你可以通过提供多个账号的refresh_token并使用`,`拼接提供：
 
 `Authorization: Bearer TOKEN1,TOKEN2,TOKEN3`
 
@@ -126,6 +153,39 @@ services:
       - TZ=Asia/Shanghai
 ```
 
+### Render部署
+
+**注意：部分部署区域可能无法连接kimi，如容器日志出现请求超时或无法连接（新加坡实测不可用）请切换其他区域部署！**
+**注意：免费账户的容器实例将在一段时间不活动时自动停止运行，这会导致下次请求时遇到50秒或更长的延迟，建议查看[Render容器保活](https://github.com/LLM-Red-Team/free-api-hub/#Render%E5%AE%B9%E5%99%A8%E4%BF%9D%E6%B4%BB)**
+
+1. fork本项目到你的github账号下。
+
+2. 访问 [Render](https://dashboard.render.com/) 并登录你的github账号。
+
+3. 构建你的 Web Service（New+ -> Build and deploy from a Git repository -> Connect你fork的项目 -> 选择部署区域 -> 选择实例类型为Free -> Create Web Service）。
+
+4. 等待构建完成后，复制分配的域名并拼接URL访问即可。
+
+### Vercel部署
+
+**注意：Vercel免费账户的请求响应超时时间为10秒，但接口响应通常较久，可能会遇到Vercel返回的504超时错误！**
+
+请先确保安装了Node.js环境。
+
+```shell
+npm i -g vercel --registry http://registry.npmmirror.com
+vercel login
+git clone https://github.com/LLM-Red-Team/kimi-free-api
+cd kimi-free-api
+vercel --prod
+```
+
+### Zeabur部署
+
+**注意：免费账户的容器实例可能无法稳定运行**
+
+[![Deploy on Zeabur](https://zeabur.com/button.svg)](https://zeabur.com/templates/GRFYBP)
+
 ## 原生部署
 
 请准备一台具有公网IP的服务器并将8000端口开放。
@@ -193,6 +253,8 @@ Authorization: Bearer [refresh_token]
 请求数据：
 ```json
 {
+    // 模型名称随意填写，如果不希望输出检索过程模型名称请包含silent_search
+    "model": "kimi",
     "messages": [
         {
             "role": "user",
@@ -223,9 +285,9 @@ Authorization: Bearer [refresh_token]
         }
     ],
     "usage": {
-        "prompt_tokens": 0,
-        "completion_tokens": 0,
-        "total_tokens": 0
+        "prompt_tokens": 1,
+        "completion_tokens": 1,
+        "total_tokens": 2
     },
     "created": 1710152062
 }
@@ -246,6 +308,8 @@ Authorization: Bearer [refresh_token]
 请求数据：
 ```json
 {
+    // 模型名称随意填写，如果不希望输出检索过程模型名称请包含silent_search
+    "model": "kimi",
     "messages": [
         {
             "role": "user",
@@ -285,9 +349,9 @@ Authorization: Bearer [refresh_token]
         }
     ],
     "usage": {
-        "prompt_tokens": 0,
-        "completion_tokens": 0,
-        "total_tokens": 0
+        "prompt_tokens": 1,
+        "completion_tokens": 1,
+        "total_tokens": 2
     },
     "created": 100920
 }
@@ -310,6 +374,8 @@ Authorization: Bearer [refresh_token]
 请求数据：
 ```json
 {
+    // 模型名称随意填写，如果不希望输出检索过程模型名称请包含silent_search
+    "model": "kimi",
     "messages": [
         {
             "role": "user",
@@ -349,14 +415,34 @@ Authorization: Bearer [refresh_token]
         }
     ],
     "usage": {
-        "prompt_tokens": 0,
-        "completion_tokens": 0,
-        "total_tokens": 0
+        "prompt_tokens": 1,
+        "completion_tokens": 1,
+        "total_tokens": 2
     },
     "created": 1710123627
 }
 ```
 
+### refresh_token存活检测
+
+检测refresh_token是否存活，如果存活live未true，否则为false，请不要频繁（小于10分钟）调用此接口。
+
+**POST /token/check**
+
+请求数据：
+```json
+{
+    "token": "eyJhbGciOiJIUzUxMiIsInR5cCI6IkpXVCJ9..."
+}
+```
+
+响应数据：
+```json
+{
+    "live": true
+}
+```
+
 ## 注意事项
 
 ### Nginx反代优化
@@ -374,4 +460,12 @@ tcp_nopush on;
 tcp_nodelay on;
 # 设置保持连接的超时时间，这里设置为120秒。如果在这段时间内，客户端和服务器之间没有进一步的通信，连接将被关闭。
 keepalive_timeout 120;
-```
+```
+
+### Token统计
+
+由于推理侧不在kimi-free-api，因此token不可统计，将以固定数字返回!!!!!
+
+## Star History
+
+[![Star History Chart](https://api.star-history.com/svg?repos=LLM-Red-Team/kimi-free-api&type=Date)](https://star-history.com/#LLM-Red-Team/kimi-free-api&Date)

README_EN.md

@@ -0,0 +1,434 @@
+# KIMI AI Free Service
+
+![](https://img.shields.io/github/license/llm-red-team/kimi-free-api.svg)
+![](https://img.shields.io/github/stars/llm-red-team/kimi-free-api.svg)
+![](https://img.shields.io/github/forks/llm-red-team/kimi-free-api.svg)
+![](https://img.shields.io/docker/pulls/vinlic/kimi-free-api.svg)
+
+Supports high-speed streaming output, multi-turn dialogues, internet search, long document reading, image analysis, zero-configuration deployment, multi-token support, and automatic session trace cleanup.
+
+Fully compatible with the ChatGPT interface.
+
+Also, the following four free APIs are available for your attention:
+
+Step to the Stars (StepChat) API to API [step-free-api](https://github.com/LLM-Red-Team/step-free-api)
+
+Ali Tongyi (Qwen) API to API [qwen-free-api](https://github.com/LLM-Red-Team/qwen-free-api)
+
+ZhipuAI (Wisdom Map Clear Words) API to API [glm-free-api](https://github.com/LLM-Red-Team/glm-free-api)
+
+MetaAI (metaso) 接口转API [metaso-free-api](https://github.com/LLM-Red-Team/metaso-free-api)
+
+Listening Intelligence (Emohaa) API to API [emohaa-free-api](https://github.com/LLM-Red-Team/emohaa-free-api)
+
+## Table of Contents
+
+* [Disclaimer](#disclaimer)
+*[Online experience](#在线experience)
+* [Effect Example](#EffectExample)
+* [Access preparation](#access preparation)
+   * [Multiple account access](#multiple account access)
+* [Docker Deployment](#DockerDeployment)
+   * [Docker-compose deployment](#Docker-compose deployment)
+* [Native Deployment](#nativedeployment)
+* [Interface List](#Interface List)
+   * [Dialogue completion](#dialogue completion)
+   * [Document Interpretation](#document interpretation)
+   * [Image analysis](#imageanalysis)
+   * [refresh_token survival detection](#refresh_token survival detection)
+* [Note](# NOTE)
+   * [Nginx anti-generation optimization](#Nginx anti-generation optimization)
+
+## Disclaimer
+
+**This organization and individuals do not accept any financial donations and transactions. This project is purely for research, communication, and learning purposes!**
+
+**For personal use only, it is forbidden to provide services or commercial use externally to avoid causing service pressure on the official, otherwise, bear the risk yourself!**
+
+**For personal use only, it is forbidden to provide services or commercial use externally to avoid causing service pressure on the official, otherwise, bear the risk yourself!**
+
+**For personal use only, it is forbidden to provide services or commercial use externally to avoid causing service pressure on the official, otherwise, bear the risk yourself!**
+
+## Online Experience
+
+This link is only for temporary testing of functions and cannot be used for a long time. For long-term use, please deploy by yourself.
+
+https://udify.app/chat/Po0F6BMJ15q5vu2P
+
+## Effect Examples
+
+### Identity Verification
+
+![Identity Verification](./doc/example-1.png)
+
+### Multi-turn Dialogue
+
+![Multi-turn Dialogue](./doc/example-6.png)
+
+### Internet Search
+
+![Internet Search](./doc/example-2.png)
+
+### Long Document Reading
+
+![Long Document Reading](./doc/example-5.png)
+
+### Image Analysis
+
+![Image Analysis](./doc/example-3.png)
+
+### Consistent Responsiveness
+
+![Consistent Responsiveness](https://github.com/LLM-Red-Team/kimi-free-api/assets/20235341/48c7ec00-2b03-46c4-95d0-452d3075219b)
+
+## Access Preparation
+
+Get the `refresh_token` from [kimi.moonshot.cn](https://kimi.moonshot.cn)
+
+Start a conversation with kimi at will, then open the developer tool with F12, and find the value of `refresh_token` from Application > Local Storage, which will be used as the value of the Bearer Token in Authorization: `Authorization: Bearer TOKEN`
+
+![example0](./doc/example-0.png)
+
+If you see `refresh_token` as an array, please use `.` to join it before using.
+
+![example8](./doc/example-8.jpg)
+
+### Multi-Account Access
+
+Currently, kimi limits ordinary accounts to only 30 rounds of long-text Q&A within every 3 hours (short text is unlimited). You can provide multiple account refresh_tokens and use `,` to join them:
+
+`Authorization: Bearer TOKEN1,TOKEN2,TOKEN3`
+
+The service will pick one each time a request is made.
+
+## Docker Deployment
+
+Please prepare a server with a public IP and open port 8000.
+
+Pull the image and start the service
+
+```shell
+docker run -it -d --init --name kimi-free-api -p 8000:8000 -e TZ=Asia/Shanghai vinlic/kimi-free-api:latest
+```
+
+check real-time service logs
+
+```shell
+docker logs -f kimi-free-api
+```
+
+Restart service
+
+```shell
+docker restart kimi-free-api
+```
+
+Out of service
+
+```shell
+docker stop kimi-free-api
+```
+
+### Docker-compose deployment
+
+```yaml
+version: '3'
+
+services:
+  kimi-free-api:
+    container_name: kimi-free-api
+    image: vinlic/kimi-free-api:latest
+    restart: always
+    ports:
+      - "8000:8000"
+    environment:
+      - TZ=Asia/Shanghai
+```
+
+## Native deployment
+
+Please prepare a server with a public IP and open port 8000.
+
+Please install the Node.js environment and configure the environment variables first, and confirm that the node command is available.
+
+Install dependencies
+
+```shell
+npm i
+```
+
+Install PM2 for process guarding
+
+```shell
+npm i -g pm2
+```
+
+Compile and build. When you see the dist directory, the build is complete.
+
+```shell
+npm run build
+```
+
+Start service
+
+```shell
+pm2 start dist/index.js --name "kimi-free-api"
+```
+
+View real-time service logs
+
+```shell
+pm2 logs kimi-free-api
+```
+
+Restart service
+
+```shell
+pm2 reload kimi-free-api
+```
+
+Out of service
+
+```shell
+pm2 stop kimi-free-api
+```
+
+## Zeabur Deployment
+
+[![Deploy on Zeabur](https://zeabur.com/button.svg)](https://zeabur.com/templates/GRFYBP)
+
+## interface list
+
+Currently, the `/v1/chat/completions` interface compatible with openai is supported. You can use the client access interface compatible with openai or other clients, or use online services such as [dify](https://dify.ai/) Access and use.
+
+### Conversation completion
+
+Conversation completion interface, compatible with openai's [chat-completions-api](https://platform.openai.com/docs/guides/text-generation/chat-completions-api).
+
+**POST /v1/chat/completions**
+
+The header needs to set the Authorization header:
+```
+Authorization: Bearer [refresh_token]
+```
+
+Request data:
+```json
+{
+     // Fill in the model name as you like. If you do not want to output the retrieval process model name, please include silent_search.
+     "model": "kimi",
+     "messages": [
+         {
+             "role": "user",
+             "content": "test"
+         }
+     ],
+     // Whether to enable online search, default false
+     "use_search": true,
+     // If using SSE stream, please set it to true, the default is false
+     "stream": false
+}
+```
+
+Response data:
+
+```json
+{
+     "id": "cnndivilnl96vah411dg",
+     "model": "kimi",
+     "object": "chat.completion",
+     "choices": [
+         {
+             "index": 0,
+             "message": {
+                 "role": "assistant",
+                 "content": "Hello! I am Kimi, an artificial intelligence assistant developed by Dark Side of the Moon Technology Co., Ltd. I am good at conversation in Chinese and English. I can help you obtain information, answer questions, and read and understand the documents you provide. and web content. If you have any questions or need help, feel free to let me know!"
+             },
+             "finish_reason": "stop"
+         }
+     ],
+     "usage": {
+         "prompt_tokens": 1,
+         "completion_tokens": 1,
+         "total_tokens": 2
+     },
+     "created": 1710152062
+}
+```
+
+### Document interpretation
+
+Provide an accessible file URL or BASE64_URL to parse.
+
+**POST /v1/chat/completions**
+
+The header needs to set the Authorization header:
+
+```
+Authorization: Bearer [refresh_token]
+```
+
+Request data:
+```json
+{
+     // Fill in the model name as you like. If you do not want to output the retrieval process model name, please include silent_search.
+     "model": "kimi",
+     "messages": [
+         {
+             "role": "user",
+             "content": [
+                 {
+                     "type": "file",
+                     "file_url": {
+                         "url": "https://mj101-1317487292.cos.ap-shanghai.myqcloud.com/ai/test.pdf"
+                     }
+                 },
+                 {
+                     "type": "text",
+                     "text": "What does the document say?"
+                 }
+             ]
+         }
+     ],
+     // It is recommended to turn off online search to prevent interference in interpreting results.
+     "use_search": false
+}
+```
+
+Response data:
+```json
+{
+     "id": "cnmuo7mcp7f9hjcmihn0",
+     "model": "kimi",
+     "object": "chat.completion",
+     "choices": [
+         {
+             "index": 0,
+             "message": {
+                 "role": "assistant",
+                 "content": "The document contains several examples of ancient magical spells from magical texts from the ancient Greek and Roman periods known as PGM (Papyri Graecae Magicae). The following are examples of several spells mentioned in the document Contents:\n\n1. The first spell (PMG 4.1390 – 1495) describes a ritual that requires leaving some of your leftover bread, dividing it into seven small pieces, and then going to the heroes, gladiators, and those who died violent deaths The place where people were killed. Spell a spell on the piece of bread and throw it out, then pick up some contaminated soil from the ritual site and throw it into the home of the woman you like, then go to sleep. The content of the spell is to pray to the goddess of fate (Moirai), The Roman goddesses of Fates and the forces of nature (Daemons) were invoked to help make wishes come true.\n\n2. The second incantation (PMG 4.1342 – 57) was a summoning spell performed by speaking a series of mystical names and Words to summon a being called Daemon to cause a person named Tereous (born from Apia) to be mentally and emotionally tortured until she came to the spellcaster Didymos (born from Taipiam).\n \n3. The third spell (PGM 4.1265 – 74) mentions a mysterious name called NEPHERIĒRI, which is related to Aphrodite, the goddess of love. In order to win the heart of a beautiful woman, one needs to keep it for three days of purity, offer frankincense and recite the name while offering the offering. Then, as you approach the lady, recite the name silently seven times in your mind and do this for seven consecutive days with the hope of success.\n\n4. The fourth mantra ( PGM 4.1496 – 1) describes an incantation recited while burning myrrh. This incantation is a prayer to myrrh in the hope that it will attract a person named [name ] woman (her mother's name was [name]), making her unable to sit, eat, look at or kiss other people, but instead had only the caster in her mind until she came to the caster.\n\nThese Spells reflect ancient people's beliefs in magic and supernatural powers, and the ways in which they attempted to influence the emotions and behavior of others through these spells."
+             },
+             "finish_reason": "stop"
+         }
+     ],
+     "usage": {
+         "prompt_tokens": 1,
+         "completion_tokens": 1,
+         "total_tokens": 2
+     },
+     "created": 100920
+}
+```
+
+### Image analysis
+
+Provide an accessible image URL or BASE64_URL to parse.
+
+This format is compatible with the [gpt-4-vision-preview](https://platform.openai.com/docs/guides/vision) API format. You can also use this format to transmit documents for parsing.
+
+**POST /v1/chat/completions**
+
+The header needs to set the Authorization header:
+
+```
+Authorization: Bearer [refresh_token]
+```
+
+Request data:
+```json
+{
+     // Fill in the model name as you like. If you do not want to output the retrieval process model name, please include silent_search.
+     "model": "kimi",
+     "messages": [
+         {
+             "role": "user",
+             "content": [
+                 {
+                     "type": "image_url",
+                     "image_url": {
+                         "url": "https://www.moonshot.cn/assets/logo/normal-dark.png"
+                     }
+                 },
+                 {
+                     "type": "text",
+                     "text": "What does the image describe?"
+                 }
+             ]
+         }
+     ],
+     // It is recommended to turn off online search to prevent interference in interpreting results.
+     "use_search": false
+}
+```
+
+Response data:
+```json
+{
+     "id": "cnn6l8ilnl92l36tu8ag",
+     "model": "kimi",
+     "object": "chat.completion",
+     "choices": [
+         {
+             "index": 0,
+             "message": {
+                 "role": "assistant",
+                 "content": "The image shows the words "Moonshot AI", which may be the logo or brand identity of Dark Side of the Moon Technology Co., Ltd. (Moonshot AI). Usually such images are used to represent a company or product and convey brand information .Since the image is in PNG format, it could be a logo with a transparent background, used on a website, app, or other visual material."
+             },
+             "finish_reason": "stop"
+         }
+     ],
+     "usage": {
+         "prompt_tokens": 1,
+         "completion_tokens": 1,
+         "total_tokens": 2
+     },
+     "created": 1710123627
+}
+
+```
+### refresh_token survival detection
+
+Check whether refresh_token is alive. If live is not true, otherwise it is false. Please do not call this interface frequently (less than 10 minutes).
+
+**POST /token/check**
+
+Request data:
+```json
+{
+     "token": "eyJhbGciOiJIUzUxMiIsInR5cCI6IkpXVCJ9..."
+}
+```
+
+Response data:
+```json
+{
+     "live": true
+}
+```
+
+## Precautions
+
+### Nginx anti-generation optimization
+
+If you are using Nginx reverse proxy kimi-free-api, please add the following configuration items to optimize the output effect of the stream and optimize the experience.
+
+```nginx
+# Turn off proxy buffering. When set to off, Nginx will immediately send client requests to the backend server and immediately send responses received from the backend server back to the client.
+proxy_buffering off;
+# Enable chunked transfer encoding. Chunked transfer encoding allows servers to send data in chunks for dynamically generated content without knowing the size of the content in advance.
+chunked_transfer_encoding on;
+# Turn on TCP_NOPUSH, which tells Nginx to send as much data as possible before sending the packet to the client. This is usually used in conjunction with sendfile to improve network efficiency.
+tcp_nopush on;
+# Turn on TCP_NODELAY, which tells Nginx not to delay sending data and to send small data packets immediately. In some cases, this can reduce network latency.
+tcp_nodelay on;
+#Set the timeout to keep the connection, here it is set to 120 seconds. If there is no further communication between client and server during this time, the connection will be closed.
+keepalive_timeout 120;
+```
+
+### Token statistics
+
+Since the inference side is not in kimi-free-api, the token cannot be counted and will be returned as a fixed number!!!!!
+
+## Star History
+
+[![Star History Chart](https://api.star-history.com/svg?repos=LLM-Red-Team/kimi-free-api&type=Date)](https://star-history.com/ #LLM-Red-Team/kimi-free-api&Date)

package.json

@@ -1,6 +1,6 @@
 {
   "name": "kimi-free-api",
-  "version": "0.0.11",
+  "version": "0.0.28",
   "description": "Kimi Free API Server",
   "type": "module",
   "main": "dist/index.js",

public/welcome.html

@@ -0,0 +1,10 @@
+<!DOCTYPE html>
+<html>
+    <head>
+        <meta charset="utf-8"/>
+        <title>🚀 服务已启动</title>
+    </head>
+    <body>
+        <p>kimi-free-api已启动！<br>请通过LobeChat / NextChat / Dify等客户端或OpenAI SDK接入！</p>
+    </body>
+</html>

src/api/consts/exceptions.ts

@@ -4,5 +4,6 @@ export default {
     API_REQUEST_FAILED: [-2001, '请求失败'],
     API_TOKEN_EXPIRES: [-2002, 'Token已失效'],
     API_FILE_URL_INVALID: [-2003, '远程文件URL非法'],
-    API_FILE_EXECEEDS_SIZE: [-2004, '远程文件超出大小']
+    API_FILE_EXECEEDS_SIZE: [-2004, '远程文件超出大小'],
+    API_CHAT_STREAM_PUSHING: [-2005, '已有对话流正在输出']
 }

src/api/controllers/chat.ts

@@ -14,6 +14,10 @@ import util from '@/lib/util.ts';
 const MODEL_NAME = 'kimi';
 // access_token有效期
 const ACCESS_TOKEN_EXPIRES = 300;
+// 最大重试次数
+const MAX_RETRY_COUNT = 3;
+// 重试延迟
+const RETRY_DELAY = 5000;
 // 伪装headers
 const FAKE_HEADERS = {
   'Accept': '*/*',
@@ -22,13 +26,13 @@ const FAKE_HEADERS = {
   'Origin': 'https://kimi.moonshot.cn',
   'Cookie': util.generateCookie(),
   'R-Timezone': 'Asia/Shanghai',
-  'Sec-Ch-Ua': '"Chromium";v="122", "Not(A:Brand";v="24", "Google Chrome";v="122"',
+  'Sec-Ch-Ua': '"Google Chrome";v="123", "Not:A-Brand";v="8", "Chromium";v="123"',
   'Sec-Ch-Ua-Mobile': '?0',
   'Sec-Ch-Ua-Platform': '"Windows"',
   'Sec-Fetch-Dest': 'empty',
   'Sec-Fetch-Mode': 'cors',
   'Sec-Fetch-Site': 'same-origin',
-  'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/122.0.0.0 Safari/537.36'
+  'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/123.0.0.0 Safari/537.36'
 };
 // 文件最大大小
 const FILE_MAX_SIZE = 100 * 1024 * 1024;
@@ -52,9 +56,21 @@ async function requestToken(refreshToken: string) {
   const result = await (async () => {
     const result = await axios.get('https://kimi.moonshot.cn/api/auth/token/refresh', {
       headers: {
+        Accept: '*/*',
+        'Accept-Encoding': 'gzip, deflate, br, zstd',
+        'Accept-Language': 'zh-CN,zh;q=0.9',
         Authorization: `Bearer ${refreshToken}`,
-        Referer: 'https://kimi.moonshot.cn',
-        ...FAKE_HEADERS
+        'Cache-Control': 'no-cache',
+        'Cookie': util.generateCookie(),
+        Pragma: 'no-cache',
+        Referer: 'https://kimi.moonshot.cn/',
+        'Sec-Ch-Ua': '"Google Chrome";v="123", "Not:A-Brand";v="8", "Chromium";v="123"',
+        'Sec-Ch-Ua-Mobile': '?0',
+        'Sec-Ch-Ua-Platform': '"Windows"',
+        'Sec-Fetch-Dest': 'empty',
+        'Sec-Fetch-Mode': 'cors',
+        'Sec-Fetch-Site': 'same-origin',
+        'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/122.0.0.0 Safari/537.36'
       },
       timeout: 15000,
       validateStatus: () => true
@@ -63,14 +79,16 @@ async function requestToken(refreshToken: string) {
       access_token,
       refresh_token
     } = checkResult(result, refreshToken);
+    const { id: userId } = await getUserInfo(access_token, refreshToken);
     return {
+      userId,
       accessToken: access_token,
       refreshToken: refresh_token,
       refreshTime: util.unixTimestamp() + ACCESS_TOKEN_EXPIRES
     }
   })()
     .then(result => {
-      if(accessTokenRequestQueueMap[refreshToken]) {
+      if (accessTokenRequestQueueMap[refreshToken]) {
         accessTokenRequestQueueMap[refreshToken].forEach(resolve => resolve(result));
         delete accessTokenRequestQueueMap[refreshToken];
       }
@@ -78,13 +96,13 @@ async function requestToken(refreshToken: string) {
       return result;
     })
     .catch(err => {
-      if(accessTokenRequestQueueMap[refreshToken]) {
+      if (accessTokenRequestQueueMap[refreshToken]) {
         accessTokenRequestQueueMap[refreshToken].forEach(resolve => resolve(err));
         delete accessTokenRequestQueueMap[refreshToken];
       }
       return err;
     });
-  if(_.isError(result))
+  if (_.isError(result))
     throw result;
   return result;
 }
@@ -96,7 +114,7 @@ async function requestToken(refreshToken: string) {
  * 
  * @param refreshToken 用于刷新access_token的refresh_token
  */
-async function acquireToken(refreshToken: string): Promise<string> {
+async function acquireToken(refreshToken: string): Promise<any> {
   let result = accessTokenMap.get(refreshToken);
   if (!result) {
     result = await requestToken(refreshToken);
@@ -106,7 +124,26 @@ async function acquireToken(refreshToken: string): Promise<string> {
     result = await requestToken(refreshToken);
     accessTokenMap.set(refreshToken, result);
   }
-  return result.accessToken;
+  return result;
+}
+
+/**
+ * 获取用户信息
+ * 
+ * @param refreshToken 用于刷新access_token的refresh_token
+ */
+async function getUserInfo(accessToken: string, refreshToken: string) {
+  const result = await axios.get('https://kimi.moonshot.cn/api/user', {
+    headers: {
+      Authorization: `Bearer ${accessToken}`,
+      Referer: 'https://kimi.moonshot.cn/',
+      'X-Traffic-Id': `7${util.generateRandomString({ length: 18, charset: 'numeric' })}`,
+      ...FAKE_HEADERS
+    },
+    timeout: 15000,
+    validateStatus: () => true
+  });
+  return checkResult(result, refreshToken);
 }
 
 /**
@@ -117,14 +154,18 @@ async function acquireToken(refreshToken: string): Promise<string> {
  * @param refreshToken 用于刷新access_token的refresh_token
  */
 async function createConversation(name: string, refreshToken: string) {
-  const token = await acquireToken(refreshToken);
+  const {
+    accessToken,
+    userId
+  } = await acquireToken(refreshToken);
   const result = await axios.post('https://kimi.moonshot.cn/api/chat', {
-    name,
-    is_example: false
+    is_example: false,
+    name
   }, {
     headers: {
-      Authorization: `Bearer ${token}`,
-      Referer: 'https://kimi.moonshot.cn',
+      Authorization: `Bearer ${accessToken}`,
+      Referer: 'https://kimi.moonshot.cn/',
+      'X-Traffic-Id': userId,
       ...FAKE_HEADERS
     },
     timeout: 15000,
@@ -144,11 +185,43 @@ async function createConversation(name: string, refreshToken: string) {
  * @param refreshToken 用于刷新access_token的refresh_token
  */
 async function removeConversation(convId: string, refreshToken: string) {
-  const token = await acquireToken(refreshToken);
+  const {
+    accessToken,
+    userId
+  } = await acquireToken(refreshToken);
   const result = await axios.delete(`https://kimi.moonshot.cn/api/chat/${convId}`, {
     headers: {
-      Authorization: `Bearer ${token}`,
+      Authorization: `Bearer ${accessToken}`,
       Referer: `https://kimi.moonshot.cn/chat/${convId}`,
+      'X-Traffic-Id': userId,
+      ...FAKE_HEADERS
+    },
+    timeout: 15000,
+    validateStatus: () => true
+  });
+  checkResult(result, refreshToken);
+}
+
+/**
+ * prompt片段提交
+ * 
+ * @param query prompt
+ * @param refreshToken 用于刷新access_token的refresh_token
+ */
+async function promptSnippetSubmit(query: string, refreshToken: string) {
+  const {
+    accessToken,
+    userId
+  } = await acquireToken(refreshToken);
+  const result = await axios.post('https://kimi.moonshot.cn/api/prompt-snippet/instance', {
+    "offset": 0,
+    "size": 10,
+    "query": query.replace('user:', '').replace('assistant:', '')
+  }, {
+    headers: {
+      Authorization: `Bearer ${accessToken}`,
+      Referer: 'https://kimi.moonshot.cn/',
+      'X-Traffic-Id': userId,
       ...FAKE_HEADERS
     },
     timeout: 15000,
@@ -160,92 +233,180 @@ async function removeConversation(convId: string, refreshToken: string) {
 /**
  * 同步对话补全
  * 
+ * @param model 模型名称
  * @param messages 参考gpt系列消息格式，多轮对话请完整提供上下文
  * @param refreshToken 用于刷新access_token的refresh_token
  * @param useSearch 是否开启联网搜索
+ * @param retryCount 重试次数
  */
-async function createCompletion(messages: any[], refreshToken: string, useSearch = true) {
-  logger.info(messages);
+async function createCompletion(model = MODEL_NAME, messages: any[], refreshToken: string, useSearch = true, retryCount = 0) {
+  return (async () => {
+    logger.info(messages);
 
-  // 提取引用文件URL并上传kimi获得引用的文件ID列表
-  const refFileUrls = extractRefFileUrls(messages);
-  const refs = refFileUrls.length ? await Promise.all(refFileUrls.map(fileUrl => uploadFile(fileUrl, refreshToken))) : [];
+    // 提取引用文件URL并上传kimi获得引用的文件ID列表
+    const refFileUrls = extractRefFileUrls(messages);
+    const refs = refFileUrls.length ? await Promise.all(refFileUrls.map(fileUrl => uploadFile(fileUrl, refreshToken))) : [];
 
-  // 创建会话
-  const convId = await createConversation(`cmpl-${util.uuid(false)}`, refreshToken);
+    // 伪装调用获取用户信息
+    fakeRequest(refreshToken)
+      .catch(err => logger.error(err));
 
-  // 请求流
-  const token = await acquireToken(refreshToken);
-  const result = await axios.post(`https://kimi.moonshot.cn/api/chat/${convId}/completion/stream`, {
-    messages: messagesPrepare(messages),
-    refs,
-    use_search: useSearch
-  }, {
-    headers: {
-      Authorization: `Bearer ${token}`,
-      Referer: `https://kimi.moonshot.cn/chat/${convId}`,
-      ...FAKE_HEADERS
-    },
-    // 120秒超时
-    timeout: 120000,
-    validateStatus: () => true,
-    responseType: 'stream'
-  });
+    // 创建会话
+    const convId = await createConversation("未命名会话", refreshToken);
 
-  const streamStartTime = util.timestamp();
-  // 接收流为输出文本
-  const answer = await receiveStream(convId, result.data);
-  logger.success(`Stream has completed transfer ${util.timestamp() - streamStartTime}ms`);
+    // 请求流
+    const {
+      accessToken,
+      userId
+    } = await acquireToken(refreshToken);
+    const sendMessages = messagesPrepare(messages);
+    const result = await axios.post(`https://kimi.moonshot.cn/api/chat/${convId}/completion/stream`, {
+      messages: sendMessages,
+      refs,
+      use_search: useSearch
+    }, {
+      headers: {
+        Authorization: `Bearer ${accessToken}`,
+        Referer: `https://kimi.moonshot.cn/chat/${convId}`,
+        'X-Traffic-Id': userId,
+        ...FAKE_HEADERS
+      },
+      // 120秒超时
+      timeout: 120000,
+      validateStatus: () => true,
+      responseType: 'stream'
+    });
 
-  // 异步移除会话，如果消息不合规，此操作可能会抛出数据库错误异常，请忽略
-  removeConversation(convId, refreshToken)
-    .catch(err => console.error(err));
+    const streamStartTime = util.timestamp();
+    // 接收流为输出文本
+    const answer = await receiveStream(model, convId, result.data);
+    logger.success(`Stream has completed transfer ${util.timestamp() - streamStartTime}ms`);
 
-  return answer;
+    // 异步移除会话，如果消息不合规，此操作可能会抛出数据库错误异常，请忽略
+    removeConversation(convId, refreshToken)
+      .catch(err => console.error(err));
+    promptSnippetSubmit(sendMessages[0].content, refreshToken)
+      .catch(err => console.error(err));
+
+    return answer;
+  })()
+    .catch(err => {
+      if (retryCount < MAX_RETRY_COUNT) {
+        logger.error(`Stream response error: ${err.message}`);
+        logger.warn(`Try again after ${RETRY_DELAY / 1000}s...`);
+        return (async () => {
+          await new Promise(resolve => setTimeout(resolve, RETRY_DELAY));
+          return createCompletion(model, messages, refreshToken, useSearch, retryCount + 1);
+        })();
+      }
+      throw err;
+    });
 }
 
 /**
  * 流式对话补全
  * 
+ * @param model 模型名称
  * @param messages 参考gpt系列消息格式，多轮对话请完整提供上下文
  * @param refreshToken 用于刷新access_token的refresh_token
  * @param useSearch 是否开启联网搜索
+ * @param retryCount 重试次数
  */
-async function createCompletionStream(messages: any[], refreshToken: string, useSearch = true) {
-  logger.info(messages);
+async function createCompletionStream(model = MODEL_NAME, messages: any[], refreshToken: string, useSearch = true, retryCount = 0) {
+  return (async () => {
+    logger.info(messages);
 
-  // 提取引用文件URL并上传kimi获得引用的文件ID列表
-  const refFileUrls = extractRefFileUrls(messages);
-  const refs = refFileUrls.length ? await Promise.all(refFileUrls.map(fileUrl => uploadFile(fileUrl, refreshToken))) : [];
+    // 提取引用文件URL并上传kimi获得引用的文件ID列表
+    const refFileUrls = extractRefFileUrls(messages);
+    const refs = refFileUrls.length ? await Promise.all(refFileUrls.map(fileUrl => uploadFile(fileUrl, refreshToken))) : [];
 
-  // 创建会话
-  const convId = await createConversation(`cmpl-${util.uuid(false)}`, refreshToken);
+    // 伪装调用获取用户信息
+    fakeRequest(refreshToken)
+      .catch(err => logger.error(err));
 
-  // 请求流
-  const token = await acquireToken(refreshToken);
-  const result = await axios.post(`https://kimi.moonshot.cn/api/chat/${convId}/completion/stream`, {
-    messages: messagesPrepare(messages),
-    refs,
-    use_search: useSearch
-  }, {
-    // 120秒超时
-    timeout: 120000,
+    // 创建会话
+    const convId = await createConversation("未命名会话", refreshToken);
+
+    // 请求流
+    const {
+      accessToken,
+      userId
+    } = await acquireToken(refreshToken);
+    const sendMessages = messagesPrepare(messages);
+    const result = await axios.post(`https://kimi.moonshot.cn/api/chat/${convId}/completion/stream`, {
+      messages: sendMessages,
+      refs,
+      use_search: useSearch
+    }, {
+      // 120秒超时
+      timeout: 120000,
+      headers: {
+        Authorization: `Bearer ${accessToken}`,
+        Referer: `https://kimi.moonshot.cn/chat/${convId}`,
+        'X-Traffic-Id': userId,
+        ...FAKE_HEADERS
+      },
+      validateStatus: () => true,
+      responseType: 'stream'
+    });
+    const streamStartTime = util.timestamp();
+    // 创建转换流将消息格式转换为gpt兼容格式
+    return createTransStream(model, convId, result.data, () => {
+      logger.success(`Stream has completed transfer ${util.timestamp() - streamStartTime}ms`);
+      // 流传输结束后异步移除会话，如果消息不合规，此操作可能会抛出数据库错误异常，请忽略
+      removeConversation(convId, refreshToken)
+        .catch(err => console.error(err));
+      promptSnippetSubmit(sendMessages[0].content, refreshToken)
+        .catch(err => console.error(err));
+    });
+  })()
+    .catch(err => {
+      if (retryCount < MAX_RETRY_COUNT) {
+        logger.error(`Stream response error: ${err.message}`);
+        logger.warn(`Try again after ${RETRY_DELAY / 1000}s...`);
+        return (async () => {
+          await new Promise(resolve => setTimeout(resolve, RETRY_DELAY));
+          return createCompletionStream(model, messages, refreshToken, useSearch, retryCount + 1);
+        })();
+      }
+      throw err;
+    });
+}
+
+/**
+ * 调用一些接口伪装访问
+ * 
+ * 随机挑一个
+ * 
+ * @param refreshToken 用于刷新access_token的refresh_token
+ */
+async function fakeRequest(refreshToken: string) {
+  const {
+    accessToken,
+    userId
+  } = await acquireToken(refreshToken);
+  const options = {
     headers: {
-      Authorization: `Bearer ${token}`,
-      Referer: `https://kimi.moonshot.cn/chat/${convId}`,
+      Authorization: `Bearer ${accessToken}`,
+      Referer: `https://kimi.moonshot.cn/`,
+      'X-Traffic-Id': userId,
       ...FAKE_HEADERS
-    },
-    validateStatus: () => true,
-    responseType: 'stream'
-  });
-  const streamStartTime = util.timestamp();
-  // 创建转换流将消息格式转换为gpt兼容格式
-  return createTransStream(convId, result.data, () => {
-    logger.success(`Stream has completed transfer ${util.timestamp() - streamStartTime}ms`);
-    // 流传输结束后异步移除会话，如果消息不合规，此操作可能会抛出数据库错误异常，请忽略
-    removeConversation(convId, refreshToken)
-      .catch(err => console.error(err));
-  });
+    }
+  };
+  await [
+    () => axios.get('https://kimi.moonshot.cn/api/user', options),
+    () => axios.get('https://kimi.moonshot.cn/api/chat_1m/user/status', options),
+    () => axios.post('https://kimi.moonshot.cn/api/chat/list', {
+      offset: 0,
+      size: 50
+    }, options),
+    () => axios.post('https://kimi.moonshot.cn/api/show_case/list', {
+      offset: 0,
+      size: 4,
+      enable_cache: true,
+      order: "asc"
+    }, options)
+  ][Math.floor(Math.random() * 4)]();
 }
 
 /**
@@ -254,21 +415,27 @@ async function createCompletionStream(messages: any[], refreshToken: string, use
  * @param messages 参考gpt系列消息格式，多轮对话请完整提供上下文
  */
 function extractRefFileUrls(messages: any[]) {
-  return messages.reduce((urls, message) => {
-    if (_.isArray(message.content)) {
-      message.content.forEach(v => {
-        if (!_.isObject(v) || !['file', 'image_url'].includes(v['type']))
-          return;
-        // kimi-free-api支持格式
-        if (v['type'] == 'file' && _.isObject(v['file_url']) && _.isString(v['file_url']['url']))
-          urls.push(v['file_url']['url']);
-        // 兼容gpt-4-vision-preview API格式
-        else if (v['type'] == 'image_url' && _.isObject(v['image_url']) && _.isString(v['image_url']['url']))
-          urls.push(v['image_url']['url']);
-      });
-    }
+  const urls = [];
+  // 如果没有消息，则返回[]
+  if (!messages.length) {
     return urls;
-  }, []);
+  }
+  // 只获取最新的消息
+  const lastMessage = messages[messages.length - 1];
+  if (_.isArray(lastMessage.content)) {
+    lastMessage.content.forEach(v => {
+      if (!_.isObject(v) || !['file', 'image_url'].includes(v['type']))
+        return;
+      // kimi-free-api支持格式
+      if (v['type'] == 'file' && _.isObject(v['file_url']) && _.isString(v['file_url']['url']))
+        urls.push(v['file_url']['url']);
+      // 兼容gpt-4-vision-preview API格式
+      else if (v['type'] == 'image_url' && _.isObject(v['image_url']) && _.isString(v['image_url']['url']))
+        urls.push(v['image_url']['url']);
+    });
+  }
+  logger.info("本次请求上传：" + urls.length + "个文件");
+  return urls;
 }
 
 /**
@@ -282,17 +449,39 @@ function extractRefFileUrls(messages: any[]) {
  * @param messages 参考gpt系列消息格式，多轮对话请完整提供上下文
  */
 function messagesPrepare(messages: any[]) {
+  // 注入消息提升注意力
+  let latestMessage = messages[messages.length - 1];
+  let hasFileOrImage = Array.isArray(latestMessage.content)
+    && latestMessage.content.some(v => (typeof v === 'object' && ['file', 'image_url'].includes(v['type'])));
+  // 第二轮开始注入system prompt
+  if (messages.length > 2) {
+    if (hasFileOrImage) {
+      let newFileMessage = {
+        "content": "关注用户最新发送文件和消息",
+        "role": "system"
+      };
+      messages.splice(messages.length - 1, 0, newFileMessage);
+      logger.info("注入提升尾部文件注意力system prompt");
+    } else {
+      let newTextMessage = {
+        "content": "关注用户最新的消息",
+        "role": "system"
+      };
+      messages.splice(messages.length - 1, 0, newTextMessage);
+      logger.info("注入提升尾部消息注意力system prompt");
+    }
+  }
+
   const content = messages.reduce((content, message) => {
-    if (_.isArray(message.content)) {
+    if (Array.isArray(message.content)) {
       return message.content.reduce((_content, v) => {
-        if (!_.isObject(v) || v['type'] != 'text')
-          return _content;
-        return _content + (v['text'] || '');
+        if (!_.isObject(v) || v['type'] != 'text') return _content;
+        return _content + `${message.role || "user"}:${v["text"] || ""}\n`;
       }, content);
     }
-    return content += `${message.role || 'user'}:${wrapUrlsToTags(message.content)}\n`;
+    return content += `${message.role || "user"}:${message.role == 'user' ? wrapUrlsToTags(message.content) : message.content}\n`;
   }, '');
-
+  logger.info("\n对话合并：\n" + content);
   return [
     { role: 'user', content }
   ]
@@ -316,15 +505,19 @@ function wrapUrlsToTags(content: string) {
  * @param refreshToken 用于刷新access_token的refresh_token
  */
 async function preSignUrl(filename: string, refreshToken: string) {
-  const token = await acquireToken(refreshToken);
+  const {
+    accessToken,
+    userId
+  } = await acquireToken(refreshToken);
   const result = await axios.post('https://kimi.moonshot.cn/api/pre-sign-url', {
     action: 'file',
     name: filename
   }, {
     timeout: 15000,
     headers: {
-      Authorization: `Bearer ${token}`,
-      Referer: `https://kimi.moonshot.cn`,
+      Authorization: `Bearer ${accessToken}`,
+      Referer: `https://kimi.moonshot.cn/`,
+      'X-Traffic-Id': userId,
       ...FAKE_HEADERS
     },
     validateStatus: () => true
@@ -393,19 +586,23 @@ async function uploadFile(fileUrl: string, refreshToken: string) {
   // 获取文件的MIME类型
   mimeType = mimeType || mime.getType(filename);
   // 上传文件到目标OSS
-  const token = await acquireToken(refreshToken);
+  const {
+    accessToken,
+    userId
+  } = await acquireToken(refreshToken);
   let result = await axios.request({
     method: 'PUT',
     url: uploadUrl,
     data: fileData,
     // 100M限制
     maxBodyLength: FILE_MAX_SIZE,
-    // 60秒超时
-    timeout: 60000,
+    // 120秒超时
+    timeout: 120000,
     headers: {
       'Content-Type': mimeType,
-      Authorization: `Bearer ${token}`,
-      Referer: `https://kimi.moonshot.cn`,
+      Authorization: `Bearer ${accessToken}`,
+      Referer: `https://kimi.moonshot.cn/`,
+      'X-Traffic-Id': userId,
       ...FAKE_HEADERS
     },
     validateStatus: () => true
@@ -420,8 +617,9 @@ async function uploadFile(fileUrl: string, refreshToken: string) {
     timeout: 15000
   }, {
     headers: {
-      Authorization: `Bearer ${token}`,
-      Referer: `https://kimi.moonshot.cn`,
+      Authorization: `Bearer ${accessToken}`,
+      Referer: `https://kimi.moonshot.cn/`,
+      'X-Traffic-Id': userId,
       ...FAKE_HEADERS
     }
   });
@@ -433,8 +631,9 @@ async function uploadFile(fileUrl: string, refreshToken: string) {
     timeout: 120000
   }, {
     headers: {
-      Authorization: `Bearer ${token}`,
-      Referer: `https://kimi.moonshot.cn`,
+      Authorization: `Bearer ${accessToken}`,
+      Referer: `https://kimi.moonshot.cn/`,
+      'X-Traffic-Id': userId,
       ...FAKE_HEADERS
     }
   });
@@ -461,29 +660,33 @@ function checkResult(result: AxiosResponse, refreshToken: string) {
     return result.data;
   if (error_type == 'auth.token.invalid')
     accessTokenMap.delete(refreshToken);
+  if (error_type == 'chat.user_stream_pushing')
+    throw new APIException(EX.API_CHAT_STREAM_PUSHING);
   throw new APIException(EX.API_REQUEST_FAILED, `[请求kimi失败]: ${message}`);
 }
 
 /**
  * 从流接收完整的消息内容
  * 
+ * @param model 模型名称
  * @param convId 会话ID
  * @param stream 消息流
  */
-async function receiveStream(convId: string, stream: any) {
+async function receiveStream(model: string, convId: string, stream: any) {
   return new Promise((resolve, reject) => {
-    // 第一条消息初始化
+    // 消息初始化
     const data = {
       id: convId,
-      model: MODEL_NAME,
+      model,
       object: 'chat.completion',
       choices: [
         { index: 0, message: { role: 'assistant', content: '' }, finish_reason: 'stop' }
       ],
-      usage: { prompt_tokens: 0, completion_tokens: 0, total_tokens: 0 },
+      usage: { prompt_tokens: 1, completion_tokens: 1, total_tokens: 2 },
       created: util.unixTimestamp()
     };
     let refContent = '';
+    const silentSearch = model.indexOf('silent_search') != -1;
     const parser = createParser(event => {
       try {
         if (event.type !== "event") return;
@@ -492,8 +695,9 @@ async function receiveStream(convId: string, stream: any) {
         if (_.isError(result))
           throw new Error(`Stream response invalid: ${event.data}`);
         // 处理消息
-        if (result.event == 'cmpl') {
-          data.choices[0].message.content += result.text;
+        if (result.event == 'cmpl' && result.text) {
+          const exceptCharIndex = result.text.indexOf("<22>");
+          data.choices[0].message.content += result.text.substring(0, exceptCharIndex == -1 ? result.text.length : exceptCharIndex);
         }
         // 处理结束或错误
         else if (result.event == 'all_done' || result.event == 'error') {
@@ -502,8 +706,8 @@ async function receiveStream(convId: string, stream: any) {
           resolve(data);
         }
         // 处理联网搜索
-        else if (result.event == 'search_plus' && result.msg && result.msg.type == 'get_res')
-          refContent += `${result.msg.title}(${result.msg.url})\n`;
+        else if (!silentSearch && result.event == 'search_plus' && result.msg && result.msg.type == 'get_res')
+          refContent += `${result.msg.title} - ${result.msg.url}\n`;
         // else
         //   logger.warn(result.event, result);
       }
@@ -524,19 +728,21 @@ async function receiveStream(convId: string, stream: any) {
  * 
  * 将流格式转换为gpt兼容流格式
  * 
+ * @param model 模型名称
  * @param convId 会话ID
  * @param stream 消息流
  * @param endCallback 传输结束回调
  */
-function createTransStream(convId: string, stream: any, endCallback?: Function) {
+function createTransStream(model: string, convId: string, stream: any, endCallback?: Function) {
   // 消息创建时间
   const created = util.unixTimestamp();
   // 创建转换流
   const transStream = new PassThrough();
   let searchFlag = false;
+  const silentSearch = model.indexOf('silent_search') != -1;
   !transStream.closed && transStream.write(`data: ${JSON.stringify({
     id: convId,
-    model: MODEL_NAME,
+    model,
     object: 'chat.completion.chunk',
     choices: [
       { index: 0, delta: { role: 'assistant', content: '' }, finish_reason: null }
@@ -552,12 +758,14 @@ function createTransStream(convId: string, stream: any, endCallback?: Function)
         throw new Error(`Stream response invalid: ${event.data}`);
       // 处理消息
       if (result.event == 'cmpl') {
+        const exceptCharIndex = result.text.indexOf("<22>");
+        const chunk = result.text.substring(0, exceptCharIndex == -1 ? result.text.length : exceptCharIndex);
         const data = `data: ${JSON.stringify({
           id: convId,
-          model: MODEL_NAME,
+          model,
           object: 'chat.completion.chunk',
           choices: [
-            { index: 0, delta: { content: (searchFlag ? '\n' : '') + result.text }, finish_reason: null }
+            { index: 0, delta: { content: (searchFlag ? '\n' : '') + chunk }, finish_reason: null }
           ],
           created
         })}\n\n`;
@@ -569,7 +777,7 @@ function createTransStream(convId: string, stream: any, endCallback?: Function)
       else if (result.event == 'all_done' || result.event == 'error') {
         const data = `data: ${JSON.stringify({
           id: convId,
-          model: MODEL_NAME,
+          model,
           object: 'chat.completion.chunk',
           choices: [
             {
@@ -578,7 +786,7 @@ function createTransStream(convId: string, stream: any, endCallback?: Function)
               } : {}, finish_reason: 'stop'
             }
           ],
-          usage: { prompt_tokens: 0, completion_tokens: 0, total_tokens: 0 },
+          usage: { prompt_tokens: 1, completion_tokens: 1, total_tokens: 2 },
           created
         })}\n\n`;
         !transStream.closed && transStream.write(data);
@@ -586,17 +794,17 @@ function createTransStream(convId: string, stream: any, endCallback?: Function)
         endCallback && endCallback();
       }
       // 处理联网搜索
-      else if (result.event == 'search_plus' && result.msg && result.msg.type == 'get_res') {
+      else if (!silentSearch && result.event == 'search_plus' && result.msg && result.msg.type == 'get_res') {
         if (!searchFlag)
           searchFlag = true;
         const data = `data: ${JSON.stringify({
           id: convId,
-          model: MODEL_NAME,
+          model,
           object: 'chat.completion.chunk',
           choices: [
             {
               index: 0, delta: {
-                content: `检索 ${result.msg.title}(${result.msg.url}) ...\n`
+                content: `检索 ${result.msg.title} - ${result.msg.url} ...\n`
               }, finish_reason: null
             }
           ],
@@ -628,9 +836,35 @@ function tokenSplit(authorization: string) {
   return authorization.replace('Bearer ', '').split(',');
 }
 
+/**
+ * 获取Token存活状态
+ */
+async function getTokenLiveStatus(refreshToken: string) {
+  const result = await axios.get('https://kimi.moonshot.cn/api/auth/token/refresh', {
+    headers: {
+      Authorization: `Bearer ${refreshToken}`,
+      Referer: 'https://kimi.moonshot.cn/',
+      ...FAKE_HEADERS
+    },
+    timeout: 15000,
+    validateStatus: () => true
+  });
+  try {
+    const {
+      access_token,
+      refresh_token
+    } = checkResult(result, refreshToken);
+    return !!(access_token && refresh_token)
+  }
+  catch (err) {
+    return false;
+  }
+}
+
 export default {
   createConversation,
   createCompletion,
   createCompletionStream,
+  getTokenLiveStatus,
   tokenSplit
 };

src/api/routes/chat.ts

@@ -19,15 +19,16 @@ export default {
             const tokens = chat.tokenSplit(request.headers.authorization);
             // 随机挑选一个refresh_token
             const token = _.sample(tokens);
+            const model = request.body.model;
             const messages =  request.body.messages;
             if (request.body.stream) {
-                const stream = await chat.createCompletionStream(request.body.messages, token, request.body.use_search);
+                const stream = await chat.createCompletionStream(model, messages, token, request.body.use_search);
                 return new Response(stream, {
                     type: "text/event-stream"
                 });
             }
             else
-                return await chat.createCompletion(messages, token, request.body.use_search);
+                return await chat.createCompletion(model, messages, token, request.body.use_search);
         }
 
     }

src/api/routes/index.ts

@@ -1,5 +1,25 @@
+import fs from 'fs-extra';
+
+import Response from '@/lib/response/Response.ts';
 import chat from "./chat.ts";
+import ping from "./ping.ts";
+import token from './token.ts';
 
 export default [
-    chat
+    {
+        get: {
+            '/': async () => {
+                const content = await fs.readFile('public/welcome.html');
+                return new Response(content, {
+                    type: 'html',
+                    headers: {
+                        Expires: '-1'
+                    }
+                });
+            }
+        }
+    },
+    chat,
+    ping,
+    token
 ];

src/api/routes/ping.ts

@@ -0,0 +1,6 @@
+export default {
+  prefix: '/ping',
+  get: {
+    '': async () => "pong"
+  }
+}

src/api/routes/token.ts

@@ -0,0 +1,25 @@
+import _ from 'lodash';
+
+import Request from '@/lib/request/Request.ts';
+import Response from '@/lib/response/Response.ts';
+import chat from '@/api/controllers/chat.ts';
+import logger from '@/lib/logger.ts';
+
+export default {
+
+    prefix: '/token',
+
+    post: {
+
+        '/check': async (request: Request) => {
+            request
+                .validate('body.token', _.isString)
+            const live = await chat.getTokenLiveStatus(request.body.token);
+            return {
+                live
+            }
+        }
+
+    }
+
+}

src/lib/configs/system-config.ts

@@ -44,12 +44,12 @@ export class SystemConfig {
         this.requestBody = Object.assign(requestBody || {}, {
             enableTypes: ['json', 'form', 'text', 'xml'],
             encoding: 'utf-8',
-            formLimit: '10mb',
-            jsonLimit: '10mb',
-            textLimit: '10mb',
-            xmlLimit: '10mb',
+            formLimit: '100mb',
+            jsonLimit: '100mb',
+            textLimit: '100mb',
+            xmlLimit: '100mb',
             formidable: {
-                maxFileSize: '30mb'
+                maxFileSize: '100mb'
             },
             multipart: true,
             parsedMethods: ['POST', 'PUT', 'PATCH']

src/lib/exceptions/Exception.ts

@@ -29,6 +29,11 @@ export default class Exception extends Error {
         this.errmsg = _errmsg || errmsg;
     }
 
+    compare(exception: (string | number)[]) {
+        const [errcode] = exception as [number, string];
+        return this.errcode == errcode;
+    }
+
     setHTTPStatusCode(value: number) {
         this.httpStatusCode = value;
         return this;

src/lib/logger.ts

@@ -9,13 +9,15 @@ import { format as dateFormat } from 'date-fns';
 import config from './config.ts';
 import util from './util.ts';
 
+const isVercelEnv = process.env.VERCEL;
+
 class LogWriter {
 
     #buffers = [];
 
     constructor() {
-        fs.ensureDirSync(config.system.logDirPath);
-        this.work();
+        !isVercelEnv && fs.ensureDirSync(config.system.logDirPath);
+        !isVercelEnv && this.work();
     }
 
     push(content) {
@@ -24,16 +26,16 @@ class LogWriter {
     }
 
     writeSync(buffer) {
-        fs.appendFileSync(path.join(config.system.logDirPath, `/${util.getDateString()}.log`), buffer);
+        !isVercelEnv && fs.appendFileSync(path.join(config.system.logDirPath, `/${util.getDateString()}.log`), buffer);
     }
 
     async write(buffer) {
-        await fs.appendFile(path.join(config.system.logDirPath, `/${util.getDateString()}.log`), buffer);
+        !isVercelEnv && await fs.appendFile(path.join(config.system.logDirPath, `/${util.getDateString()}.log`), buffer);
     }
 
     flush() {
         if(!this.#buffers.length) return;
-        fs.appendFileSync(path.join(config.system.logDirPath, `/${util.getDateString()}.log`), Buffer.concat(this.#buffers));
+        !isVercelEnv && fs.appendFileSync(path.join(config.system.logDirPath, `/${util.getDateString()}.log`), Buffer.concat(this.#buffers));
     }
 
     work() {

src/lib/response/FailureBody.ts

@@ -15,7 +15,7 @@ export default class FailureBody extends Body {
         else if(error instanceof APIException || error instanceof Exception)
             ({ errcode, errmsg, data, httpStatusCode } = error);
         else if(_.isError(error))
-            error = new Exception(EX.SYSTEM_ERROR, error.message);
+            ({ errcode, errmsg, data, httpStatusCode } = new Exception(EX.SYSTEM_ERROR, error.message));
         super({
             code: errcode || -1,
             message: errmsg || 'Internal error',

src/lib/server.ts

@@ -73,7 +73,11 @@ class Server {
         this.app.use((ctx: any) => {
             const request = new Request(ctx);
             logger.debug(`-> ${ctx.request.method} ${ctx.request.url} request is not supported - ${request.remoteIP || "unknown"}`);
-            const failureBody = new FailureBody(new Exception(EX.SYSTEM_NOT_ROUTE_MATCHING, "Request is not supported"));
+            // const failureBody = new FailureBody(new Exception(EX.SYSTEM_NOT_ROUTE_MATCHING, "Request is not supported"));
+            // const response = new Response(failureBody);
+            const message = `[请求有误]: 正确请求为 POST -> /v1/chat/completions，当前请求为 ${ctx.request.method} -> ${ctx.request.url} 请纠正`;
+            logger.warn(message);
+            const failureBody = new FailureBody(new Error(message));
             const response = new Response(failureBody);
             response.injectTo(ctx);
             if(config.system.requestLog)

src/lib/util.ts

@@ -50,13 +50,10 @@ const util = {
     generateCookie() {
         const timestamp = util.unixTimestamp();
         const items = [
-            `Hm_lvt_4532beacc312859e0aa3e4a80566b706=${timestamp - Math.round(Math.random() * 2592000)}`,
             `Hm_lvt_358cae4815e85d48f7e8ab7f3680a74b=${timestamp - Math.round(Math.random() * 2592000)}`,
             `_ga=GA1.1.${util.generateRandomString({ length: 10, charset: 'numeric' })}.${timestamp - Math.round(Math.random() * 2592000)}`,
-            `_ga_31QPQG2YYD=GS1.1.${timestamp - Math.round(Math.random() * 2592000)}.17.0.${timestamp - Math.round(Math.random() * 2592000)}.0.0.0`,
-            `Hm_lpvt_4532beacc312859e0aa3e4a80566b706=${timestamp - Math.round(Math.random() * 2592000)}`,
-            `Hm_lpvt_358cae4815e85d48f7e8ab7f3680a74b=${timestamp - Math.round(Math.random() * 2592000)}`,
-            `_ga_YXD8W70SZP=GS1.1.${timestamp - Math.round(Math.random() * 2592000)}.35.1.${timestamp - Math.round(Math.random() * 2592000)}.0.0.0`
+            `_ga_YXD8W70SZP=GS1.1.${timestamp - Math.round(Math.random() * 2592000)}.1.1.${timestamp - Math.round(Math.random() * 2592000)}.0.0.0`,
+            `Hm_lpvt_358cae4815e85d48f7e8ab7f3680a74b=${timestamp - Math.round(Math.random() * 2592000)}`
         ];
         return items.join('; ');
     },

vercel.json

@@ -0,0 +1,27 @@
+{
+    "builds": [
+        {
+            "src": "./dist/*.html",
+            "use": "@vercel/static"
+        },
+        {
+            "src": "./dist/index.js",
+            "use": "@vercel/node"
+        }
+    ],
+    "routes": [
+        {
+            "src": "/",
+            "dest": "/dist/welcome.html"
+        },
+        {
+            "src": "/(.*)",
+            "dest": "/dist",
+            "headers": {
+                "Access-Control-Allow-Credentials": "true",
+                "Access-Control-Allow-Methods": "GET,OPTIONS,PATCH,DELETE,POST,PUT",
+                "Access-Control-Allow-Headers": "X-CSRF-Token, X-Requested-With, Accept, Accept-Version, Content-Length, Content-MD5, Content-Type, Date, X-Api-Version, Content-Type, Authorization"
+            }
+        }
+    ]
+}