Function enqueueNativeTaskSync

packages/db/src/task-queue.ts:20–116

(input: EnqueueTaskInput)

import { canUserUseRuntimeSync } from "./runtime-grants.ts";

export function enqueueNativeTaskSync(input: EnqueueTaskInput): QueuedTaskRecord | null {
  const db = getDatabase();
  const workspaceId = input.workspaceId ?? DEFAULT_WORKSPACE_ID;
  const binding = readEmployeeRuntimeBindingSync(input.assignee, workspaceId);
  if (!binding) {
    return null;
  }

  const now = new Date().toISOString();
  const queueId = `queue-${randomLikeId()}`;
  const payload = {
    taskId: input.taskId,
    assignee: input.assignee,
    title: input.title,
    channel: input.channel,
    priority: input.priority,
    ...(input.metadata ?? {}),
    requester:
      input.requestedByUserId || input.requestedByDisplayName
        ? {
            userId: input.requestedByUserId,
            displayName: input.requestedByDisplayName,
          }
        : undefined,
  };
  const routerSession = resolveRouterSessionForTaskSync({
    id: queueId,
    workspaceId,
    agentId: input.assignee,
    triggerType: input.triggerType ?? "manual",
    inputJson: JSON.stringify(payload),
    issueId: input.taskId,
  });

  db.prepare(
    `INSERT INTO agent_task_queue (
      id,
      workspace_id,
      agent_id,
      runtime_id,
      router_session_id,
      issue_id,
      trigger_type,
      priority,
      status,
      input_json,
      requested_by_user_id,
      requested_by_display_name,
      queued_at,
      created_at,
      updated_at
    ) VALUES (?, ?, ?, ?, ?, ?, ?, ?, 'queued', ?, ?, ?, ?, ?, ?)`,
  ).run(
    queueId,
    workspaceId,
    input.assignee,
    binding.runtimeId,
    routerSession.id,