Compare commits

...

11 Commits

Author SHA1 Message Date
Michal
fe00f42bce fix(ungated-global): create settings secret with a valid backend FK
Some checks failed
CI/CD / typecheck (pull_request) Successful in 1m19s
CI/CD / test (pull_request) Failing after 27s
CI/CD / lint (pull_request) Successful in 2m50s
CI/CD / smoke (pull_request) Has been skipped
CI/CD / build (pull_request) Has been skipped
CI/CD / publish (pull_request) Has been skipped
bootstrapUngatedGlobal wrote its seed marker into the mcpctl-system-settings
Secret, creating the row with the default backendId '' when it did not exist.
The Secret_backendId_fkey constraint is enforced at insert time, so on a DB
where that secret was absent, mcpd crash-looped on startup (P2003).

Fix: run the seed after bootstrapSecretBackends (so the default plaintext
backend exists) and set backendId to the resolved default on create. If no
backend exists at all, skip writing the marker rather than crash.

Co-Authored-By: Claude Opus 4.8 <noreply@anthropic.com>
2026-10-03 01:57:37 +01:00
7bf9d49a02 Merge pull request 'ungated-global: system project whose servers ride every project, pre-gate' (#137) from feat/ungated-global into main
Some checks failed
CI/CD / lint (push) Successful in 1m13s
CI/CD / test (push) Successful in 1m25s
CI/CD / typecheck (push) Successful in 3m6s
CI/CD / smoke (push) Failing after 1m58s
CI/CD / build (push) Successful in 2m11s
CI/CD / publish (push) Has been skipped
2026-10-03 00:46:08 +00:00
Michal
7b70c91c41 ungated-global: system project whose servers ride every project, pre-gate
Some checks failed
CI/CD / lint (pull_request) Successful in 1m12s
CI/CD / test (pull_request) Successful in 1m26s
CI/CD / typecheck (pull_request) Successful in 3m22s
CI/CD / smoke (pull_request) Failing after 1m57s
CI/CD / build (pull_request) Successful in 5m15s
CI/CD / publish (pull_request) Has been skipped
New seed-once system project `ungated-global`: every server attached to it
is merged into every project's MCP endpoint in front of the gate (listed
and callable before begin_session), and its project prompt is prepended to
every project's instructions.

- mcpd: bootstrapUngatedGlobal seeds the project once-ever (marker key
  `ungatedGlobalSeeded` in mcpctl-system-settings), with default server
  `calcmcp` (patched CalcMCP fork, mysources.co.uk/michal/calcmcp:1.1.0)
  and a "never do math yourself, always use calcmcp" prompt. Deletions are
  durable: `mcpctl delete server calcmcp -p ungated-global` stays deleted.
- mcpd: GET /projects/:id/servers appends global servers flagged
  `ungatedGlobal: true` (direct attachment wins, no self-merge);
  GET /projects/:id/instructions prepends the global prompt and lists the
  global servers.
- mcplocal: discovery surfaces the flagged names; the gate plugin exempts
  them — gated tools/list returns begin_session + exempt tools, calls to
  them pass through without ungating, and initialize instructions list
  them under "Available immediately (no begin_session required)".
- templates/calcmcp.yaml so a deleted default can be re-created by hand.
- docs/ungated-global.md.

