// src/tools/invites.ts
import { z } from "zod";
import { McpServer } from "@modelcontextprotocol/sdk/server/mcp.js";
import { getGhostApiConfig, generateGhostAdminToken } from "../ghostApi.js";
import axios from 'axios';
// Parameter schemas as ZodRawShape (object literals)
const browseParams = {
filter: z.string().optional(),
limit: z.number().optional(),
page: z.number().optional(),
order: z.string().optional(),
};
const addParams = {
role_id: z.string(),
email: z.string(),
};
const deleteParams = {
id: z.string(),
};
export function registerInviteTools(server: McpServer) {
// Browse invites
server.tool(
"invites_browse",
browseParams,
async (args, _extra) => {
const config = getGhostApiConfig();
if (!config) {
return { isError: true, content: [{ type: "text", text: "Ghost API not configured" }] };
}
try {
const token = generateGhostAdminToken(config.key);
const url = `${config.url}/ghost/api/admin/invites/`;
const headers = {
'Authorization': `Ghost ${token}`
};
const response = await axios.get(url, { params: args, headers });
return {
content: [
{
type: "text",
text: JSON.stringify(response.data.invites, null, 2),
},
],
};
} catch (error: any) {
const status = error?.response?.status ?? error?.status ?? "unknown";
const body = error?.response?.data ?? error?.data ?? error?.message ?? String(error);
const bodyText = typeof body === "string" ? body : JSON.stringify(body, null, 2);
return {
isError: true,
content: [
{
type: "text",
text: `invites_browse failed. status=${status}\n${bodyText}`,
},
],
};
}
}
);
// Add invite
server.tool(
"invites_add",
addParams,
async (args, _extra) => {
const config = getGhostApiConfig();
if (!config) {
return { isError: true, content: [{ type: "text", text: "Ghost API not configured" }] };
}
try {
const token = generateGhostAdminToken(config.key);
const url = `${config.url}/ghost/api/admin/invites/`;
const headers = {
'Authorization': `Ghost ${token}`
};
const response = await axios.post(url, { invites: [args] }, { headers });
return {
content: [
{
type: "text",
text: JSON.stringify(response.data.invites[0], null, 2),
},
],
};
} catch (error: any) {
const status = error?.response?.status ?? error?.status ?? "unknown";
const body = error?.response?.data ?? error?.data ?? error?.message ?? String(error);
const bodyText = typeof body === "string" ? body : JSON.stringify(body, null, 2);
return {
isError: true,
content: [
{
type: "text",
text: `invites_add failed. status=${status}\n${bodyText}`,
},
],
};
}
}
);
// Delete invite
server.tool(
"invites_delete",
deleteParams,
async (args, _extra) => {
const config = getGhostApiConfig();
if (!config) {
return { isError: true, content: [{ type: "text", text: "Ghost API not configured" }] };
}
try {
const token = generateGhostAdminToken(config.key);
const url = `${config.url}/ghost/api/admin/invites/${args.id}/`;
const headers = {
'Authorization': `Ghost ${token}`
};
await axios.delete(url, { headers });
return {
content: [
{
type: "text",
text: `Invite with id ${args.id} deleted.`,
},
],
};
} catch (error: any) {
const status = error?.response?.status ?? error?.status ?? "unknown";
const body = error?.response?.data ?? error?.data ?? error?.message ?? String(error);
const bodyText = typeof body === "string" ? body : JSON.stringify(body, null, 2);
return {
isError: true,
content: [
{
type: "text",
text: `invites_delete failed. status=${status}\n${bodyText}`,
},
],
};
}
}
);
}