Function processWorkflowBlockFromDb

apps/sim/lib/copilot/chat/process-contents.ts:519–566

(
  workflowId: string,
  userId: string | undefined,
  blockId: string,
  label?: string,
  currentWorkspaceId?: string
)

}

async function processWorkflowBlockFromDb(
  workflowId: string,
  userId: string | undefined,
  blockId: string,
  label?: string,
  currentWorkspaceId?: string
): Promise<AgentContext | null> {
  try {
    let workflowRecord: Awaited<ReturnType<typeof getActiveWorkflowRecord>> = null
    if (userId) {
      const authorization = await authorizeWorkflowByWorkspacePermission({
        workflowId,
        userId,
        action: 'read',
      })
      if (!authorization.allowed) {
        return null
      }
      if (currentWorkspaceId && authorization.workflow?.workspaceId !== currentWorkspaceId) {
        return null
      }
      workflowRecord = authorization.workflow ?? null
    }

    if (!workflowRecord) {
      workflowRecord = await getActiveWorkflowRecord(workflowId)
    }
    if (!workflowRecord) return null

    const folderPath = await resolveWorkflowFolderPath(
      workflowRecord.workspaceId ?? currentWorkspaceId,
      workflowRecord.folderId
    )
    const dir = canonicalWorkflowVfsDir({ name: workflowRecord.name, folderPath })
    const tag = label ? `@${label} in Workflow` : `@${blockId} in Workflow`
    // Point at the workflow state; the block id tells the model which node to
    // look up inside state.json without inlining the full block definition.
    return {
      type: 'workflow_block',
      tag,
      content: `Block id: ${blockId}`,
      path: `${dir}/state.json`,
    }
  } catch (error) {
    logger.error('Error processing workflow_block context', { workflowId, blockId, error })
    return null
  }
}

async function processExecutionLogFromDb(
  executionId: string,