import { Background, ColorMode, ReactFlow, ReactFlowProvider, useReactFlow } from '@xyflow/react' import { useParams } from 'common' import { useTheme } from 'next-themes' import { useEffect, useMemo } from 'react' import { PrimaryDatabaseNode, ReplicationNode } from './Nodes' import { getDagreGraphLayout } from './ReplicationDiagram.utils' import { useReplicationDestinationsQuery } from '@/data/replication/destinations-query' import { timeout } from '@/lib/helpers' import '@xyflow/react/dist/style.css' import { SmoothstepEdge } from './Edges' import { checkLocalETLNotSetUp } from '@/data/replication/utils' export const ReplicationDiagram = () => { return ( ) } const nodeTypes = { primary: PrimaryDatabaseNode, replication: ReplicationNode, } const edgeTypes = { smoothstep: SmoothstepEdge } const ReplicationDiagramContent = () => { const reactFlow = useReactFlow() const { resolvedTheme } = useTheme() const { ref: projectRef = 'default' } = useParams() const { data, error: destinationsError, isSuccess: isSuccessDestinations, isError: isErrorDestinations, } = useReplicationDestinationsQuery({ projectRef, }) const destinations = useMemo(() => data?.destinations ?? [], [data]) const isLocalETLNotSetUp = checkLocalETLNotSetUp(destinationsError) const skipRenderingDestinations = isErrorDestinations && isLocalETLNotSetUp const nodes = useMemo(() => { return [ { id: projectRef, type: 'primary', data: {}, position: { x: 0, y: 5 } }, ...destinations.map((x) => ({ id: x.id.toString(), type: 'replication', data: {}, position: { x: 0, y: 0 }, })), ] }, [destinations, projectRef]) const edges = useMemo(() => { const shiftEdgeEnd = destinations.length > 1 return destinations.map((x) => ({ id: `${projectRef}-${x.id}`, source: projectRef, target: x.id.toString(), type: 'smoothstep', className: 'cursor-default!', data: { type: 'etl', identifier: x.id.toString(), shiftEdgeEnd }, })) }, [destinations, projectRef]) const backgroundPatternColor = resolvedTheme === 'dark' ? 'rgba(255, 255, 255, 0.3)' : 'rgba(0, 0, 0, 0.4)' const setReactFlow = async () => { const graph = getDagreGraphLayout(nodes, edges) reactFlow.setNodes(graph.nodes) reactFlow.setEdges(graph.edges) // [Joshen] Odd fix to ensure that react flow snaps back to center when adding nodes await timeout(1) reactFlow.fitView({ minZoom: 0.8, maxZoom: 0.9 }) } useEffect(() => { if (nodes.length > 0 && (isSuccessDestinations || skipRenderingDestinations)) { setReactFlow() } }, [nodes, isSuccessDestinations, skipRenderingDestinations]) return (
) }