d25d482dc2
Publish CLI Package / publish-npm (push) Waiting to run
Publish Python SDK / publish-pypi (push) Waiting to run
Publish TypeScript SDK / publish-npm (push) Waiting to run
CI / Migrate Dev DB (push) Has been skipped
CI / Detect Version (push) Has been cancelled
CI / Migrate DB (push) Has been cancelled
CI / Build Dev ECR (./docker/app.Dockerfile, ECR_APP) (push) Has been cancelled
CI / Build Dev ECR (./docker/db.Dockerfile, ECR_MIGRATIONS) (push) Has been cancelled
CI / Build Dev ECR (./docker/pii.Dockerfile, ECR_PII) (push) Has been cancelled
CI / Build Dev ECR (./docker/realtime.Dockerfile, ECR_REALTIME) (push) Has been cancelled
CI / Deploy Trigger.dev (Dev) (push) Has been cancelled
CI / Build AMD64 (./docker/app.Dockerfile, ECR_APP, ghcr.io/simstudioai/simstudio) (push) Has been cancelled
CI / Build AMD64 (./docker/db.Dockerfile, ECR_MIGRATIONS, ghcr.io/simstudioai/migrations) (push) Has been cancelled
CI / Build AMD64 (./docker/pii.Dockerfile, ECR_PII, ghcr.io/simstudioai/pii) (push) Has been cancelled
CI / Build AMD64 (./docker/realtime.Dockerfile, ECR_REALTIME, ghcr.io/simstudioai/realtime) (push) Has been cancelled
CI / Build ARM64 (GHCR Only) (./docker/app.Dockerfile, ghcr.io/simstudioai/simstudio) (push) Has been cancelled
CI / Build ARM64 (GHCR Only) (./docker/db.Dockerfile, ghcr.io/simstudioai/migrations) (push) Has been cancelled
CI / Build ARM64 (GHCR Only) (./docker/pii.Dockerfile, ghcr.io/simstudioai/pii) (push) Has been cancelled
CI / Build ARM64 (GHCR Only) (./docker/realtime.Dockerfile, ghcr.io/simstudioai/realtime) (push) Has been cancelled
CI / Create GHCR Manifests (ghcr.io/simstudioai/migrations) (push) Has been cancelled
CI / Create GHCR Manifests (ghcr.io/simstudioai/pii) (push) Has been cancelled
CI / Create GHCR Manifests (ghcr.io/simstudioai/realtime) (push) Has been cancelled
CI / Create GHCR Manifests (ghcr.io/simstudioai/simstudio) (push) Has been cancelled
CI / Check Docs Changes (push) Has been cancelled
CI / Process Docs (push) Has been cancelled
CI / Create GitHub Release (push) Has been cancelled
CI / Test and Build (push) Has been cancelled
154 lines
5.5 KiB
TypeScript
154 lines
5.5 KiB
TypeScript
import { type Edge, type Node, Position } from 'reactflow'
|
|
|
|
/**
|
|
* Tool entry displayed as a chip on a block (e.g. an Agent's attached tools).
|
|
*/
|
|
export interface PreviewTool {
|
|
name: string
|
|
type: string
|
|
bgColor: string
|
|
}
|
|
|
|
/**
|
|
* A single block in a preview workflow. Presentational shape — authored by hand
|
|
* for docs diagrams, not the app's full serialized block state.
|
|
*/
|
|
export interface PreviewBlock {
|
|
id: string
|
|
name: string
|
|
type: string
|
|
bgColor: string
|
|
rows: Array<{ title: string; value: string }>
|
|
/**
|
|
* Branch rows, each with its own right-edge source handle whose id is the
|
|
* branch id. Author ids in the app's own handle scheme so edges match the
|
|
* real workflow representation verbatim: `condition-<id>` on Condition
|
|
* blocks, `router-<routeId>` on Routers.
|
|
*/
|
|
branches?: Array<{ id: string; label: string; value?: string }>
|
|
tools?: PreviewTool[]
|
|
position: { x: number; y: number }
|
|
hideTargetHandle?: boolean
|
|
/** When set, the block renders as a Loop/Parallel container sized to hold its children. */
|
|
size?: { width: number; height: number }
|
|
/** Id of the container block this block sits inside. Its position is relative to the container. */
|
|
parentId?: string
|
|
}
|
|
|
|
/**
|
|
* A workflow rendered as a read-only, app-styled diagram in the docs.
|
|
*/
|
|
export interface PreviewWorkflow {
|
|
id: string
|
|
name: string
|
|
blocks: PreviewBlock[]
|
|
edges: Array<{ id: string; source: string; target: string; sourceHandle?: string }>
|
|
}
|
|
|
|
export const BLOCK_STAGGER = 0.12
|
|
export const EASE_OUT: [number, number, number, number] = [0.16, 1, 0.3, 1]
|
|
|
|
const EDGE_STYLE = { stroke: 'var(--workflow-edge)', strokeWidth: 2 } as const
|
|
const EDGE_STYLE_HIGHLIGHT = { stroke: 'var(--brand-secondary)', strokeWidth: 2.5 } as const
|
|
/** Edges leaving a block's error port render red, matching the editor. */
|
|
const EDGE_STYLE_ERROR = { stroke: 'var(--text-error)', strokeWidth: 2 } as const
|
|
|
|
/** Optional emphasis: light one block or one edge and dim everything else. */
|
|
export interface HighlightOptions {
|
|
highlightBlock?: string
|
|
highlightEdge?: string
|
|
/** Ring one block (selection) without dimming the rest. */
|
|
selectedBlock?: string
|
|
}
|
|
|
|
/**
|
|
* Converts a {@link PreviewWorkflow} to React Flow nodes and edges.
|
|
*
|
|
* @param workflow - The workflow definition
|
|
* @param animate - When true, node/edge data carries stagger metadata
|
|
* @param highlight - Optional block/edge to emphasize (dims the rest)
|
|
*/
|
|
export function toReactFlowElements(
|
|
workflow: PreviewWorkflow,
|
|
animate = false,
|
|
highlight: HighlightOptions = {}
|
|
): { nodes: Node[]; edges: Edge[] } {
|
|
const { highlightBlock, highlightEdge, selectedBlock } = highlight
|
|
const hasHighlight = Boolean(highlightBlock || highlightEdge)
|
|
const blockIndexMap = new Map(workflow.blocks.map((b, i) => [b.id, i]))
|
|
|
|
const blocksById = new Map(workflow.blocks.map((b) => [b.id, b]))
|
|
|
|
const nodes: Node[] = workflow.blocks.map((block, index) => {
|
|
const isContainer = Boolean(block.size)
|
|
// Nested blocks are authored relative to their container; render them at
|
|
// absolute coordinates (not React Flow parentNode children) so the edges
|
|
// between a container and its nested blocks render reliably and on top.
|
|
const parent = block.parentId ? blocksById.get(block.parentId) : undefined
|
|
const position = parent
|
|
? { x: parent.position.x + block.position.x, y: parent.position.y + block.position.y }
|
|
: block.position
|
|
return {
|
|
id: block.id,
|
|
type: isContainer ? 'previewContainer' : 'previewBlock',
|
|
position,
|
|
zIndex: isContainer ? 0 : 1,
|
|
...(block.size ? { style: { width: block.size.width, height: block.size.height } } : {}),
|
|
data: {
|
|
name: block.name,
|
|
blockType: block.type,
|
|
bgColor: block.bgColor,
|
|
rows: block.rows,
|
|
branches: block.branches,
|
|
tools: block.tools,
|
|
hideTargetHandle: block.hideTargetHandle,
|
|
size: block.size,
|
|
index,
|
|
animate,
|
|
isHighlighted: highlightBlock === block.id || selectedBlock === block.id,
|
|
isDimmed: hasHighlight && highlightBlock !== block.id,
|
|
},
|
|
draggable: true,
|
|
selectable: false,
|
|
connectable: false,
|
|
sourcePosition: Position.Right,
|
|
targetPosition: Position.Left,
|
|
}
|
|
})
|
|
|
|
const edges: Edge[] = workflow.edges.map((e) => {
|
|
const sourceIndex = blockIndexMap.get(e.source) ?? 0
|
|
const isEdgeHighlight = highlightEdge === e.id
|
|
const dimmed = hasHighlight && !isEdgeHighlight
|
|
const isErrorEdge = e.sourceHandle === 'error'
|
|
// Subflow containers expose a right-edge output handle (`loop-end-source` /
|
|
// `parallel-end-source`) and a left-edge input handle with no id; regular
|
|
// blocks use `source` / `target`. Resolve each end to the block's real handle
|
|
// so edges into and out of Loop/Parallel containers still connect.
|
|
const sourceBlock = blocksById.get(e.source)
|
|
const targetBlock = blocksById.get(e.target)
|
|
const sourceHandle =
|
|
e.sourceHandle ?? (sourceBlock?.size ? `${sourceBlock.type}-end-source` : 'source')
|
|
const targetHandle = targetBlock?.size ? undefined : 'target'
|
|
return {
|
|
id: e.id,
|
|
source: e.source,
|
|
target: e.target,
|
|
type: 'previewEdge',
|
|
animated: false,
|
|
style: {
|
|
...(isEdgeHighlight ? EDGE_STYLE_HIGHLIGHT : isErrorEdge ? EDGE_STYLE_ERROR : EDGE_STYLE),
|
|
opacity: dimmed ? 0.35 : 1,
|
|
},
|
|
sourceHandle,
|
|
targetHandle,
|
|
data: {
|
|
animate,
|
|
delay: animate ? sourceIndex * BLOCK_STAGGER + BLOCK_STAGGER : 0,
|
|
},
|
|
}
|
|
})
|
|
|
|
return { nodes, edges }
|
|
}
|