Function processWorkflowFromDb

apps/sim/lib/copilot/chat/process-contents.ts:357–402

(
  workflowId: string,
  userId: string | undefined,
  tag: string,
  kind: 'workflow' | 'current_workflow' = 'workflow',
  currentWorkspaceId?: string,
  _chatId?: string
)

}

async function processWorkflowFromDb(
  workflowId: string,
  userId: string | undefined,
  tag: string,
  kind: 'workflow' | 'current_workflow' = 'workflow',
  currentWorkspaceId?: string,
  _chatId?: 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

    // Emit a VFS-path pointer instead of the full (potentially huge) workflow
    // state/meta. `current_workflow` points at the live state; a plain
    // `workflow` mention points at the lighter metadata file.
    const folderPath = await resolveWorkflowFolderPath(
      workflowRecord.workspaceId ?? currentWorkspaceId,
      workflowRecord.folderId
    )
    const dir = canonicalWorkflowVfsDir({ name: workflowRecord.name, folderPath })
    const path = kind === 'current_workflow' ? `${dir}/state.json` : `${dir}/meta.json`
    return { type: kind, tag, content: '', path }
  } catch (error) {
    logger.error('Error processing workflow context', { workflowId, error })
    return null
  }
}

async function processPastChat(chatId: string, tagOverride?: string): Promise<AgentContext | null> {
  try {