MigrateRepos/kimi-free-api
1
0
Fork 0
mirror of https://github.com/LLM-Red-Team/kimi-free-api.git synced 2024-11-01 12:09:20 +08:00
Code Issues Packages Projects Releases Wiki Activity

first commit

Browse Source
This commit is contained in:
Vinlic 2024-03-08 19:21:53 +08:00
commit 78b267c3e8
32 changed files with 1711 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
.gitignore vendored Normal file
View File

@ -0,0 +1,3 @@
dist/
node_modules/
logs/

8
configs/dev/api.yml Normal file
View File

@ -0,0 +1,8 @@
chatCompletion:
provider: zhipuai
model: glm-4
apiKey: 99b6167d7f421fc2187785503d2ffe9f.WncREpjXE26ediTw
contextLength: 131072
maxToken: 8192
concurrencyLimit: 5
waitReponseTimeout: 30000

6
configs/dev/service.yml Normal file
View File

@ -0,0 +1,6 @@
# 服务名称
name: kimi-free-api
# 服务绑定主机地址
host: '0.0.0.0'
# 服务绑定端口
port: 8000

14
configs/dev/system.yml Normal file
View File

@ -0,0 +1,14 @@
# 是否开启请求日志
requestLog: true
# 临时目录路径
tmpDir: ./tmp
# 日志目录路径
logDir: ./logs
# 日志写入间隔（毫秒）
logWriteInterval: 200
# 日志文件有效期（毫秒）
logFileExpires: 2626560000
# 公共目录路径
publicDir: ./public
# 临时文件有效期（毫秒）
tmpFileExpires: 86400000

0
libs.d.ts vendored Normal file
View File

50
package.json Normal file
View File

@ -0,0 +1,50 @@
{
"name": "kimi-free-api",
"version": "0.0.1",
"description": "Kimi Free Server",
"type": "module",
"main": "dist/index.js",
"module": "dist/index.mjs",
"types": "dist/index.d.ts",
"directories": {
"dist": "dist"
},
"files": [
"dist/"
],
"scripts": {
"dev": "tsup src/index.ts --format cjs,esm --sourcemap --dts --publicDir public --watch --onSuccess \"node dist/index.js\"",
"build": "tsup src/index.ts --format cjs,esm --sourcemap --dts --clean --publicDir public"
},
"author": "Vinlic",
"license": "ISC",
"dependencies": {
"axios": "^1.6.7",
"colors": "^1.4.0",
"crc-32": "^1.2.2",
"cron": "^3.1.6",
"date-fns": "^3.3.1",
"eventsource-parser": "^1.1.2",
"fs-extra": "^11.2.0",
"https-proxy-agent": "^7.0.4",
"koa": "^2.15.0",
"koa-body": "^5.0.0",
"koa-bodyparser": "^4.4.1",
"koa-range": "^0.3.0",
"koa-router": "^12.0.1",
"koa2-cors": "^2.0.6",
"lodash": "^4.17.21",
"mime": "^4.0.1",
"minimist": "^1.2.8",
"randomstring": "^1.3.0",
"socks-proxy-agent": "^8.0.2",
"uuid": "^9.0.1",
"yaml": "^2.3.4"
},
"devDependencies": {
"@types/lodash": "^4.14.202",
"@types/mime": "^3.0.4",
"tsup": "^8.0.2",
"typescript": "^5.3.3"
}
}

5
src/api/consts/exceptions.ts Normal file
View File

@ -0,0 +1,5 @@
export default {
API_TEST: [-9999, 'API异常错误'],
API_REQUEST_PARAMS_INVALID: [-2000, '请求参数非法'],
API_REQUEST_FAILED: [-2001, '请求失败'],
}

158
src/api/controllers/chat.ts Normal file
View File

@ -0,0 +1,158 @@
import { PassThrough } from "stream";
import _ from 'lodash';
import axios, { AxiosResponse } from 'axios';
import APIException from "@/lib/exceptions/APIException.ts";
import EX from "@/api/consts/exceptions.ts";
import { createParser } from 'eventsource-parser'
import logger from '@/lib/logger.ts';
import util from '@/lib/util.ts';
const TOKEN_EXPIRES = 120;
let currentAccessToken: string | null = null;
let currentRefreshToken: string | null = null;
let latestRefreshTime = 0;
function setRefreshToken(refreshToken: string) {
currentRefreshToken = refreshToken || 'eyJhbGciOiJIUzUxMiIsInR5cCI6IkpXVCJ9.eyJpc3MiOiJ1c2VyLWNlbnRlciIsImV4cCI6MTcxNzY2NzkzMSwiaWF0IjoxNzA5ODkxOTMxLCJqdGkiOiJjbmxlMm1wcmRpamFpbGxzcHJuMCIsInR5cCI6InJlZnJlc2giLCJzdWIiOiJjbmVyMGgybG5sOTU3N3MzMmluZyIsInNwYWNlX2lkIjoiY25lcXA1ODNyMDdkajd1a3JqcjAiLCJhYnN0cmFjdF91c2VyX2lkIjoiY25lcXA1ODNyMDdkajd1a3JqcWcifQ.XMDecAmBq817_n3xtRqIwIlS9QQLIClS1PaVh4EY8bqhiHr8SxFxbiTEyuRuPPTnCB90eUJNc_LchLMjUo8cKA';
}
async function refreshToken() {
const refreshToken = currentRefreshToken;
const result = await axios.get('https://kimi.moonshot.cn/api/auth/token/refresh', {
headers: {
Authorization: `Bearer ${refreshToken}`
}
});
const {
access_token,
refresh_token
} = checkResult(result);
currentAccessToken = access_token;
currentRefreshToken = refresh_token;
logger.info(`Current access_token: ${currentAccessToken}`);
logger.info(`Current refresh_token: ${currentRefreshToken}`);
logger.success('Token refresh completed');
}
async function requestToken() {
if (util.unixTimestamp() - latestRefreshTime > TOKEN_EXPIRES)
await refreshToken();
return currentAccessToken;
}
async function createConversation(name: string) {
const token = await requestToken();
const result = await axios.post('https://kimi.moonshot.cn/api/chat', {
name,
is_example: false
}, {
headers: {
Authorization: `Bearer ${token}`
}
});
const {
id: convId
} = checkResult(result);
return convId;
}
async function removeConversation(convId: string) {
const token = await requestToken();
const result = await axios.delete(`https://kimi.moonshot.cn/api/chat/${convId}`, {
headers: {
Authorization: `Bearer ${token}`
}
});
checkResult(result);
}
async function createCompletionStream(messages: any[], useSearch = true) {
console.log(messages);
const convId = await createConversation(`cmpl-${util.uuid(false)}`);
const token = await requestToken();
const result = await axios.post(`https://kimi.moonshot.cn/api/chat/${convId}/completion/stream`, {
messages,
use_search: useSearch
}, {
headers: {
Authorization: `Bearer ${token}`
},
responseType: 'stream'
});
return createTransStream(convId, result.data);
}
function checkResult(result: AxiosResponse) {
if(!result.data)
return null;
const { error_type, message } = result.data;
if (!_.isString(error_type))
return result.data;
console.log(result.data);
throw new APIException(EX.API_REQUEST_FAILED, message);
}
function createTransStream(convId: string, stream: any) {
const created = parseInt(performance.now() as any);
const transStream = new PassThrough();
!transStream.closed && transStream.write(`data: ${JSON.stringify({
id: convId,
model: 'kimi',
object: 'chat.completion.chunk',
choices: [
{ index: 0, delta: { role: 'assistant', content: '' }, finish_reason: null }
],
created
})}\n\n`);
const parser = createParser(event => {
try {
if (event.type !== "event") return;
const result = _.attempt(() => JSON.parse(event.data));
if (_.isError(result))
throw new Error(`stream response invalid: ${event.data}`);
if (result.event == 'cmpl') {
const data = `data: ${JSON.stringify({
id: convId,
model: 'kimi',
object: 'chat.completion.chunk',
choices: [
{ index: 0, delta: { content: result.text }, finish_reason: null }
],
created
})}\n\n`;
!transStream.closed && transStream.write(data);
}
else if (result.event == 'all_done') {
const data = `data: ${JSON.stringify({
id: convId,
model: 'kimi',
object: 'chat.completion.chunk',
choices: [
{ index: 0, delta: {}, finish_reason: 'stop' }
],
created
})}\n\n`;
!transStream.closed && transStream.write(data);
!transStream.closed && transStream.end('[DONE]');
removeConversation(convId).catch(err => console.error(err));
}
}
catch (err) {
logger.error(err);
!transStream.closed && transStream.end('\n\n');
}
});
stream.on("data", buffer => parser.feed(buffer.toString()));
stream.once("error", () => !transStream.closed && transStream.end('[DONE]'));
stream.once("close", () => !transStream.closed && transStream.end('[DONE]'));
return transStream;
}
export default {
setRefreshToken,
refreshToken,
createConversation,
createCompletionStream
};

25
src/api/routes/chat.ts Normal file
View File

