Oak-Team
/
oak-cli
13
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 19 Wiki Activity

start适配现有的connector

This commit is contained in:
Xu Chang 2024-02-29 08:39:39 +08:00
parent 2f60f3cb70
commit 064a65c51e
2 changed files with 2 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
lib/server/start.js
View File

@ -85,8 +85,7 @@ async function startup(path, contextBuilder, connector, omitWatchers, omitTimers
} }
router.post(connector.getRouter(), async (ctx) => { router.post(connector.getRouter(), async (ctx) => {
const { request } = ctx; const { request } = ctx;
const data = request.files ? Object.assign({}, request.body, request.files) : request.body; // 这里处理multiPart的文件，不是太好 const { contextString, aspectName, data } = connector.parseRequest(request.headers, request.body, request.files);
const { contextString, aspectName } = connector.parseRequestHeaders(request.headers);
const { result, opRecords, message } = await appLoader.execAspect(aspectName, request.headers, contextString, data); const { result, opRecords, message } = await appLoader.execAspect(aspectName, request.headers, contextString, data);
const { body, headers } = await connector.serializeResult(result, opRecords, request.headers, request.body, message); const { body, headers } = await connector.serializeResult(result, opRecords, request.headers, request.body, message);
ctx.response.body = body; ctx.response.body = body;

3
src/server/start.ts
View File

@ -97,8 +97,7 @@ export async function startup<ED extends EntityDict & BaseEntityDict, Cxt extend
router.post(connector.getRouter(), async (ctx) => { router.post(connector.getRouter(), async (ctx) => {
const { request } = ctx; const { request } = ctx;
const data = request.files ? Object.assign({}, request.body, request.files) : request.body; // 这里处理multiPart的文件，不是太好 const { contextString, aspectName, data } = connector.parseRequest(request.headers, request.body, request.files);
const { contextString, aspectName } = connector.parseRequestHeaders(request.headers);
const { result, opRecords, message } = await appLoader.execAspect(aspectName, request.headers, contextString, data); const { result, opRecords, message } = await appLoader.execAspect(aspectName, request.headers, contextString, data);
const { body, headers } = await connector.serializeResult(result, opRecords, request.headers, request.body, message); const { body, headers } = await connector.serializeResult(result, opRecords, request.headers, request.body, message);