Workflow tags

Author: Sg312

apps/sim/lib/copilot/process-contents.ts

@@ -2,8 +2,11 @@ import { db } from '@sim/db'
 import { document, knowledgeBase, templates } from '@sim/db/schema'
 import { createLogger } from '@sim/logger'
 import { and, eq, isNull } from 'drizzle-orm'
-import { readFileRecord } from '@/lib/copilot/vfs/file-reader'
-import { serializeTableMeta } from '@/lib/copilot/vfs/serializers'
+import {
+  serializeFileMeta,
+  serializeTableMeta,
+  serializeWorkflowMeta,
+} from '@/lib/copilot/vfs/serializers'
 import { upsertWorkflowReadHashForSanitizedState } from '@/lib/copilot/workflow-read-hashes'
 import { getAllowedIntegrationsFromEnv } from '@/lib/core/config/feature-flags'
 import { getTableById } from '@/lib/table/service'
@@ -318,7 +321,7 @@ async function processWorkflowFromDb(
   chatId?: string
 ): Promise<AgentContext | null> {
   try {
-    let workflowName: string | undefined
+    let workflowRecord: Awaited<ReturnType<typeof getActiveWorkflowRecord>> = null
 
     if (userId) {
       const authorization = await authorizeWorkflowByWorkspacePermission({
@@ -332,7 +335,27 @@ async function processWorkflowFromDb(
       if (currentWorkspaceId && authorization.workflow?.workspaceId !== currentWorkspaceId) {
         return null
       }
-      workflowName = authorization.workflow?.name ?? undefined
+      workflowRecord = authorization.workflow ?? null
+    }
+
+    if (!workflowRecord) {
+      workflowRecord = await getActiveWorkflowRecord(workflowId)
+    }
+
+    if (kind === 'workflow') {
+      if (!workflowRecord) return null
+      const content = serializeWorkflowMeta({
+        id: workflowRecord.id,
+        name: workflowRecord.name,
+        description: workflowRecord.description,
+        isDeployed: workflowRecord.isDeployed,
+        deployedAt: workflowRecord.deployedAt,
+        runCount: workflowRecord.runCount,
+        lastRunAt: workflowRecord.lastRunAt,
+        createdAt: workflowRecord.createdAt,
+        updatedAt: workflowRecord.updatedAt,
+      })
+      return { type: kind, tag, content }
     }
 
     const normalized = await loadWorkflowFromNormalizedTables(workflowId)
@@ -341,11 +364,6 @@ async function processWorkflowFromDb(
       return null
     }
 
-    if (!workflowName) {
-      const record = await getActiveWorkflowRecord(workflowId)
-      workflowName = record?.name ?? undefined
-    }
-
     const workflowState = {
       blocks: normalized.blocks || {},
       edges: normalized.edges || [],
@@ -359,7 +377,7 @@ async function processWorkflowFromDb(
     const content = JSON.stringify(
       {
         workflowId,
-        workflowName: workflowName || undefined,
+        workflowName: workflowRecord?.name || undefined,
         state: sanitizedState,
       },
       null,
@@ -786,18 +804,15 @@ async function resolveFileResource(
 ): Promise<AgentContext | null> {
   const record = await getWorkspaceFile(workspaceId, fileId)
   if (!record) return null
-  const fileResult = await readFileRecord(record)
-  const meta = {
-    id: record.id,
-    name: record.name,
-    contentType: record.type,
-    size: record.size,
-    uploadedAt: record.uploadedAt.toISOString(),
-    content: fileResult?.content || `[Could not read ${record.name}]`,
-  }
   return {
     type: 'active_resource',
     tag: '@active_resource',
-    content: JSON.stringify(meta, null, 2),
+    content: serializeFileMeta({
+      id: record.id,
+      name: record.name,
+      contentType: record.type,
+      size: record.size,
+      uploadedAt: record.uploadedAt,
+    }),
   }
 }