@ -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';
export default {
prefix: '/v1/chat',
post: {
'/completions': async (request: Request) => {
request
.validate('body.messages', _.isArray)
chat.setRefreshToken(request.body.refresh_token);
const stream = await chat.createCompletionStream(request.body.messages, request.body.use_search);
return new Response(stream, {
type: "text/event-stream"
});
}
}
}

5
src/api/routes/index.ts Normal file
View File

@ -0,0 +1,5 @@
import chat from "./chat.ts";
export default [
chat
];

82
src/daemon.ts Normal file
View File

@ -0,0 +1,82 @@
/**
* 守护进程
*/
import process from 'process';
import path from 'path';
import { spawn } from 'child_process';
import fs from 'fs-extra';
import { format as dateFormat } from 'date-fns';
import 'colors';
const CRASH_RESTART_LIMIT = 600; //进程崩溃重启次数限制
const CRASH_RESTART_DELAY = 5000; //进程崩溃重启延迟
const LOG_PATH = path.resolve("./logs/daemon.log"); //守护进程日志路径
let crashCount = 0; //进程崩溃次数
let currentProcess; //当前运行进程
/**
* 写入守护进程日志
*/
function daemonLog(value, color?: string) {
try {
const head = `[daemon][${dateFormat(new Date(), "yyyy-MM-dd HH:mm:ss.SSS")}] `;
value = head + value;
console.log(color ? value[color] : value);
fs.ensureDirSync(path.dirname(LOG_PATH));
fs.appendFileSync(LOG_PATH, value + "\n");
}
catch(err) {
console.error("daemon log write error:", err);
}
}
daemonLog(`daemon pid: ${process.pid}`);
function createProcess() {
const childProcess = spawn("node", ["index.js", ...process.argv.slice(2)]); //启动子进程
childProcess.stdout.pipe(process.stdout, { end: false }); //将子进程输出管道到当前进程输出
childProcess.stderr.pipe(process.stderr, { end: false }); //将子进程错误输出管道到当前进程输出
currentProcess = childProcess; //更新当前进程
daemonLog(`process(${childProcess.pid}) has started`);
childProcess.on("error", err => daemonLog(`process(${childProcess.pid}) error: ${err.stack}`, "red"));
childProcess.on("close", code => {
if(code === 0) //进程正常退出
daemonLog(`process(${childProcess.pid}) has exited`);
else if(code === 2) //进程已被杀死
daemonLog(`process(${childProcess.pid}) has been killed!`, "bgYellow");
else if(code === 3) { //进程主动重启
daemonLog(`process(${childProcess.pid}) has restart`, "yellow");
createProcess(); //重新创建进程
}
else { //进程发生崩溃
if(crashCount++ < CRASH_RESTART_LIMIT) { //进程崩溃次数未达重启次数上限前尝试重启
daemonLog(`process(${childProcess.pid}) has crashed! delay ${CRASH_RESTART_DELAY}ms try restarting...(${crashCount})`, "bgRed");
setTimeout(() => createProcess(), CRASH_RESTART_DELAY); //延迟指定时长后再重启
}
else //进程已崩溃，且无法重启
daemonLog(`process(${childProcess.pid}) has crashed! unable to restart`, "bgRed");
}
}); //子进程关闭监听
}
process.on("exit", code => {
if(code === 0)
daemonLog("daemon process exited");
else if(code === 2)
daemonLog("daemon process has been killed!");
}); //守护进程退出事件
process.on("SIGTERM", () => {
daemonLog("received kill signal", "yellow");
currentProcess && currentProcess.kill("SIGINT");
process.exit(2);
}); //kill退出守护进程
process.on("SIGINT", () => {
currentProcess && currentProcess.kill("SIGINT");
process.exit(0);
}); //主动退出守护进程
createProcess(); //创建进程

33
src/index.ts Normal file
View File

@ -0,0 +1,33 @@
"use strict";
import environment from "@/lib/environment.ts";
import config from "@/lib/config.ts";
import "@/lib/initialize.ts";
import server from "@/lib/server.ts";
import routes from "@/api/routes/index.ts";
import logger from "@/lib/logger.ts";
import util from "@/lib/util.ts";
const startupTime = performance.now();
(async () => {
logger.header();
logger.info("<<<< kimi free server >>>>");
logger.info("Version:", environment.package.version);
logger.info("Process id:", process.pid);
logger.info("Environment:", environment.env);
logger.info("Service name:", config.service.name);
server.attachRoutes(routes);
await server.listen();
config.service.bindAddress &&
logger.success("service bind address:", config.service.bindAddress);
})()
.then(() =>
logger.success(
`Service startup completed (${Math.floor(performance.now() - startupTime)}ms)`
)
)
.catch((err) => console.error(err));

18
src/lib/config.ts Normal file
View File

@ -0,0 +1,18 @@
import serviceConfig from "./configs/service-config.ts";
import systemConfig from "./configs/system-config.ts";
import apiConfig from "./configs/api-config.ts";
class Config {
/** 服务配置 */
service = serviceConfig;
/** 系统配置 */
system = systemConfig;
/** API配置 */
api = apiConfig;
}
export default new Config();

85
src/lib/configs/api-config.ts Normal file
View File

@ -0,0 +1,85 @@
import path from 'path';
import fs from 'fs-extra';
import yaml from 'yaml';
import _ from 'lodash';
import environment from '@/lib/environment.ts';
const CONFIG_PATH = path.join(path.resolve(), 'configs/', environment.env, "/api.yml");
export interface ProxyAgent {
enable?: boolean;
protocol?: string;
host?: string;
port?: number;
}
export class ChatCompletionConfig {
/** 服务提供商 */
provider: string;
/** 调用地址 */
url: string;
/** API密钥 */
apiKey: string;
/** API版本号 */
apiVersion: string;
/** 模型名称 */
model: string;
/** 上下文长度 */
contextLength: number;
/** 单次最大token数 */
maxToken: number;
/** 并行请求数 */
concurrencyLimit: number;
/** 等待响应超时时间（毫秒） */
waitReponseTimeout: number;
/** 网络代理 */
proxyAgent: ProxyAgent | null;
constructor(options?: any) {
const { provider, url, apiKey, apiVersion, model, contextLength, concurrencyLimit, waitReponseTimeout, proxyAgent } = options || {};
this.provider = _.defaultTo(provider, 'zhipuai');
this.url = _.defaultTo(url, 'https://open.bigmodel.cn/api/paas/v4/chat/completions');
this.apiKey = _.defaultTo(apiKey, '');
this.apiVersion = _.defaultTo(apiVersion, '');
this.model = _.defaultTo(model, 'glm-4');
this.contextLength = _.defaultTo(contextLength, 131072);
this.concurrencyLimit = _.defaultTo(concurrencyLimit, 100);
this.waitReponseTimeout = _.defaultTo(waitReponseTimeout, 30000);
this.proxyAgent = _.defaultTo(proxyAgent, null);
}
static create(value) {
return ChatCompletionConfig.isInstance(value) ? value : new ChatCompletionConfig(value);
}
static isInstance(value) {
return value instanceof ChatCompletionConfig;
}
}
/**
* API配置
*/
export class APIConfig {
/** 聊天补全配置 */
chatCompletion: ChatCompletionConfig;
constructor(options?: any) {
const { chatCompletion } = options || {};
this.chatCompletion = ChatCompletionConfig.create(chatCompletion);
}
static load() {
if(!fs.pathExistsSync(CONFIG_PATH)) return new APIConfig();
const data = yaml.parse(fs.readFileSync(CONFIG_PATH).toString());
return new APIConfig(data);
}
}
export default APIConfig.load();

68
src/lib/configs/service-config.ts Normal file
View File

@ -0,0 +1,68 @@
import path from 'path';
import fs from 'fs-extra';
import yaml from 'yaml';
import _ from 'lodash';
import environment from '../environment.ts';
import util from '../util.ts';
const CONFIG_PATH = path.join(path.resolve(), 'configs/', environment.env, "/service.yml");
/**
* 服务配置
*/
export class ServiceConfig {
/** 服务名称 */
name: string;
/** @type {string} 服务绑定主机地址 */
host;
/** @type {number} 服务绑定端口 */
port;
/** @type {string} 服务路由前缀 */
urlPrefix;
/** @type {string} 服务绑定地址（外部访问地址） */
bindAddress;
constructor(options?: any) {
const { name, host, port, urlPrefix, bindAddress } = options || {};
this.name = _.defaultTo(name, 'kimi-free-api');
this.host = _.defaultTo(host, '0.0.0.0');
this.port = _.defaultTo(port, 5566);
this.urlPrefix = _.defaultTo(urlPrefix, '');
this.bindAddress = bindAddress;
}
get addressHost() {
if(this.bindAddress) return this.bindAddress;
const ipAddresses = util.getIPAddressesByIPv4();
for(let ipAddress of ipAddresses) {
if(ipAddress === this.host)
return ipAddress;
}
return ipAddresses[0] || "127.0.0.1";
}
get address() {
return `${this.addressHost}:${this.port}`;
}
get pageDirUrl() {
return `http://127.0.0.1:${this.port}/page`;
}
get publicDirUrl() {
return `http://127.0.0.1:${this.port}/public`;
}
static load() {
const external = _.pickBy(environment, (v, k) => ["name", "host", "port"].includes(k) && !_.isUndefined(v));
if(!fs.pathExistsSync(CONFIG_PATH)) return new ServiceConfig(external);
const data = yaml.parse(fs.readFileSync(CONFIG_PATH).toString());
return new ServiceConfig({ ...data, ...external });
}
}
export default ServiceConfig.load();

