mirror of
https://github.com/LLM-Red-Team/kimi-free-api.git
synced 2025-10-14 14:20:36 +00:00
Compare commits
11 Commits
Author | SHA1 | Date | |
---|---|---|---|
![]() |
fe63c20198 | ||
![]() |
72e29e4168 | ||
![]() |
9fd7ae890b | ||
![]() |
f5bea5ea68 | ||
![]() |
0b2c8434c9 | ||
![]() |
520f26f72f | ||
![]() |
462c64656e | ||
![]() |
cda36ed4fc | ||
![]() |
70ea39591b | ||
![]() |
11a145924f | ||
![]() |
1b2b7927ee |
@@ -1,6 +1,6 @@
|
||||
{
|
||||
"name": "kimi-free-api",
|
||||
"version": "0.0.19",
|
||||
"version": "0.0.23",
|
||||
"description": "Kimi Free API Server",
|
||||
"type": "module",
|
||||
"main": "dist/index.js",
|
||||
|
10
public/welcome.html
Normal file
10
public/welcome.html
Normal file
@@ -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>
|
@@ -362,52 +362,38 @@ function extractRefFileUrls(messages: any[]) {
|
||||
* @param messages 参考gpt系列消息格式,多轮对话请完整提供上下文
|
||||
*/
|
||||
function messagesPrepare(messages: any[]) {
|
||||
// 先剔除所有的 base64 数据
|
||||
let validMessages = messages.map((message) => {
|
||||
if (Array.isArray(message.content)) {
|
||||
message.content = message.content.filter(v => {
|
||||
if (typeof v === 'object' && ['file', 'image_url'].includes(v['type'])) {
|
||||
// 如果内容是 base64 数据,就剔除
|
||||
return !util.isBASE64Data(v['url']);
|
||||
}
|
||||
// 如果不是 base64 数据,就保留
|
||||
return true;
|
||||
});
|
||||
}
|
||||
return message;
|
||||
});
|
||||
|
||||
// 检查最新消息是否含有"type": "image_url"或"type": "file",如果有则注入消息
|
||||
let latestMessage = validMessages[validMessages.length - 1];
|
||||
// 注入消息提升注意力
|
||||
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'])));
|
||||
if (hasFileOrImage) {
|
||||
let newFileMessage = {
|
||||
"content": "关注用户最新发送的文件和消息",
|
||||
"role": "system"
|
||||
};
|
||||
validMessages.splice(validMessages.length - 1, 0, newFileMessage);
|
||||
logger.info("注入提升尾部文件注意力system prompt");
|
||||
} else {
|
||||
let newTextMessage = {
|
||||
"content": "关注用户最新的消息",
|
||||
"role": "system"
|
||||
};
|
||||
validMessages.splice(validMessages.length - 1, 0, newTextMessage);
|
||||
logger.info("注入提升尾部消息注意力system prompt");
|
||||
// 第二轮开始注入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 = validMessages.reduce((content, message) => {
|
||||
const content = messages.reduce((content, message) => {
|
||||
if (Array.isArray(message.content)) {
|
||||
return message.content.reduce((_content, v) => {
|
||||
if (!_.isObject(v) || v['type'] != 'text')
|
||||
return _content;
|
||||
return _content + ('user:' + v['text'] || '') + "\n";
|
||||
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`;
|
||||
}, '');
|
||||
|
||||
logger.info("\n对话合并:\n" + content);
|
||||
return [
|
||||
{ role: 'user', content }
|
||||
@@ -516,8 +502,8 @@ async function uploadFile(fileUrl: string, refreshToken: string) {
|
||||
data: fileData,
|
||||
// 100M限制
|
||||
maxBodyLength: FILE_MAX_SIZE,
|
||||
// 60秒超时
|
||||
timeout: 60000,
|
||||
// 120秒超时
|
||||
timeout: 120000,
|
||||
headers: {
|
||||
'Content-Type': mimeType,
|
||||
Authorization: `Bearer ${token}`,
|
||||
|
@@ -1,7 +1,23 @@
|
||||
import fs from 'fs-extra';
|
||||
|
||||
import Response from '@/lib/response/Response.ts';
|
||||
import chat from "./chat.ts";
|
||||
import ping from "./ping.ts";
|
||||
|
||||
export default [
|
||||
{
|
||||
get: {
|
||||
'/': async () => {
|
||||
const content = await fs.readFile('public/welcome.html');
|
||||
return new Response(content, {
|
||||
type: 'html',
|
||||
headers: {
|
||||
Expires: '-1'
|
||||
}
|
||||
});
|
||||
}
|
||||
}
|
||||
},
|
||||
chat,
|
||||
ping
|
||||
];
|
@@ -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',
|
||||
|
@@ -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)
|
||||
|
Reference in New Issue
Block a user