@lynq/lynq
v0.1.0
Published
Lightweight MCP server framework. Tool visibility control through middleware.
Maintainers
Readme
lynq
Lightweight MCP server framework. Tool visibility control through middleware.
import { createMCPServer } from "lynq";
import { auth } from "lynq/auth";
import { z } from "zod";
const server = createMCPServer({ name: "my-server", version: "1.0.0" });
// Login tool — always visible
server.tool("login", {
input: z.object({ username: z.string(), password: z.string() }),
}, async (args, ctx) => {
const user = await authenticate(args.username, args.password);
ctx.session.set("user", user);
ctx.session.authorize("auth");
return { content: [{ type: "text", text: `Welcome, ${user.name}` }] };
});
// Weather tool — hidden until authenticated
server.tool("weather", auth(), {
description: "Get weather for a city",
input: z.object({ city: z.string() }),
}, async (args) => {
const data = await fetchWeather(args.city);
return { content: [{ type: "text", text: JSON.stringify(data) }] };
});
await server.stdio();Install
npm install lynq @modelcontextprotocol/sdk zodWhy lynq
When you build an MCP server, you often need to show different tools depending on session state — hide admin tools from unauthenticated users, reveal features after onboarding, etc. The MCP protocol supports this via bidirectional tool list notifications, but wiring it by hand means managing visibility sets, diffing tool lists, and calling sendToolListChanged at the right time. lynq lets you declare visibility as middleware and handles the rest.
API
createMCPServer(info)
Creates a server instance.
const server = createMCPServer({ name: "my-server", version: "1.0.0" });server.tool(name, ...middlewares?, config, handler)
Register a tool. Middlewares are optional, config holds description and input schema.
server.tool("greet", {
description: "Greet someone",
input: z.object({ name: z.string() }),
}, async (args) => ({
content: [{ type: "text", text: `Hello ${args.name}` }],
}));
server.tool("secret", auth(), {
input: z.object({ query: z.string() }),
}, async (args) => ({
content: [{ type: "text", text: args.query }],
}));server.resource(uri, ...middlewares?, config, handler)
Register a resource. Same middleware pattern as tool(). Global middleware (server.use()) does not apply to resources.
server.resource("config://settings", {
name: "App Settings",
mimeType: "application/json",
}, async (uri) => ({
text: JSON.stringify(config),
}));
server.resource("data://users", auth(), {
name: "User Database",
mimeType: "application/json",
}, async (uri, ctx) => ({
text: JSON.stringify(await db.getUsers()),
}));server.use(middleware)
Apply middleware to all subsequently registered tools.
server.use(auth());Session
Available in handlers and middleware via ctx.session:
ctx.session.set("key", value);
ctx.session.get("key");
ctx.session.authorize("auth"); // Enable tools guarded by "auth" middlewareauth(options?)
Middleware that hides tools until authenticated.
import { auth } from "lynq/auth";
auth(); // checks ctx.session.get("user")
auth({ sessionKey: "token" }); // checks ctx.session.get("token")
auth({ message: "Login first" }); // custom error messageTesting
lynq ships a test helper that eliminates MCP boilerplate. No manual Client/InMemoryTransport setup.
import { createTestClient } from "lynq/test";
import { createMCPServer } from "lynq";
import { auth } from "lynq/auth";
import { z } from "zod";
const server = createMCPServer({ name: "my-server", version: "1.0.0" });
server.tool("weather", auth(), {
input: z.object({ city: z.string() }),
}, async (args) => ({
content: [{ type: "text", text: `Sunny in ${args.city}` }],
}));
const t = await createTestClient(server);
// Tool visibility
const tools = await t.listTools(); // string[]
expect(tools).not.toContain("weather");
// Authorize and call
t.authorize("auth");
const text = await t.callToolText("weather", { city: "Tokyo" });
expect(text).toContain("Sunny");
// Full result access
const result = await t.callTool("weather", { city: "Tokyo" });
// Resources
const uris = await t.listResources();
const content = await t.readResource("config://settings");
// Session access
t.session.set("user", { name: "alice" });
await t.close();Custom matchers
Optional vitest/jest matchers for more expressive assertions:
import { matchers } from "lynq/test";
expect.extend(matchers);
const result = await t.callTool("weather", { city: "Tokyo" });
expect(result).toHaveTextContent("Sunny");
expect(result).not.toBeError();License
MIT