84
src/lib/configs/system-config.ts Normal file
View File

@ -0,0 +1,84 @@
import path from 'path';
import fs from 'fs-extra';
import yaml from 'yaml';
import _ from 'lodash';
import environment from '../environment.ts';
const CONFIG_PATH = path.join(path.resolve(), 'configs/', environment.env, "/system.yml");
/**
* 系统配置
*/
export class SystemConfig {
/** 是否开启请求日志 */
requestLog: boolean;
/** 临时目录路径 */
tmpDir: string;
/** 日志目录路径 */
logDir: string;
/** 日志写入间隔（毫秒） */
logWriteInterval: number;
/** 日志文件有效期（毫秒） */
logFileExpires: number;
/** 公共目录路径 */
publicDir: string;
/** 临时文件有效期（毫秒） */
tmpFileExpires: number;
/** 请求体配置 */
requestBody: any;
/** 是否调试模式 */
debug: boolean;
constructor(options?: any) {
const { requestLog, tmpDir, logDir, logWriteInterval, logFileExpires, publicDir, tmpFileExpires, requestBody, debug } = options || {};
this.requestLog = _.defaultTo(requestLog, false);
this.tmpDir = _.defaultTo(tmpDir, './tmp');
this.logDir = _.defaultTo(logDir, './logs');
this.logWriteInterval = _.defaultTo(logWriteInterval, 200);
this.logFileExpires = _.defaultTo(logFileExpires, 2626560000);
this.publicDir = _.defaultTo(publicDir, './public');
this.tmpFileExpires = _.defaultTo(tmpFileExpires, 86400000);
this.requestBody = Object.assign(requestBody || {}, {
enableTypes: ['json', 'form', 'text', 'xml'],
encoding: 'utf-8',
formLimit: '10mb',
jsonLimit: '10mb',
textLimit: '10mb',
xmlLimit: '10mb',
formidable: {
maxFileSize: '30mb'
},
multipart: true,
parsedMethods: ['POST', 'PUT', 'PATCH']
});
this.debug = _.defaultTo(debug, true);
}
get rootDirPath() {
return path.resolve();
}
get tmpDirPath() {
return path.resolve(this.tmpDir);
}
get logDirPath() {
return path.resolve(this.logDir);
}
get publicDirPath() {
return path.resolve(this.publicDir);
}
static load() {
if (!fs.pathExistsSync(CONFIG_PATH)) return new SystemConfig();
const data = yaml.parse(fs.readFileSync(CONFIG_PATH).toString());
return new SystemConfig(data);
}
}
export default SystemConfig.load();

5
src/lib/consts/exceptions.ts Normal file
View File

@ -0,0 +1,5 @@
export default {
SYSTEM_ERROR: [-1000, '系统异常'],
SYSTEM_REQUEST_VALIDATION_ERROR: [-1001, '请求参数校验错误'],
SYSTEM_NOT_ROUTE_MATCHING: [-1002, '无匹配的路由']
} as Record<string, [number, string]>

44
src/lib/environment.ts Normal file
View File

@ -0,0 +1,44 @@
import path from 'path';
import fs from 'fs-extra';
import minimist from 'minimist';
import _ from 'lodash';
const cmdArgs = minimist(process.argv.slice(2)); //获取命令行参数
const envVars = process.env; //获取环境变量
class Environment {
/** 命令行参数 */
cmdArgs: any;
/** 环境变量 */
envVars: any;
/** 环境名称 */
env?: string;
/** 服务名称 */
name?: string;
/** 服务地址 */
host?: string;
/** 服务端口 */
port?: number;
/** 包参数 */
package: any;
constructor(options: any = {}) {
const { cmdArgs, envVars, package: _package } = options;
this.cmdArgs = cmdArgs;
this.envVars = envVars;
this.env = _.defaultTo(cmdArgs.env || envVars.SERVER_ENV, 'dev');
this.name = cmdArgs.name || envVars.SERVER_NAME || undefined;
this.host = cmdArgs.host || envVars.SERVER_HOST || undefined;
this.port = Number(cmdArgs.port || envVars.SERVER_PORT) ? Number(cmdArgs.port || envVars.SERVER_PORT) : undefined;
this.package = _package;
}
}
export default new Environment({
cmdArgs,
envVars,
package: JSON.parse(fs.readFileSync(path.join(path.resolve(), "package.json")).toString())
});

14
src/lib/exceptions/APIException.ts Normal file
View File

@ -0,0 +1,14 @@
import Exception from './Exception.js';
export default class APIException extends Exception {
/**
* 构造异常
*
* @param {[number, string]} exception 异常
*/
constructor(exception: (string | number)[], errmsg?: string) {
super(exception, errmsg);
}
}

42
src/lib/exceptions/Exception.ts Normal file
View File

@ -0,0 +1,42 @@
import assert from 'assert';
import _ from 'lodash';
export default class Exception extends Error {
/** 错误码 */
errcode: number;
/** 错误消息 */
errmsg: string;
/** 数据 */
data: any;
/** HTTP状态码 */
httpStatusCode: number;
/**
* 构造异常
*
* @param exception 异常
* @param _errmsg 异常消息
*/
constructor(exception: (string | number)[], _errmsg?: string) {
assert(_.isArray(exception), 'Exception must be Array');
const [errcode, errmsg] = exception as [number, string];
assert(_.isFinite(errcode), 'Exception errcode invalid');
assert(_.isString(errmsg), 'Exception errmsg invalid');
super(_errmsg || errmsg);
this.errcode = errcode;
this.errmsg = _errmsg || errmsg;
}
setHTTPStatusCode(value: number) {
this.httpStatusCode = value;
return this;
}
setData(value: any) {
this.data = _.defaultTo(value, null);
return this;
}
}

61
src/lib/http-status-codes.ts Normal file
View File

