Taskmaster

/** * Direct function wrapper for expandAllTasks */ import { expandAllTasks } from '../../../../scripts/modules/task-manager.js'; import { disableSilentMode, enableSilentMode } from '../../../../scripts/modules/utils.js'; import { resolveComplexityReportOutputPath } from '../../../../src/utils/path-utils.js'; import { createLogWrapper } from '../../tools/utils.js'; /** * Expand all pending tasks with subtasks (Direct Function Wrapper) * @param {Object} args - Function arguments * @param {string} args.tasksJsonPath - Explicit path to the tasks.json file. * @param {number|string} [args.num] - Number of subtasks to generate * @param {boolean} [args.research] - Enable research-backed subtask generation * @param {string} [args.prompt] - Additional context to guide subtask generation * @param {boolean} [args.force] - Force regeneration of subtasks for tasks that already have them * @param {string} [args.projectRoot] - Project root path. * @param {string} [args.tag] - Tag for the task (optional) * @param {Object} log - Logger object from FastMCP * @param {Object} context - Context object containing session * @returns {Promise<{success: boolean, data?: Object, error?: {code: string, message: string}}>} */ export async function expandAllTasksDirect(args, log, context = {}) { const { session } = context; // Extract session // Destructure expected args, including projectRoot and complexityReportPath const { tasksJsonPath, num, research, prompt, force, projectRoot, tag, complexityReportPath: providedComplexityReportPath } = args; // Create logger wrapper using the utility const mcpLog = createLogWrapper(log); // Use provided complexity report path or compute it const complexityReportPath = providedComplexityReportPath || resolveComplexityReportOutputPath(null, { projectRoot, tag }, log); log.info( `Expand all tasks will use complexity report at: ${complexityReportPath}` ); if (!tasksJsonPath) { log.error('expandAllTasksDirect called without tasksJsonPath'); return { success: false, error: { code: 'MISSING_ARGUMENT', message: 'tasksJsonPath is required' } }; } enableSilentMode(); // Enable silent mode for the core function call try { log.info( `Calling core expandAllTasks with args: ${JSON.stringify({ num, research, prompt, force, projectRoot, tag })}` ); // Parse parameters (ensure correct types) const numSubtasks = num ? parseInt(num, 10) : undefined; const useResearch = research === true; const additionalContext = prompt || ''; const forceFlag = force === true; // Call the core function, passing options and the context object { session, mcpLog, projectRoot, tag, complexityReportPath } const result = await expandAllTasks( tasksJsonPath, numSubtasks, useResearch, additionalContext, forceFlag, { session, mcpLog, projectRoot, tag, complexityReportPath }, 'json' ); // Core function now returns a summary object including the *aggregated* telemetryData return { success: true, data: { message: `Expand all operation completed. Expanded: ${result.expandedCount}, Failed: ${result.failedCount}, Skipped: ${result.skippedCount}`, details: { expandedCount: result.expandedCount, failedCount: result.failedCount, skippedCount: result.skippedCount, tasksToExpand: result.tasksToExpand }, telemetryData: result.telemetryData // Pass the aggregated object } }; } catch (error) { // Log the error using the MCP logger log.error(`Error during core expandAllTasks execution: ${error.message}`); // Optionally log stack trace if available and debug enabled // if (error.stack && log.debug) { log.debug(error.stack); } return { success: false, error: { code: 'CORE_FUNCTION_ERROR', // Or a more specific code if possible message: error.message } }; } finally { disableSilentMode(); // IMPORTANT: Ensure silent mode is always disabled } }