#!/usr/bin/env node
import { Server } from '@modelcontextprotocol/sdk/server/index.js';
import { StdioServerTransport } from '@modelcontextprotocol/sdk/server/stdio.js';
import {
CallToolRequestSchema,
ListResourcesRequestSchema,
ListToolsRequestSchema,
ReadResourceRequestSchema,
Tool,
Resource,
TextContent,
ErrorCode,
McpError
} from '@modelcontextprotocol/sdk/types.js';
import { execAppleScript } from './applescript.js';
import { AiDDBackendClient } from './aidd-backend-client.js';
import { z } from 'zod';
class AiDDMCPServer {
private server: Server;
private backendClient: AiDDBackendClient;
constructor() {
this.server = new Server(
{
name: 'AiDD',
version: '3.0.0',
},
{
capabilities: {
tools: {},
resources: {},
},
}
);
this.backendClient = new AiDDBackendClient();
this.setupHandlers();
this.setupBackendListeners();
}
private setupBackendListeners() {
this.backendClient.on('progress', (data) => {
console.error(`Progress: ${data.operation} - ${data.progress}% - ${data.message}`);
});
this.backendClient.on('error', (data) => {
console.error(`Backend error: ${data.type} - ${data.error}`);
});
}
private setupHandlers() {
// Handle tool listing
this.server.setRequestHandler(ListToolsRequestSchema, async () => ({
tools: this.getTools(),
}));
// Handle resource listing
this.server.setRequestHandler(ListResourcesRequestSchema, async () => ({
resources: this.getResources(),
}));
// Handle resource reading
this.server.setRequestHandler(ReadResourceRequestSchema, async (request) => {
const { uri } = request.params;
return await this.handleResourceRead(uri);
});
// Handle tool calls
this.server.setRequestHandler(CallToolRequestSchema, async (request) => {
const { name, arguments: args } = request.params;
try {
switch (name) {
// Notes Management
case 'list_notes':
return await this.handleListNotes(args);
case 'read_note':
return await this.handleReadNote(args);
case 'create_note':
return await this.handleCreateNote(args);
case 'import_apple_notes':
return await this.handleImportAppleNotes(args);
// Action Items Management
case 'list_action_items':
return await this.handleListActionItems(args);
case 'read_action_item':
return await this.handleReadActionItem(args);
case 'extract_action_items':
return await this.handleExtractActionItems(args);
// Tasks Management
case 'list_tasks':
return await this.handleListTasks(args);
case 'read_task':
return await this.handleReadTask(args);
case 'convert_to_tasks':
return await this.handleConvertToTasks(args);
case 'score_tasks':
return await this.handleScoreTasks(args);
// Authentication Tools
case 'connect':
return await this.handleConnect(args);
case 'disconnect':
return await this.handleDisconnect();
case 'status':
return await this.handleStatus();
// Utility Tools
case 'check_backend_health':
return await this.handleCheckBackendHealth();
default:
throw new McpError(ErrorCode.MethodNotFound, `Unknown tool: ${name}`);
}
} catch (error) {
if (error instanceof z.ZodError) {
throw new McpError(
ErrorCode.InvalidParams,
`Invalid parameters: ${error.errors.map(e => e.message).join(', ')}`
);
}
throw error;
}
});
}
private getTools(): Tool[] {
return [
// =============================================================================
// NOTES MANAGEMENT
// =============================================================================
{
name: 'list_notes',
description: 'List notes from your AiDD account with optional sorting and pagination',
inputSchema: {
type: 'object',
properties: {
sortBy: {
type: 'string',
enum: ['createdAt', 'updatedAt', 'title'],
description: 'Field to sort by (default: updatedAt)',
},
order: {
type: 'string',
enum: ['asc', 'desc'],
description: 'Sort order (default: desc)',
},
limit: {
type: 'number',
description: 'Maximum number of notes to return (default: 100)',
},
offset: {
type: 'number',
description: 'Number of notes to skip for pagination (default: 0)',
},
},
},
},
{
name: 'read_note',
description: 'Read a specific note from your AiDD account',
inputSchema: {
type: 'object',
properties: {
noteId: {
type: 'string',
description: 'ID of the note to read',
},
},
required: ['noteId'],
},
},
{
name: 'create_note',
description: 'Create a new note in your AiDD account',
inputSchema: {
type: 'object',
properties: {
title: {
type: 'string',
description: 'Title of the note',
},
content: {
type: 'string',
description: 'Content of the note',
},
tags: {
type: 'array',
items: { type: 'string' },
description: 'Tags for the note (optional)',
},
category: {
type: 'string',
enum: ['work', 'personal'],
description: 'Category of the note (default: personal)',
},
},
required: ['title', 'content'],
},
},
{
name: 'import_apple_notes',
description: 'Import notes from Apple Notes and save them to your AiDD account or extract action items directly',
inputSchema: {
type: 'object',
properties: {
folder: {
type: 'string',
description: 'Specific Apple Notes folder to import from (optional)',
},
query: {
type: 'string',
description: 'Search query to filter notes (optional)',
},
limit: {
type: 'number',
description: 'Maximum notes to import (default: 50)',
},
saveAs: {
type: 'string',
enum: ['notes', 'action-items'],
description: 'Save as AiDD notes or extract action items directly (default: notes)',
},
},
},
},
// =============================================================================
// ACTION ITEMS MANAGEMENT
// =============================================================================
{
name: 'list_action_items',
description: 'List action items from your AiDD account with optional sorting and pagination',
inputSchema: {
type: 'object',
properties: {
sortBy: {
type: 'string',
enum: ['createdAt', 'updatedAt', 'priority', 'dueDate'],
description: 'Field to sort by (default: createdAt)',
},
order: {
type: 'string',
enum: ['asc', 'desc'],
description: 'Sort order (default: desc)',
},
limit: {
type: 'number',
description: 'Maximum number of action items to return (default: 100)',
},
offset: {
type: 'number',
description: 'Number of action items to skip for pagination (default: 0)',
},
},
},
},
{
name: 'read_action_item',
description: 'Read a specific action item from your AiDD account',
inputSchema: {
type: 'object',
properties: {
actionItemId: {
type: 'string',
description: 'ID of the action item to read',
},
},
required: ['actionItemId'],
},
},
{
name: 'extract_action_items',
description: 'Extract action items from notes or text using AiDD AI processing',
inputSchema: {
type: 'object',
properties: {
source: {
type: 'string',
enum: ['notes', 'text'],
description: 'Extract from saved notes or provided text',
},
noteIds: {
type: 'array',
items: { type: 'string' },
description: 'Specific note IDs to process (required if source=notes)',
},
text: {
type: 'string',
description: 'Text content to extract action items from (required if source=text)',
},
extractionMode: {
type: 'string',
enum: ['quick', 'comprehensive', 'adhd-optimized'],
description: 'Extraction mode (default: adhd-optimized)',
},
},
required: ['source'],
},
},
// =============================================================================
// TASKS MANAGEMENT
// =============================================================================
{
name: 'list_tasks',
description: 'List tasks from your AiDD account with optional sorting and pagination',
inputSchema: {
type: 'object',
properties: {
sortBy: {
type: 'string',
enum: ['createdAt', 'updatedAt', 'score', 'dueDate'],
description: 'Field to sort by (default: score)',
},
order: {
type: 'string',
enum: ['asc', 'desc'],
description: 'Sort order (default: desc for score, asc for dueDate)',
},
limit: {
type: 'number',
description: 'Maximum number of tasks to return (default: 100)',
},
offset: {
type: 'number',
description: 'Number of tasks to skip for pagination (default: 0)',
},
},
},
},
{
name: 'read_task',
description: 'Read a specific task from your AiDD account',
inputSchema: {
type: 'object',
properties: {
taskId: {
type: 'string',
description: 'ID of the task to read',
},
},
required: ['taskId'],
},
},
{
name: 'convert_to_tasks',
description: 'Convert action items to ADHD-optimized tasks using AiDD AI processing. IMPORTANT: When the user says "convert these action items" or references specific items from a previous extraction, you MUST pass those specific action item IDs in the actionItemIds array. Only leave actionItemIds empty when the user explicitly says "convert ALL action items" or when no specific items were referenced.',
inputSchema: {
type: 'object',
properties: {
actionItemIds: {
type: 'array',
items: { type: 'string' },
description: 'Action item IDs to convert. REQUIRED when user references "these" items or specific items from a previous operation. Use the IDs from the extract_action_items response. Only omit when user explicitly wants ALL action items converted.',
},
breakdownMode: {
type: 'string',
enum: ['simple', 'adhd-optimized', 'detailed'],
description: 'Task breakdown mode (default: adhd-optimized)',
},
},
},
},
{
name: 'score_tasks',
description: 'Score all tasks using AiDD AI for optimal ADHD-friendly prioritization',
inputSchema: {
type: 'object',
properties: {
considerCurrentEnergy: {
type: 'boolean',
description: 'Consider current energy levels (default: true)',
},
timeOfDay: {
type: 'string',
enum: ['morning', 'afternoon', 'evening', 'auto'],
description: 'Time of day for optimization (default: auto)',
},
},
},
},
// =============================================================================
// AUTHENTICATION & UTILITY TOOLS
// =============================================================================
{
name: 'connect',
description: 'Connect to your AiDD account with email/password or OAuth',
inputSchema: {
type: 'object',
properties: {
email: {
type: 'string',
description: 'Your AiDD account email (optional - for email/password auth)',
},
password: {
type: 'string',
description: 'Your AiDD account password (optional - for email/password auth)',
},
},
},
},
{
name: 'disconnect',
description: 'Disconnect from your AiDD account and clear credentials',
inputSchema: { type: 'object', properties: {} },
},
{
name: 'status',
description: 'Check authentication status and account information',
inputSchema: { type: 'object', properties: {} },
},
{
name: 'check_backend_health',
description: 'Check AiDD backend service health and connectivity',
inputSchema: { type: 'object', properties: {} },
},
];
}
private getResources(): Resource[] {
return [
{
uri: 'aidd://notes',
name: 'Notes',
description: 'All notes from your AiDD account',
mimeType: 'application/json',
},
{
uri: 'aidd://action-items',
name: 'Action Items',
description: 'All action items from your AiDD account',
mimeType: 'application/json',
},
{
uri: 'aidd://tasks',
name: 'Tasks',
description: 'All ADHD-optimized tasks from your AiDD account',
mimeType: 'application/json',
},
{
uri: 'aidd://backend/health',
name: 'Backend Health',
description: 'AiDD backend service health status',
mimeType: 'application/json',
},
];
}
// =============================================================================
// NOTES MANAGEMENT HANDLERS
// =============================================================================
private async handleListNotes(args: any) {
try {
const notes = await this.backendClient.listNotes(args);
const response = `
š **Notes Retrieved**
**Total notes:** ${notes.length}
${notes.slice(0, 10).map((note: any, i: number) => `
${i + 1}. **${note.title}**
ā¢ ID: ${note.id}
ā¢ Category: ${note.category || 'personal'}
ā¢ Created: ${new Date(note.createdAt).toLocaleDateString()}
${note.tags && note.tags.length > 0 ? `ā¢ Tags: ${note.tags.join(', ')}` : ''}
`).join('\n')}
${notes.length > 10 ? `\n... and ${notes.length - 10} more notes` : ''}
`;
return {
content: [{
type: 'text',
text: response,
} as TextContent],
};
} catch (error) {
return {
content: [{
type: 'text',
text: `ā Error listing notes: ${error instanceof Error ? error.message : 'Unknown error'}`,
} as TextContent],
};
}
}
private async handleReadNote(args: any) {
try {
const note = await this.backendClient.readNote(args.noteId);
const response = `
š **Note Details**
**Title:** ${note.title}
**ID:** ${note.id}
**Category:** ${note.category || 'personal'}
**Created:** ${new Date(note.createdAt).toLocaleDateString()}
${note.tags && note.tags.length > 0 ? `**Tags:** ${note.tags.join(', ')}` : ''}
**Content:**
${note.content}
`;
return {
content: [{
type: 'text',
text: response,
} as TextContent],
};
} catch (error) {
return {
content: [{
type: 'text',
text: `ā Error reading note: ${error instanceof Error ? error.message : 'Unknown error'}`,
} as TextContent],
};
}
}
private async handleCreateNote(args: any) {
try {
const note = await this.backendClient.createNote(args);
const response = `
ā
**Note Created**
**Title:** ${note.title}
**ID:** ${note.id}
**Category:** ${note.category || 'personal'}
${note.tags && note.tags.length > 0 ? `**Tags:** ${note.tags.join(', ')}` : ''}
The note has been saved to your AiDD account.
`;
return {
content: [{
type: 'text',
text: response,
} as TextContent],
};
} catch (error) {
return {
content: [{
type: 'text',
text: `ā Error creating note: ${error instanceof Error ? error.message : 'Unknown error'}`,
} as TextContent],
};
}
}
private async handleImportAppleNotes(args: any) {
const { folder, query, limit = 50, saveAs = 'notes' } = args;
// Build AppleScript query
let searchCondition = '';
if (query && query !== '*') {
searchCondition = `whose body contains "${query}" or name contains "${query}"`;
}
const script = `
on run
tell application "Notes"
set output to "["
set noteCount to 0
set maxCount to ${limit}
${folder ?
`set targetFolder to folder "${folder}"
set allNotes to notes of targetFolder ${searchCondition}` :
`set allNotes to every note ${searchCondition}`
}
repeat with aNote in allNotes
if noteCount ā„ maxCount then exit repeat
set noteTitle to name of aNote as string
set noteId to id of aNote as string
set noteBody to body of aNote as string
-- Escape JSON special characters
set noteTitle to my escapeJSON(noteTitle)
set noteBody to my escapeJSON(noteBody)
set noteId to my escapeJSON(noteId)
if noteCount > 0 then set output to output & ","
set output to output & "{\\"id\\":\\"" & noteId & "\\",\\"title\\":\\"" & noteTitle & "\\",\\"content\\":\\"" & noteBody & "\\"}"
set noteCount to noteCount + 1
end repeat
set output to output & "]"
return output
end tell
end run
on escapeJSON(str)
set str to my replace(str, "\\\\", "\\\\\\\\")
set str to my replace(str, "\\"", "\\\\\\"")
set str to my replace(str, return, "\\\\n")
set str to my replace(str, linefeed, "\\\\n")
set str to my replace(str, tab, "\\\\t")
return str
end escapeJSON
on replace(str, find, replacement)
set text item delimiters to find
set pieces to text items of str
set text item delimiters to replacement
set str to pieces as string
set text item delimiters to ""
return str
end replace
`;
try {
const result = await execAppleScript(script);
const notes = JSON.parse(result);
if (saveAs === 'action-items') {
// Extract action items directly
const actionItems = await this.backendClient.extractActionItems(notes);
const response = `
š„ **Apple Notes Imported & Converted to Action Items**
**Summary:**
ā¢ Notes imported: ${notes.length}
${folder ? `ā¢ From folder: ${folder}` : 'ā¢ From: All folders'}
${query ? `ā¢ Search filter: "${query}"` : ''}
ā¢ Action items extracted: ${actionItems.length}
**Extracted Action Items:**
${actionItems.slice(0, 10).map((item: any, i: number) => `
${i + 1}. **${item.title}**
ā¢ Priority: ${item.priority}
ā¢ Category: ${item.category}
${item.dueDate ? `ā¢ Due: ${item.dueDate}` : ''}
`).join('\n')}
${actionItems.length > 10 ? `\n... and ${actionItems.length - 10} more items` : ''}
Action items have been saved to your AiDD account.
`;
return {
content: [{
type: 'text',
text: response,
} as TextContent],
};
} else {
// Save as notes
const savedNotes = [];
for (const note of notes) {
try {
const saved = await this.backendClient.createNote({
title: note.title,
content: note.content,
tags: [],
category: 'personal',
});
savedNotes.push(saved);
} catch (error) {
console.error(`Failed to save note: ${note.title}`, error);
}
}
const response = `
š„ **Apple Notes Imported & Saved**
**Summary:**
ā¢ Notes imported: ${notes.length}
${folder ? `ā¢ From folder: ${folder}` : 'ā¢ From: All folders'}
${query ? `ā¢ Search filter: "${query}"` : ''}
ā¢ Notes saved: ${savedNotes.length}
**Saved Notes:**
${savedNotes.slice(0, 10).map((note: any, i: number) => `
${i + 1}. **${note.title}**
ā¢ ID: ${note.id}
ā¢ Category: ${note.category}
`).join('\n')}
${savedNotes.length > 10 ? `\n... and ${savedNotes.length - 10} more notes` : ''}
Notes have been saved to your AiDD account.
`;
return {
content: [{
type: 'text',
text: response,
} as TextContent],
};
}
} catch (error) {
return {
content: [{
type: 'text',
text: `ā Error importing notes: ${error instanceof Error ? error.message : 'Unknown error'}`,
} as TextContent],
};
}
}
// =============================================================================
// ACTION ITEMS MANAGEMENT HANDLERS
// =============================================================================
private async handleListActionItems(args: any) {
try {
const actionItems = await this.backendClient.listActionItems(args);
const response = `
š **Action Items Retrieved**
**Total action items:** ${actionItems.length}
${actionItems.slice(0, 10).map((item: any, i: number) => `
${i + 1}. **${item.title}**
ā¢ ID: ${item.id}
ā¢ Priority: ${item.priority}
ā¢ Category: ${item.category}
${item.dueDate ? `ā¢ Due: ${new Date(item.dueDate).toLocaleDateString()}` : ''}
${item.tags && item.tags.length > 0 ? `ā¢ Tags: ${item.tags.join(', ')}` : ''}
`).join('\n')}
${actionItems.length > 10 ? `\n... and ${actionItems.length - 10} more items` : ''}
`;
return {
content: [{
type: 'text',
text: response,
} as TextContent],
};
} catch (error) {
return {
content: [{
type: 'text',
text: `ā Error listing action items: ${error instanceof Error ? error.message : 'Unknown error'}`,
} as TextContent],
};
}
}
private async handleReadActionItem(args: any) {
try {
const item = await this.backendClient.readActionItem(args.actionItemId);
const response = `
š **Action Item Details**
**Title:** ${item.title}
**ID:** ${item.id}
**Priority:** ${item.priority}
**Category:** ${item.category}
${item.dueDate ? `**Due Date:** ${new Date(item.dueDate).toLocaleDateString()}` : ''}
${item.tags && item.tags.length > 0 ? `**Tags:** ${item.tags.join(', ')}` : ''}
**Description:**
${item.description || 'No description'}
`;
return {
content: [{
type: 'text',
text: response,
} as TextContent],
};
} catch (error) {
return {
content: [{
type: 'text',
text: `ā Error reading action item: ${error instanceof Error ? error.message : 'Unknown error'}`,
} as TextContent],
};
}
}
private async handleExtractActionItems(args: any) {
try {
const { source, noteIds, text, extractionMode = 'adhd-optimized' } = args;
let notesToProcess: any[] = [];
if (source === 'notes') {
if (!noteIds || noteIds.length === 0) {
// Get all notes
const allNotes = await this.backendClient.listNotes({});
notesToProcess = allNotes;
} else {
// Get specific notes
for (const noteId of noteIds) {
const note = await this.backendClient.readNote(noteId);
notesToProcess.push(note);
}
}
} else if (source === 'text') {
if (!text) {
throw new Error('Text content is required when source is "text"');
}
notesToProcess = [{
id: 'temp',
title: 'User Provided Text',
content: text,
}];
}
const actionItems = await this.backendClient.extractActionItems(notesToProcess);
// Collect all action item IDs for potential follow-up operations
const actionItemIds = actionItems.map((item: any) => item.id).filter(Boolean);
const response = `
š **Action Items Extracted**
**Summary:**
ā¢ Source: ${source === 'notes' ? `${notesToProcess.length} notes` : 'provided text'}
ā¢ Extraction mode: ${extractionMode}
ā¢ Action items found: ${actionItems.length}
**Extracted Action Items:**
${actionItems.slice(0, 10).map((item: any, i: number) => `
${i + 1}. **${item.title}**
ā¢ ID: ${item.id}
ā¢ Priority: ${item.priority}
ā¢ Category: ${item.category}
ā¢ Confidence: ${(item.confidence * 100).toFixed(0)}%
${item.dueDate ? `ā¢ Due: ${item.dueDate}` : ''}
${item.tags && item.tags.length > 0 ? `ā¢ Tags: ${item.tags.join(', ')}` : ''}
`).join('\n')}
${actionItems.length > 10 ? `\n... and ${actionItems.length - 10} more items` : ''}
Action items have been saved to your AiDD account.
**Action Item IDs (for convert_to_tasks):**
${JSON.stringify(actionItemIds)}
`;
return {
content: [{
type: 'text',
text: response,
} as TextContent],
};
} catch (error) {
return {
content: [{
type: 'text',
text: `ā Error extracting action items: ${error instanceof Error ? error.message : 'Unknown error'}`,
} as TextContent],
};
}
}
// =============================================================================
// TASKS MANAGEMENT HANDLERS
// =============================================================================
private async handleListTasks(args: any) {
try {
const tasks = await this.backendClient.listTasks(args);
const response = `
ā
**Tasks Retrieved**
**Total tasks:** ${tasks.length}
${tasks.slice(0, 10).map((task: any, i: number) => `
${i + 1}. **${task.title}**
ā¢ ID: ${task.id}
${task.score !== undefined ? `ā¢ Score: ${task.score}/100` : ''}
${task.estimatedTime ? `ā¢ Time: ${task.estimatedTime} min` : ''}
${task.energyRequired ? `ā¢ Energy: ${task.energyRequired}` : ''}
${task.dueDate ? `ā¢ Due: ${new Date(task.dueDate).toLocaleDateString()}` : ''}
`).join('\n')}
${tasks.length > 10 ? `\n... and ${tasks.length - 10} more tasks` : ''}
`;
return {
content: [{
type: 'text',
text: response,
} as TextContent],
};
} catch (error) {
return {
content: [{
type: 'text',
text: `ā Error listing tasks: ${error instanceof Error ? error.message : 'Unknown error'}`,
} as TextContent],
};
}
}
private async handleReadTask(args: any) {
try {
const task = await this.backendClient.readTask(args.taskId);
const response = `
ā
**Task Details**
**Title:** ${task.title}
**ID:** ${task.id}
${task.score !== undefined ? `**Score:** ${task.score}/100` : ''}
${task.estimatedTime ? `**Estimated Time:** ${task.estimatedTime} minutes` : ''}
${task.energyRequired ? `**Energy Required:** ${task.energyRequired}` : ''}
${task.taskType ? `**Task Type:** ${task.taskType}` : ''}
${task.dueDate ? `**Due Date:** ${new Date(task.dueDate).toLocaleDateString()}` : ''}
${task.tags && task.tags.length > 0 ? `**Tags:** ${task.tags.join(', ')}` : ''}
**Description:**
${task.description || 'No description'}
${task.dependsOnTaskOrders && task.dependsOnTaskOrders.length > 0 ?
`**Dependencies:** Tasks ${task.dependsOnTaskOrders.join(', ')}` : ''}
`;
return {
content: [{
type: 'text',
text: response,
} as TextContent],
};
} catch (error) {
return {
content: [{
type: 'text',
text: `ā Error reading task: ${error instanceof Error ? error.message : 'Unknown error'}`,
} as TextContent],
};
}
}
private async handleConvertToTasks(args: any) {
try {
const { actionItemIds, breakdownMode = 'adhd-optimized' } = args;
let actionItems: any[] = [];
if (!actionItemIds || actionItemIds.length === 0) {
// Convert all action items
actionItems = await this.backendClient.listActionItems({});
} else {
// Convert specific action items
for (const id of actionItemIds) {
const item = await this.backendClient.readActionItem(id);
actionItems.push(item);
}
}
const tasks = await this.backendClient.convertToTasks(actionItems);
const response = `
āØ **Tasks Created (ADHD-Optimized)**
**Summary:**
ā¢ Action items converted: ${actionItems.length}
ā¢ Tasks created: ${tasks.length}
ā¢ Breakdown mode: ${breakdownMode}
ā¢ Average tasks per item: ${(tasks.length / actionItems.length).toFixed(1)}
**Created Tasks:**
${tasks.slice(0, 15).map((task: any, i: number) => `
${i + 1}. **${task.title}**
ā¢ Time: ${task.estimatedTime} min
ā¢ Energy: ${task.energyRequired}
ā¢ Type: ${task.taskType}
${task.dependsOnTaskOrders && task.dependsOnTaskOrders.length > 0 ? `ā¢ Depends on: Task ${task.dependsOnTaskOrders.join(', ')}` : ''}
`).join('\n')}
${tasks.length > 15 ? `\n... and ${tasks.length - 15} more tasks` : ''}
**Task Breakdown:**
ā¢ Quick wins: ${tasks.filter((t: any) => t.taskType === 'quick_win').length}
ā¢ Focus required: ${tasks.filter((t: any) => t.taskType === 'focus_required').length}
ā¢ Collaborative: ${tasks.filter((t: any) => t.taskType === 'collaborative').length}
ā¢ Creative: ${tasks.filter((t: any) => t.taskType === 'creative').length}
ā¢ Administrative: ${tasks.filter((t: any) => t.taskType === 'administrative').length}
Tasks have been saved to your AiDD account.
`;
return {
content: [{
type: 'text',
text: response,
} as TextContent],
};
} catch (error) {
return {
content: [{
type: 'text',
text: `ā Error converting to tasks: ${error instanceof Error ? error.message : 'Unknown error'}`,
} as TextContent],
};
}
}
private async handleScoreTasks(args: any) {
try {
const { considerCurrentEnergy = true, timeOfDay = 'auto' } = args;
// Get all tasks
const tasks = await this.backendClient.listTasks({});
// Score tasks using backend AI
const scoredTasks = await this.backendClient.scoreTasks(tasks);
// Sort by score
scoredTasks.sort((a: any, b: any) => b.score - a.score);
const actualTimeOfDay = timeOfDay === 'auto' ? this.getTimeOfDay() : timeOfDay;
const response = `
šÆ **Tasks Scored & Prioritized**
**Summary:**
ā¢ Tasks scored: ${scoredTasks.length}
ā¢ Time optimization: ${actualTimeOfDay}
ā¢ Energy considered: ${considerCurrentEnergy ? 'Yes' : 'No'}
**Top Priority Tasks (Next 2 Hours):**
${scoredTasks.slice(0, 5).map((task: any, i: number) => `
${i + 1}. **${task.title}** (Score: ${task.score}/100)
${task.factors ? `ā¢ Urgency: ${task.factors.urgency}/10` : ''}
${task.factors ? `ā¢ Importance: ${task.factors.importance}/10` : ''}
${task.factors ? `ā¢ Effort: ${task.factors.effort}/10` : ''}
${task.factors ? `ā¢ ADHD Match: ${task.factors.adhd_compatibility}/10` : ''}
${task.recommendation ? `š ${task.recommendation}` : ''}
`).join('\n')}
**Suggested Schedule:**
š
**Morning (High Energy):**
${scoredTasks.filter((t: any) => t.factors && t.factors.effort >= 7).slice(0, 3).map((t: any) => ` ā¢ ${t.title}`).join('\n') || ' No high-energy tasks'}
āļø **Afternoon (Medium Energy):**
${scoredTasks.filter((t: any) => t.factors && t.factors.effort >= 4 && t.factors.effort < 7).slice(0, 3).map((t: any) => ` ā¢ ${t.title}`).join('\n') || ' No medium-energy tasks'}
š **Evening (Low Energy):**
${scoredTasks.filter((t: any) => t.factors && t.factors.effort < 4).slice(0, 3).map((t: any) => ` ā¢ ${t.title}`).join('\n') || ' No low-energy tasks'}
All tasks have been scored and saved to your AiDD account.
`;
return {
content: [{
type: 'text',
text: response,
} as TextContent],
};
} catch (error) {
return {
content: [{
type: 'text',
text: `ā Error scoring tasks: ${error instanceof Error ? error.message : 'Unknown error'}`,
} as TextContent],
};
}
}
// =============================================================================
// AUTHENTICATION HANDLERS
// =============================================================================
private async handleConnect(args?: any) {
try {
const authManager = (this.backendClient as any).authManager;
let success = false;
// If email/password provided, use email authentication
if (args?.email && args?.password) {
success = await authManager.signInWithEmail(args.email, args.password);
if (!success) {
return {
content: [{
type: 'text',
text: 'ā Failed to sign in with email/password. Please check your credentials.',
} as TextContent],
};
}
} else {
// Otherwise use default authentication (device-based)
success = await this.backendClient.authenticate();
}
if (success) {
const info = authManager.getUserInfo();
return {
content: [{
type: 'text',
text: `ā
Connected to AiDD\n\nš§ Email: ${info.email || 'Unknown'}\nš Subscription: ${info.subscription || 'FREE'}\nš User ID: ${info.userId || 'Unknown'}\n\nReady to manage your tasks!`,
} as TextContent],
};
} else {
return {
content: [{
type: 'text',
text: 'ā Failed to connect to AiDD. Please try again or provide email/password.',
} as TextContent],
};
}
} catch (error) {
return {
content: [{
type: 'text',
text: `ā Error connecting to AiDD: ${error instanceof Error ? error.message : 'Unknown error'}`,
} as TextContent],
};
}
}
private async handleDisconnect() {
try {
const authManager = (this.backendClient as any).authManager;
await authManager.signOut();
return {
content: [{
type: 'text',
text: 'ā
Successfully disconnected from AiDD account',
} as TextContent],
};
} catch (error) {
return {
content: [{
type: 'text',
text: `ā Error disconnecting: ${error instanceof Error ? error.message : 'Unknown error'}`,
} as TextContent],
};
}
}
private async handleStatus() {
try {
const authManager = (this.backendClient as any).authManager;
const isSignedIn = authManager.isSignedIn();
if (isSignedIn) {
const info = authManager.getUserInfo();
return {
content: [{
type: 'text',
text: `ā
Connected to AiDD\n\nš§ Email: ${info.email || 'Unknown'}\nš Subscription: ${info.subscription || 'FREE'}\nš User ID: ${info.userId || 'Unknown'}\n\nReady to process your tasks!`,
} as TextContent],
};
} else {
return {
content: [{
type: 'text',
text: 'ā Not connected to AiDD\n\nUse the connect tool to sign in.',
} as TextContent],
};
}
} catch (error) {
return {
content: [{
type: 'text',
text: `ā Error checking status: ${error instanceof Error ? error.message : 'Unknown error'}`,
} as TextContent],
};
}
}
// =============================================================================
// UTILITY HANDLERS
// =============================================================================
private async handleCheckBackendHealth() {
try {
const isHealthy = await this.backendClient.checkHealth();
const response = isHealthy
? 'ā
AiDD backend is healthy and responding'
: 'ā AiDD backend is not responding. Please check your connection.';
return {
content: [{
type: 'text',
text: response,
} as TextContent],
};
} catch (error) {
return {
content: [{
type: 'text',
text: `ā Error checking backend health: ${error instanceof Error ? error.message : 'Unknown error'}`,
} as TextContent],
};
}
}
// Helper methods
private getTimeOfDay(): string {
const hour = new Date().getHours();
if (hour < 12) return 'morning';
if (hour < 17) return 'afternoon';
return 'evening';
}
private async handleResourceRead(uri: string) {
switch (uri) {
case 'aidd://notes':
const notes = await this.backendClient.listNotes({});
return {
contents: [{
uri,
mimeType: 'application/json',
text: JSON.stringify(notes, null, 2),
}],
};
case 'aidd://action-items':
const actionItems = await this.backendClient.listActionItems({});
return {
contents: [{
uri,
mimeType: 'application/json',
text: JSON.stringify(actionItems, null, 2),
}],
};
case 'aidd://tasks':
const tasks = await this.backendClient.listTasks({});
return {
contents: [{
uri,
mimeType: 'application/json',
text: JSON.stringify(tasks, null, 2),
}],
};
case 'aidd://backend/health':
const isHealthy = await this.backendClient.checkHealth();
return {
contents: [{
uri,
mimeType: 'application/json',
text: JSON.stringify({ healthy: isHealthy }, null, 2),
}],
};
default:
throw new McpError(ErrorCode.InvalidRequest, `Unknown resource: ${uri}`);
}
}
async run() {
const transport = new StdioServerTransport();
await this.server.connect(transport);
console.error('AiDD MCP Server running (v3.0 - Comprehensive CRUD)...');
}
}
// Start the server
const server = new AiDDMCPServer();
server.run().catch(console.error);