@ -0,0 +1,61 @@
export default {
CONTINUE: 100, //客户端应当继续发送请求。这个临时响应是用来通知客户端它的部分请求已经被服务器接收，且仍未被拒绝。客户端应当继续发送请求的剩余部分，或者如果请求已经完成，忽略这个响应。服务器必须在请求完成后向客户端发送一个最终响应
SWITCHING_PROTOCOLS: 101, //服务器已经理解了客户端的请求，并将通过Upgrade 消息头通知客户端采用不同的协议来完成这个请求。在发送完这个响应最后的空行后，服务器将会切换到在Upgrade 消息头中定义的那些协议。只有在切换新的协议更有好处的时候才应该采取类似措施。例如，切换到新的HTTP 版本比旧版本更有优势，或者切换到一个实时且同步的协议以传送利用此类特性的资源
PROCESSING: 102, //处理将被继续执行
OK: 200, //请求已成功，请求所希望的响应头或数据体将随此响应返回
CREATED: 201, //请求已经被实现，而且有一个新的资源已经依据请求的需要而建立，且其 URI 已经随Location 头信息返回。假如需要的资源无法及时建立的话，应当返回 '202 Accepted'
ACCEPTED: 202, //服务器已接受请求，但尚未处理。正如它可能被拒绝一样，最终该请求可能会也可能不会被执行。在异步操作的场合下，没有比发送这个状态码更方便的做法了。返回202状态码的响应的目的是允许服务器接受其他过程的请求（例如某个每天只执行一次的基于批处理的操作），而不必让客户端一直保持与服务器的连接直到批处理操作全部完成。在接受请求处理并返回202状态码的响应应当在返回的实体中包含一些指示处理当前状态的信息，以及指向处理状态监视器或状态预测的指针，以便用户能够估计操作是否已经完成
NON_AUTHORITATIVE_INFO: 203, //服务器已成功处理了请求，但返回的实体头部元信息不是在原始服务器上有效的确定集合，而是来自本地或者第三方的拷贝。当前的信息可能是原始版本的子集或者超集。例如，包含资源的元数据可能导致原始服务器知道元信息的超级。使用此状态码不是必须的，而且只有在响应不使用此状态码便会返回200 OK的情况下才是合适的
NO_CONTENT: 204, //服务器成功处理了请求，但不需要返回任何实体内容，并且希望返回更新了的元信息。响应可能通过实体头部的形式，返回新的或更新后的元信息。如果存在这些头部信息，则应当与所请求的变量相呼应。如果客户端是浏览器的话，那么用户浏览器应保留发送了该请求的页面，而不产生任何文档视图上的变化，即使按照规范新的或更新后的元信息应当被应用到用户浏览器活动视图中的文档。由于204响应被禁止包含任何消息体，因此它始终以消息头后的第一个空行结尾
RESET_CONTENT: 205, //服务器成功处理了请求，且没有返回任何内容。但是与204响应不同，返回此状态码的响应要求请求者重置文档视图。该响应主要是被用于接受用户输入后，立即重置表单，以便用户能够轻松地开始另一次输入。与204响应一样，该响应也被禁止包含任何消息体，且以消息头后的第一个空行结束
PARTIAL_CONTENT: 206, //服务器已经成功处理了部分 GET 请求。类似于FlashGet或者迅雷这类的HTTP下载工具都是使用此类响应实现断点续传或者将一个大文档分解为多个下载段同时下载。该请求必须包含 Range 头信息来指示客户端希望得到的内容范围，并且可能包含 If-Range 来作为请求条件。响应必须包含如下的头部域：Content-Range 用以指示本次响应中返回的内容的范围；如果是Content-Type为multipart/byteranges的多段下载，则每一段multipart中都应包含Content-Range域用以指示本段的内容范围。假如响应中包含Content-Length，那么它的数值必须匹配它返回的内容范围的真实字节数。Date和ETag或Content-Location，假如同样的请求本应该返回200响应。Expires, Cache-Control，和/或 Vary，假如其值可能与之前相同变量的其他响应对应的值不同的话。假如本响应请求使用了 If-Range 强缓存验证，那么本次响应不应该包含其他实体头；假如本响应的请求使用了 If-Range 弱缓存验证，那么本次响应禁止包含其他实体头；这避免了缓存的实体内容和更新了的实体头信息之间的不一致。否则，本响应就应当包含所有本应该返回200响应中应当返回的所有实体头部域。假如 ETag 或 Latest-Modified 头部不能精确匹配的话，则客户端缓存应禁止将206响应返回的内容与之前任何缓存过的内容组合在一起。任何不支持 Range 以及 Content-Range 头的缓存都禁止缓存206响应返回的内容
MULTIPLE_STATUS: 207, //代表之后的消息体将是一个XML消息，并且可能依照之前子请求数量的不同，包含一系列独立的响应代码
MULTIPLE_CHOICES: 300, //被请求的资源有一系列可供选择的回馈信息，每个都有自己特定的地址和浏览器驱动的商议信息。用户或浏览器能够自行选择一个首选的地址进行重定向。除非这是一个HEAD请求，否则该响应应当包括一个资源特性及地址的列表的实体，以便用户或浏览器从中选择最合适的重定向地址。这个实体的格式由Content-Type定义的格式所决定。浏览器可能根据响应的格式以及浏览器自身能力，自动作出最合适的选择。当然，RFC 2616规范并没有规定这样的自动选择该如何进行。如果服务器本身已经有了首选的回馈选择，那么在Location中应当指明这个回馈的 URI；浏览器可能会将这个 Location 值作为自动重定向的地址。此外，除非额外指定，否则这个响应也是可缓存的
MOVED_PERMANENTLY: 301, //被请求的资源已永久移动到新位置，并且将来任何对此资源的引用都应该使用本响应返回的若干个URI之一。如果可能，拥有链接编辑功能的客户端应当自动把请求的地址修改为从服务器反馈回来的地址。除非额外指定，否则这个响应也是可缓存的。新的永久性的URI应当在响应的Location域中返回。除非这是一个HEAD请求，否则响应的实体中应当包含指向新的URI的超链接及简短说明。如果这不是一个GET或者HEAD请求，因此浏览器禁止自动进行重定向，除非得到用户的确认，因为请求的条件可能因此发生变化。注意：对于某些使用 HTTP/1.0 协议的浏览器，当它们发送的POST请求得到了一个301响应的话，接下来的重定向请求将会变成GET方式
FOUND: 302, //请求的资源现在临时从不同的URI响应请求。由于这样的重定向是临时的，客户端应当继续向原有地址发送以后的请求。只有在Cache-Control或Expires中进行了指定的情况下，这个响应才是可缓存的。新的临时性的URI应当在响应的 Location 域中返回。除非这是一个HEAD请求，否则响应的实体中应当包含指向新的URI的超链接及简短说明。如果这不是一个GET或者HEAD请求，那么浏览器禁止自动进行重定向，除非得到用户的确认，因为请求的条件可能因此发生变化。注意：虽然RFC 1945和RFC 2068规范不允许客户端在重定向时改变请求的方法，但是很多现存的浏览器将302响应视作为303响应，并且使用GET方式访问在Location中规定的URI，而无视原先请求的方法。状态码303和307被添加了进来，用以明确服务器期待客户端进行何种反应
SEE_OTHER: 303, //对应当前请求的响应可以在另一个URI上被找到，而且客户端应当采用 GET 的方式访问那个资源。这个方法的存在主要是为了允许由脚本激活的POST请求输出重定向到一个新的资源。这个新的 URI 不是原始资源的替代引用。同时，303响应禁止被缓存。当然，第二个请求（重定向）可能被缓存。新的 URI 应当在响应的Location域中返回。除非这是一个HEAD请求，否则响应的实体中应当包含指向新的URI的超链接及简短说明。注意：许多 HTTP/1.1 版以前的浏览器不能正确理解303状态。如果需要考虑与这些浏览器之间的互动，302状态码应该可以胜任，因为大多数的浏览器处理302响应时的方式恰恰就是上述规范要求客户端处理303响应时应当做的
NOT_MODIFIED: 304, //如果客户端发送了一个带条件的GET请求且该请求已被允许，而文档的内容（自上次访问以来或者根据请求的条件）并没有改变，则服务器应当返回这个状态码。304响应禁止包含消息体，因此始终以消息头后的第一个空行结尾。该响应必须包含以下的头信息：Date，除非这个服务器没有时钟。假如没有时钟的服务器也遵守这些规则，那么代理服务器以及客户端可以自行将Date字段添加到接收到的响应头中去（正如RFC 2068中规定的一样），缓存机制将会正常工作。ETag或 Content-Location，假如同样的请求本应返回200响应。Expires, Cache-Control，和/或Vary，假如其值可能与之前相同变量的其他响应对应的值不同的话。假如本响应请求使用了强缓存验证，那么本次响应不应该包含其他实体头；否则（例如，某个带条件的 GET 请求使用了弱缓存验证），本次响应禁止包含其他实体头；这避免了缓存了的实体内容和更新了的实体头信息之间的不一致。假如某个304响应指明了当前某个实体没有缓存，那么缓存系统必须忽视这个响应，并且重复发送不包含限制条件的请求。假如接收到一个要求更新某个缓存条目的304响应，那么缓存系统必须更新整个条目以反映所有在响应中被更新的字段的值
USE_PROXY: 305, //被请求的资源必须通过指定的代理才能被访问。Location域中将给出指定的代理所在的URI信息，接收者需要重复发送一个单独的请求，通过这个代理才能访问相应资源。只有原始服务器才能建立305响应。注意：RFC 2068中没有明确305响应是为了重定向一个单独的请求，而且只能被原始服务器建立。忽视这些限制可能导致严重的安全后果
UNUSED: 306, //在最新版的规范中，306状态码已经不再被使用
TEMPORARY_REDIRECT: 307, //请求的资源现在临时从不同的URI 响应请求。由于这样的重定向是临时的，客户端应当继续向原有地址发送以后的请求。只有在Cache-Control或Expires中进行了指定的情况下，这个响应才是可缓存的。新的临时性的URI 应当在响应的Location域中返回。除非这是一个HEAD请求，否则响应的实体中应当包含指向新的URI 的超链接及简短说明。因为部分浏览器不能识别307响应，因此需要添加上述必要信息以便用户能够理解并向新的 URI 发出访问请求。如果这不是一个GET或者HEAD请求，那么浏览器禁止自动进行重定向，除非得到用户的确认，因为请求的条件可能因此发生变化
BAD_REQUEST: 400, //1.语义有误，当前请求无法被服务器理解。除非进行修改，否则客户端不应该重复提交这个请求 2.请求参数有误
UNAUTHORIZED: 401, //当前请求需要用户验证。该响应必须包含一个适用于被请求资源的 WWW-Authenticate 信息头用以询问用户信息。客户端可以重复提交一个包含恰当的 Authorization 头信息的请求。如果当前请求已经包含了 Authorization 证书，那么401响应代表着服务器验证已经拒绝了那些证书。如果401响应包含了与前一个响应相同的身份验证询问，且浏览器已经至少尝试了一次验证，那么浏览器应当向用户展示响应中包含的实体信息，因为这个实体信息中可能包含了相关诊断信息。参见RFC 2617
PAYMENT_REQUIRED: 402, //该状态码是为了将来可能的需求而预留的
FORBIDDEN: 403, //服务器已经理解请求，但是拒绝执行它。与401响应不同的是，身份验证并不能提供任何帮助，而且这个请求也不应该被重复提交。如果这不是一个HEAD请求，而且服务器希望能够讲清楚为何请求不能被执行，那么就应该在实体内描述拒绝的原因。当然服务器也可以返回一个404响应，假如它不希望让客户端获得任何信息
NOT_FOUND: 404, //请求失败，请求所希望得到的资源未被在服务器上发现。没有信息能够告诉用户这个状况到底是暂时的还是永久的。假如服务器知道情况的话，应当使用410状态码来告知旧资源因为某些内部的配置机制问题，已经永久的不可用，而且没有任何可以跳转的地址。404这个状态码被广泛应用于当服务器不想揭示到底为何请求被拒绝或者没有其他适合的响应可用的情况下
METHOD_NOT_ALLOWED: 405, //请求行中指定的请求方法不能被用于请求相应的资源。该响应必须返回一个Allow 头信息用以表示出当前资源能够接受的请求方法的列表。鉴于PUT，DELETE方法会对服务器上的资源进行写操作，因而绝大部分的网页服务器都不支持或者在默认配置下不允许上述请求方法，对于此类请求均会返回405错误
NO_ACCEPTABLE: 406, //请求的资源的内容特性无法满足请求头中的条件，因而无法生成响应实体。除非这是一个 HEAD 请求，否则该响应就应当返回一个包含可以让用户或者浏览器从中选择最合适的实体特性以及地址列表的实体。实体的格式由Content-Type头中定义的媒体类型决定。浏览器可以根据格式及自身能力自行作出最佳选择。但是，规范中并没有定义任何作出此类自动选择的标准
PROXY_AUTHENTICATION_REQUIRED: 407, //与401响应类似，只不过客户端必须在代理服务器上进行身份验证。代理服务器必须返回一个Proxy-Authenticate用以进行身份询问。客户端可以返回一个Proxy-Authorization信息头用以验证。参见RFC 2617
REQUEST_TIMEOUT: 408, //请求超时。客户端没有在服务器预备等待的时间内完成一个请求的发送。客户端可以随时再次提交这一请求而无需进行任何更改
CONFLICT: 409, //由于和被请求的资源的当前状态之间存在冲突，请求无法完成。这个代码只允许用在这样的情况下才能被使用：用户被认为能够解决冲突，并且会重新提交新的请求。该响应应当包含足够的信息以便用户发现冲突的源头。冲突通常发生于对PUT请求的处理中。例如，在采用版本检查的环境下，某次PUT提交的对特定资源的修改请求所附带的版本信息与之前的某个（第三方）请求向冲突，那么此时服务器就应该返回一个409错误，告知用户请求无法完成。此时，响应实体中很可能会包含两个冲突版本之间的差异比较，以便用户重新提交归并以后的新版本
GONE: 410, //被请求的资源在服务器上已经不再可用，而且没有任何已知的转发地址。这样的状况应当被认为是永久性的。如果可能，拥有链接编辑功能的客户端应当在获得用户许可后删除所有指向这个地址的引用。如果服务器不知道或者无法确定这个状况是否是永久的，那么就应该使用404状态码。除非额外说明，否则这个响应是可缓存的。410响应的目的主要是帮助网站管理员维护网站，通知用户该资源已经不再可用，并且服务器拥有者希望所有指向这个资源的远端连接也被删除。这类事件在限时、增值服务中很普遍。同样，410响应也被用于通知客户端在当前服务器站点上，原本属于某个个人的资源已经不再可用。当然，是否需要把所有永久不可用的资源标记为'410 Gone'，以及是否需要保持此标记多长时间，完全取决于服务器拥有者
LENGTH_REQUIRED: 411, //服务器拒绝在没有定义Content-Length头的情况下接受请求。在添加了表明请求消息体长度的有效Content-Length头之后，客户端可以再次提交该请求
PRECONDITION_FAILED: 412, //服务器在验证在请求的头字段中给出先决条件时，没能满足其中的一个或多个。这个状态码允许客户端在获取资源时在请求的元信息（请求头字段数据）中设置先决条件，以此避免该请求方法被应用到其希望的内容以外的资源上
REQUEST_ENTITY_TOO_LARGE: 413, //服务器拒绝处理当前请求，因为该请求提交的实体数据大小超过了服务器愿意或者能够处理的范围。此种情况下，服务器可以关闭连接以免客户端继续发送此请求。如果这个状况是临时的，服务器应当返回一个 Retry-After 的响应头，以告知客户端可以在多少时间以后重新尝试
REQUEST_URI_TOO_LONG: 414, //请求的URI长度超过了服务器能够解释的长度，因此服务器拒绝对该请求提供服务。这比较少见，通常的情况包括：本应使用POST方法的表单提交变成了GET方法，导致查询字符串（Query String）过长。重定向URI “黑洞”，例如每次重定向把旧的URI作为新的URI的一部分，导致在若干次重定向后URI超长。客户端正在尝试利用某些服务器中存在的安全漏洞攻击服务器。这类服务器使用固定长度的缓冲读取或操作请求的URI，当GET后的参数超过某个数值后，可能会产生缓冲区溢出，导致任意代码被执行[1]。没有此类漏洞的服务器，应当返回414状态码
UNSUPPORTED_MEDIA_TYPE: 415, //对于当前请求的方法和所请求的资源，请求中提交的实体并不是服务器中所支持的格式，因此请求被拒绝
REQUESTED_RANGE_NOT_SATISFIABLE: 416, //如果请求中包含了Range请求头，并且Range中指定的任何数据范围都与当前资源的可用范围不重合，同时请求中又没有定义If-Range请求头，那么服务器就应当返回416状态码。假如Range使用的是字节范围，那么这种情况就是指请求指定的所有数据范围的首字节位置都超过了当前资源的长度。服务器也应当在返回416状态码的同时，包含一个Content-Range实体头，用以指明当前资源的长度。这个响应也被禁止使用multipart/byteranges作为其 Content-Type
EXPECTION_FAILED: 417, //在请求头Expect中指定的预期内容无法被服务器满足，或者这个服务器是一个代理服务器，它有明显的证据证明在当前路由的下一个节点上，Expect的内容无法被满足
TOO_MANY_CONNECTIONS: 421, //从当前客户端所在的IP地址到服务器的连接数超过了服务器许可的最大范围。通常，这里的IP地址指的是从服务器上看到的客户端地址（比如用户的网关或者代理服务器地址）。在这种情况下，连接数的计算可能涉及到不止一个终端用户
UNPROCESSABLE_ENTITY: 422, //请求格式正确，但是由于含有语义错误，无法响应
FAILED_DEPENDENCY: 424, //由于之前的某个请求发生的错误，导致当前请求失败，例如PROPPATCH
UNORDERED_COLLECTION: 425, //在WebDav Advanced Collections 草案中定义，但是未出现在《WebDAV 顺序集协议》（RFC 3658）中
UPGRADE_REQUIRED: 426, //客户端应当切换到TLS/1.0
RETRY_WITH: 449, //由微软扩展，代表请求应当在执行完适当的操作后进行重试
INTERNAL_SERVER_ERROR: 500, //服务器遇到了一个未曾预料的状况，导致了它无法完成对请求的处理。一般来说，这个问题都会在服务器的程序码出错时出现
NOT_IMPLEMENTED: 501, //服务器不支持当前请求所需要的某个功能。当服务器无法识别请求的方法，并且无法支持其对任何资源的请求
BAD_GATEWAY: 502, //作为网关或者代理工作的服务器尝试执行请求时，从上游服务器接收到无效的响应
SERVICE_UNAVAILABLE: 503, //由于临时的服务器维护或者过载，服务器当前无法处理请求。这个状况是临时的，并且将在一段时间以后恢复。如果能够预计延迟时间，那么响应中可以包含一个 Retry-After 头用以标明这个延迟时间。如果没有给出这个 Retry-After 信息，那么客户端应当以处理500响应的方式处理它。注意：503状态码的存在并不意味着服务器在过载的时候必须使用它。某些服务器只不过是希望拒绝客户端的连接
GATEWAY_TIMEOUT: 504, //作为网关或者代理工作的服务器尝试执行请求时，未能及时从上游服务器（URI标识出的服务器，例如HTTP、FTP、LDAP）或者辅助服务器（例如DNS）收到响应。注意：某些代理服务器在DNS查询超时时会返回400或者500错误
HTTP_VERSION_NOT_SUPPORTED: 505, //服务器不支持，或者拒绝支持在请求中使用的HTTP版本。这暗示着服务器不能或不愿使用与客户端相同的版本。响应中应当包含一个描述了为何版本不被支持以及服务器支持哪些协议的实体
VARIANT_ALSO_NEGOTIATES: 506, //服务器存在内部配置错误：被请求的协商变元资源被配置为在透明内容协商中使用自己，因此在一个协商处理中不是一个合适的重点
INSUFFICIENT_STORAGE: 507, //服务器无法存储完成请求所必须的内容。这个状况被认为是临时的
BANDWIDTH_LIMIT_EXCEEDED: 509, //服务器达到带宽限制。这不是一个官方的状态码，但是仍被广泛使用
NOT_EXTENDED: 510 //获取资源所需要的策略并没有没满足
};

