Function handleCreateTask

notfair-cmo/src/server/orchestration/handlers.ts:94–143

(
  input: CreateTaskInput,
  ctx: HandlerContext,
)

};

export async function handleCreateTask(
  input: CreateTaskInput,
  ctx: HandlerContext,
): Promise<HandlerResult<Task>> {
  const template = templateForKey(input.assignee);
  if (!template) {
    return { ok: false, error: `Unknown assignee template '${input.assignee}'` };
  }
  if (template.key === "cmo") {
    return { ok: false, error: "CMO cannot assign tasks to itself — pick a specialist" };
  }

  // Look up the assignee by template_key — agent_ids encode the
  // personal name (e.g. `acme-google-ads-ana`), so we can't synthesize
  // one from the role alone.
  const assigneeEntry = (await listProjectAgents(ctx.project_slug)).find(
    (a) => a.template_key === template.key,
  );
  if (!assigneeEntry || !(await agentExists(assigneeEntry.agent_id))) {
    return {
      ok: false,
      error: `Assignee agent for role '${template.key}' is not provisioned for this project`,
    };
  }
  const assigneeAgentId = assigneeEntry.agent_id;

  const task = createTask({
    project_slug: ctx.project_slug,
    agent_id: assigneeAgentId,
    title: input.title,
    brief: input.brief,
    success_criteria: input.success_criteria ?? null,
    assigner_agent_id: ctx.agent_id,
    status: "proposed",
  });

  logAgentAction({
    project_slug: ctx.project_slug,
    agent_id: ctx.agent_id,
    action_type: "task_created",
    summary: `Created task '${task.title}' for ${template.display_name}.`,
    payload: { task_id: task.id, assignee: assigneeAgentId },
  });

  // Auto-start the delegated task. Lazy import keeps the orchestration →
  // run-task → gateway chain out of modules that just want createTask.
  const { startTaskIfProposed } = await import("./run-task");
  const started = startTaskIfProposed(task);
  return { ok: true, data: started };
}

// ── submit_task_status ──────────────────────────────────────────────────