feat: 优化netTool,使用netTool封装的方法返回响应对象
All checks were successful
Egg CI/CD / build-image (push) Successful in 28s
Egg CI/CD / deploy (push) Successful in 21s

This commit is contained in:
zhaoyingbo 2024-07-12 10:43:59 +00:00
parent 0c6ab743db
commit 3f71247287
4 changed files with 26 additions and 15 deletions

View File

@ -3,6 +3,7 @@ import { manageMessageReq } from "./routes/message";
import { manageMicroAppReq } from "./routes/microApp";
import { manageSheetReq } from "./routes/sheet";
import { initSchedule } from "./schedule";
import netTool from "./services/netTool";
initSchedule();
@ -11,7 +12,7 @@ const server = Bun.serve({
try {
const url = new URL(req.url);
// 根路由
if (url.pathname === "/") return new Response("hello, glade to see you!");
if (url.pathname === "/") return netTool.ok("hello, glade to see you!");
// 机器人
if (url.pathname === "/bot") return await manageBotReq(req);
// 消息代理发送
@ -22,11 +23,11 @@ const server = Bun.serve({
if (url.pathname.startsWith("/micro_app"))
return await manageMicroAppReq(req);
// 其他
return new Response("hello, glade to see you!");
return netTool.ok("hello, glade to see you!");
} catch (error: any) {
// 错误处理
console.error("🚀 ~ serve ~ error", error);
return new Response(error.message || "server error", { status: 500 });
return netTool.serverError(error.message || "server error");
}
},
port: 3000,

View File

@ -1,3 +1,4 @@
import netTool from "../../services/netTool";
import { manageActionMsg } from "./actionMsg";
import { manageEventMsg } from "./eventMsg";
@ -9,8 +10,9 @@ export const manageBotReq = async (req: Request) => {
return Response.json({ challenge: body?.challenge });
}
// 处理Event消息
if (manageEventMsg(body)) return new Response("success");
if (manageEventMsg(body)) return netTool.ok();
// 处理Action消息
if (manageActionMsg(body)) return new Response("success");
return new Response("hello, glade to see you!");
if (manageActionMsg(body)) return netTool.ok();
// 其他
return netTool.ok();
};

View File

@ -1,4 +1,5 @@
import service from "../../services";
import netTool from "../../services/netTool";
import { trimPathPrefix } from "../../utils/pathTools";
/**
@ -11,7 +12,7 @@ const manageLogin = async (req: Request) => {
const code = url.searchParams.get("code");
const appName = url.searchParams.get("app_name") || undefined;
if (!code) {
return new Response("code not found", { status: 400 });
return netTool.badRequest("code not found");
}
const {
code: resCode,
@ -46,10 +47,10 @@ const manageBatchUser = async (req: Request) => {
console.log("🚀 ~ manageBatchUser ~ body:", body);
const { user_ids, user_id_type, app_name } = body;
if (!user_ids) {
return new Response("user_ids not found", { status: 400 });
return netTool.badRequest("user_ids not found");
}
if (!user_id_type) {
return new Response("user_id_type not found", { status: 400 });
return netTool.badRequest("user_id_type not found");
}
const { code, data, msg } = await service.lark.user.batchGet(app_name)(
@ -88,5 +89,5 @@ export const manageMicroAppReq = async (req: Request) => {
if (withoutPrefix === "/batch_user") {
return manageBatchUser(req);
}
return new Response("hello, glade to see you!");
return netTool.ok();
};

View File

@ -191,34 +191,41 @@ netTool.patch = <T = any>(
* 400 Bad Request的响应对象
*
* @param msg -
* @param requestId - ID
* @returns 400 Bad Request的响应对象
*/
netTool.badRequest = (msg: string) => new Response(msg, { status: 400 });
netTool.badRequest = (msg: string, requestId?: string) =>
Response.json({ code: 400, msg, requestId }, { status: 400 });
/**
* 404 Not Found的响应对象
*
* @param msg -
* @param requestId - ID
* @returns 404 Not Found的响应对象
*/
netTool.notFound = (msg: string) => new Response(msg, { status: 404 });
netTool.notFound = (msg: string, requestId?: string) =>
Response.json({ code: 404, msg, requestId }, { status: 404 });
/**
* 500 Internal Server Error的响应对象
*
* @param msg -
* @param data -
* @param requestId - ID
* @returns 500 Internal Server Error的响应对象
*/
netTool.serverError = (msg: string, data: any) =>
Response.json({ code: 500, msg, data }, { status: 500 });
netTool.serverError = (msg: string, data?: any, requestId?: string) =>
Response.json({ code: 500, msg, data, requestId }, { status: 500 });
/**
* 200 OK的响应对象
*
* @param data -
* @param requestId - ID
* @returns 200 OK的响应对象
*/
netTool.ok = (data?: any) => Response.json({ code: 200, msg: "ok", data });
netTool.ok = (data?: any, requestId?: string) =>
Response.json({ code: 200, msg: "ok", data, requestId });
export default netTool;