Function prepareDaemonTaskContext

packages/daemon/src/task-context.ts:388–473

(input: {
  runtime: AgentRuntimeRecord;
  task: QueuedTaskRecord;
  workDir: string;
  agentProfile?: ActiveEmployee;
  channelDocuments?: ChannelDocument[];
  agentDocumentContexts?: AgentDocumentContext[];
  contactContext?: ContactAgentContext;
  payloadOverride?: Partial<ParsedTaskPayload>;
  routerSessionContext?: RouterSessionPromptContext;
  feishuLarkCliResourceGrants?: FeishuLarkCliResourceGrant[];
})

}

export function prepareDaemonTaskContext(input: {
  runtime: AgentRuntimeRecord;
  task: QueuedTaskRecord;
  workDir: string;
  agentProfile?: ActiveEmployee;
  channelDocuments?: ChannelDocument[];
  agentDocumentContexts?: AgentDocumentContext[];
  contactContext?: ContactAgentContext;
  payloadOverride?: Partial<ParsedTaskPayload>;
  routerSessionContext?: RouterSessionPromptContext;
  feishuLarkCliResourceGrants?: FeishuLarkCliResourceGrant[];
}): PreparedDaemonTaskContext {
  const payload = {
    ...parseTaskPayload(input.task),
    ...(input.payloadOverride ?? {}),
  } satisfies ParsedTaskPayload;
  const attachmentLines = materializeAttachments(payload.attachments, input.workDir);
  const workspaceState = readWorkspaceStateSync(input.task.workspaceId);
  const runtimeApps = listRuntimeAppContextEntriesForRuntimeSync({
    workspaceId: input.task.workspaceId,
    runtimeId: input.runtime.id,
  });
  const agentDocumentContexts = input.agentDocumentContexts ?? contextsFromLegacyDocuments(input.channelDocuments ?? []);
  const feishuLarkCliResourceGrants = input.feishuLarkCliResourceGrants ?? [];
  const agentName = payload.assignee ?? input.task.agentId;
  const agentNotifications = resolveAgentNotificationsForTask({
    workspaceId: input.task.workspaceId,
    agentName,
    task: input.task,
    payload,
    agentDocumentContexts,
  });
  const documentPermissionRequests = listDocumentPermissionRequestsSync({
    workspaceId: input.task.workspaceId,
    requestedByAgentName: agentName,
  }).filter((request) => request.status === "pending" || request.status === "rejected");
  const visibleDocuments = agentDocumentContexts.map((context) => context.document);
  let agentSkills = resolveAgentSkills(workspaceState, input.agentProfile, input.task.workspaceId);
  agentSkills = includeGoogleWorkspaceCliSkill(agentSkills, workspaceState.skills, visibleDocuments, {
    workspaceId: input.task.workspaceId,
    agentName,
    channelName: payload.channelName ?? payload.channel,
  });
  agentSkills = filterRuntimeAppSkillsByRuntimeAvailability(agentSkills, runtimeApps);
  const agentKnowledgePages = resolveAgentKnowledgePages(workspaceState, input.agentProfile, input.task.workspaceId);
  const skillDirectories = materializeAgentSkills(agentSkills, input.workDir, input.runtime.provider);
  const knowledgeContextDir = materializeAgentKnowledgePages(agentKnowledgePages, input.workDir);
  const channelDocumentsContextDir =
    agentDocumentContexts.length > 0
      ? materializeChannelDocuments(agentDocumentContexts, input.workDir, input.task.workspaceId)
      : undefined;

  return {
    prompt: buildTaskPromptWithDocumentContexts(
      input.runtime,
      payload,
      attachmentLines,
      input.agentProfile,