import { CakemailAPI } from '../cakemail-api.js';
import { handleCakemailError } from '../utils/errors.js';
import { HandlerRegistry } from '../types/tools.js';
import logger from '../utils/logger.js';
// Import individual handlers
import { handleHealthCheck } from './health.js';
import {
handleGetTokenStatus,
handleRefreshToken,
handleValidateToken,
handleGetTokenScopes
} from './auth.js';
import {
handleGetSenders,
handleCreateSender,
handleGetSender,
handleUpdateSender,
handleDeleteSender,
handleListConfirmedSenders
} from './senders.js';
import {
handleListCampaigns,
handleGetLatestCampaigns,
handleGetCampaign,
handleCreateCampaign,
handleUpdateCampaign,
handleSendCampaign,
handleDeleteCampaign,
handleDebugCampaignAccess,
handleRenderCampaign,
handleSendTestEmail,
handleScheduleCampaign,
handleUnscheduleCampaign,
handleRescheduleCampaign,
handleSuspendCampaign,
handleResumeCampaign,
handleCancelCampaign,
handleArchiveCampaign,
handleUnarchiveCampaign,
handleGetCampaignRevisions,
handleGetCampaignLinks,
handleCreateBEETemplate,
handleValidateBEETemplate
} from './campaigns.js';
import {
handleSendEmail,
handleGetEmail,
handleRenderEmail,
handleGetEmailLogs,
handleGetEmailStats,
handleSendTransactionalEmail,
handleSendMarketingEmail,
handleGetEmailLogsWithAnalysis
} from './email.js';
import {
handleGetCampaignLogs
} from './logs.js';
import {
// Campaign analytics
handleGetCampaignStats,
handleGetCampaignLinksStats,
// Email statistics
handleGetEmailStats as handleGetEmailStatsReports,
// List and account stats
handleGetListStats as handleGetListStatsReports,
handleGetAccountStats,
handleGetActionStats,
// Export management
handleListCampaignReportsExports,
handleCreateCampaignReportsExport,
handleGetCampaignReportsExport,
handleDownloadCampaignReportsExport,
handleDeleteCampaignReportsExport,
handleListSuppressedEmailsExports,
handleCreateSuppressedEmailsExport,
handleGetSuppressedEmailsExport,
handleDownloadSuppressedEmailsExport,
handleDeleteSuppressedEmailsExport,
// Debug utilities
handleDebugReportsAccess
} from './reports/index.js';
import {
handleGetSelfAccount,
handleGetRetryConfig
} from './account.js';
import {
handleListSubAccounts,
handleCreateSubAccount,
handleGetSubAccount,
handleUpdateSubAccount,
handleDeleteSubAccount,
handleSuspendSubAccount,
handleUnsuspendSubAccount,
handleVerifySubAccountEmail,
handleResendVerificationEmail,
handleConvertSubAccountToOrganization,
handleDebugSubAccountAccess,
handleExportSubAccounts
} from './sub-accounts.js';
import {
handleListLists,
handleCreateList,
handleGetList,
handleUpdateList,
handleDeleteList,
handleArchiveList,
handleGetListStats,
handleGetListStatsTimeSeries,
handleGetListMovementLogs
} from './lists.js';
import {
handleListTemplates,
handleCreateTemplate,
handleGetTemplate,
handleUpdateTemplate,
handleDeleteTemplate,
handleDuplicateTemplate,
handleRenderTemplate
} from './templates.js';
import {
handleListContacts,
handleCreateContact,
handleGetContact,
handleUpdateContact,
handleDeleteContact,
handleUnsubscribeContact,
handleImportContacts,
handleTagContacts,
handleUntagContacts,
handleSearchContacts
} from './contacts.js';
import { handleDiagnoseDeliveryIssue } from './diagnostics.js';
// Create the handler registry (phase 1 - core handlers only)
export const handlerRegistry: HandlerRegistry = {
// Health
'cakemail_health_check': handleHealthCheck,
// Authentication
'cakemail_get_token_status': handleGetTokenStatus,
'cakemail_refresh_token': handleRefreshToken,
'cakemail_validate_token': handleValidateToken,
'cakemail_get_token_scopes': handleGetTokenScopes,
// Senders
'cakemail_get_senders': handleGetSenders,
'cakemail_list_confirmed_senders': handleListConfirmedSenders,
'cakemail_create_sender': handleCreateSender,
'cakemail_get_sender': handleGetSender,
'cakemail_update_sender': handleUpdateSender,
'cakemail_delete_sender': handleDeleteSender,
// Campaigns (with BEE support)
'cakemail_list_campaigns': handleListCampaigns,
'cakemail_get_latest_campaigns': handleGetLatestCampaigns,
'cakemail_get_campaign': handleGetCampaign,
'cakemail_create_campaign': handleCreateCampaign,
'cakemail_update_campaign': handleUpdateCampaign,
'cakemail_send_campaign': handleSendCampaign,
'cakemail_delete_campaign': handleDeleteCampaign,
'cakemail_debug_campaign_access': handleDebugCampaignAccess,
'cakemail_render_campaign': handleRenderCampaign,
'cakemail_send_test_email': handleSendTestEmail,
'cakemail_schedule_campaign': handleScheduleCampaign,
'cakemail_unschedule_campaign': handleUnscheduleCampaign,
'cakemail_reschedule_campaign': handleRescheduleCampaign,
'cakemail_suspend_campaign': handleSuspendCampaign,
'cakemail_resume_campaign': handleResumeCampaign,
'cakemail_cancel_campaign': handleCancelCampaign,
'cakemail_archive_campaign': handleArchiveCampaign,
'cakemail_unarchive_campaign': handleUnarchiveCampaign,
'cakemail_get_campaign_revisions': handleGetCampaignRevisions,
'cakemail_get_campaign_links': handleGetCampaignLinks,
// BEEeditor specific tools
'cakemail_create_bee_template': handleCreateBEETemplate,
'cakemail_validate_bee_template': handleValidateBEETemplate,
// Email API v2
'cakemail_send_email': handleSendEmail,
'cakemail_get_email': handleGetEmail,
'cakemail_render_email': handleRenderEmail,
'cakemail_get_email_logs': handleGetEmailLogs,
'cakemail_get_email_stats': handleGetEmailStats,
'cakemail_send_transactional_email': handleSendTransactionalEmail,
'cakemail_send_marketing_email': handleSendMarketingEmail,
'cakemail_get_email_logs_with_analysis': handleGetEmailLogsWithAnalysis,
// Logs
'cakemail_get_campaign_logs': handleGetCampaignLogs,
// Reports - Campaign Analytics
'cakemail_get_campaign_stats': handleGetCampaignStats,
'cakemail_get_campaign_links_stats': handleGetCampaignLinksStats,
// Reports - Email Statistics
'cakemail_get_reports_email_stats': handleGetEmailStatsReports,
// Reports - List Analytics
'cakemail_get_reports_list_stats': handleGetListStatsReports,
// Reports - Account Overview
'cakemail_get_account_stats': handleGetAccountStats,
// Reports - Workflow Analytics
'cakemail_get_action_stats': handleGetActionStats,
// Reports - Campaign Exports
'cakemail_list_campaign_reports_exports': handleListCampaignReportsExports,
'cakemail_create_campaign_reports_export': handleCreateCampaignReportsExport,
'cakemail_get_campaign_reports_export': handleGetCampaignReportsExport,
'cakemail_download_campaign_reports_export': handleDownloadCampaignReportsExport,
'cakemail_delete_campaign_reports_export': handleDeleteCampaignReportsExport,
// Reports - Suppressed Emails Exports
'cakemail_list_suppressed_emails_exports': handleListSuppressedEmailsExports,
'cakemail_create_suppressed_emails_export': handleCreateSuppressedEmailsExport,
'cakemail_get_suppressed_emails_export': handleGetSuppressedEmailsExport,
'cakemail_download_suppressed_emails_export': handleDownloadSuppressedEmailsExport,
'cakemail_delete_suppressed_emails_export': handleDeleteSuppressedEmailsExport,
// Reports - Debug
'cakemail_debug_reports_access': handleDebugReportsAccess,
// Account
'cakemail_get_self_account': handleGetSelfAccount,
'cakemail_get_retry_config': handleGetRetryConfig,
// Sub-Account Management
'cakemail_list_sub_accounts': handleListSubAccounts,
'cakemail_create_sub_account': handleCreateSubAccount,
'cakemail_get_sub_account': handleGetSubAccount,
'cakemail_update_sub_account': handleUpdateSubAccount,
'cakemail_delete_sub_account': handleDeleteSubAccount,
'cakemail_suspend_sub_account': handleSuspendSubAccount,
'cakemail_unsuspend_sub_account': handleUnsuspendSubAccount,
'cakemail_verify_sub_account_email': handleVerifySubAccountEmail,
'cakemail_resend_sub_account_verification': handleResendVerificationEmail,
'cakemail_convert_sub_account_to_organization': handleConvertSubAccountToOrganization,
'cakemail_debug_sub_account_access': handleDebugSubAccountAccess,
'cakemail_export_sub_accounts': handleExportSubAccounts,
// List Management
'cakemail_list_lists': handleListLists,
'cakemail_create_list': handleCreateList,
'cakemail_get_list': handleGetList,
'cakemail_update_list': handleUpdateList,
'cakemail_delete_list': handleDeleteList,
'cakemail_archive_list': handleArchiveList,
'cakemail_get_list_stats': handleGetListStats,
'cakemail_get_list_stats_time_series': handleGetListStatsTimeSeries,
'cakemail_get_list_movement_logs': handleGetListMovementLogs,
// Template Management
'cakemail_list_templates': handleListTemplates,
'cakemail_create_template': handleCreateTemplate,
'cakemail_get_template': handleGetTemplate,
'cakemail_update_template': handleUpdateTemplate,
'cakemail_delete_template': handleDeleteTemplate,
'cakemail_duplicate_template': handleDuplicateTemplate,
'cakemail_render_template': handleRenderTemplate,
// Contact Management
'cakemail_list_contacts': handleListContacts,
'cakemail_create_contact': handleCreateContact,
'cakemail_get_contact': handleGetContact,
'cakemail_update_contact': handleUpdateContact,
'cakemail_delete_contact': handleDeleteContact,
'cakemail_unsubscribe_contact': handleUnsubscribeContact,
'cakemail_import_contacts': handleImportContacts,
'cakemail_tag_contacts': handleTagContacts,
'cakemail_untag_contacts': handleUntagContacts,
'cakemail_search_contacts': handleSearchContacts,
// Diagnostic Tools
'cakemail_diagnose_delivery_issue': handleDiagnoseDeliveryIssue,
// Note: Additional handlers will be added incrementally as they are fully implemented
};
const isDebug = process.env.CAKEMAIL_DEBUG === 'true';
// Main handler dispatcher
export async function handleToolCall(request: any, api: CakemailAPI) {
if (isDebug) logger.info({ incoming: request }, 'Received tool call request');
const { name, arguments: args } = request.params;
const handler = handlerRegistry[name];
if (!handler) {
const response = {
content: [
{
type: 'text',
text: `❌ **Unknown Tool**: ${name}\n\nThis tool is not recognized. Please check the tool name and try again.`,
},
],
isError: true,
};
if (isDebug) logger.info({ outgoing: response }, 'Sending tool call response');
return response;
}
try {
const response = await handler(args, api);
if (isDebug) logger.info({ outgoing: response }, 'Sending tool call response');
return response;
} catch (error) {
const response = handleCakemailError(error);
if (isDebug) logger.info({ outgoing: response, error }, 'Sending tool call error response');
return response;
}
}
