Lars
cab5758b0d
Bug:
- Analysis nodes showed "Prompt #7edc6d6b-6cd5..." in canvas
- After re-selecting prompt, showed readable name "Pipeline: Ernährungs-Analyse"
- After loading workflow, showed UUID again
Root Cause:
- Serializer saved only prompt_id, not prompt_name
- Deserializer expected prompt_name but got null
- AnalysisNode fallback logic: data.prompt_name || `Prompt #{prompt_id}`
- Result: Showed UUID as fallback
Fix:
- workflowSerializer.js line 25: Added prompt_name to serialization
- Now saves both prompt_id AND prompt_name in graph_data
- On load: prompt_name is restored → AnalysisNode shows readable name
Testing:
- Create workflow with analysis node + prompt selection
- Save → Canvas should show "Pipeline: Körper-Analyse" (not UUID)
- Reload → Canvas should still show readable name (not UUID)
119 lines
3.4 KiB
JavaScript
119 lines
3.4 KiB
JavaScript
/**
|
|
* Workflow Serialization Utilities
|
|
*
|
|
* Konvertiert zwischen React Flow (Canvas) und Backend-Format (JSONB).
|
|
*/
|
|
|
|
/**
|
|
* Serialisiert React Flow Graph zu Backend-kompatiblem Format
|
|
*
|
|
* @param {Array} nodes - React Flow nodes
|
|
* @param {Array} edges - React Flow edges
|
|
* @param {Object} metadata - Zusätzliche Metadaten
|
|
* @returns {Object} JSONB-kompatibles Objekt für ai_prompts.graph_data
|
|
*/
|
|
export function serializeToWorkflowGraph(nodes, edges, metadata = {}) {
|
|
const workflowNodes = nodes.map(node => ({
|
|
id: node.id,
|
|
type: node.type,
|
|
label: node.data.label || node.type,
|
|
position: { x: node.position.x, y: node.position.y },
|
|
|
|
// Type-spezifische Felder
|
|
...(node.type === 'analysis' && {
|
|
prompt_id: node.data.prompt_id || null,
|
|
prompt_name: node.data.prompt_name || null,
|
|
questions: node.data.questions || [],
|
|
fallback_strategy: node.data.fallback_strategy || 'conservative_skip'
|
|
}),
|
|
|
|
...(node.type === 'logic' && {
|
|
condition: node.data.condition || null,
|
|
fallback_strategy: node.data.fallback_strategy || 'conservative_skip'
|
|
}),
|
|
|
|
...(node.type === 'join' && {
|
|
join_strategy: node.data.join_strategy || 'wait_all',
|
|
skip_handling: node.data.skip_handling || 'ignore_skipped',
|
|
min_paths: node.data.min_paths || 2
|
|
})
|
|
}))
|
|
|
|
const workflowEdges = edges.map(edge => ({
|
|
id: edge.id,
|
|
source: edge.source,
|
|
target: edge.target,
|
|
label: edge.data?.label || null,
|
|
sourceHandle: edge.sourceHandle || null,
|
|
targetHandle: edge.targetHandle || null
|
|
}))
|
|
|
|
return {
|
|
nodes: workflowNodes,
|
|
edges: workflowEdges,
|
|
metadata: {
|
|
created_at: metadata.created_at || new Date().toISOString(),
|
|
updated_at: new Date().toISOString(),
|
|
version: metadata.version || '1.0'
|
|
}
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Deserialisiert Backend-Format zu React Flow Graph
|
|
*
|
|
* @param {Object} jsonbData - ai_prompts.graph_data (JSONB)
|
|
* @returns {Object} { nodes, edges, metadata }
|
|
*/
|
|
export function deserializeFromWorkflowGraph(jsonbData) {
|
|
if (!jsonbData || !jsonbData.nodes || !jsonbData.edges) {
|
|
throw new Error('Invalid workflow graph data')
|
|
}
|
|
|
|
const reactFlowNodes = jsonbData.nodes.map(node => ({
|
|
id: node.id,
|
|
type: node.type,
|
|
position: { x: node.position.x, y: node.position.y },
|
|
data: {
|
|
label: node.label,
|
|
|
|
...(node.type === 'analysis' && {
|
|
prompt_id: node.prompt_id,
|
|
prompt_name: node.prompt_name || null, // Falls vom Backend mitgeliefert
|
|
questions: node.questions || [],
|
|
fallback_strategy: node.fallback_strategy || 'conservative_skip'
|
|
}),
|
|
|
|
...(node.type === 'logic' && {
|
|
condition: node.condition || null,
|
|
fallback_strategy: node.fallback_strategy || 'conservative_skip'
|
|
}),
|
|
|
|
...(node.type === 'join' && {
|
|
join_strategy: node.join_strategy || 'wait_all',
|
|
skip_handling: node.skip_handling || 'ignore_skipped',
|
|
min_paths: node.min_paths || 2
|
|
})
|
|
}
|
|
}))
|
|
|
|
const reactFlowEdges = jsonbData.edges.map(edge => ({
|
|
id: edge.id,
|
|
source: edge.source,
|
|
target: edge.target,
|
|
sourceHandle: edge.sourceHandle || null,
|
|
targetHandle: edge.targetHandle || null,
|
|
data: {
|
|
label: edge.label || null
|
|
},
|
|
type: 'default',
|
|
animated: false
|
|
}))
|
|
|
|
return {
|
|
nodes: reactFlowNodes,
|
|
edges: reactFlowEdges,
|
|
metadata: jsonbData.metadata || {}
|
|
}
|
|
}
|