eggjs@eggjs/tegg-controller-plugin
使用注解的方式来开发 egg 中的 Controller
Install
# tegg 注解
npm i --save @eggjs/tegg
# tegg 插件
npm i --save @eggjs/tegg-plugin
# tegg controller 插件
npm i --save @eggjs/tegg-controller-plugin
Prepare
// tsconfig.json
{
"extends": "@eggjs/tsconfig"
}
Config
// config/plugin.js
exports.tegg = {
package: '@eggjs/tegg-plugin',
enable: true,
};
exports.teggController = {
package: '@eggjs/tegg-controller-plugin',
enable: true,
};
Usage
Middleware
Middleware 支持多个入参，依次传入要生效的中间件 中间件注解，可以添加在类/方法上。添加在类上时，对类上所有方法生效，添加在方法上时，只对当前方法生效。
// app/middleware/global_log.ts
import { Context } from 'egg';
import type { Next } from '@eggjs/controller-decorator';
export default async function globalLog(ctx: Context, next: Next) {
ctx.logger.info('have a request');
return next();
}
export default async function globalLog2(ctx: Context, next: Next) {
ctx.logger.info('have a request2');
return next();
}
// app/controller/FooController.ts
import { Middleware } from '@eggjs/tegg';
@Middleware(globalLog,globalLog2)
export class FooController {
@Middleware(methodCount)
async hello() {
}
}
Context
当需要 egg context 时，可以使用 @Context 注解来声明。
// app/controller/FooController.ts
import { Context, EggContext } from '@eggjs/tegg';
export class FooController {
@Middleware(methodCount)
async hello(@Context() ctx: EggContext) {
}
}
HTTP 注解
HTTPController/HTTPMethod
@HTTPController 注解用来声明当前类是一个 HTTP controller，可以配置路径前缀。
@HTTPMethod 注解用来声明当前方法是一个 HTTP method，只有带了这个注解，HTTP 方法才会被暴露出去，可以配置方法路径，
// app/controller/FooController.ts
import { Context, EggContext, HTTPController, HTTPMethod, HTTPMethodEnum } from '@eggjs/tegg';
@HTTPController({
path: '/foo',
})
export class FooController {
@HTTPMethod({
method: HTTPMethodEnum.GET,
path: '/hello',
})
async hello() {
}
}
Param
HTTP 协议中有各种各样的传参方式，比如 query,path,body 等等。
HTTPBody
接收 body 参数
// app/controller/FooController.ts
import { Context, EggContext, HTTPController, HTTPMethod, HTTPMethodEnum, HTTPBody } from '@eggjs/tegg';
@HTTPController({
path: '/foo',
})
export class FooController {
@HTTPMethod({
method: HTTPMethodEnum.GET,
path: '/hello',
})
async hello(@HTTPBody() name: string) {
return `hello, ${name}`;
}
}
HTTPQuery/HTTPQueries
两者的区别在于参数是否为数组， HTTPQuery 只会取第一个参数，HTTPQueries 只提供数组形式。 HTTPQuery 的参数类型只能是 string, HTTPQueries 的参数类型只能是 string[]。
// app/controller/FooController.ts
import { Context, EggContext, HTTPController, HTTPMethod, HTTPMethodEnum, HTTPQuery, HTTPQueries } from '@eggjs/tegg';
@HTTPController({
path: '/foo',
})
export class FooController {
@HTTPMethod({
method: HTTPMethodEnum.GET,
path: '/hello',
})
async hello(
// /foo/hello?name=bar
// HTTPQuery: name=bar
// HTTPQueries: name=[bar]
@HTTPQuery() name: string,
@HTTPQueries() names: string[],
) {
return `hello, ${name}`;
}
}
如果需要使用别名，比如说 query 中的 name 不能在 js 中声明时，如 foo[bar] 这类的。可以通过以下形式
@HTTPQuery({ name: 'foo[bar]' }) fooBar: string,
HTTPParam
接收 path 中的参数，类型只能为 string
// app/controller/FooController.ts
import { Context, EggContext, HTTPController, HTTPMethod, HTTPMethodEnum, HTTPBody } from '@eggjs/tegg';
@HTTPController({
path: '/foo',
})
export class FooController {
@HTTPMethod({
method: HTTPMethodEnum.GET,
path: '/:id',
})
async hello(@HTTPParam() id: string) {
return `hello, ${name}`;
}
}
如果需要使用别名，比如说 path 中使用正则声明 /foo/(.*), 可以通过以下形式
// 具体 name 值可以查看 path-to-regexp
@HTTPParam({ name: '0' }) id: string
Host
Host 注解，用于指定 HTTP 方法仅在 host 匹配时执行。 可以添加在类/方法上。添加在类上时，对类上所有方法生效，添加在方法上时，只对当前方法生效。方法上的注解可以覆盖类上的注解
// app/controller/FooController.ts
import { Host } from '@eggjs/tegg';
@Host('foo.eggjs.com')
export class FooController {
// 仅能通过 foo.eggjs.com 访问
async hello() {
}
// 仅能通过 bar.eggjs.com 访问
@Host('bar.eggjs.com')
async bar() {
}
}
MCP 注解
MCPController/MCPPrompt/MCPTool/MCPResource
@MCPController 注解用来声明当前类是一个 MCP controller。
通过使用装饰器 @MCPPrompt @MCPTool @MCPResource 来声明对应的 MCP 类型。
使用 @ToolArgsSchema @PromptArgsSchema @Extra 来 schema 和 extra。
import {
MCPController,
PromptArgs,
ToolArgs,
MCPPromptResponse,
MCPToolResponse,
MCPResourceResponse,
MCPPrompt,
MCPTool,
MCPResource,
PromptArgsSchema,
Logger,
Inject,
ToolArgsSchema,
} from '@eggjs/tegg';
import z from 'zod';
export const PromptType = {
name: z.string(),
};
export const ToolType = {
name: z.string({
description: 'npm package name',
}),
};
@MCPController()
export class McpController {
@Inject()
logger: Logger;
@MCPPrompt()
async foo(@PromptArgsSchema(PromptType) args: PromptArgs<typeof PromptType>): Promise<MCPPromptResponse> {
this.logger.info('hello world');
return {
messages: [
{
role: 'user',
content: {
type: 'text',
text: `Generate a concise but descriptive commit message for these changes:\n\n${args.name}`,
},
},
],
};
}
@MCPTool()
async bar(@ToolArgsSchema(ToolType) args: ToolArgs<typeof ToolType>): Promise<MCPToolResponse> {
return {
content: [
{
type: 'text',
text: `npm package: ${args.name} not found`,
},
],
};
}
@MCPResource({
template: [
'mcp://npm/{name}{?version}',
{
list: () => {
return {
resources: [
{ name: 'egg', uri: 'mcp://npm/egg?version=4.10.0' },
{ name: 'mcp', uri: 'mcp://npm/mcp?version=0.10.0' },
],
};
},
},
],
})
async car(uri: URL): Promise<MCPResourceResponse> {
return {
contents: [{
uri: uri.toString(),
text: 'MOCK TEXT',
}],
};
}
}
MCP 地址
MCP controller 完整的实现了 SSE / streamable HTTP / streamable stateless HTTP 三种模式，默认情况下，他们的路径分别是 /mcp/init /mcp/stream /mcp/stateless/stream, 你可以根据你所需要的场景，灵活使用对应的接口。
// config.{env}.ts
import { randomUUID } from 'node:crypto';
export default () => {
const config = {
mcp: {
sseInitPath: '/mcp/init', // SSE path
sseMessagePath: '/mcp/message', // SSE message path
streamPath: '/mcp/stream', // streamable path
statelessStreamPath: '/mcp/stateless/stream', // stateless streamable path
sessionIdGenerator: randomUUID,
},
};
return config;
};