28
src/lib/initialize.ts Normal file
View File

@ -0,0 +1,28 @@
import logger from './logger.js';
// 允许无限量的监听器
process.setMaxListeners(Infinity);
// 输出未捕获异常
process.on("uncaughtException", (err, origin) => {
logger.error(`An unhandled error occurred: ${origin}`, err);
});
// 输出未处理的Promise.reject
process.on("unhandledRejection", (_, promise) => {
promise.catch(err => logger.error("An unhandled rejection occurred:", err));
});
// 输出系统警告信息
process.on("warning", warning => logger.warn("System warning: ", warning));
// 进程退出监听
process.on("exit", () => {
logger.info("Service exit");
logger.footer();
});
// 进程被kill
process.on("SIGTERM", () => {
logger.warn("received kill signal");
process.exit(2);
});
// Ctrl-C进程退出
process.on("SIGINT", () => {
process.exit(0);
});

4
src/lib/interfaces/ICompletionMessage.ts Normal file
View File

@ -0,0 +1,4 @@
export default interface ICompletionMessage {
role: 'system' | 'assistant' | 'user' | 'function';
content: string;
}

182
src/lib/logger.ts Normal file
View File

@ -0,0 +1,182 @@
import path from 'path';
import _util from 'util';
import 'colors';
import _ from 'lodash';
import fs from 'fs-extra';
import { format as dateFormat } from 'date-fns';
import config from './config.ts';
import util from './util.ts';
class LogWriter {
#buffers = [];
constructor() {
fs.ensureDirSync(config.system.logDirPath);
this.work();
}
push(content) {
const buffer = Buffer.from(content);
this.#buffers.push(buffer);
}
writeSync(buffer) {
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);
}
flush() {
if(!this.#buffers.length) return;
fs.appendFileSync(path.join(config.system.logDirPath, `/${util.getDateString()}.log`), Buffer.concat(this.#buffers));
}
work() {
if (!this.#buffers.length) return setTimeout(this.work.bind(this), config.system.logWriteInterval);
const buffer = Buffer.concat(this.#buffers);
this.#buffers = [];
this.write(buffer)
.finally(() => setTimeout(this.work.bind(this), config.system.logWriteInterval))
.catch(err => console.error("Log write error:", err));
}
}
class LogText {
/** @type {string} 日志级别 */
level;
/** @type {string} 日志文本 */
text;
/** @type {string} 日志来源 */
source;
/** @type {Date} 日志发生时间 */
time = new Date();
constructor(level, ...params) {
this.level = level;
this.text = _util.format.apply(null, params);
this.source = this.#getStackTopCodeInfo();
}
#getStackTopCodeInfo() {
const unknownInfo = { name: "unknown", codeLine: 0, codeColumn: 0 };
const stackArray = new Error().stack.split("\n");
const text = stackArray[4];
if (!text)
return unknownInfo;
const match = text.match(/at (.+) \((.+)\)/) || text.match(/at (.+)/);
if (!match || !_.isString(match[2] || match[1]))
return unknownInfo;
const temp = match[2] || match[1];
const _match = temp.match(/([a-zA-Z0-9_\-\.]+)\:(\d+)\:(\d+)$/);
if (!_match)
return unknownInfo;
const [, scriptPath, codeLine, codeColumn] = _match as any;
return {
name: scriptPath ? scriptPath.replace(/.js$/, "") : "unknown",
path: scriptPath || null,
codeLine: parseInt(codeLine || 0),
codeColumn: parseInt(codeColumn || 0)
};
}
toString() {
return `[${dateFormat(this.time, "yyyy-MM-dd HH:mm:ss.SSS")}][${this.level}][${this.source.name}<${this.source.codeLine},${this.source.codeColumn}>] ${this.text}`;
}
}
class Logger {
/** @type {Object} 系统配置 */
config = {};
/** @type {Object} 日志级别映射 */
static Level = {
Success: "success",
Info: "info",
Log: "log",
Debug: "debug",
Warning: "warning",
Error: "error",
Fatal: "fatal"
};
/** @type {Object} 日志级别文本颜色樱色 */
static LevelColor = {
[Logger.Level.Success]: "green",
[Logger.Level.Info]: "brightCyan",
[Logger.Level.Debug]: "white",
[Logger.Level.Warning]: "brightYellow",
[Logger.Level.Error]: "brightRed",
[Logger.Level.Fatal]: "red"
};
#writer;
constructor() {
this.#writer = new LogWriter();
}
header() {
this.#writer.writeSync(Buffer.from(`\n\n===================== LOG START ${dateFormat(new Date(), "yyyy-MM-dd HH:mm:ss.SSS")} =====================\n\n`));
}
footer() {
this.#writer.flush(); //将未写入文件的日志缓存写入
this.#writer.writeSync(Buffer.from(`\n\n===================== LOG END ${dateFormat(new Date(), "yyyy-MM-dd HH:mm:ss.SSS")} =====================\n\n`));
}
success(...params) {
const content = new LogText(Logger.Level.Success, ...params).toString();
console.info(content[Logger.LevelColor[Logger.Level.Success]]);
this.#writer.push(content + "\n");
}
info(...params) {
const content = new LogText(Logger.Level.Info, ...params).toString();
console.info(content[Logger.LevelColor[Logger.Level.Info]]);
this.#writer.push(content + "\n");
}
log(...params) {
const content = new LogText(Logger.Level.Log, ...params).toString();
console.log(content[Logger.LevelColor[Logger.Level.Log]]);
this.#writer.push(content + "\n");
}
debug(...params) {
if(!config.system.debug) return; //非调试模式忽略debug
const content = new LogText(Logger.Level.Debug, ...params).toString();
console.debug(content[Logger.LevelColor[Logger.Level.Debug]]);
this.#writer.push(content + "\n");
}
warn(...params) {
const content = new LogText(Logger.Level.Warning, ...params).toString();
console.warn(content[Logger.LevelColor[Logger.Level.Warning]]);
this.#writer.push(content + "\n");
}
error(...params) {
const content = new LogText(Logger.Level.Error, ...params).toString();
console.error(content[Logger.LevelColor[Logger.Level.Error]]);
this.#writer.push(content);
}
fatal(...params) {
const content = new LogText(Logger.Level.Fatal, ...params).toString();
console.error(content[Logger.LevelColor[Logger.Level.Fatal]]);
this.#writer.push(content);
}
destory() {
this.#writer.destory();
}
}
export default new Logger();

72
src/lib/request/Request.ts Normal file
View File

@ -0,0 +1,72 @@
import _ from 'lodash';
import APIException from '@/lib/exceptions/APIException.ts';
import EX from '@/api/consts/exceptions.ts';
import logger from '@/lib/logger.ts';
import util from '@/lib/util.ts';
export interface RequestOptions {
time?: number;
}
export default class Request {
/** 请求方法 */
method: string;
/** 请求URL */
url: string;
/** 请求路径 */
path: string;
/** 请求载荷类型 */
type: string;
/** 请求headers */
headers: any;
/** 请求原始查询字符串 */
search: string;
/** 请求查询参数 */
query: any;
/** 请求URL参数 */
params: any;
/** 请求载荷 */
body: any;
/** 上传的文件 */
files: any[];
/** 客户端IP地址 */
remoteIP: string | null;
/** 请求接受时间戳（毫秒） */
time: number;
constructor(ctx, options: RequestOptions = {}) {
const { time } = options;
this.method = ctx.request.method;
this.url = ctx.request.url;
this.path = ctx.request.path;
this.type = ctx.request.type;
this.headers = ctx.request.headers || {};
this.search = ctx.request.search;
this.query = ctx.query || {};
this.params = ctx.params || {};
this.body = ctx.request.body || {};
this.files = ctx.request.files || {};
this.remoteIP = this.headers["X-Real-IP"] || this.headers["x-real-ip"] || this.headers["X-Forwarded-For"] || this.headers["x-forwarded-for"] || ctx.ip || null;
this.time = Number(_.defaultTo(time, util.timestamp()));
}
validate(key: string, fn?: Function) {
try {
const value = _.get(this, key);
if (fn) {
if (fn(value) === false)
throw `[Mismatch] -> ${fn}`;
}
else if (_.isUndefined(value))
throw '[Undefined]';
}
catch (err) {
logger.warn(`Params ${key} invalid:`, err);
throw new APIException(EX.API_REQUEST_PARAMS_INVALID, `Params ${key} invalid`);
}
return this;
}
}

41
src/lib/response/Body.ts Normal file
View File

@ -0,0 +1,41 @@
import _ from 'lodash';
export interface BodyOptions {
code?: number;
message?: string;
data?: any;
statusCode?: number;
}
export default class Body {
/** 状态码 */
code: number;
/** 状态消息 */
message: string;
/** 载荷 */
data: any;
/** HTTP状态码 */
statusCode: number;
constructor(options: BodyOptions = {}) {
const { code, message, data, statusCode } = options;
this.code = Number(_.defaultTo(code, 0));
this.message = _.defaultTo(message, 'OK');
this.data = _.defaultTo(data, null);
this.statusCode = Number(_.defaultTo(statusCode, 200));
}
toObject() {
return {
code: this.code,
message: this.message,
data: this.data
};
}
static isInstance(value) {
return value instanceof Body;
}
}

31
src/lib/response/FailureBody.ts Normal file
View File

@ -0,0 +1,31 @@
import _ from 'lodash';
import Body from './Body.ts';
import Exception from '../exceptions/Exception.ts';
import APIException from '../exceptions/APIException.ts';
import EX from '../consts/exceptions.ts';
import HTTP_STATUS_CODES from '../http-status-codes.ts';
export default class FailureBody extends Body {
constructor(error: APIException | Exception | Error, _data?: any) {
let errcode, errmsg, data = _data, httpStatusCode = HTTP_STATUS_CODES.OK;;
if(_.isString(error))
error = new Exception(EX.SYSTEM_ERROR, error);
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);
super({
code: errcode || -1,
message: errmsg || 'Internal error',
data,
statusCode: httpStatusCode
});
}
static isInstance(value) {
return value instanceof FailureBody;
}
}

63
src/lib/response/Response.ts Normal file
View File

@ -0,0 +1,63 @@
import mime from 'mime';
import _ from 'lodash';
import Body from './Body.ts';
import util from '../util.ts';
export interface ResponseOptions {
statusCode?: number;
type?: string;
headers?: Record<string, any>;
redirect?: string;
body?: any;
size?: number;
time?: number;
}
export default class Response {
/** 响应HTTP状态码 */
statusCode: number;
/** 响应内容类型 */
type: string;
/** 响应headers */
headers: Record<string, any>;
/** 重定向目标 */
redirect: string;
/** 响应载荷 */
body: any;
/** 响应载荷大小 */
size: number;
/** 响应时间戳 */
time: number;
constructor(body: any, options: ResponseOptions = {}) {
const { statusCode, type, headers, redirect, size, time } = options;
this.statusCode = Number(_.defaultTo(statusCode, Body.isInstance(body) ? body.statusCode : undefined))
this.type = type;
this.headers = headers;
this.redirect = redirect;
this.size = size;
this.time = Number(_.defaultTo(time, util.timestamp()));
this.body = body;
}
injectTo(ctx) {
this.redirect && ctx.redirect(this.redirect);
this.statusCode && (ctx.status = this.statusCode);
this.type && (ctx.type = mime.getType(this.type) || this.type);
const headers = this.headers || {};
if(this.size && !headers["Content-Length"] && !headers["content-length"])
headers["Content-Length"] = this.size;
ctx.set(headers);
if(Body.isInstance(this.body))
ctx.body = this.body.toObject();
else
ctx.body = this.body;
}
static isInstance(value) {
return value instanceof Response;
}
}

19
src/lib/response/SuccessfulBody.ts Normal file
View File

@ -0,0 +1,19 @@
import _ from 'lodash';
import Body from './Body.ts';
export default class SuccessfulBody extends Body {
constructor(data: any, message?: string) {
super({
code: 0,
message: _.defaultTo(message, "OK"),
data
});
}
static isInstance(value) {
return value instanceof SuccessfulBody;
}
}

169
src/lib/server.ts Normal file
View File

@ -0,0 +1,169 @@
import Koa from 'koa';
import KoaRouter from 'koa-router';
import koaRange from 'koa-range';
import koaCors from "koa2-cors";
import koaBody from 'koa-body';
import _ from 'lodash';
import Exception from './exceptions/Exception.ts';
import Request from './request/Request.ts';
import Response from './response/Response.js';
import FailureBody from './response/FailureBody.ts';
import EX from './consts/exceptions.ts';
import logger from './logger.ts';
import config from './config.ts';
class Server {
app;
router;
constructor() {
this.app = new Koa();
this.app.use(koaCors());
// 范围请求支持
this.app.use(koaRange);
this.router = new KoaRouter({ prefix: config.service.urlPrefix });
// 前置处理异常拦截
this.app.use(async (ctx: any, next: Function) => {
if(ctx.request.type === "application/xml" || ctx.request.type === "application/ssml+xml")
ctx.req.headers["content-type"] = "text/xml";
try { await next() }
catch (err) {
logger.error(err);
const failureBody = new FailureBody(err);
new Response(failureBody).injectTo(ctx);
}
});
// 载荷解析器支持
this.app.use(koaBody(_.clone(config.system.requestBody)));
this.app.on("error", (err: any) => {
// 忽略连接重试、中断、管道、取消错误
if (["ECONNRESET", "ECONNABORTED", "EPIPE", "ECANCELED"].includes(err.code)) return;
logger.error(err);
});
logger.success("Server initialized");
}
/**
* 附加路由
*
* @param routes 路由列表
*/
attachRoutes(routes: any[]) {
routes.forEach((route: any) => {
const prefix = route.prefix || "";
for (let method in route) {
if(method === "prefix") continue;
if (!_.isObject(route[method])) {
logger.warn(`Router ${prefix} ${method} invalid`);
continue;
}
for (let uri in route[method]) {
this.router[method](`${prefix}${uri}`, async ctx => {
const { request, response } = await this.#requestProcessing(ctx, route[method][uri]);
if(response != null && config.system.requestLog)
logger.info(`<- ${request.method} ${request.url} ${response.time - request.time}ms`);
});
}
}
logger.info(`Route ${config.service.urlPrefix || ""}${prefix} attached`);
});
this.app.use(this.router.routes());
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 response = new Response(failureBody);
response.injectTo(ctx);
if(config.system.requestLog)
logger.info(`<- ${request.method} ${request.url} ${response.time - request.time}ms`);
});
}
/**
* 请求处理
*
* @param ctx 上下文
* @param routeFn 路由方法
*/
#requestProcessing(ctx: any, routeFn: Function): Promise<any> {
return new Promise(resolve => {
const request = new Request(ctx);
try {
if(config.system.requestLog)
logger.info(`-> ${request.method} ${request.url}`);
routeFn(request)
.then(response => {
try {
if(!Response.isInstance(response)) {
const _response = new Response(response);
_response.injectTo(ctx);
return resolve({ request, response: _response });
}
response.injectTo(ctx);
resolve({ request, response });
}
catch(err) {
logger.error(err);
const failureBody = new FailureBody(err);
const response = new Response(failureBody);
response.injectTo(ctx);
resolve({ request, response });
}
})
.catch(err => {
try {
logger.error(err);
const failureBody = new FailureBody(err);
const response = new Response(failureBody);
response.injectTo(ctx);
resolve({ request, response });
}
catch(err) {
logger.error(err);
const failureBody = new FailureBody(err);
const response = new Response(failureBody);
response.injectTo(ctx);
resolve({ request, response });
}
});
}
catch(err) {
logger.error(err);
const failureBody = new FailureBody(err);
const response = new Response(failureBody);
response.injectTo(ctx);
resolve({ request, response });
}
});
}
/**
* 监听端口
*/
async listen() {
const host = config.service.host;
const port = config.service.port;
await Promise.all([
new Promise((resolve, reject) => {
if(host === "0.0.0.0" || host === "localhost" || host === "127.0.0.1")
return resolve(null);
this.app.listen(port, "localhost", err => {
if(err) return reject(err);
resolve(null);
});
}),
new Promise((resolve, reject) => {
this.app.listen(port, host, err => {
if(err) return reject(err);
resolve(null);
});
})
]);
logger.success(`Server listening on port ${port} (${host})`);
}
}
export default new Server();

