Function upsertAsyncToolCall

apps/sim/lib/copilot/async-runs/repository.ts:231–303

(input: {
  runId?: string | null
  checkpointId?: string | null
  toolCallId: string
  toolName: string
  args?: Record<string, unknown>
  status?: CopilotAsyncToolStatus
})

}

export async function upsertAsyncToolCall(input: {
  runId?: string | null
  checkpointId?: string | null
  toolCallId: string
  toolName: string
  args?: Record<string, unknown>
  status?: CopilotAsyncToolStatus
}) {
  return withDbSpan(
    TraceSpan.CopilotAsyncRunsUpsertAsyncToolCall,
    'UPSERT',
    'copilot_async_tool_calls',
    {
      [TraceAttr.ToolCallId]: input.toolCallId,
      [TraceAttr.ToolName]: input.toolName,
      [TraceAttr.CopilotAsyncToolStatus]: input.status ?? 'pending',
      [TraceAttr.RunId]: input.runId ?? undefined,
    },
    async () => {
      const existing = await getAsyncToolCall(input.toolCallId)
      const incomingStatus = input.status ?? 'pending'
      if (
        existing &&
        (isTerminalAsyncStatus(existing.status) || isDeliveredAsyncStatus(existing.status)) &&
        !isTerminalAsyncStatus(incomingStatus) &&
        !isDeliveredAsyncStatus(incomingStatus)
      ) {
        logger.info('Ignoring async tool upsert that would downgrade terminal state', {
          toolCallId: input.toolCallId,
          existingStatus: existing.status,
          incomingStatus,
        })
        return existing
      }
      const effectiveRunId = input.runId ?? existing?.runId ?? null
      if (!effectiveRunId) {
        logger.warn('upsertAsyncToolCall missing runId and no existing row', {
          toolCallId: input.toolCallId,
          toolName: input.toolName,
          status: input.status ?? 'pending',
        })
        return null
      }

      const now = new Date()
      const [row] = await db
        .insert(copilotAsyncToolCalls)
        .values({
          runId: effectiveRunId,
          checkpointId: input.checkpointId ?? null,
          toolCallId: input.toolCallId,
          toolName: input.toolName,
          args: input.args ?? {},
          status: incomingStatus,
          updatedAt: now,
        })
        .onConflictDoUpdate({
          target: copilotAsyncToolCalls.toolCallId,