Co-Authored-By: Claude Fable 5 <noreply@anthropic.com>
2026-10-03 01:45:44 +01:00
23c8218811 Merge pull request 'templates/ttrss: image 1.0.1 (Sec-Fetch fix + isError)' (#136) from fix/ttrss-template-101 into main
Some checks failed
CI/CD / lint (push) Successful in 1m11s
CI/CD / test (push) Successful in 1m40s
CI/CD / typecheck (push) Successful in 2m56s
CI/CD / smoke (push) Failing after 1m58s
CI/CD / build (push) Successful in 2m10s
CI/CD / publish (push) Has been skipped
2026-10-02 22:56:26 +00:00
Michal
b2aaa9d18d templates/ttrss: image 1.0.1 (node:http Sec-Fetch fix + isError)
Some checks failed
CI/CD / typecheck (pull_request) Successful in 1m17s
CI/CD / test (pull_request) Successful in 1m24s
CI/CD / lint (pull_request) Successful in 2m51s
CI/CD / smoke (pull_request) Failing after 1m57s
CI/CD / build (pull_request) Successful in 5m11s
CI/CD / publish (pull_request) Has been skipped
Co-Authored-By: Claude Opus 4.8 <noreply@anthropic.com>
2026-10-02 23:56:13 +01:00
45b875ae2c Merge pull request 'ambient context: give every project's model a clock' (#135) from feat/ambient-context into main
Some checks failed
CI/CD / lint (push) Successful in 1m16s
CI/CD / test (push) Successful in 1m25s
CI/CD / typecheck (push) Successful in 3m16s
CI/CD / smoke (push) Failing after 1m57s
CI/CD / build (push) Successful in 2m18s
CI/CD / publish (push) Has been skipped
2026-10-01 23:33:38 +00:00
Michal
979e9720c0 ambient context: give every project's model a clock
Some checks failed
CI/CD / lint (pull_request) Successful in 1m16s
CI/CD / test (pull_request) Successful in 1m26s
CI/CD / typecheck (pull_request) Successful in 3m25s
CI/CD / smoke (pull_request) Failing after 1m57s
CI/CD / build (pull_request) Successful in 5m9s
CI/CD / publish (pull_request) Has been skipped
Models consuming projects have no idea what day it is. Three always-on
layers from mcplocal plus one from mcpd:

- initialize instructions and the begin_session briefing carry
  '[context] now: <date/time> — project: <name>' (frozen at session
  start by design);
- a get_current_time virtual tool (ungated catalogs only, same pattern
  as read_prompts);
- every tools/call result gets a trailing '[context] now: …' content
  item at the endpoint send site — the only chokepoint that also covers
  virtual tools, gate intercepts and failure results, and the layer
  that keeps a days-old chat session current;
- mcpd agent/project chat system blocks append the same line each turn.

Time renders as UTC plus an optional local timezone from
MCPLOCAL_AMBIENT_TZ (IANA name; both services read it; invalid or unset
means UTC only). ~15 tokens per stamp, minute precision.

Co-Authored-By: Claude Fable 5 <noreply@anthropic.com>
2026-10-02 00:33:20 +01:00
f9ef4ebcb9 Merge pull request 'templates: jmap, dav, karakeep, ttrss for personal-service projects' (#134) from feat/personal-service-templates into main
Some checks failed
CI/CD / lint (push) Successful in 1m12s
CI/CD / test (push) Successful in 1m49s
CI/CD / typecheck (push) Successful in 3m13s
CI/CD / build (push) Successful in 2m36s
CI/CD / smoke (push) Failing after 3m51s
CI/CD / publish (push) Has been skipped
2026-10-01 22:59:23 +00:00
Michal
1180bbdc1d templates/dav: baked stdio image instead of npx
Some checks failed
CI/CD / typecheck (pull_request) Successful in 1m19s
CI/CD / lint (pull_request) Successful in 2m44s
CI/CD / test (pull_request) Successful in 1m25s
CI/CD / build (pull_request) Successful in 2m46s
CI/CD / smoke (pull_request) Failing after 3m48s
CI/CD / publish (pull_request) Has been skipped
dav-mcp declares tsdav/tsdav-utils as GitHub-URL deps — npx on the
git-less node-runner dies with 'spawn git ENOENT' (observed: dav-michal
CrashLoopBackOff on first deploy). Upstream's ghcr image PID-1s the HTTP
server, so mysources.co.uk/michal/dav-mcp bakes the install and execs
src/server-stdio.js.

Co-Authored-By: Claude Fable 5 <noreply@anthropic.com>
2026-10-01 23:47:12 +01:00
Michal
709068ce68 templates/jmap: drafts3 image + JMAP_REBASE_SESSION_URLS
Some checks failed
CI/CD / lint (pull_request) Successful in 1m14s
CI/CD / test (pull_request) Successful in 1m28s
CI/CD / typecheck (pull_request) Successful in 2m53s
CI/CD / smoke (pull_request) Failing after 2m5s
CI/CD / build (pull_request) Successful in 4m43s
CI/CD / publish (pull_request) Has been skipped
Stalwart's session advertises publicUrl-absolute endpoints; over the
ClusterIP those hairpin through Envoy and 403. Verified in-cluster:
apiUrl came back as https://smtp.ad.itaz.eu/jmap/.

Co-Authored-By: Claude Fable 5 <noreply@anthropic.com>
2026-09-30 01:42:05 +01:00
Michal
c1f0117b80 templates: jmap, dav, karakeep, ttrss for personal-service projects
Some checks failed
CI/CD / typecheck (pull_request) Successful in 1m20s
CI/CD / lint (pull_request) Successful in 2m38s
CI/CD / test (pull_request) Successful in 1m28s
CI/CD / build (pull_request) Successful in 2m26s
CI/CD / smoke (pull_request) Failing after 3m16s
CI/CD / publish (pull_request) Has been skipped
jmap and ttrss are custom images (mysources.co.uk/michal/{jmap-mcp,ttrss-mcp});
dav-mcp and @karakeep/mcp run on the node runner. Health checks are real
backend calls. Applied live 2026-09-30; these seeds keep the next mcpd
image rebuild from reverting them.

Co-Authored-By: Claude Fable 5 <noreply@anthropic.com>
2026-09-30 01:35:43 +01:00
29 changed files with 1260 additions and 27 deletions

56
docs/ungated-global.md Normal file
View File

@@ -0,0 +1,56 @@
# ungated-global: servers under every project, before the gate
`ungated-global` is a system project with one special property: **every server
attached to it is exposed under every project's MCP endpoint, in front of the
gate** — its tools are listed and callable before `begin_session`, and the
project's `prompt` is prepended to every project's instructions.
Fresh mcpd instances seed it **once** with the default `calcmcp` server
(scientific calculator, patched fork of
[thinkitpossible/CalcMCP](https://github.com/thinkitpossible/CalcMCP) at
<https://mysources.co.uk/michal/CalcMCP>) and a prompt telling models to never
do math themselves and always use calcmcp.
## Semantics
- **Seed-once, not resurrect**: the first successful mcpd startup writes
`ungatedGlobalSeeded: true` into the `mcpctl-system-settings` secret. After
that, nothing is ever re-created — deletions are durable:
- `mcpctl delete server calcmcp -p ungated-global` detaches the default
server (delete the server resource itself to also stop its instance);
- deleting the whole `ungated-global` project turns the feature off.
To re-create the default by hand there is a `calcmcp` template:
`mcpctl create server calcmcp --from-template calcmcp`, then attach it to
a (re-created) `ungated-global` project.
- **Merging** happens in mcpd:
- `GET /api/v1/projects/:id/servers` appends ungated-global's servers,
flagged `ungatedGlobal: true`. A server attached to the project directly
wins (no duplicate, no flag).
- `GET /api/v1/projects/:id/instructions` prepends ungated-global's
`prompt` and appends its servers to the server list.
- **Gate exemption** happens in mcplocal: discovery passes the flagged names
into the gate plugin (`ungatedServers`); while a session is gated,
`tools/list` returns `begin_session` **plus** the exempt servers' tools, and
calls to them pass through without triggering the gate intercept or
ungating the session. Initialize instructions list them under
"Available immediately (no begin_session required)".
## Editing the prompt
The pre-gate directive lives on the project itself:
```bash
mcpctl patch project ungated-global --prompt "…"
```
Caveat: clients that ignore MCP initialize instructions (e.g. LibreChat uses
config-literal serverInstructions) never see project prompts — for those, the
carrier is the tool/server descriptions themselves, which is why calcmcp's
server description also says "use it for every mathematical calculation".
## Security note
Anything attached to ungated-global is reachable from **every** project by
**every** token that can reach any project endpoint. Only attach servers that
are safe in every context: no secrets, no egress, no side effects. calcmcp is
pure compute (no env, no network).

View File

@@ -0,0 +1,137 @@
/**
* Bootstrap the `ungated-global` system project.
*
* Servers attached to this project are merged into EVERY project's MCP
* endpoint, in front of the gate: their tools are listed and callable
* before begin_session, and the project's prompt is prepended to every
* project's instructions. See docs/ungated-global.md.
*
* Seeding is ONCE-EVER, not idempotent-per-startup like the other
* bootstraps: the whole point of `mcpctl delete server calcmcp -p
* ungated-global` is that the default stays gone. A marker key in the
* `mcpctl-system-settings` secret records that seeding already happened,
* so later startups leave admin deletions alone.
*/
import type { PrismaClient } from '@prisma/client';
import { SYSTEM_SETTINGS_SECRET } from './system-settings.js';
import { DEFAULT_PLAINTEXT_BACKEND_NAME } from './secret-backends.js';
/** Well-known project whose servers are exposed under every project, pre-gate. */
export const UNGATED_GLOBAL_PROJECT_NAME = 'ungated-global';
/** Settings key: set after the one-time seed so deletions stay deleted. */
export const SETTING_UNGATED_GLOBAL_SEEDED = 'ungatedGlobalSeeded';
/** Well-known email for the system user (shared with bootstrapSystemProject). */
const SYSTEM_USER_EMAIL = 'system@mcpctl.local';
const DEFAULT_SERVER = {
name: 'calcmcp',
description:
'Scientific calculator (SymPy/NumPy/SciPy): symbolic algebra, calculus, '
+ 'equation & ODE solving, linear algebra, statistics, FFT. '
+ 'Use it for EVERY mathematical calculation instead of computing yourself.',
dockerImage: 'mysources.co.uk/michal/calcmcp:1.1.0',
transport: 'STDIO' as const,
repositoryUrl: 'https://mysources.co.uk/michal/CalcMCP',
healthCheck: {
tool: 'symbolic_tool',
arguments: { operation: 'simplify', expression: '1+1' },
intervalSeconds: 300,
timeoutSeconds: 10,
},
};
const DEFAULT_PROMPT = `Mathematical reliability rule: never perform mathematical calculations yourself, not even simple-looking arithmetic. Always use the calcmcp tools (symbolic_tool, numpy_tool, scipy_tool) for every calculation — arithmetic, algebra, calculus, equations, matrices, statistics. They are available immediately, no begin_session needed. Better safe than sorry: if an answer involves numbers, compute it with calcmcp.`;
async function isSeeded(prisma: PrismaClient): Promise<boolean> {
const secret = await prisma.secret.findUnique({ where: { name: SYSTEM_SETTINGS_SECRET } });
if (!secret) return false;
const data = (secret.data ?? {}) as Record<string, unknown>;
return data[SETTING_UNGATED_GLOBAL_SEEDED] === true;
}
async function markSeeded(prisma: PrismaClient): Promise<void> {
const existing = await prisma.secret.findUnique({ where: { name: SYSTEM_SETTINGS_SECRET } });
const data = { ...((existing?.data ?? {}) as Record<string, unknown>), [SETTING_UNGATED_GLOBAL_SEEDED]: true };
const keyNames = Object.keys(data).sort();
if (existing) {
await prisma.secret.update({
where: { name: SYSTEM_SETTINGS_SECRET },
data: { data, keyNames, version: existing.version + 1 },
});
} else {
// The Secret.backendId FK is enforced at insert time, so a fresh row
// must point at a real backend. bootstrapUngatedGlobal runs after
// bootstrapSecretBackends, so the default plaintext backend exists;
// fall back to any backend if the name ever changes.
const backend =
(await prisma.secretBackend.findUnique({ where: { name: DEFAULT_PLAINTEXT_BACKEND_NAME } }))
?? (await prisma.secretBackend.findFirst({ where: { isDefault: true } }))
?? (await prisma.secretBackend.findFirst());
if (!backend) {
// No backend at all — skip marking rather than crash startup. The seed
// above still ran; worst case it re-runs (idempotent upserts) next boot.
console.warn('ungated-global: no SecretBackend found, seed marker not written');
return;
}
await prisma.secret.create({
data: { name: SYSTEM_SETTINGS_SECRET, data, keyNames, backendId: backend.id },
});
}
}
/**
* Seed the ungated-global project with its default calcmcp server, once ever.
* Safe to call on every startup; after the first successful seed (or after an
* admin deletes any of it) nothing is re-created.
*/
export async function bootstrapUngatedGlobal(prisma: PrismaClient): Promise<void> {
if (await isSeeded(prisma)) return;
const systemUser = await prisma.user.upsert({
where: { email: SYSTEM_USER_EMAIL },
create: {
email: SYSTEM_USER_EMAIL,
name: 'System',
passwordHash: '!locked',
role: 'USER',
},
update: {},
});
const project = await prisma.project.upsert({
where: { name: UNGATED_GLOBAL_PROJECT_NAME },
create: {
name: UNGATED_GLOBAL_PROJECT_NAME,
description: 'System project: servers here are exposed under every project, before the gate',
prompt: DEFAULT_PROMPT,
gated: false,
ownerId: systemUser.id,
},
update: {},
});
const server = await prisma.mcpServer.upsert({
where: { name: DEFAULT_SERVER.name },
create: {
name: DEFAULT_SERVER.name,
description: DEFAULT_SERVER.description,
dockerImage: DEFAULT_SERVER.dockerImage,
transport: DEFAULT_SERVER.transport,
repositoryUrl: DEFAULT_SERVER.repositoryUrl,
healthCheck: DEFAULT_SERVER.healthCheck,
},
update: {},
});
await prisma.projectServer.upsert({
where: { projectId_serverId: { projectId: project.id, serverId: server.id } },
create: { projectId: project.id, serverId: server.id },
update: {},
});
await markSeeded(prisma);
console.log(`Seeded ${UNGATED_GLOBAL_PROJECT_NAME} project with default server '${DEFAULT_SERVER.name}'`);
}

View File

@@ -60,6 +60,7 @@ import { PersonalityService } from './services/personality.service.js';
import { registerPersonalityRoutes } from './routes/personalities.js';
import { registerWebUi } from './routes/web-ui.js';
import { bootstrapSystemProject } from './bootstrap/system-project.js';
import { bootstrapUngatedGlobal } from './bootstrap/ungated-global.js';
import { SET_OWN_PASSWORD_OPERATION } from './bootstrap/self-password-permission.js';
import { registerLogRoutes } from './routes/logs.js';
import { errorLogBuffer } from './services/error-log-buffer.js';
@@ -435,6 +436,11 @@ async function main(): Promise<void> {
// pre-existing `Secret` rows are pointed at it. Idempotent per run.
await bootstrapSecretBackends(prisma);
// Seed-once ungated-global project (default calcmcp server, deletable).
// MUST run after bootstrapSecretBackends: its seed marker lives in the
// mcpctl-system-settings Secret, whose creation needs a valid backend FK.
await bootstrapUngatedGlobal(prisma);
// CUID detection for RBAC name resolution
const CUID_RE = /^c[^\s-]{8,}$/i;
const nameResolvers: Record<string, { findById(id: string): Promise<{ name: string } | null> }> = {

View File

@@ -49,21 +49,40 @@ export function registerProjectRoutes(app: FastifyInstance, service: ProjectServ
reply.code(204);
});
// List servers in a project (for mcplocal discovery)
// List servers in a project (for mcplocal discovery). Servers of the
// ungated-global system project ride along for every project, flagged
// `ungatedGlobal: true` so mcplocal exempts them from the gate. A server
// attached to the project directly wins over its global copy.
app.get<{ Params: { id: string } }>('/api/v1/projects/:id/servers', async (request) => {
const project = await service.resolveAndGet(request.params.id);
return project.servers.map((ps) => ps.server);
const own = project.servers.map((ps) => ps.server);
const ownNames = new Set(own.map((s) => (s as Record<string, unknown>).name as string));
const globals = (await service.getGlobalServers(project.name))
.filter((g) => !ownNames.has(g.name as string));
return [...own, ...globals];
});
// Get project instructions for LLM (prompt + server list)
// Get project instructions for LLM (prompt + server list). The
// ungated-global project's prompt is prepended so its directive (e.g.
// "always use calcmcp for math") reaches every project's model pre-gate.
app.get<{ Params: { id: string } }>('/api/v1/projects/:id/instructions', async (request) => {
const project = await service.resolveAndGet(request.params.id);
const globalPrompt = await service.getGlobalPrompt(project.name);
const ownNames = new Set(project.servers.map((ps) => (ps.server as Record<string, unknown>).name as string));
const globals = (await service.getGlobalServers(project.name))
.filter((g) => !ownNames.has(g.name as string));
return {
prompt: project.prompt,
servers: project.servers.map((ps) => ({
name: (ps.server as Record<string, unknown>).name as string,
description: (ps.server as Record<string, unknown>).description as string,
})),
prompt: [globalPrompt, project.prompt].filter(Boolean).join('\n\n'),
servers: [
...project.servers.map((ps) => ({
name: (ps.server as Record<string, unknown>).name as string,
description: (ps.server as Record<string, unknown>).description as string,
})),
...globals.map((g) => ({
name: g.name as string,
description: g.description as string,
})),
],
};
});
}

View File

@@ -22,6 +22,7 @@
* adapter default. `extra` is forwarded as-is for provider-specific knobs.
*/
import type { ChatMessage } from '@prisma/client';
import { ambientContextLine } from '@mcpctl/shared';
import type { AgentService } from './agent.service.js';
import type { LlmService } from './llm.service.js';
import { effectivePoolName } from './llm.service.js';
@@ -728,6 +729,9 @@ export class ChatService {
...sortedProjectPrompts.map((p) => p.content),
...personalityPromptContents,
mergedParams.systemAppend ?? '',
// Rebuilt every turn, so the agent's clock stays current. Reads the
// same MCPLOCAL_AMBIENT_TZ env as mcplocal (see shared/ambient-time).
ambientContextLine(),
]
.filter((s) => s.length > 0)
.join('\n\n');
@@ -842,6 +846,8 @@ export class ChatService {
baseSystem,
...projectPrompts.map((p) => p.content),
mergedParams.systemAppend ?? '',
// Rebuilt every turn — the model's clock (same env as mcplocal).
ambientContextLine(),
]
.filter((s) => s.length > 0)
.join('\n\n');

View File

@@ -2,6 +2,7 @@ import type { IProjectRepository, ProjectWithRelations } from '../repositories/p
import type { IMcpServerRepository } from '../repositories/interfaces.js';
import { CreateProjectSchema, UpdateProjectSchema } from '../validation/project.schema.js';
import { NotFoundError, ConflictError } from './mcp-server.service.js';
import { UNGATED_GLOBAL_PROJECT_NAME } from '../bootstrap/ungated-global.js';
import type { McpConfig } from './mcp-config-generator.js';
export class ProjectService {
@@ -22,6 +23,39 @@ export class ProjectService {
return project;
}
/**
* Servers of the `ungated-global` system project, for merging into another
* project's server list / instructions. Returns [] when asked for the
* global project itself (no self-merge), when the project was deleted, or
* on any lookup failure — global servers are an additive convenience and
* must never break a project endpoint.
*/
async getGlobalServers(forProjectName: string): Promise<Array<Record<string, unknown>>> {
if (forProjectName === UNGATED_GLOBAL_PROJECT_NAME) return [];
try {
const global = await this.projectRepo.findByName(UNGATED_GLOBAL_PROJECT_NAME);
if (global === null) return [];
return global.servers.map((ps) => ({
...(ps.server as unknown as Record<string, unknown>),
ungatedGlobal: true,
}));
} catch {
return [];
}
}
/** Prompt of the `ungated-global` project (prepended to every project's instructions). */
async getGlobalPrompt(forProjectName: string): Promise<string | null> {
if (forProjectName === UNGATED_GLOBAL_PROJECT_NAME) return null;
try {
const global = await this.projectRepo.findByName(UNGATED_GLOBAL_PROJECT_NAME);
const prompt = global?.prompt?.trim();
return prompt ? prompt : null;
} catch {
return null;
}
}
/** Resolve by ID or name. */
async resolveAndGet(idOrName: string): Promise<ProjectWithRelations> {
// Try by ID first

View File

@@ -0,0 +1,117 @@
import { describe, it, expect, vi, beforeEach } from 'vitest';
import {
bootstrapUngatedGlobal,
UNGATED_GLOBAL_PROJECT_NAME,
SETTING_UNGATED_GLOBAL_SEEDED,
} from '../src/bootstrap/ungated-global.js';
import { SYSTEM_SETTINGS_SECRET } from '../src/bootstrap/system-settings.js';
import type { PrismaClient } from '@prisma/client';
function mockPrisma(opts: { settingsData?: Record<string, unknown> | null } = {}): PrismaClient {
const secretRow = opts.settingsData
? { id: 'secret-1', name: SYSTEM_SETTINGS_SECRET, data: opts.settingsData, version: 3 }
: null;
return {
secret: {
findUnique: vi.fn(async () => secretRow),
update: vi.fn(async () => ({})),
create: vi.fn(async () => ({})),
},
secretBackend: {
findUnique: vi.fn(async () => ({ id: 'backend-default', name: 'default', isDefault: true })),
findFirst: vi.fn(async () => ({ id: 'backend-default', name: 'default', isDefault: true })),
},
user: {
upsert: vi.fn(async () => ({ id: 'sys-user-id', email: 'system@mcpctl.local' })),
},
project: {
upsert: vi.fn(async (args: { where: { name: string } }) => ({ id: 'proj-ug', name: args.where.name })),
},
mcpServer: {
upsert: vi.fn(async (args: { where: { name: string } }) => ({ id: 'srv-calc', name: args.where.name })),
},
projectServer: {
upsert: vi.fn(async () => ({})),
},
} as unknown as PrismaClient;
}
describe('bootstrapUngatedGlobal', () => {
let prisma: PrismaClient;
beforeEach(() => {
prisma = mockPrisma();
});
it('seeds the ungated-global project with the calcmcp server and attaches it', async () => {
await bootstrapUngatedGlobal(prisma);
expect(prisma.project.upsert).toHaveBeenCalledWith(
expect.objectContaining({
where: { name: UNGATED_GLOBAL_PROJECT_NAME },
create: expect.objectContaining({ gated: false, prompt: expect.stringContaining('calcmcp') }),
}),
);
expect(prisma.mcpServer.upsert).toHaveBeenCalledWith(
expect.objectContaining({
where: { name: 'calcmcp' },
create: expect.objectContaining({
dockerImage: expect.stringContaining('calcmcp'),
transport: 'STDIO',
}),
}),
);
expect(prisma.projectServer.upsert).toHaveBeenCalledWith(
expect.objectContaining({
where: { projectId_serverId: { projectId: 'proj-ug', serverId: 'srv-calc' } },
}),
);
});
it('marks the seed as done in the system settings secret', async () => {
await bootstrapUngatedGlobal(prisma);
// Settings secret didn't exist → created with the marker key and a valid backend FK
expect(prisma.secret.create).toHaveBeenCalledWith(
expect.objectContaining({
data: expect.objectContaining({
name: SYSTEM_SETTINGS_SECRET,
backendId: 'backend-default',
data: expect.objectContaining({ [SETTING_UNGATED_GLOBAL_SEEDED]: true }),
}),
}),
);
});
it('does NOT re-seed when the marker is set (deletions stay deleted)', async () => {
prisma = mockPrisma({ settingsData: { [SETTING_UNGATED_GLOBAL_SEEDED]: true } });
await bootstrapUngatedGlobal(prisma);
expect(prisma.project.upsert).not.toHaveBeenCalled();
expect(prisma.mcpServer.upsert).not.toHaveBeenCalled();
expect(prisma.projectServer.upsert).not.toHaveBeenCalled();
expect(prisma.secret.update).not.toHaveBeenCalled();
expect(prisma.secret.create).not.toHaveBeenCalled();
});
it('preserves existing settings keys when writing the marker', async () => {
prisma = mockPrisma({ settingsData: { allowSelfPasswordChange: false } });
await bootstrapUngatedGlobal(prisma);
expect(prisma.secret.update).toHaveBeenCalledWith(
expect.objectContaining({
where: { name: SYSTEM_SETTINGS_SECRET },
data: expect.objectContaining({
data: {
allowSelfPasswordChange: false,
[SETTING_UNGATED_GLOBAL_SEEDED]: true,
},
version: 4,
}),
}),
);
});
});

View File

@@ -155,10 +155,11 @@ describe('ChatService — project chat', () => {
expect(t.projectId).toBe('proj-1');
expect(t.agentId).toBeNull();
expect(t.ownerId).toBe('owner-1');
// system message = project.prompt then HIGH then LOW
// system message = project.prompt then HIGH then LOW, then the ambient
// context line (the model's clock, appended every turn).
const sys = (adapter.infer as ReturnType<typeof vi.fn>).mock.calls[0][0].body.messages[0];
expect(sys.role).toBe('system');
expect(sys.content).toBe('Project system prompt.\n\nHIGH\n\nLOW');
expect(sys.content).toMatch(/^Project system prompt\.\n\nHIGH\n\nLOW\n\n\[context\] now: /);
});
it('routes tool calls to the project dispatcher with projectId', async () => {

View File

@@ -388,6 +388,8 @@ describe('ChatService', () => {
expect(text.indexOf('HIGH prompt')).toBeLessThan(text.indexOf('LOW prompt'));
// Agent's own system prompt leads.
expect(text.indexOf('You are a helpful agent.')).toBeLessThan(text.indexOf('HIGH prompt'));
// The ambient context line (the model's clock) closes the block.
expect(text).toMatch(/\n\n\[context\] now: .+$/);
});
it('refuses tool calls when the agent has no project attached', async () => {

View File

@@ -345,4 +345,78 @@ describe('Project Routes', () => {
expect(body.serverOverrides).toEqual({ ha: { proxyModel: 'ha-special' } });
});
});
describe('ungated-global merge', () => {
const mkPs = (id: string, name: string, description = '') =>
({ id: `ps-${id}`, projectId: 'x', serverId: id, createdAt: new Date(), server: { id, name, description } }) as never;
function repoWithGlobal(ownServers: never[] = []) {
const repo = mockProjectRepo();
vi.mocked(repo.findById).mockImplementation(async (id: string) =>
id === 'p1' ? makeProject({ id: 'p1', name: 'my-proj', prompt: 'own prompt', servers: ownServers }) : null);
vi.mocked(repo.findByName).mockImplementation(async (name: string) => {
if (name === 'ungated-global') {
return makeProject({
id: 'p-ug',
name: 'ungated-global',
prompt: 'Always use calcmcp for math.',
gated: false,
servers: [mkPs('srv-calc', 'calcmcp', 'scientific calculator')],
});
}
return null;
});
return repo;
}
it('GET /servers appends global servers flagged ungatedGlobal', async () => {
await createApp(repoWithGlobal([mkPs('srv-ha', 'ha')]));
const res = await app.inject({ method: 'GET', url: '/api/v1/projects/p1/servers' });
expect(res.statusCode).toBe(200);
const body = res.json<Array<{ name: string; ungatedGlobal?: boolean }>>();
expect(body.map((s) => s.name)).toEqual(['ha', 'calcmcp']);
expect(body[0]!.ungatedGlobal).toBeUndefined();
expect(body[1]!.ungatedGlobal).toBe(true);
});
it('GET /servers does not duplicate a server also attached directly', async () => {
await createApp(repoWithGlobal([mkPs('srv-calc', 'calcmcp')]));
const res = await app.inject({ method: 'GET', url: '/api/v1/projects/p1/servers' });
const body = res.json<Array<{ name: string; ungatedGlobal?: boolean }>>();
expect(body).toHaveLength(1);
expect(body[0]!.name).toBe('calcmcp');
expect(body[0]!.ungatedGlobal).toBeUndefined();
});
it('GET /servers on ungated-global itself does not self-merge', async () => {
const repo = repoWithGlobal();
vi.mocked(repo.findById).mockImplementation(async (id: string) =>
id === 'p-ug'
? makeProject({ id: 'p-ug', name: 'ungated-global', servers: [mkPs('srv-calc', 'calcmcp')] })
: null);
await createApp(repo);
const res = await app.inject({ method: 'GET', url: '/api/v1/projects/p-ug/servers' });
const body = res.json<Array<{ name: string }>>();
expect(body).toHaveLength(1);
});
it('GET /instructions prepends the global prompt and lists global servers', async () => {
await createApp(repoWithGlobal([mkPs('srv-ha', 'ha', 'home assistant')]));
const res = await app.inject({ method: 'GET', url: '/api/v1/projects/p1/instructions' });
expect(res.statusCode).toBe(200);
const body = res.json<{ prompt: string; servers: Array<{ name: string }> }>();
expect(body.prompt).toBe('Always use calcmcp for math.\n\nown prompt');
expect(body.servers.map((s) => s.name)).toEqual(['ha', 'calcmcp']);
});
it('GET /servers is unchanged when ungated-global does not exist', async () => {
const repo = mockProjectRepo();
vi.mocked(repo.findById).mockImplementation(async (id: string) =>
id === 'p1' ? makeProject({ id: 'p1', name: 'my-proj', servers: [mkPs('srv-ha', 'ha')] }) : null);
await createApp(repo);
const res = await app.inject({ method: 'GET', url: '/api/v1/projects/p1/servers' });
const body = res.json<Array<{ name: string }>>();
expect(body.map((s) => s.name)).toEqual(['ha']);
});
});
});

View File

@@ -11,6 +11,12 @@ interface McpdServer {
status?: string;
/** Per-server tool-call deadline override, in seconds. Null = use the global. */
toolCallTimeoutSeconds?: number | null;
/**
* True when the server comes from the `ungated-global` system project
* rather than this project's own attachments. mcplocal exempts such
* servers from the gate: their tools are listed and callable pre-begin_session.
*/
ungatedGlobal?: boolean;
}
/**
@@ -28,12 +34,19 @@ export async function refreshUpstreams(router: McpRouter, mcpdClient: McpdClient
*
* @param authToken - Optional bearer token forwarded to mcpd for RBAC checks.
*/
export interface ProjectUpstreams {
/** Names of all registered upstream servers. */
names: string[];
/** Subset that came from the ungated-global project (gate-exempt). */
ungatedServers: string[];
}
export async function refreshProjectUpstreams(
router: McpRouter,
mcpdClient: McpdClient,
projectName: string,
authToken?: string,
): Promise<string[]> {
): Promise<ProjectUpstreams> {
const path = `/api/v1/projects/${encodeURIComponent(projectName)}/servers`;
let servers: McpdServer[];
@@ -54,7 +67,11 @@ export async function refreshProjectUpstreams(
// Bind a per-request client with the caller's bearer so each McpdUpstream
// forwards the same identity that passed project discovery.
const upstreamClient = authToken ? mcpdClient.withToken(authToken) : mcpdClient;
return syncUpstreams(router, upstreamClient, servers);
const names = await syncUpstreams(router, upstreamClient, servers);
return {
names,
ungatedServers: servers.filter((s) => s.ungatedGlobal === true).map((s) => s.name),
};
}
/**

View File

@@ -22,6 +22,8 @@ import type { TrafficCapture } from './traffic.js';
import { LLMProviderAdapter } from '../proxymodel/llm-adapter.js';
import { FileCache } from '../proxymodel/file-cache.js';
import { createDefaultPlugin } from '../proxymodel/plugins/default.js';
import { createAmbientContextPlugin } from '../proxymodel/plugins/ambient-context.js';
import { ambientContextLine } from '@mcpctl/shared';
import { createAgentsPlugin } from '../proxymodel/plugins/agents.js';
import { createFavouriteIndexPlugin } from '../proxymodel/plugins/favourite-index.js';
import { composePlugins } from '../proxymodel/plugins/compose.js';
@@ -92,7 +94,7 @@ export function registerProjectMcpEndpoint(app: FastifyInstance, mcpdClient: Mcp
// Create new router or refresh existing one
const router = existing?.router ?? new McpRouter();
await refreshProjectUpstreams(router, mcpdClient, projectName, authToken);
const { ungatedServers } = await refreshProjectUpstreams(router, mcpdClient, projectName, authToken);
// Resolve project LLM model: local override → mcpd recommendation → global default
const localOverride = loadProjectLlmOverride(projectName);
@@ -163,6 +165,9 @@ export function registerProjectMcpEndpoint(app: FastifyInstance, mcpdClient: Mcp
providerRegistry: effectiveRegistry,
};
if (resolvedModel) pluginConfig.modelOverride = resolvedModel;
// Servers from the ungated-global project bypass the gate: listed and
// callable before begin_session, in every project.
if (ungatedServers.length > 0) pluginConfig.ungatedServers = ungatedServers;
// Route gate prompt-selection through a server Llm (mcpd inference proxy)
// so cloud/server keys stay at the k8s level; the local personal-token
// provider is the fallback. See credential-tiering. A dedicated fast
@@ -190,6 +195,11 @@ export function registerProjectMcpEndpoint(app: FastifyInstance, mcpdClient: Mcp
// project show up as virtual MCP servers in tools/list, regardless of
// which proxymodel the project is using.
chain.push(createAgentsPlugin());
// Ambient context LAST: its onToolsList must see the gate's finished
// catalog (append get_current_time only when ungated), and its
// date/project instruction line belongs at the end of the merged
// instructions. Always on for every project.
chain.push(createAmbientContextPlugin());
router.setPlugin(composePlugins(chain));
// Fetch project instructions and set on router. Must ride the CALLER's
@@ -247,6 +257,24 @@ export function registerProjectMcpEndpoint(app: FastifyInstance, mcpdClient: Mcp
return response;
}
/**
* Append the ambient "now" line to every tools/call result as a SEPARATE
* trailing content item — never mutate existing items, so clients that
* JSON.parse a single text item keep working. Endpoint-level on purpose:
* this is the only chokepoint that also covers virtual tools (which bypass
* plugin onToolCallAfter), gate intercepts, drill-down pages, and
* failureResponse results. Initialize instructions carry the same line but
* freeze at session start; this trailer is what keeps a days-old chat
* session's model on today's date.
*/
function appendAmbientTrailer(response: unknown, method?: string): unknown {
if (method !== 'tools/call') return response;
const r = response as { result?: { content?: unknown } };
if (!r.result || !Array.isArray(r.result.content)) return response;
r.result.content.push({ type: 'text', text: ambientContextLine() });
return response;
}
/**
* Turn a deadline or an unexpected throw into something the client can read.
*
@@ -523,7 +551,10 @@ export function registerProjectMcpEndpoint(app: FastifyInstance, mcpdClient: Mcp
try {
await transport.send(
maybeAnnotateRecreation(response, sid, method) as unknown as JSONRPCMessage,
appendAmbientTrailer(
maybeAnnotateRecreation(response, sid, method),
method,
) as unknown as JSONRPCMessage,
);
} catch (sendErr) {
console.error(

View File

@@ -0,0 +1,56 @@
/**
* Ambient Context plugin — gives every project's model a clock.
*
* Always on, composed LAST in the project plugin chain so that:
* - onToolsList sees the gate's (and favourite-index's) finished list and
* only appends get_current_time to UNGATED catalogs;
* - its onInitialize line lands at the end of the merged instructions.
*
* The per-result "[context] now: …" trailer deliberately does NOT live here:
* virtual tools bypass plugin onToolCallAfter entirely (router dispatches
* them first), so the only chokepoint covering every tools/call result is
* endpoint-level — see appendAmbientTrailer in http/project-mcp-endpoint.ts.
*/
import { ambientContextLine, formatCurrentTimeResult } from '@mcpctl/shared';
import type { ProxyModelPlugin } from '../plugin.js';
import type { ToolDefinition } from '../types.js';
export const GET_CURRENT_TIME_TOOL_NAME = 'get_current_time';
function getCurrentTimeTool(): ToolDefinition {
return {
name: GET_CURRENT_TIME_TOOL_NAME,
description:
'Current date and time, in UTC and the configured local timezone. '
+ 'Call this whenever a task depends on today\'s date or the current time.',
inputSchema: { type: 'object', properties: {} },
};
}
export function createAmbientContextPlugin(): ProxyModelPlugin {
return {
name: 'ambient-context',
async onSessionCreate(ctx) {
// Registered unconditionally: virtual dispatch precedes the gate
// intercept, so the tool is callable even while gated (same as
// read_prompts today). Visibility is controlled in onToolsList.
ctx.registerTool(getCurrentTimeTool(), async () => ({
content: [{ type: 'text', text: formatCurrentTimeResult() }],
}));
},
async onInitialize(_request, ctx) {
return { instructions: `${ambientContextLine()} — project: ${ctx.projectName}` };
},
async onToolsList(tools) {
// A gated catalog is [begin_session, ...gate-exempt ungated-global
// tools] (gate.ts onToolsList); begin_session never appears in an
// ungated list, so its presence remains the gated marker.
if (tools.some((t) => t.name === 'begin_session')) return tools;
if (tools.some((t) => t.name === GET_CURRENT_TIME_TOOL_NAME)) return tools;
return [...tools, getCurrentTimeTool()];
},
};
}

View File

@@ -7,6 +7,7 @@
*
* This plugin replaces the hardcoded gate logic in router.ts.
*/
import { ambientContextLine } from '@mcpctl/shared';
import type { JsonRpcRequest, JsonRpcResponse } from '../../types.js';
import type { ToolDefinition } from '../types.js';
import type { ProxyModelPlugin, PluginSessionContext } from '../plugin.js';
@@ -54,6 +55,12 @@ export interface GatePluginConfig {
* personal-token provider registry. See credential-tiering principle.
*/
llmProvider?: string;
/**
* Server names (canonical, as in `server/tool`) exempt from the gate —
* typically servers of the ungated-global project. Their tools are listed
* and callable while the session is still gated.
*/
ungatedServers?: string[];
}
const MAX_RESPONSE_CHARS = 24_000;
@@ -72,6 +79,13 @@ export function createGatePlugin(config: GatePluginConfig = {}): ProxyModelPlugi
// Per-session state tracking (plugin-scoped, not global SessionGate)
const sessionGate = new SessionGate();
// Gate-exempt servers (ungated-global project): tools pass the gate untouched.
const ungatedSet = new Set(config.ungatedServers ?? []);
const isGateExempt = (toolName: string): boolean => {
const slash = toolName.indexOf('/');
return slash > 0 && ungatedSet.has(toolName.slice(0, slash));
};
return {
name: 'gate',
description: 'Gated session flow: begin_session → prompt selection → ungate.',
@@ -121,9 +135,17 @@ export function createGatePlugin(config: GatePluginConfig = {}): ProxyModelPlugi
// canonical `server/tool` would name functions the model cannot call.
try {
const tools = await ctx.discoverTools();
if (tools.length > 0) {
const exempt = tools.filter((t) => isGateExempt(t.name));
const gatedTools = tools.filter((t) => !isGateExempt(t.name));
if (exempt.length > 0) {
parts.push('\nAvailable immediately (no begin_session required):');
for (const t of exempt) {
parts.push(` ${sanitizeWireName(t.name)}`);
}
}
if (gatedTools.length > 0) {
parts.push('\nAvailable MCP server tools (accessible after begin_session):');
for (const t of tools) {
for (const t of gatedTools) {
parts.push(` ${sanitizeWireName(t.name)}`);
}
}
@@ -159,9 +181,9 @@ export function createGatePlugin(config: GatePluginConfig = {}): ProxyModelPlugi
},
async onToolsList(tools, ctx) {
// When gated, only show begin_session
// When gated, show begin_session plus any gate-exempt (ungated-global) tools
if (sessionGate.isGated(ctx.sessionId)) {
return [getBeginSessionTool(llmSelector)];
return [getBeginSessionTool(llmSelector), ...tools.filter((t) => isGateExempt(t.name))];
}
// When ungated, show upstream tools + read_prompts + propose_prompt (no begin_session)
@@ -169,8 +191,9 @@ export function createGatePlugin(config: GatePluginConfig = {}): ProxyModelPlugi
},
async onToolCallBefore(toolName, args, request, ctx) {
// If gated and trying to call a real tool, auto-ungate via keyword extraction
if (sessionGate.isGated(ctx.sessionId)) {
// If gated and trying to call a real tool, auto-ungate via keyword extraction.
// Gate-exempt (ungated-global) tools pass straight through without ungating.
if (sessionGate.isGated(ctx.sessionId) && !isGateExempt(toolName)) {
return handleGatedIntercept(request, ctx, toolName, args, sessionGate, tagMatcher);
}
return null;
@@ -413,6 +436,10 @@ async function handleBeginSession(
// Build response
const responseParts: string[] = [];
// The model starting this session has no clock; the briefing anchors it.
// (The endpoint's per-result trailer keeps later turns current.)
responseParts.push(`${ambientContextLine()}\n`);
if (degradedReason !== null) {
responseParts.push(
`⚠ Smart prompt-selection unavailable (${degradedReason}). `

View File

@@ -0,0 +1,75 @@
import { describe, it, expect, afterEach } from 'vitest';
import {
AMBIENT_TZ_ENV,
ambientTz,
formatAmbientNow,
ambientContextLine,
formatCurrentTimeResult,
} from '@mcpctl/shared';
const SUMMER = new Date('2026-07-01T09:30:00Z'); // London = BST, +01:00
const WINTER = new Date('2026-01-15T09:30:00Z'); // London = GMT, +00:00
afterEach(() => {
delete process.env[AMBIENT_TZ_ENV];
});
describe('ambientTz', () => {
it('returns undefined when unset', () => {
delete process.env[AMBIENT_TZ_ENV];
expect(ambientTz()).toBeUndefined();
});
it('returns a valid IANA name', () => {
process.env[AMBIENT_TZ_ENV] = 'Europe/London';
expect(ambientTz()).toBe('Europe/London');
});
it('falls back to undefined on an invalid name without throwing', () => {
process.env[AMBIENT_TZ_ENV] = 'Not/AZone';
expect(ambientTz()).toBeUndefined();
});
});
describe('formatAmbientNow', () => {
it('renders UTC-only when no tz', () => {
expect(formatAmbientNow(SUMMER, undefined)).toBe('Wed 2026-07-01 09:30 UTC');
});
it('renders local + UTC in summer (BST +01:00)', () => {
expect(formatAmbientNow(SUMMER, 'Europe/London'))
.toBe('Wed 2026-07-01 10:30 +01:00 Europe/London (09:30 UTC)');
});
it('renders local + UTC in winter (GMT +00:00)', () => {
expect(formatAmbientNow(WINTER, 'Europe/London'))
.toBe('Thu 2026-01-15 09:30 +00:00 Europe/London (09:30 UTC)');
});
it('stays short (~15 tokens)', () => {
expect(formatAmbientNow(SUMMER, 'Europe/London').length).toBeLessThan(70);
});
});
describe('ambientContextLine', () => {
it('prefixes with [context] now:', () => {
delete process.env[AMBIENT_TZ_ENV];
expect(ambientContextLine(SUMMER)).toBe('[context] now: Wed 2026-07-01 09:30 UTC');
});
});
describe('formatCurrentTimeResult', () => {
it('includes UTC ISO and epoch, no local line when tz unset', () => {
delete process.env[AMBIENT_TZ_ENV];
const text = formatCurrentTimeResult(SUMMER);
expect(text).toContain('UTC: 2026-07-01T09:30:00.000Z');
expect(text).toContain(`Unix epoch seconds: ${Math.floor(SUMMER.getTime() / 1000)}`);
expect(text).not.toContain('Europe/London');
});
it('includes the local rendering when tz set', () => {
process.env[AMBIENT_TZ_ENV] = 'Europe/London';
const text = formatCurrentTimeResult(SUMMER);
expect(text).toContain('Europe/London: Wed 2026-07-01 10:30 +01:00 Europe/London (09:30 UTC)');
});
});

View File

@@ -0,0 +1,117 @@
/**
* ambient-context plugin tests — get_current_time visibility (gated vs
* ungated, no double-append), callable result, and the initialize
* instruction line. Driven through a real McpRouter with the gate composed
* first, mirroring project-mcp-endpoint wiring (ambient-context LAST).
*/
import { describe, it, expect, vi } from 'vitest';
import { McpRouter } from '../src/router.js';
import type { UpstreamConnection, JsonRpcRequest, JsonRpcResponse } from '../src/types.js';
import type { McpdClient } from '../src/http/mcpd-client.js';
import { createGatePlugin } from '../src/proxymodel/plugins/gate.js';
import { composePlugins } from '../src/proxymodel/plugins/compose.js';
import {
createAmbientContextPlugin,
GET_CURRENT_TIME_TOOL_NAME,
} from '../src/proxymodel/plugins/ambient-context.js';
import type { LLMProviderAdapter } from '../src/proxymodel/llm-adapter.js';
import { MemoryCache } from '../src/proxymodel/cache.js';
function mockUpstream(name: string, tools: Array<{ name: string }>): UpstreamConnection {
return {
name,
isAlive: vi.fn(() => true),
close: vi.fn(async () => {}),
onNotification: vi.fn(),
send: vi.fn(async (req: JsonRpcRequest): Promise<JsonRpcResponse> => {
if (req.method === 'tools/list') return { jsonrpc: '2.0', id: req.id, result: { tools } };
if (req.method === 'resources/list') return { jsonrpc: '2.0', id: req.id, result: { resources: [] } };
if (req.method === 'prompts/list') return { jsonrpc: '2.0', id: req.id, result: { prompts: [] } };
return { jsonrpc: '2.0', id: req.id, error: { code: -32601, message: 'Not found' } };
}),
} as UpstreamConnection;
}
function mockMcpdClient(): McpdClient {
return {
get: vi.fn(async () => []),
post: vi.fn(async () => ({})),
put: vi.fn(async () => ({})),
delete: vi.fn(async () => {}),
forward: vi.fn(async () => ({ status: 200, body: {} })),
withHeaders: vi.fn(function (this: McpdClient) { return this; }),
} as unknown as McpdClient;
}
function setup(opts: { gated?: boolean } = {}) {
const router = new McpRouter();
router.setPromptConfig(mockMcpdClient(), 'test-project');
router.setPlugin(composePlugins([
createGatePlugin({ gated: opts.gated ?? false, providerRegistry: null }),
createAmbientContextPlugin(),
]));
router.setProxyModel('default', { complete: async () => '', available: () => false } as unknown as LLMProviderAdapter, new MemoryCache());
router.addUpstream(mockUpstream('k8s', [{ name: 'get_pods' }]));
return router;
}
async function listTools(router: McpRouter, sessionId = 's1'): Promise<string[]> {
const res = await router.route({ jsonrpc: '2.0', id: 2, method: 'tools/list' }, { sessionId });
return (res.result as { tools: Array<{ name: string }> }).tools.map((t) => t.name);
}
describe('ambient-context plugin', () => {
it('appends get_current_time to an ungated catalog, once', async () => {
const router = setup();
await router.route({ jsonrpc: '2.0', id: 1, method: 'initialize' }, { sessionId: 's1' });
const names = await listTools(router);
expect(names).toContain('k8s/get_pods');
expect(names.filter((n) => n === GET_CURRENT_TIME_TOOL_NAME)).toHaveLength(1);
// Second list: still exactly one.
const again = await listTools(router);
expect(again.filter((n) => n === GET_CURRENT_TIME_TOOL_NAME)).toHaveLength(1);
});
it('does not leak get_current_time into a gated catalog', async () => {
const router = setup({ gated: true });
await router.route({ jsonrpc: '2.0', id: 1, method: 'initialize' }, { sessionId: 's1' });
const names = await listTools(router);
expect(names).toEqual(['begin_session']);
});
it('lists get_current_time after begin_session ungates the session', async () => {
const router = setup({ gated: true });
await router.route({ jsonrpc: '2.0', id: 1, method: 'initialize' }, { sessionId: 's1' });
await router.route(
{ jsonrpc: '2.0', id: 2, method: 'tools/call', params: { name: 'begin_session', arguments: { description: 'testing ambient context' } } },
{ sessionId: 's1' },
);
const names = await listTools(router);
expect(names).toContain(GET_CURRENT_TIME_TOOL_NAME);
});
it('get_current_time returns the UTC time', async () => {
const router = setup();
await router.route({ jsonrpc: '2.0', id: 1, method: 'initialize' }, { sessionId: 's1' });
const res = await router.route(
{ jsonrpc: '2.0', id: 3, method: 'tools/call', params: { name: GET_CURRENT_TIME_TOOL_NAME, arguments: {} } },
{ sessionId: 's1' },
);
const text = (res.result as { content: Array<{ text: string }> }).content[0]!.text;
expect(text).toMatch(/^UTC: \d{4}-\d{2}-\d{2}T\d{2}:\d{2}:\d{2}/m);
expect(text).toContain('Unix epoch seconds:');
});
it('adds the context line and project name to initialize instructions', async () => {
const router = setup();
const res = await router.route({ jsonrpc: '2.0', id: 1, method: 'initialize' }, { sessionId: 's1' });
const instructions = (res.result as { instructions?: string }).instructions ?? '';
expect(instructions).toContain('[context] now:');
expect(instructions).toContain('project: test-project');
});
});

View File

@@ -74,6 +74,8 @@ function setupPluginRouter(opts: {
/** When set, the heavy provider's complete() rejects — exercises the loud fallback. */
llmError?: boolean;
byteBudget?: number;
/** Gate-exempt server names (ungated-global project). */
ungatedServers?: string[];
} = {}): { router: McpRouter; mcpdClient: McpdClient } {
const router = new McpRouter();
const prompts = opts.prompts ?? samplePrompts;
@@ -105,6 +107,7 @@ function setupPluginRouter(opts: {
gated: opts.gated !== false,
providerRegistry,
byteBudget: opts.byteBudget,
...(opts.ungatedServers ? { ungatedServers: opts.ungatedServers } : {}),
});
router.setPlugin(gatePlugin);
@@ -160,6 +163,63 @@ describe('Gate Plugin via setPlugin()', () => {
});
});
describe('gate-exempt (ungated-global) servers', () => {
it('lists exempt server tools alongside begin_session while gated', async () => {
const { router } = setupPluginRouter({ ungatedServers: ['calcmcp'] });
router.addUpstream(mockUpstream('calcmcp', { tools: [{ name: 'symbolic_tool' }] }));
router.addUpstream(mockUpstream('ha', { tools: [{ name: 'get_entities' }] }));
await router.route({ jsonrpc: '2.0', id: 1, method: 'initialize' }, { sessionId: 's1' });
const res = await router.route(
{ jsonrpc: '2.0', id: 2, method: 'tools/list' },
{ sessionId: 's1' },
);
const names = (res.result as { tools: Array<{ name: string }> }).tools.map((t) => t.name);
expect(names).toContain('begin_session');
expect(names).toContain('calcmcp/symbolic_tool');
expect(names).not.toContain('ha/get_entities');
});
it('calls an exempt tool while gated without intercept and stays gated', async () => {
const { router } = setupPluginRouter({ ungatedServers: ['calcmcp'] });
router.addUpstream(mockUpstream('calcmcp', { tools: [{ name: 'symbolic_tool' }] }));
await router.route({ jsonrpc: '2.0', id: 1, method: 'initialize' }, { sessionId: 's1' });
const callRes = await router.route(
{ jsonrpc: '2.0', id: 2, method: 'tools/call', params: { name: 'calcmcp/symbolic_tool', arguments: { operation: 'simplify', expression: '1+1' } } },
{ sessionId: 's1' },
);
const content = (callRes.result as { content: Array<{ text: string }> }).content;
// Real upstream result, not a gate intercept briefing (the router
// strips the server prefix when forwarding to the upstream)
expect(content[0]!.text).toBe('Called symbolic_tool');
// Session must STILL be gated: non-exempt catalog stays hidden
const toolsRes = await router.route(
{ jsonrpc: '2.0', id: 3, method: 'tools/list' },
{ sessionId: 's1' },
);
const names = (toolsRes.result as { tools: Array<{ name: string }> }).tools.map((t) => t.name);
expect(names).toContain('begin_session');
});
it('lists exempt tools under "Available immediately" in initialize instructions', async () => {
const { router } = setupPluginRouter({ ungatedServers: ['calcmcp'] });
router.addUpstream(mockUpstream('calcmcp', { tools: [{ name: 'symbolic_tool' }] }));
router.addUpstream(mockUpstream('ha', { tools: [{ name: 'get_entities' }] }));
const res = await router.route(
{ jsonrpc: '2.0', id: 1, method: 'initialize' },
{ sessionId: 's1' },
);
const instructions = (res.result as { instructions?: string }).instructions ?? '';
expect(instructions).toContain('Available immediately (no begin_session required):');
expect(instructions).toContain('calcmcp_symbolic_tool');
expect(instructions).toContain('Available MCP server tools (accessible after begin_session):');
expect(instructions).toContain('ha_get_entities');
});
});
describe('tools/list gating', () => {
it('shows only begin_session when session is gated', async () => {
const { router } = setupPluginRouter();
@@ -199,6 +259,19 @@ describe('Gate Plugin via setPlugin()', () => {
});
describe('begin_session', () => {
it('opens the briefing with the ambient context line (the model has no clock)', async () => {
const { router } = setupPluginRouter();
await router.route({ jsonrpc: '2.0', id: 1, method: 'initialize' }, { sessionId: 's1' });
const res = await router.route(
{ jsonrpc: '2.0', id: 2, method: 'tools/call', params: { name: 'begin_session', arguments: { tags: ['zigbee'] } } },
{ sessionId: 's1' },
);
const text = ((res.result as { content: Array<{ text: string }> }).content[0]!.text);
expect(text).toMatch(/^\[context\] now: /);
});
it('falls back with a visible warning when the LLM selector errors (no silent degrade)', async () => {
const { router } = setupPluginRouter({ withLlm: true, llmError: true });
await router.route({ jsonrpc: '2.0', id: 1, method: 'initialize' }, { sessionId: 's1' });

View File

@@ -27,9 +27,22 @@ describe('refreshProjectUpstreams', () => {
]);
const registered = await refreshProjectUpstreams(router, client as any, 'smart-home');
expect(registered).toEqual(['grafana', 'ha']);
expect(registered.names).toEqual(['grafana', 'ha']);
expect(registered.ungatedServers).toEqual([]);
});
it('reports servers flagged ungatedGlobal as gate-exempt', async () => {
const router = new McpRouter();
const client = mockMcpdClient([
{ id: 'srv-1', name: 'grafana', transport: 'stdio' },
{ id: 'srv-2', name: 'calcmcp', transport: 'stdio', ungatedGlobal: true },
]);
const registered = await refreshProjectUpstreams(router, client as any, 'smart-home');
expect(registered.names).toEqual(['grafana', 'calcmcp']);
expect(registered.ungatedServers).toEqual(['calcmcp']);
expect(router.getUpstreamNames()).toContain('grafana');
expect(router.getUpstreamNames()).toContain('ha');
expect(router.getUpstreamNames()).toContain('calcmcp');
expect(client.get).toHaveBeenCalledWith('/api/v1/projects/smart-home/servers');
});
@@ -85,7 +98,7 @@ describe('refreshProjectUpstreams', () => {
const client = mockMcpdClient([]);
const registered = await refreshProjectUpstreams(router, client as any, 'empty-project');
expect(registered).toEqual([]);
expect(registered.names).toEqual([]);
expect(router.getUpstreamNames()).toHaveLength(0);
});
});

View File

@@ -0,0 +1,138 @@
import { describe, it, expect, vi } from 'vitest';
import Fastify from 'fastify';
import { registerProjectMcpEndpoint } from '../src/http/project-mcp-endpoint.js';
import type { McpRouter } from '../src/router.js';
import type { JsonRpcRequest, JsonRpcResponse } from '../src/types.js';
/**
* Ambient-context E2E on /projects/:name/mcp: every tools/call result —
* upstream AND virtual — carries a trailing `[context] now:` content item,
* initialize instructions carry the same line, tools/list stays clean, and
* get_current_time is served on an ungated project.
*/
vi.mock('../src/discovery.js', () => ({
refreshProjectUpstreams: vi.fn(async (router: McpRouter) => {
router.addUpstream({
name: 'websearch',
send: async (req: JsonRpcRequest): Promise<JsonRpcResponse> => {
if (req.method === 'tools/list') {
return {
jsonrpc: '2.0',
id: req.id,
result: { tools: [{ name: 'fetch_content', description: 'fetch a page', inputSchema: { type: 'object' } }] },
};
}
if (req.method === 'tools/call') {
return { jsonrpc: '2.0', id: req.id, result: { content: [{ type: 'text', text: 'page body' }] } };
}
return { jsonrpc: '2.0', id: req.id, result: {} };
},
close: async () => {},
isAlive: () => true,
});
return { names: ['websearch'], ungatedServers: [] };
}),
// Ungated (content-pipeline style), like chat-web and personal-michal.
fetchProjectLlmConfig: vi.fn(async () => ({ gated: false, llmProvider: 'none' })),
}));
vi.mock('../src/http/config.js', async () => {
const actual = await vi.importActual<typeof import('../src/http/config.js')>('../src/http/config.js');
return { ...actual, loadProjectLlmOverride: vi.fn(() => undefined) };
});
function mockMcpdClient() {
const client: Record<string, unknown> = {
baseUrl: 'http://test:3100',
token: 'test-token',
get: vi.fn(async () => []),
post: vi.fn(async () => ({})),
put: vi.fn(),
delete: vi.fn(),
forward: vi.fn(async () => ({ status: 200, body: [] })),
withHeaders: vi.fn(),
withToken: vi.fn(),
withTimeout: vi.fn(),
};
(client.withHeaders as ReturnType<typeof vi.fn>).mockReturnValue(client);
(client.withToken as ReturnType<typeof vi.fn>).mockReturnValue(client);
(client.withTimeout as ReturnType<typeof vi.fn>).mockReturnValue(client);
return client;
}
function parseSse(body: string): JsonRpcResponse {
const dataLine = body.split('\n').find((l) => l.startsWith('data: '));
if (!dataLine) throw new Error(`no SSE data line in: ${body}`);
return JSON.parse(dataLine.slice('data: '.length)) as JsonRpcResponse;
}
const CONTEXT_PREFIX = '[context] now:';
describe('registerProjectMcpEndpoint ambient context', () => {
it('stamps instructions, tool results (upstream and virtual), but not tools/list', async () => {
const app = Fastify();
registerProjectMcpEndpoint(app, mockMcpdClient() as never);
await app.ready();
try {
const headers = {
'content-type': 'application/json',
accept: 'application/json, text/event-stream',
};
const init = await app.inject({
method: 'POST',
url: '/projects/chat-web/mcp',
headers,
payload: { jsonrpc: '2.0', id: 1, method: 'initialize', params: { protocolVersion: '2024-11-05', capabilities: {}, clientInfo: { name: 't', version: '0' } } },
});
expect(init.statusCode).toBe(200);
const initResponse = parseSse(init.body);
const instructions = (initResponse.result as { instructions?: string }).instructions ?? '';
expect(instructions).toContain(CONTEXT_PREFIX);
expect(instructions).toContain('project: chat-web');
// The initialize RESPONSE itself is not trailed (no result.content).
expect(JSON.stringify((initResponse.result as { content?: unknown }).content ?? null)).not.toContain(CONTEXT_PREFIX);
const sessionId = init.headers['mcp-session-id'] as string;
const sessionHeaders = { ...headers, 'mcp-session-id': sessionId };
const list = await app.inject({
method: 'POST',
url: '/projects/chat-web/mcp',
headers: sessionHeaders,
payload: { jsonrpc: '2.0', id: 2, method: 'tools/list' },
});
const listResponse = parseSse(list.body);
const names = (listResponse.result as { tools: Array<{ name: string }> }).tools.map((t) => t.name);
expect(names).toContain('get_current_time');
// tools/list is never trailed.
expect(JSON.stringify(listResponse.result)).not.toContain(CONTEXT_PREFIX);
// Upstream tool call: original content intact, trailer appended LAST.
const call = await app.inject({
method: 'POST',
url: '/projects/chat-web/mcp',
headers: sessionHeaders,
payload: { jsonrpc: '2.0', id: 3, method: 'tools/call', params: { name: 'websearch_fetch_content', arguments: { url: 'https://x' } } },
});
const callContent = (parseSse(call.body).result as { content: Array<{ type: string; text: string }> }).content;
expect(callContent.length).toBeGreaterThanOrEqual(2);
expect(callContent[0]?.text).toContain('page body');
expect(callContent[callContent.length - 1]?.text).toMatch(/^\[context\] now: /);
// Virtual tool call (bypasses plugin onToolCallAfter): still trailed.
const timeCall = await app.inject({
method: 'POST',
url: '/projects/chat-web/mcp',
headers: sessionHeaders,
payload: { jsonrpc: '2.0', id: 4, method: 'tools/call', params: { name: 'get_current_time', arguments: {} } },
});
const timeContent = (parseSse(timeCall.body).result as { content: Array<{ text: string }> }).content;
expect(timeContent[0]?.text).toContain('UTC:');
expect(timeContent[timeContent.length - 1]?.text).toMatch(/^\[context\] now: /);
} finally {
await app.close();
}
});
});

View File

@@ -40,7 +40,7 @@ vi.mock('../src/discovery.js', () => ({
close: async () => {},
isAlive: () => true,
});
return ['websearch'];
return { names: ['websearch'], ungatedServers: [] };
}),
// gated: false → no gate plugin, the full catalog is served at initialize
// (the chat-web configuration).

View File

@@ -5,7 +5,7 @@ import { registerProjectMcpEndpoint } from '../src/http/project-mcp-endpoint.js'
// Mock discovery module — we don't want real HTTP calls
vi.mock('../src/discovery.js', () => ({
refreshProjectUpstreams: vi.fn(async () => ['mock-server']),
refreshProjectUpstreams: vi.fn(async () => ({ names: ['mock-server'], ungatedServers: [] })),
fetchProjectLlmConfig: vi.fn(async () => ({})),
}));

View File

@@ -30,7 +30,7 @@ vi.mock('../src/discovery.js', () => ({
close: async () => { /* noop */ },
isAlive: () => true,
});
return ['blackhole'];
return { names: ['blackhole'], ungatedServers: [] };
}),
fetchProjectLlmConfig: vi.fn(async () => ({ gated: false, llmProvider: 'none' })),
}));

View File

@@ -0,0 +1,93 @@
/**
* Ambient time rendering — gives models a clock.
*
* Models consuming projects have no idea what day it is, so mcplocal stamps a
* short context line into initialize instructions, the begin_session
* briefing, and every tools/call result, and mcpd appends it to agent system
* blocks. One env var, `MCPLOCAL_AMBIENT_TZ` (an IANA name like
* "Europe/London", read by BOTH services despite the mcplocal-flavoured
* name), adds a local rendering next to UTC; unset or invalid means UTC only.
*
* Minute precision on purpose: the line stays ~15 tokens and does not churn
* within a minute.
*/
export const AMBIENT_TZ_ENV = 'MCPLOCAL_AMBIENT_TZ';
let warnedInvalidTz: string | undefined;
/**
* The configured IANA timezone, or undefined for UTC-only rendering.
* Read at call time (not module load) so tests and config changes apply
* without a restart. An invalid name warns once and behaves as unset.
*/
export function ambientTz(env: NodeJS.ProcessEnv = process.env): string | undefined {
const tz = env[AMBIENT_TZ_ENV]?.trim();
if (!tz) return undefined;
try {
new Intl.DateTimeFormat('en-GB', { timeZone: tz });
return tz;
} catch {
if (warnedInvalidTz !== tz) {
warnedInvalidTz = tz;
console.warn(`[ambient-time] invalid ${AMBIENT_TZ_ENV} '${tz}', falling back to UTC`);
}
return undefined;
}
}
const pad = (n: number): string => String(n).padStart(2, '0');
function utcParts(now: Date): { date: string; time: string; weekday: string } {
const weekday = ['Sun', 'Mon', 'Tue', 'Wed', 'Thu', 'Fri', 'Sat'][now.getUTCDay()] as string;
return {
weekday,
date: `${now.getUTCFullYear()}-${pad(now.getUTCMonth() + 1)}-${pad(now.getUTCDate())}`,
time: `${pad(now.getUTCHours())}:${pad(now.getUTCMinutes())}`,
};
}
/**
* One line of "now", ~15 tokens:
* tz set: `Thu 2026-10-02 10:30 +01:00 Europe/London (09:30 UTC)`
* tz unset: `Thu 2026-10-02 09:30 UTC`
*/
export function formatAmbientNow(now: Date = new Date(), tz: string | undefined = ambientTz()): string {
const utc = utcParts(now);
if (!tz) return `${utc.weekday} ${utc.date} ${utc.time} UTC`;
const parts = new Intl.DateTimeFormat('en-GB', {
timeZone: tz,
weekday: 'short',
year: 'numeric',
month: '2-digit',
day: '2-digit',
hour: '2-digit',
minute: '2-digit',
hour12: false,
timeZoneName: 'longOffset',
}).formatToParts(now);
const get = (type: string) => parts.find((p) => p.type === type)?.value ?? '';
// "GMT+01:00" → "+01:00"; plain "GMT" (winter London) → "+00:00".
const rawOffset = get('timeZoneName');
const offset = rawOffset === 'GMT' ? '+00:00' : rawOffset.replace(/^(GMT|UTC)/, '');
// Intl can render "24:00" for midnight with hour12:false; normalize.
const hour = get('hour') === '24' ? '00' : get('hour');
return `${get('weekday')} ${get('year')}-${get('month')}-${get('day')} ${hour}:${get('minute')} ${offset} ${tz} (${utc.time} UTC)`;
}
/** The ambient context line stamped into instructions and tool results. */
export function ambientContextLine(now: Date = new Date()): string {
return `[context] now: ${formatAmbientNow(now)}`;
}
/** Multi-line body for the get_current_time virtual tool. */
export function formatCurrentTimeResult(now: Date = new Date()): string {
const tz = ambientTz();
const lines = [
`UTC: ${now.toISOString()}`,
...(tz ? [`${tz}: ${formatAmbientNow(now, tz)}`] : []),
`Unix epoch seconds: ${Math.floor(now.getTime() / 1000)}`,
];
return lines.join('\n');
}

View File

@@ -1,2 +1,2 @@
// Shared utility functions
// Will be expanded as tasks are implemented
export * from './ambient-time.js';

20
templates/calcmcp.yaml Normal file
View File

@@ -0,0 +1,20 @@
name: calcmcp
version: "1.1.0"
description: Scientific calculator (SymPy/NumPy/SciPy) — symbolic algebra, calculus, equation & ODE solving, linear algebra, statistics, FFT
dockerImage: "mysources.co.uk/michal/calcmcp:1.1.0"
transport: STDIO
repositoryUrl: https://mysources.co.uk/michal/CalcMCP
# Patched fork of github.com/thinkitpossible/CalcMCP: proper MCP inputSchema,
# English tool docs, eval() removed, complex eigenvalues serialize, symbolic
# dsolve added. Pure compute — needs no env, no secrets, no egress.
# Seeded by default into the ungated-global project (see docs/ungated-global.md);
# this template exists so a deleted default can be re-created by hand:
# mcpctl create server calcmcp --from-template calcmcp
healthCheck:
tool: symbolic_tool
arguments:
operation: simplify
expression: "1+1"
intervalSeconds: 300
timeoutSeconds: 10
env: []

26
templates/dav.yaml Normal file
View File

@@ -0,0 +1,26 @@
name: dav
version: "1.0.0"
description: CalDAV/CardDAV/VTODO (Stalwart or any RFC 4791/6352 server) — calendars, events, tasks, contacts
# NOT packageName: dav-mcp declares tsdav/tsdav-utils as GitHub-URL deps, so
# `npx -y dav-mcp` dies with `spawn git ENOENT` on the git-less node-runner,
# and the upstream ghcr image starts the HTTP server as PID 1. This image
# bakes the install and execs the stdio entrypoint (NODE_OPTIONS baked in).
dockerImage: "mysources.co.uk/michal/dav-mcp:4.0.1-stdio1"
transport: STDIO
repositoryUrl: https://mysources.co.uk/michal/dav-mcp-image
healthCheck:
# A real CalDAV PROPFIND: a pass proves server URL and credentials.
tool: list_calendars
arguments: {}
intervalSeconds: 60
timeoutSeconds: 10
env:
- name: CALDAV_SERVER_URL
description: DAV base URL (e.g. http://stalwart.stalwart.svc.cluster.local:8080)
required: true
- name: CALDAV_USERNAME
description: DAV username
required: true
- name: CALDAV_PASSWORD
description: DAV password (use an app password)
required: true

45
templates/jmap.yaml Normal file
View File

@@ -0,0 +1,45 @@
name: jmap
version: "1.0.0"
description: JMAP email (Stalwart) — search/read/organize + drafts; send and delete gated off by env
dockerImage: "mysources.co.uk/michal/jmap-mcp:0.6.5-drafts3"
transport: STDIO
repositoryUrl: https://mysources.co.uk/michal/jmap-mcp
# No command: the image's entrypoint IS the MCP server (deno run), mcpd
# attaches to PID 1 stdin/stdout. Fork of wyattjoh/jmap-mcp adding
# create_draft/create_draft_reply, JMAP_DISABLE_* gating, and Basic auth
# (jmap-jam upstream only speaks Bearer).
healthCheck:
# A real Mailbox/get: a pass proves session URL, auth, and account
# resolution, not just process liveness.
tool: get_mailboxes
arguments: {}
intervalSeconds: 60
timeoutSeconds: 10
env:
- name: JMAP_SESSION_URL
description: JMAP session URL (e.g. http://stalwart.stalwart.svc.cluster.local:8080/.well-known/jmap)
required: true
- name: JMAP_BEARER_TOKEN
description: Bearer token. Provide either this OR JMAP_USERNAME + JMAP_PASSWORD.
required: false
- name: JMAP_USERNAME
description: Username for HTTP Basic auth (e.g. with a Stalwart app password)
required: false
- name: JMAP_PASSWORD
description: Password/app password for HTTP Basic auth
required: false
- name: JMAP_ACCOUNT_ID
description: Account ID (auto-detected when empty)
required: false
- name: JMAP_DISABLE_SUBMISSION
description: "true = do not register send_email/reply_to_email (drafts only)"
required: false
defaultValue: "true"
- name: JMAP_DISABLE_DELETE
description: "true = do not register delete_emails (move to Trash still works)"
required: false
defaultValue: "true"
- name: JMAP_REBASE_SESSION_URLS
description: "true = rewrite the session's apiUrl/downloadUrl/uploadUrl/eventSourceUrl onto the session URL's origin. Required over a ClusterIP: Stalwart advertises its publicUrl and the hairpinned call 403s at Envoy."
required: false
defaultValue: "true"

24
templates/karakeep.yaml Normal file
View File

@@ -0,0 +1,24 @@
name: karakeep
version: "1.0.0"
description: Karakeep bookmarks — search, read, create, lists, tags, highlights
packageName: "@karakeep/mcp"
runtime: node
transport: STDIO
repositoryUrl: https://github.com/karakeep-app/karakeep
healthCheck:
# A real API call (lists all lists): a pass proves address and API key.
tool: get-lists
arguments: {}
intervalSeconds: 60
timeoutSeconds: 10
env:
- name: KARAKEEP_API_ADDR
description: Karakeep base URL (e.g. http://karakeep-web.karakeep.svc.cluster.local:3000)
required: true
- name: KARAKEEP_API_KEY
description: API key created in the Karakeep UI (Settings → API Keys)
required: true
- name: NODE_OPTIONS
description: V8 heap cap; Node sizes its heap off host RAM, not the cgroup limit
required: false
defaultValue: "--max-old-space-size=384"

26
templates/ttrss.yaml Normal file
View File

@@ -0,0 +1,26 @@
name: ttrss
version: "1.0.0"
description: Tiny Tiny RSS — feeds, headlines, article content, read/star state, subscribe
dockerImage: "mysources.co.uk/michal/ttrss-mcp:1.0.1"
transport: STDIO
repositoryUrl: https://mysources.co.uk/michal/ttrss-mcp
# No command: the image's entrypoint IS the MCP server. Custom server; the
# public tt-rss MCPs only take a pre-made session id and die when it expires.
# This one logs in with user/password and re-logs-in on NOT_LOGGED_IN.
healthCheck:
# A real getCategories call: a pass proves URL, login, and that the
# user's "Enable API access" preference is on.
tool: list_categories
arguments: {}
intervalSeconds: 60
timeoutSeconds: 10
env:
- name: TTRSS_URL
description: Full API endpoint (e.g. http://ttrss.ttrss.svc.cluster.local/api/)
required: true
- name: TTRSS_USER
description: tt-rss user with "Enable API access" set in preferences
required: true
- name: TTRSS_PASSWORD
description: That user's password
required: true