Function buildTaskCreateTool

packages/runtime/src/task-ledger-tools.ts:30–84

(
  store: TaskLedgerStore,
  name: string,
  updateToolName: string,
)

}

function buildTaskCreateTool(
  store: TaskLedgerStore,
  name: string,
  updateToolName: string,
): MakaTool<{ tasks: Array<{ subject: string; parent_id?: string }> }, string> {
  return {
    name,
    displayName: 'Task Create',
    description:
      'Add one or more tasks to the session task ledger. The full updated ledger is re-shown each turn, ' +
      `so use this to record work you plan to do; update status with ${updateToolName} as you progress.`,
    parameters: z.object({
      tasks: z
        .array(
          z.object({
            subject: z
              .string()
              .trim()
              .min(1)
              .max(TASK_SUBJECT_MAX_CHARS)
              .describe(
                `Short imperative description of the task (max ${TASK_SUBJECT_MAX_CHARS} characters).`,
              ),
            parent_id: z
              .string()
              .min(1)
              .max(TASK_ID_MAX_CHARS)
              .refine(isSafeTaskId)
              .optional()
              .describe('Existing parent task UUID or short key (for example T1).'),
          }),
        )
        .min(1)
        .max(TASK_LEDGER_MAX_TASKS)
        .describe('One or more tasks to add. Each starts in the pending state.'),
    }),
    impl: async (input, ctx) => {
      const { created, total } = await store.create(
        ctx.sessionId,
        input.tasks.map((task) => ({
          subject: task.subject,
          ...(task.parent_id ? { parentId: task.parent_id } : {}),
        })),
        {
          runId: ctx.runId,
          turnId: ctx.turnId,
          toolCallId: ctx.toolCallId,
          source: 'tool',
          actor: 'main_agent',
        },
      );
      return `Created ${created.length} task(s); ledger total: ${total}.\n${renderSafeTaskLedgerText(created)}`;
    },
  };
}

function buildTaskUpdateTool(
  store: TaskLedgerStore,