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
103 lines
3.1 KiB
TypeScript
103 lines
3.1 KiB
TypeScript
import { getEffectiveBlockOutputs } from '@/lib/workflows/blocks/block-outputs'
|
|
import { hasTriggerCapability } from '@/lib/workflows/triggers/trigger-utils'
|
|
import { getBlock } from '@/blocks/registry'
|
|
import { isTriggerBehavior, normalizeName } from '@/executor/constants'
|
|
import type { ExecutionContext } from '@/executor/types'
|
|
import type { OutputSchema } from '@/executor/utils/block-reference'
|
|
import {
|
|
extractBaseBlockId,
|
|
extractBranchIndex,
|
|
isBranchNodeId,
|
|
} from '@/executor/utils/subflow-utils'
|
|
import type { SerializedBlock } from '@/serializer/types'
|
|
|
|
export interface BlockDataCollection {
|
|
blockData: Record<string, unknown>
|
|
blockNameMapping: Record<string, string>
|
|
blockOutputSchemas: Record<string, OutputSchema>
|
|
}
|
|
|
|
interface SubBlockWithValue {
|
|
value?: unknown
|
|
}
|
|
|
|
function paramsToSubBlocks(
|
|
params: Record<string, unknown> | undefined
|
|
): Record<string, SubBlockWithValue> {
|
|
if (!params) return {}
|
|
|
|
const subBlocks: Record<string, SubBlockWithValue> = {}
|
|
for (const [key, value] of Object.entries(params)) {
|
|
subBlocks[key] = { value }
|
|
}
|
|
return subBlocks
|
|
}
|
|
|
|
function getRegistrySchema(block: SerializedBlock): OutputSchema | undefined {
|
|
const blockType = block.metadata?.id
|
|
if (!blockType) return undefined
|
|
|
|
const subBlocks = paramsToSubBlocks(block.config?.params)
|
|
const blockConfig = getBlock(blockType)
|
|
const isTriggerCapable = blockConfig ? hasTriggerCapability(blockConfig) : false
|
|
const triggerMode = Boolean(isTriggerBehavior(block) && isTriggerCapable)
|
|
const outputs = getEffectiveBlockOutputs(blockType, subBlocks, {
|
|
triggerMode,
|
|
preferToolOutputs: !triggerMode,
|
|
includeHidden: true,
|
|
}) as OutputSchema
|
|
|
|
if (!outputs || Object.keys(outputs).length === 0) {
|
|
return undefined
|
|
}
|
|
return outputs
|
|
}
|
|
|
|
export function getBlockSchema(block: SerializedBlock): OutputSchema | undefined {
|
|
return getRegistrySchema(block)
|
|
}
|
|
|
|
export function collectBlockData(
|
|
ctx: ExecutionContext,
|
|
currentNodeId?: string
|
|
): BlockDataCollection {
|
|
const blockData: Record<string, unknown> = {}
|
|
const blockNameMapping: Record<string, string> = {}
|
|
const blockOutputSchemas: Record<string, OutputSchema> = {}
|
|
|
|
const branchIndex =
|
|
currentNodeId && isBranchNodeId(currentNodeId) ? extractBranchIndex(currentNodeId) : null
|
|
|
|
for (const [id, state] of ctx.blockStates.entries()) {
|
|
if (state.output !== undefined) {
|
|
blockData[id] = state.output
|
|
|
|
if (branchIndex !== null && isBranchNodeId(id)) {
|
|
const stateBranchIndex = extractBranchIndex(id)
|
|
if (stateBranchIndex === branchIndex) {
|
|
const baseId = extractBaseBlockId(id)
|
|
if (blockData[baseId] === undefined) {
|
|
blockData[baseId] = state.output
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
const workflowBlocks = ctx.workflow?.blocks ?? []
|
|
for (const block of workflowBlocks) {
|
|
const id = block.id
|
|
|
|
if (block.metadata?.name) {
|
|
blockNameMapping[normalizeName(block.metadata.name)] = id
|
|
}
|
|
|
|
const schema = getBlockSchema(block)
|
|
if (schema && Object.keys(schema).length > 0) {
|
|
blockOutputSchemas[id] = schema
|
|
}
|
|
}
|
|
|
|
return { blockData, blockNameMapping, blockOutputSchemas }
|
|
}
|