x

Dockerfile

@@ -0,0 +1,11 @@
+FROM node:lts-alpine
+
+WORKDIR /app
+
+COPY . .
+
+RUN npm i
+
+EXPOSE 3000
+
+CMD ["npm", "start"]

README.md

@@ -1,11 +1,68 @@
----
-title: Hi
-emoji: 🏆
-colorFrom: green
-colorTo: indigo
-sdk: docker
-pinned: false
-short_description: x
----
-
-Check out the configuration reference at https://huggingface.co/docs/hub/spaces-config-reference
+## 安装与运行
+
+### 使用 Docker 运行
+
+1. 使用 Docker 命令：
+
+   ```bash
+   docker run -d -p 8999:8999 --name hixai2api rfym21/hixai2api:latest
+   ```
+
+2. 使用 docker-compose 运行服务：
+
+   ```bash
+   curl -o docker-compose.yml https://raw.githubusercontent.com/Rfym21/Hixai2API/refs/heads/main/docker-compose.yml
+   docker compose pull && docker compose up -d
+   ```
+
+### 本地运行
+
+1. 下载仓库文件：
+
+   ```bash
+   git clone https://github.com/Rfym21/Hixai2API
+   cd Hixai2API
+   ```
+
+2. 安装依赖：
+
+   ```bash
+   npm install
+   ```
+
+3. 运行服务：
+
+   ```bash
+   npm start
+   ```
+
+## 获取 Token
+![2025-02-23_18-29-17.png](https://s2.loli.net/2025/02/23/my1SVoaqWvbTuRA.png)
+
+## API 端点
+
+### 获取模型列表
+
+- **请求方式**: `GET`
+- **URL**: `/v1/models`
+
+### 聊天完成
+
+- **请求方式**: `POST`
+- **URL**: `/v1/chat/completions`
+- **Headers**:
+  - `Authorization`: 必须提供有效的授权令牌。
+- **请求体**:
+
+  ```json
+  {
+    "model": "模型名称",
+    "messages": [
+      {
+        "role": "user",
+        "content": "用户消息"
+      }
+    ],
+    "stream": false
+  }
+  ```

docker-compose.yml

@@ -0,0 +1,7 @@
+services:
+  hixai2api:
+    container_name: hixai2api
+    image: rfym21/hixai2api:latest
+    restart: always
+    ports:
+      - "8999:8999"

package.json

@@ -0,0 +1,20 @@
+{
+  "name": "qwen2api",
+  "version": "1.0.0",
+  "main": "index.js",
+  "scripts": {
+    "start": "node src/server.js",
+    "dev": "nodemon src/server.js"
+  },
+  "keywords": [],
+  "author": "",
+  "license": "ISC",
+  "description": "",
+  "dependencies": {
+    "axios": "^1.7.9",
+    "body-parser": "^1.20.3",
+    "dotenv": "^16.4.7",
+    "express": "^4.21.2",
+    "nodemon": "^3.1.7"
+  }
+}

src/lib/chat.js

@@ -0,0 +1,136 @@
+const axios = require('axios')
+
+class Chat {
+  constructor() {
+  }
+
+  async createChat(token) {
+
+    try {
+      const response = await axios.post(`https://hix.ai/api/trpc/hixChat.createChat?batch=1`,
+        {
+          "0": {
+            "json": {
+              "title": `${new Date().toLocaleString()} New Chat`,
+              "botId": 85426
+            }
+          }
+        },
+        {
+          headers: {
+            'Content-Type': 'application/json',
+            'Cookie': `__Secure-next-auth.session-token=${token}`,
+            'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/129.0.0.0 Safari/537.36',
+            'Accept': 'application/json',
+            'Accept-Language': 'zh-CN,zh;q=0.9,en;q=0.8,en-GB;q=0.7,en-US;q=0.6',
+            'Referer': 'https://hix.ai/',
+            'Origin': 'https://hix.ai',
+            'Sec-Fetch-Dest': 'empty',
+            'Sec-Fetch-Mode': 'cors',
+            'Sec-Fetch-Site': 'cross-site'
+          }
+        }
+      )
+      return response.data[0].result.data.json.id
+    } catch (error) {
+      console.log("Token可能已失效，创建聊天失败!!!")
+      return null
+    }
+  }
+
+  async parserMessagesMode(messages) {
+    try {
+      const userMessages = messages.filter(item => item.role === 'user' || item.role === 'assistant')
+      const assistantMessages = messages.filter(item => item.role === 'assistant')
+      const systemMessages = messages.filter(item => item.role === 'system').map(item => item.content).join('\n')
+      if (userMessages.length === 1) {
+        let newMessage = `
+      ${systemMessages ? `<system>\n${systemMessages}</system>\n` : ''}
+
+      ${JSON.stringify(userMessages[userMessages.length - 1].content)}
+      `
+        return {
+          status: 200,
+          message: newMessage,
+          chatId: null,
+        }
+      } else {
+        const signRegex = /\[ChatID: (.*?)\]/
+        const sign = assistantMessages[assistantMessages.length - 1].content.match(signRegex)
+        if (sign) {
+          const chatId = sign[1].replace('[ChatID: ', '').replace(']', '')
+          return {
+            status: 200,
+            message: userMessages[userMessages.length - 1].content,
+            chatId: chatId,
+          }
+        } else {
+          return this.createForgeChat(messages)
+        }
+      }
+    } catch (error) {
+      return {
+        status: 500,
+        message: null,
+        chatId: null,
+      }
+    }
+  }
+
+  async createForgeChat(messages) {
+    let newMessage = `
+    ${JSON.stringify(messages.filter(item => item.role === 'system').map(item => item.content).join('\n')) ? `<system>\n${JSON.stringify(messages.filter(item => item.role === 'system').map(item => item.content).join('\n'))}\n</system>\n` : ''}
+
+    <history>
+    ${JSON.stringify(messages.filter(item => item.role === 'user' || item.role === 'assistant').map(item => item.content).join('\n'))}
+    </history>
+
+    ${messages[messages.length - 1].content}
+  `
+    return {
+      status: 200,
+      message: newMessage,
+      chatId: null,
+    }
+  }
+
+  async sendMessage(chatId, message, token) {
+    console.log(chatId)
+    try {
+      const response = await axios.post(`https://hix.ai/api/hix/chat`,
+        {
+          "chatId": chatId,
+          "question": message,
+          "fileUrl": "",
+          "answer": "",
+          "relatedQuestions": []
+        },
+        {
+          headers: {
+            'Content-Type': 'application/json',
+            'Cookie': `__Secure-next-auth.session-token=${token}`
+          },
+          responseType: 'stream'
+        }
+      )
+      return {
+        response: response.data,
+        status: 200,
+      }
+    } catch (error) {
+      if (error.response.status === 403) {
+        return {
+          response: null,
+          status: 403
+        }
+      }
+      return {
+        response: null,
+        status: error.response.status
+      }
+    }
+  }
+
+}
+
+module.exports = Chat

src/lib/tools.js

@@ -0,0 +1,20 @@
+const crypto = require('crypto')
+
+const uuid = () => {
+  return crypto.randomUUID()
+}
+
+const isJson = (str) => {
+  try {
+    JSON.parse(str)
+    return true
+  } catch (error) {
+    return false
+  }
+}
+
+const sleep = async (ms) => {
+  return new Promise(resolve => setTimeout(resolve, ms))
+}
+
+module.exports = { uuid, isJson, sleep }

src/server.js

@@ -0,0 +1,202 @@
+const express = require('express')
+const app = express()
+const bodyParser = require('body-parser')
+const Chat = require('./lib/chat.js')
+const { uuid, isJson } = require('./lib/tools')
+
+
+const ChatManager = new Chat()
+
+app.use(bodyParser.json({ limit: '32mb' }))
+app.use(bodyParser.urlencoded({ extended: true, limit: '32mb' }))
+
+app.get("/v1/models", async (req, res) => {
+  res.json({
+    object: "list",
+    data: [{
+      "id": "deepseek-reasoner",
+      "object": "model",
+      "created": 1686935002,
+      "owned_by": "hixai"
+    }],
+    object: "list"
+  })
+})
+
+app.post("/v1/chat/completions", async (req, res) => {
+
+  const token = req.headers.authorization?.replace("Bearer ", "")
+  if (!token) {
+    res.status(401).json({
+      error: "未提供Token!!!"
+    })
+    return
+  }
+
+  const stream = req.body.stream || false
+  let { message, chatId, status } = await ChatManager.parserMessagesMode(req.body.messages)
+  if (status === 500) {
+    res.status(500).json({
+      error: "服务器服务错误!!!"
+    })
+    return
+  }
+
+  if (stream) {
+    res.setHeader('Content-Type', 'text/event-stream')
+    res.setHeader('Cache-Control', 'no-cache')
+    res.setHeader('Connection', 'keep-alive')
+  } else {
+    res.setHeader('Content-Type', 'application/json')
+  }
+
+  const returnResponse = async (response, req, res, stream, chatId) => {
+    let reasoningStatus = false
+    let notStreamContent = ''
+    const decoder = new TextDecoder('utf-8')
+
+    const signText = `\n\n\n[ChatID: ${chatId}]\n`
+
+    const StreamTemplate = {
+      "id": `chatcmpl-${uuid()}`,
+      "object": "chat.completion.chunk",
+      "created": new Date().getTime(),
+      "choices": [
+        {
+          "index": 0,
+          "delta": {
+            "content": null
+          },
+          "finish_reason": null
+        }
+      ]
+    }
+
+    response.on('data', (chunk) => {
+      const decodeText = decoder.decode(chunk)
+
+      const lists = decodeText.split('\n').filter(item => item.trim() !== '')
+
+      for (const item of lists) {
+        try {
+          if (!item.includes('data')) {
+            continue
+          }
+
+          const decodeJson = isJson(item.replace(/^data: /, '')) ? JSON.parse(item.replace(/^data: /, '')) : null
+          let content = ''
+          if (decodeJson === null || (decodeJson.reasoning_content === undefined && decodeJson.content === undefined && decodeJson.thinking_time === undefined)) {
+            continue
+          }
+          content = decodeJson.content || decodeJson.reasoning_content
+          if (reasoningStatus === false && decodeJson.reasoning_content) {
+            content = `<think>\n${decodeJson.reasoning_content}`
+            reasoningStatus = true
+          }
+          if (decodeJson.thinking_time) {
+            content = `\n</think>\n`
+          }
+          if (content === undefined) {
+            continue
+          }
+
+          if (stream) {
+            StreamTemplate.choices[0].delta.content = content
+            res.write(`data: ${JSON.stringify(StreamTemplate)}\n\n`)
+          } else {
+            notStreamContent += content
+          }
+
+        } catch (error) {
+          // console.log(error)
+          res.status(500)
+            .json({
+              error: "服务错误!!!"
+            })
+        }
+      }
+    })
+
+    response.on('end', () => {
+      if (stream) {
+        StreamTemplate.choices[0].delta.content = signText
+        res.write(`data: ${JSON.stringify(StreamTemplate)}\n\n`)
+        res.write(`data: [DONE]\n\n`)
+        res.end()
+      } else {
+        notStreamContent += signText
+        const bodyTemplate = {
+          "id": `chatcmpl-${uuid()}`,
+          "object": "chat.completion",
+          "created": new Date().getTime(),
+          "model": req.body.model,
+          "choices": [
+            {
+              "index": 0,
+              "message": {
+                "role": "assistant",
+                "content": notStreamContent
+              },
+              "finish_reason": "stop"
+            }
+          ],
+          "usage": {
+            "prompt_tokens": 1024,
+            "completion_tokens": notStreamContent.length,
+            "total_tokens": 1024 + notStreamContent.length
+          }
+        }
+        res.json(bodyTemplate)
+      }
+    })
+  }
+
+  for (let i = 0; i < 3; i++) {
+    try {
+
+      if (!chatId) {
+        chatId = await ChatManager.createChat(token)
+        if (!chatId) {
+          res.status(500).json({
+            error: "创建聊天失败!!!"
+          })
+          return
+        }
+      }
+
+      let { response, status } = await ChatManager.sendMessage(chatId, message, token, stream)
+      if (status === 200 && response) {
+        await returnResponse(response, req, res, stream, chatId)
+        return
+      } else if (status === 403) {
+        message = await ChatManager.createForgeChat(req.body.messages)
+        chatId = null
+      } else {
+        res.status(500).json({
+          error: "请求发送失败!!!"
+        })
+        return
+      }
+
+    }
+    catch (error) {
+      res.status(500).json({
+        error: "服务器服务错误!!!"
+      })
+      return
+    }
+
+  }
+
+  res.status(500).json({
+    error: "多次尝试后依旧失败!!!"
+  })
+
+})
+
+
+app.listen(8999, () => {
+  console.log('Server is running on port 8999')
+})
+
+