import type { Viewport } from 'reactflow'
|
import type { BlockEnum, ConversationVariable, Edge, EnvironmentVariable, Node } from '@/app/components/workflow/types'
|
import type { TransferMethod } from '@/types/app'
|
import type { ErrorHandleTypeEnum } from '@/app/components/workflow/nodes/_base/components/error-handle/types'
|
|
export type AgentLogItem = {
|
node_execution_id: string,
|
id: string,
|
node_id: string,
|
parent_id?: string,
|
label: string,
|
data: object, // debug data
|
error?: string,
|
status: string,
|
metadata?: {
|
elapsed_time?: number
|
provider?: string
|
icon?: string
|
},
|
}
|
|
export type AgentLogItemWithChildren = AgentLogItem & {
|
hasCircle?: boolean
|
children: AgentLogItemWithChildren[]
|
}
|
|
export type NodeTracing = {
|
id: string
|
index: number
|
predecessor_node_id: string
|
node_id: string
|
iteration_id?: string
|
loop_id?: string
|
node_type: BlockEnum
|
title: string
|
inputs: any
|
process_data: any
|
outputs?: any
|
status: string
|
parallel_run_id?: string
|
error?: string
|
elapsed_time: number
|
execution_metadata?: {
|
total_tokens: number
|
total_price: number
|
currency: string
|
iteration_id?: string
|
iteration_index?: number
|
loop_id?: string
|
loop_index?: number
|
parallel_id?: string
|
parallel_start_node_id?: string
|
parent_parallel_id?: string
|
parent_parallel_start_node_id?: string
|
parallel_mode_run_id?: string
|
iteration_duration_map?: IterationDurationMap
|
loop_duration_map?: LoopDurationMap
|
error_strategy?: ErrorHandleTypeEnum
|
agent_log?: AgentLogItem[]
|
tool_info?: {
|
agent_strategy?: string
|
icon?: string
|
}
|
loop_variable_map?: Record<string, any>
|
}
|
metadata: {
|
iterator_length: number
|
iterator_index: number
|
loop_length: number
|
loop_index: number
|
}
|
created_at: number
|
created_by: {
|
id: string
|
name: string
|
email: string
|
}
|
iterDurationMap?: IterationDurationMap
|
loopDurationMap?: LoopDurationMap
|
finished_at: number
|
extras?: any
|
expand?: boolean // for UI
|
details?: NodeTracing[][] // iteration or loop detail
|
retryDetail?: NodeTracing[] // retry detail
|
retry_index?: number
|
parallelDetail?: { // parallel detail. if is in parallel, this field will be set
|
isParallelStartNode?: boolean
|
parallelTitle?: string
|
branchTitle?: string
|
children?: NodeTracing[]
|
}
|
parallel_id?: string
|
parallel_start_node_id?: string
|
parent_parallel_id?: string
|
parent_parallel_start_node_id?: string
|
agentLog?: AgentLogItemWithChildren[] // agent log
|
}
|
|
export type FetchWorkflowDraftResponse = {
|
id: string
|
graph: {
|
nodes: Node[]
|
edges: Edge[]
|
viewport?: Viewport
|
}
|
features?: any
|
created_at: number
|
created_by: {
|
id: string
|
name: string
|
email: string
|
}
|
hash: string
|
updated_at: number
|
updated_by: {
|
id: string
|
name: string
|
email: string
|
},
|
tool_published: boolean
|
environment_variables?: EnvironmentVariable[]
|
conversation_variables?: ConversationVariable[]
|
version: string
|
marked_name: string
|
marked_comment: string
|
}
|
|
export type VersionHistory = FetchWorkflowDraftResponse
|
|
export type FetchWorkflowDraftPageParams = {
|
appId: string
|
initialPage: number
|
limit: number
|
userId?: string
|
namedOnly?: boolean
|
}
|
|
export type FetchWorkflowDraftPageResponse = {
|
items: VersionHistory[]
|
has_more: boolean
|
page: number
|
}
|
|
export type NodeTracingListResponse = {
|
data: NodeTracing[]
|
}
|
|
export type WorkflowStartedResponse = {
|
task_id: string
|
workflow_run_id: string
|
event: string
|
data: {
|
id: string
|
workflow_id: string
|
sequence_number: number
|
created_at: number
|
}
|
}
|
|
export type WorkflowFinishedResponse = {
|
task_id: string
|
workflow_run_id: string
|
event: string
|
data: {
|
id: string
|
workflow_id: string
|
status: string
|
outputs: any
|
error: string
|
elapsed_time: number
|
total_tokens: number
|
total_steps: number
|
created_at: number
|
created_by: {
|
id: string
|
name: string
|
email: string
|
}
|
finished_at: number
|
files?: FileResponse[]
|
}
|
}
|
|
export type NodeStartedResponse = {
|
task_id: string
|
workflow_run_id: string
|
event: string
|
data: NodeTracing
|
}
|
|
export type FileResponse = {
|
related_id: string
|
extension: string
|
filename: string
|
size: number
|
mime_type: string
|
transfer_method: TransferMethod
|
type: string
|
url: string
|
upload_file_id: string
|
}
|
|
export type NodeFinishedResponse = {
|
task_id: string
|
workflow_run_id: string
|
event: string
|
data: NodeTracing
|
}
|
|
export type IterationStartedResponse = {
|
task_id: string
|
workflow_run_id: string
|
event: string
|
data: NodeTracing
|
}
|
|
export type IterationNextResponse = {
|
task_id: string
|
workflow_run_id: string
|
event: string
|
data: NodeTracing
|
}
|
|
export type IterationFinishedResponse = {
|
task_id: string
|
workflow_run_id: string
|
event: string
|
data: NodeTracing
|
}
|
|
export type LoopStartedResponse = {
|
task_id: string
|
workflow_run_id: string
|
event: string
|
data: NodeTracing
|
}
|
|
export type LoopNextResponse = {
|
task_id: string
|
workflow_run_id: string
|
event: string
|
data: NodeTracing
|
}
|
|
export type LoopFinishedResponse = {
|
task_id: string
|
workflow_run_id: string
|
event: string
|
data: NodeTracing
|
}
|
|
export type ParallelBranchStartedResponse = {
|
task_id: string
|
workflow_run_id: string
|
event: string
|
data: NodeTracing
|
}
|
|
export type ParallelBranchFinishedResponse = {
|
task_id: string
|
workflow_run_id: string
|
event: string
|
data: NodeTracing
|
}
|
|
export type TextChunkResponse = {
|
task_id: string
|
workflow_run_id: string
|
event: string
|
data: {
|
text: string
|
}
|
}
|
|
export type TextReplaceResponse = {
|
task_id: string
|
workflow_run_id: string
|
event: string
|
data: {
|
text: string
|
}
|
}
|
|
export type AgentLogResponse = {
|
task_id: string
|
event: string
|
data: AgentLogItemWithChildren
|
}
|
|
export type WorkflowRunHistory = {
|
id: string
|
sequence_number: number
|
version: string
|
conversation_id?: string
|
message_id?: string
|
graph: {
|
nodes: Node[]
|
edges: Edge[]
|
viewport?: Viewport
|
}
|
inputs: Record<string, string>
|
status: string
|
outputs: Record<string, any>
|
error?: string
|
elapsed_time: number
|
total_tokens: number
|
total_steps: number
|
created_at: number
|
finished_at: number
|
created_by_account: {
|
id: string
|
name: string
|
email: string
|
}
|
}
|
export type WorkflowRunHistoryResponse = {
|
data: WorkflowRunHistory[]
|
}
|
|
export type ChatRunHistoryResponse = {
|
data: WorkflowRunHistory[]
|
}
|
|
export type NodesDefaultConfigsResponse = {
|
type: string
|
config: any
|
}[]
|
|
export type ConversationVariableResponse = {
|
data: (ConversationVariable & { updated_at: number; created_at: number })[]
|
has_more: boolean
|
limit: number
|
total: number
|
page: number
|
}
|
|
export type IterationDurationMap = Record<string, number>
|
export type LoopDurationMap = Record<string, number>
|
export type LoopVariableMap = Record<string, any>
|
|
export type WorkflowConfigResponse = {
|
parallel_depth_limit: number
|
}
|
|
export type PublishWorkflowParams = {
|
title: string
|
releaseNotes: string
|
}
|
|
export type UpdateWorkflowParams = {
|
workflowId: string
|
title: string
|
releaseNotes: string
|
}
|