276
src/lib/util.ts Normal file
View File

@ -0,0 +1,276 @@
import os from 'os';
import path from 'path';
import crypto from 'crypto';
import { Readable, Writable } from 'stream';
import 'colors';
import mime from 'mime';
import fs from 'fs-extra';
import { v1 as uuid } from 'uuid';
import { format as dateFormat } from 'date-fns';
import CRC32 from 'crc-32';
import randomstring from 'randomstring';
import _ from 'lodash';
import { CronJob } from 'cron';
import { SocksProxyAgent } from 'socks-proxy-agent';
import { HttpsProxyAgent } from 'https-proxy-agent';
import type { ProxyAgent } from './configs/api-config.ts';
import HTTP_STATUS_CODE from './http-status-codes.ts';
const autoIdMap = new Map();
const util = {
is2DArrays(value: any) {
return _.isArray(value) && (!value[0] || (_.isArray(value[0]) && _.isArray(value[value.length - 1])));
},
uuid: (separator = true) => separator ? uuid() : uuid().replace(/\-/g, ""),
autoId: (prefix = '') => {
let index = autoIdMap.get(prefix);
if(index > 999999) index = 0; //超过最大数字则重置为0
autoIdMap.set(prefix, (index || 0) + 1);
return `${prefix}${index || 1}`;
},
ignoreJSONParse(value: string) {
const result = _.attempt(() => JSON.parse(value));
if(_.isError(result))
return null;
return result;
},
generateRandomString(options: any): string {
return randomstring.generate(options);
},
getResponseContentType(value: any): string | null {
return value.headers ? (value.headers["content-type"] || value.headers["Content-Type"]) : null;
},
mimeToExtension(value: string) {
let extension = mime.getExtension(value);
if(extension == "mpga")
return "mp3";
return extension;
},
extractURLExtension(value: string) {
const extname = path.extname(new URL(value).pathname);
return extname.substring(1).toLowerCase();
},
createCronJob(cronPatterns: any, callback?: Function) {
if(!_.isFunction(callback)) throw new Error("callback must be an Function");
return new CronJob(cronPatterns, () => callback(), null, false, "Asia/Shanghai");
},
createProxyAgent(options: ProxyAgent) {
const { enable, protocol, host, port } = options;
if(enable === false)
return null;
switch(protocol) {
case "socks5":
return new SocksProxyAgent(`${protocol}://${host}:${port}`);
case "http":
case "https":
return new HttpsProxyAgent(`${protocol}://${host}:${port}`);
default:
throw new Error(`protocol ${protocol} is not supported`);
}
},
getDateString(format = "yyyy-MM-dd", date = new Date()) {
return dateFormat(date, format);
},
getIPAddressesByIPv4(): string[] {
const interfaces = os.networkInterfaces();
const addresses = [];
for (let name in interfaces) {
const networks = interfaces[name];
const results = networks.filter(network => network.family === "IPv4" && network.address !== "127.0.0.1" && !network.internal);
if (results[0] && results[0].address)
addresses.push(results[0].address);
}
return addresses;
},
getMACAddressesByIPv4(): string[] {
const interfaces = os.networkInterfaces();
const addresses = [];
for (let name in interfaces) {
const networks = interfaces[name];
const results = networks.filter(network => network.family === "IPv4" && network.address !== "127.0.0.1" && !network.internal);
if (results[0] && results[0].mac)
addresses.push(results[0].mac);
}
return addresses;
},
generateSSEData(event?: string, data?: string, retry?: number) {
return `event: ${event || "message"}\ndata: ${(data || "").replace(/\n/g, "\\n").replace(/\s/g, "\\s")}\nretry: ${retry || 3000}\n\n`;
},
buildDataBASE64(type, ext, buffer) {
return `data:${type}/${ext.replace("jpg", "jpeg")};base64,${buffer.toString("base64")}`;
},
isLinux() {
return os.platform() !== "win32";
},
isIPAddress(value) {
return _.isString(value) && (/^((2[0-4]\d|25[0-5]|[01]?\d\d?)\.){3}(2[0-4]\d|25[0-5]|[01]?\d\d?)$/.test(value) || /\s*((([0-9A-Fa-f]{1,4}:){7}([0-9A-Fa-f]{1,4}|:))|(([0-9A-Fa-f]{1,4}:){6}(:[0-9A-Fa-f]{1,4}|((25[0-5]|2[0-4]\d|1\d\d|[1-9]?\d)(\.(25[0-5]|2[0-4]\d|1\d\d|[1-9]?\d)){3})|:))|(([0-9A-Fa-f]{1,4}:){5}(((:[0-9A-Fa-f]{1,4}){1,2})|:((25[0-5]|2[0-4]\d|1\d\d|[1-9]?\d)(\.(25[0-5]|2[0-4]\d|1\d\d|[1-9]?\d)){3})|:))|(([0-9A-Fa-f]{1,4}:){4}(((:[0-9A-Fa-f]{1,4}){1,3})|((:[0-9A-Fa-f]{1,4})?:((25[0-5]|2[0-4]\d|1\d\d|[1-9]?\d)(\.(25[0-5]|2[0-4]\d|1\d\d|[1-9]?\d)){3}))|:))|(([0-9A-Fa-f]{1,4}:){3}(((:[0-9A-Fa-f]{1,4}){1,4})|((:[0-9A-Fa-f]{1,4}){0,2}:((25[0-5]|2[0-4]\d|1\d\d|[1-9]?\d)(\.(25[0-5]|2[0-4]\d|1\d\d|[1-9]?\d)){3}))|:))|(([0-9A-Fa-f]{1,4}:){2}(((:[0-9A-Fa-f]{1,4}){1,5})|((:[0-9A-Fa-f]{1,4}){0,3}:((25[0-5]|2[0-4]\d|1\d\d|[1-9]?\d)(\.(25[0-5]|2[0-4]\d|1\d\d|[1-9]?\d)){3}))|:))|(([0-9A-Fa-f]{1,4}:){1}(((:[0-9A-Fa-f]{1,4}){1,6})|((:[0-9A-Fa-f]{1,4}){0,4}:((25[0-5]|2[0-4]\d|1\d\d|[1-9]?\d)(\.(25[0-5]|2[0-4]\d|1\d\d|[1-9]?\d)){3}))|:))|(:(((:[0-9A-Fa-f]{1,4}){1,7})|((:[0-9A-Fa-f]{1,4}){0,5}:((25[0-5]|2[0-4]\d|1\d\d|[1-9]?\d)(\.(25[0-5]|2[0-4]\d|1\d\d|[1-9]?\d)){3}))|:)))(%.+)?\s*/.test(value));
},
isPort(value) {
return _.isNumber(value) && value > 0 && value < 65536;
},
isReadStream(value): boolean {
return value && (value instanceof Readable || "readable" in value || value.readable);
},
isWriteStream(value): boolean {
return value && (value instanceof Writable || "writable" in value || value.writable);
},
isHttpStatusCode(value) {
return _.isNumber(value) && Object.values(HTTP_STATUS_CODE).includes(value);
},
isURL(value) {
return !_.isUndefined(value) && /^(http|https)/.test(value);
},
isSrc(value) {
return !_.isUndefined(value) && /^\/.+\.[0-9a-zA-Z]+(\?.+)?$/.test(value);
},
isBASE64(value) {
return !_.isUndefined(value) && /^[a-zA-Z0-9\/\+]+(=?)+$/.test(value);
},
isBASE64Image(value) {
return /^data:image/.test(value);
},
extractBASE64ImageFormat(value): string | null {
const match = value.trim().match(/^data:image\/(.+);base64,/);
if(!match) return null;
return match[1];
},
removeBASE64ImageHeader(value): string {
return value.replace(/^data:image\/(.+);base64,/, "");
},
isDataString(value): boolean {
return /^(base64|json):/.test(value);
},
isStringNumber(value) {
return _.isFinite(Number(value));
},
isUnixTimestamp(value) {
return /^[0-9]{10}$/.test(`${value}`);
},
isTimestamp(value) {
return /^[0-9]{13}$/.test(`${value}`);
},
isEmail(value) {
return /^([a-zA-Z0-9]+[_|\_|\.]?)*[a-zA-Z0-9]+@([a-zA-Z0-9]+[_|\_|\.]?)*[a-zA-Z0-9]+\.[a-zA-Z]{2,3}$/.test(value);
},
isAsyncFunction(value) {
return Object.prototype.toString.call(value) === "[object AsyncFunction]";
},
async isAPNG(filePath) {
let head;
const readStream = fs.createReadStream(filePath, { start: 37, end: 40 });
const readPromise = new Promise((resolve, reject) => {
readStream.once("end", resolve);
readStream.once("error", reject);
});
readStream.once("data", data => head = data);
await readPromise;
return head.compare(Buffer.from([0x61, 0x63, 0x54, 0x4c])) === 0;
},
unixTimestamp() {
return parseInt(`${Date.now() / 1000}`);
},
timestamp() {
return Date.now();
},
urlJoin(...values) {
let url = "";
for (let i = 0; i < values.length; i++)
url += `${i > 0 ? "/" : ""}${values[i].replace(/^\/*/, "").replace(/\/*$/, "")}`;
return url;
},
millisecondsToHmss(milliseconds) {
if (_.isString(milliseconds)) return milliseconds;
milliseconds = parseInt(milliseconds);
const sec = Math.floor(milliseconds / 1000);
const hours = Math.floor(sec / 3600);
const minutes = Math.floor((sec - hours * 3600) / 60);
const seconds = sec - hours * 3600 - minutes * 60;
const ms = milliseconds % 60000 - seconds * 1000;
return `${hours > 9 ? hours : "0" + hours}:${minutes > 9 ? minutes : "0" + minutes}:${seconds > 9 ? seconds : "0" + seconds}.${ms}`;
},
millisecondsToTimeString(milliseconds) {
if(milliseconds < 1000)
return `${milliseconds}ms`;
if(milliseconds < 60000)
return `${parseFloat((milliseconds / 1000).toFixed(2))}s`;
return `${Math.floor(milliseconds / 1000 / 60)}m${Math.floor(milliseconds / 1000 % 60)}s`;
},
rgbToHex(r, g, b): string {
return ((1 << 24) + (r << 16) + (g << 8) + b).toString(16).slice(1);
},
hexToRgb(hex) {
const value = parseInt(hex.replace(/^#/, ""), 16);
return [(value >> 16) & 255, (value >> 8) & 255, value & 255];
},
md5(value) {
return crypto.createHash("md5").update(value).digest("hex");
},
crc32(value) {
return _.isBuffer(value) ? CRC32.buf(value) : CRC32.str(value);
},
arrayParse(value): any[] {
return _.isArray(value) ? value : [value];
},
booleanParse(value) {
return value === "true" || value === true ? true : false
},
encodeBASE64(value) {
return Buffer.from(value).toString("base64");
},
decodeBASE64(value) {
return Buffer.from(value, "base64").toString();
},
};
export default util;

16
tsconfig.json Normal file
View File

@ -0,0 +1,16 @@
{
"compilerOptions": {
"baseUrl": ".",
"module": "NodeNext",
"moduleResolution": "NodeNext",
"allowImportingTsExtensions": true,
"allowSyntheticDefaultImports": true,
"noEmit": true,
"paths": {
"@/*": ["src/*"]
},
"outDir": "./dist"
},
"include": ["src/**/*", "libs.d.ts"],
"exclude": ["node_modules", "dist"]
}