/**
* Notion tool handlers for Context Sync MCP Server
*/
import type { NotionIntegration } from './notion-integration.js';
export function createNotionHandlers(notionIntegration: NotionIntegration | null) {
return {
async handleNotionSearch(args: { query: string }) {
if (!notionIntegration) {
return {
content: [{
type: 'text',
text: 'ā Notion is not configured. Run `context-sync setup` to configure Notion integration.',
}],
isError: true,
};
}
try {
const results = await notionIntegration.searchPages(args.query);
let response = `š **Notion Search Results for "${args.query}"**\n\n`;
response += `Found ${results.pages.length} page(s)\n\n`;
results.pages.forEach((page, i) => {
response += `${i + 1}. **${page.title}**\n`;
response += ` ID: ${page.id}\n`;
response += ` URL: ${page.url}\n`;
response += ` Last edited: ${new Date(page.lastEditedTime).toLocaleString()}\n\n`;
});
if (results.pages.length === 0) {
response += `š” **Tips:**\n`;
response += `ā¢ Make sure pages are shared with your Notion integration\n`;
response += `ā¢ Try a different search query\n`;
response += `ā¢ Check your Notion workspace permissions\n`;
}
return {
content: [{ type: 'text', text: response }],
};
} catch (error: any) {
return {
content: [{
type: 'text',
text: `ā **Failed to search Notion**\n\nError: ${error.message}`,
}],
isError: true,
};
}
},
async handleNotionReadPage(args: { pageId: string }) {
if (!notionIntegration) {
return {
content: [{
type: 'text',
text: 'ā Notion is not configured. Run `context-sync setup` to configure Notion integration.',
}],
isError: true,
};
}
try {
const page = await notionIntegration.readPage(args.pageId);
let response = `š **${page.title}**\n\n`;
response += `š ${page.url}\n\n`;
response += `---\n\n`;
response += page.content;
return {
content: [{ type: 'text', text: response }],
};
} catch (error: any) {
return {
content: [{
type: 'text',
text: `ā **Failed to read page**\n\nError: ${error.message}\n\nMake sure:\nā¢ The page ID is correct\nā¢ The page is shared with your integration`,
}],
isError: true,
};
}
},
async handleNotionCreatePage(args: { title: string; content: string; parentPageId?: string }) {
if (!notionIntegration) {
return {
content: [{
type: 'text',
text: 'ā Notion is not configured. Run `context-sync setup` to configure Notion integration.',
}],
isError: true,
};
}
try {
const page = await notionIntegration.createPage(args.title, args.content, args.parentPageId);
let response = `ā
**Page Created Successfully!**\n\n`;
response += `š **${page.title}**\n`;
response += `š ${page.url}\n`;
response += `š Page ID: ${page.id}\n\n`;
response += `š” You can now:\n`;
response += `ā¢ Open the page in Notion\n`;
response += `ā¢ Read it with: notion_read_page pageId:"${page.id}"\n`;
response += `ā¢ Update it with: notion_update_page\n`;
return {
content: [{ type: 'text', text: response }],
};
} catch (error: any) {
return {
content: [{
type: 'text',
text: `ā **Failed to create page**\n\nError: ${error.message}\n\nMake sure:\nā¢ A default parent page is configured, or provide parentPageId\nā¢ The parent page is shared with your integration`,
}],
isError: true,
};
}
},
async handleNotionUpdatePage(args: { pageId: string; content: string }) {
if (!notionIntegration) {
return {
content: [{
type: 'text',
text: 'ā Notion is not configured. Run `context-sync setup` to configure Notion integration.',
}],
isError: true,
};
}
try {
await notionIntegration.updatePage(args.pageId, args.content);
let response = `ā
**Page Updated Successfully!**\n\n`;
response += `š Page ID: ${args.pageId}\n`;
response += `āØ Content has been replaced with new content\n\n`;
response += `š” Read the updated page with: notion_read_page pageId:"${args.pageId}"\n`;
return {
content: [{ type: 'text', text: response }],
};
} catch (error: any) {
return {
content: [{
type: 'text',
text: `ā **Failed to update page**\n\nError: ${error.message}`,
}],
isError: true,
};
}
},
async handleSyncDecisionToNotion(args: { decisionId: string }, storage: any) {
if (!notionIntegration) {
return {
content: [{
type: 'text',
text: 'ā Notion is not configured. Run `context-sync setup` to configure Notion integration.',
}],
isError: true,
};
}
try {
// Get the decision from storage
const decisions = storage.getDecisions();
const decision = decisions.find((d: any) => d.id === args.decisionId);
if (!decision) {
return {
content: [{
type: 'text',
text: `ā Decision with ID "${args.decisionId}" not found.\n\nUse get_project_context to see available decisions.`,
}],
isError: true,
};
}
const page = await notionIntegration.syncDecision(decision);
let response = `ā
**Decision Synced to Notion!**\n\n`;
response += `š **ADR: ${decision.description}**\n`;
response += `š ${page.url}\n`;
response += `š Page ID: ${page.id}\n\n`;
response += `The decision has been formatted as an Architecture Decision Record (ADR) in Notion.\n`;
return {
content: [{ type: 'text', text: response }],
};
} catch (error: any) {
return {
content: [{
type: 'text',
text: `ā **Failed to sync decision**\n\nError: ${error.message}`,
}],
isError: true,
};
}
},
async handleCreateProjectDashboard(args: { projectId?: string }, storage: any, currentProjectId: string | null) {
if (!notionIntegration) {
return {
content: [{
type: 'text',
text: 'ā Notion is not configured. Run `context-sync setup` to configure Notion integration.',
}],
isError: true,
};
}
try {
const projectId = args.projectId || currentProjectId;
if (!projectId) {
return {
content: [{
type: 'text',
text: 'ā No project specified and no current project set. Use set_workspace first or provide projectId.',
}],
isError: true,
};
}
const project = storage.getProject(projectId);
if (!project) {
return {
content: [{
type: 'text',
text: `ā Project with ID "${projectId}" not found.`,
}],
isError: true,
};
}
const page = await notionIntegration.createProjectDashboard(project);
let response = `ā
**Project Dashboard Created!**\n\n`;
response += `š **Project: ${project.name}**\n`;
response += `š ${page.url}\n`;
response += `š Page ID: ${page.id}\n\n`;
response += `The dashboard includes:\n`;
response += `ā¢ Project overview\n`;
response += `ā¢ Tech stack\n`;
response += `ā¢ Architecture notes\n`;
response += `ā¢ Creation & update timestamps\n`;
return {
content: [{ type: 'text', text: response }],
};
} catch (error: any) {
return {
content: [{
type: 'text',
text: `ā **Failed to create dashboard**\n\nError: ${error.message}`,
}],
isError: true,
};
}
},
};
}
