Fix Neo4j node and edge edit problem
This commit is contained in:
@@ -13,7 +13,10 @@ interface EditablePropertyRowProps {
|
|||||||
name: string // Property name to display and edit
|
name: string // Property name to display and edit
|
||||||
value: any // Initial value of the property
|
value: any // Initial value of the property
|
||||||
onClick?: () => void // Optional click handler for the property value
|
onClick?: () => void // Optional click handler for the property value
|
||||||
|
nodeId?: string // ID of the node (for node type)
|
||||||
entityId?: string // ID of the entity (for node type)
|
entityId?: string // ID of the entity (for node type)
|
||||||
|
edgeId?: string // ID of the edge (for edge type)
|
||||||
|
dynamicId?: string
|
||||||
entityType?: 'node' | 'edge' // Type of graph entity
|
entityType?: 'node' | 'edge' // Type of graph entity
|
||||||
sourceId?: string // Source node ID (for edge type)
|
sourceId?: string // Source node ID (for edge type)
|
||||||
targetId?: string // Target node ID (for edge type)
|
targetId?: string // Target node ID (for edge type)
|
||||||
@@ -30,7 +33,10 @@ const EditablePropertyRow = ({
|
|||||||
name,
|
name,
|
||||||
value: initialValue,
|
value: initialValue,
|
||||||
onClick,
|
onClick,
|
||||||
|
nodeId,
|
||||||
|
edgeId,
|
||||||
entityId,
|
entityId,
|
||||||
|
dynamicId,
|
||||||
entityType,
|
entityType,
|
||||||
sourceId,
|
sourceId,
|
||||||
targetId,
|
targetId,
|
||||||
@@ -66,7 +72,7 @@ const EditablePropertyRow = ({
|
|||||||
setIsSubmitting(true)
|
setIsSubmitting(true)
|
||||||
|
|
||||||
try {
|
try {
|
||||||
if (entityType === 'node' && entityId) {
|
if (entityType === 'node' && entityId && nodeId) {
|
||||||
let updatedData = { [name]: value }
|
let updatedData = { [name]: value }
|
||||||
|
|
||||||
if (name === 'entity_id') {
|
if (name === 'entity_id') {
|
||||||
@@ -79,12 +85,12 @@ const EditablePropertyRow = ({
|
|||||||
}
|
}
|
||||||
|
|
||||||
await updateEntity(entityId, updatedData, true)
|
await updateEntity(entityId, updatedData, true)
|
||||||
await updateGraphNode(entityId, name, value)
|
await updateGraphNode(nodeId, entityId, name, value)
|
||||||
toast.success(t('graphPanel.propertiesView.success.entityUpdated'))
|
toast.success(t('graphPanel.propertiesView.success.entityUpdated'))
|
||||||
} else if (entityType === 'edge' && sourceId && targetId) {
|
} else if (entityType === 'edge' && sourceId && targetId && edgeId && dynamicId) {
|
||||||
const updatedData = { [name]: value }
|
const updatedData = { [name]: value }
|
||||||
await updateRelation(sourceId, targetId, updatedData)
|
await updateRelation(sourceId, targetId, updatedData)
|
||||||
await updateGraphEdge(sourceId, targetId, name, value)
|
await updateGraphEdge(edgeId, dynamicId, sourceId, targetId, name, value)
|
||||||
toast.success(t('graphPanel.propertiesView.success.relationUpdated'))
|
toast.success(t('graphPanel.propertiesView.success.relationUpdated'))
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@@ -93,6 +93,7 @@ const refineNodeProperties = (node: RawNodeType): NodeType => {
|
|||||||
if (state.sigmaGraph && state.rawGraph) {
|
if (state.sigmaGraph && state.rawGraph) {
|
||||||
try {
|
try {
|
||||||
if (!state.sigmaGraph.hasNode(node.id)) {
|
if (!state.sigmaGraph.hasNode(node.id)) {
|
||||||
|
console.warn('Node not found in sigmaGraph:', node.id)
|
||||||
return {
|
return {
|
||||||
...node,
|
...node,
|
||||||
relationships: []
|
relationships: []
|
||||||
@@ -139,7 +140,8 @@ const refineEdgeProperties = (edge: RawEdgeType): EdgeType => {
|
|||||||
|
|
||||||
if (state.sigmaGraph && state.rawGraph) {
|
if (state.sigmaGraph && state.rawGraph) {
|
||||||
try {
|
try {
|
||||||
if (!state.sigmaGraph.hasEdge(edge.id)) {
|
if (!state.sigmaGraph.hasEdge(edge.dynamicId)) {
|
||||||
|
console.warn('Edge not found in sigmaGraph:', edge.id, 'dynamicId:', edge.dynamicId)
|
||||||
return {
|
return {
|
||||||
...edge,
|
...edge,
|
||||||
sourceNode: undefined,
|
sourceNode: undefined,
|
||||||
@@ -171,6 +173,9 @@ const PropertyRow = ({
|
|||||||
value,
|
value,
|
||||||
onClick,
|
onClick,
|
||||||
tooltip,
|
tooltip,
|
||||||
|
nodeId,
|
||||||
|
edgeId,
|
||||||
|
dynamicId,
|
||||||
entityId,
|
entityId,
|
||||||
entityType,
|
entityType,
|
||||||
sourceId,
|
sourceId,
|
||||||
@@ -181,7 +186,10 @@ const PropertyRow = ({
|
|||||||
value: any
|
value: any
|
||||||
onClick?: () => void
|
onClick?: () => void
|
||||||
tooltip?: string
|
tooltip?: string
|
||||||
|
nodeId?: string
|
||||||
entityId?: string
|
entityId?: string
|
||||||
|
edgeId?: string
|
||||||
|
dynamicId?: string
|
||||||
entityType?: 'node' | 'edge'
|
entityType?: 'node' | 'edge'
|
||||||
sourceId?: string
|
sourceId?: string
|
||||||
targetId?: string
|
targetId?: string
|
||||||
@@ -202,7 +210,10 @@ const PropertyRow = ({
|
|||||||
name={name}
|
name={name}
|
||||||
value={value}
|
value={value}
|
||||||
onClick={onClick}
|
onClick={onClick}
|
||||||
|
nodeId={nodeId}
|
||||||
entityId={entityId}
|
entityId={entityId}
|
||||||
|
edgeId={edgeId}
|
||||||
|
dynamicId={dynamicId}
|
||||||
entityType={entityType}
|
entityType={entityType}
|
||||||
sourceId={sourceId}
|
sourceId={sourceId}
|
||||||
targetId={targetId}
|
targetId={targetId}
|
||||||
@@ -265,7 +276,7 @@ const NodePropertiesView = ({ node }: { node: NodeType }) => {
|
|||||||
</div>
|
</div>
|
||||||
</div>
|
</div>
|
||||||
<div className="bg-primary/5 max-h-96 overflow-auto rounded p-1">
|
<div className="bg-primary/5 max-h-96 overflow-auto rounded p-1">
|
||||||
<PropertyRow name={t('graphPanel.propertiesView.node.id')} value={node.id} />
|
<PropertyRow name={t('graphPanel.propertiesView.node.id')} value={String(node.id)} />
|
||||||
<PropertyRow
|
<PropertyRow
|
||||||
name={t('graphPanel.propertiesView.node.labels')}
|
name={t('graphPanel.propertiesView.node.labels')}
|
||||||
value={node.labels.join(', ')}
|
value={node.labels.join(', ')}
|
||||||
@@ -285,7 +296,8 @@ const NodePropertiesView = ({ node }: { node: NodeType }) => {
|
|||||||
key={name}
|
key={name}
|
||||||
name={name}
|
name={name}
|
||||||
value={node.properties[name]}
|
value={node.properties[name]}
|
||||||
entityId={node.properties['entity_id'] || node.id}
|
nodeId={String(node.id)}
|
||||||
|
entityId={node.properties['entity_id']}
|
||||||
entityType="node"
|
entityType="node"
|
||||||
isEditable={name === 'description' || name === 'entity_id'}
|
isEditable={name === 'description' || name === 'entity_id'}
|
||||||
/>
|
/>
|
||||||
@@ -350,10 +362,11 @@ const EdgePropertiesView = ({ edge }: { edge: EdgeType }) => {
|
|||||||
key={name}
|
key={name}
|
||||||
name={name}
|
name={name}
|
||||||
value={edge.properties[name]}
|
value={edge.properties[name]}
|
||||||
entityId={edge.id}
|
edgeId={String(edge.id)}
|
||||||
|
dynamicId={String(edge.dynamicId)}
|
||||||
entityType="edge"
|
entityType="edge"
|
||||||
sourceId={edge.source}
|
sourceId={edge.sourceNode?.properties['entity_id'] || edge.source}
|
||||||
targetId={edge.target}
|
targetId={edge.targetNode?.properties['entity_id'] || edge.target}
|
||||||
isEditable={name === 'description' || name === 'keywords'}
|
isEditable={name === 'description' || name === 'keywords'}
|
||||||
/>
|
/>
|
||||||
)
|
)
|
||||||
|
@@ -5,6 +5,8 @@ import { getGraphLabels } from '@/api/lightrag'
|
|||||||
import MiniSearch from 'minisearch'
|
import MiniSearch from 'minisearch'
|
||||||
|
|
||||||
export type RawNodeType = {
|
export type RawNodeType = {
|
||||||
|
// for NetworkX: id is identical to properties['entity_id']
|
||||||
|
// for Neo4j: id is unique identifier for each node
|
||||||
id: string
|
id: string
|
||||||
labels: string[]
|
labels: string[]
|
||||||
properties: Record<string, any>
|
properties: Record<string, any>
|
||||||
@@ -18,20 +20,25 @@ export type RawNodeType = {
|
|||||||
}
|
}
|
||||||
|
|
||||||
export type RawEdgeType = {
|
export type RawEdgeType = {
|
||||||
|
// for NetworkX: id is "source-target"
|
||||||
|
// for Neo4j: id is unique identifier for each edge
|
||||||
id: string
|
id: string
|
||||||
source: string
|
source: string
|
||||||
target: string
|
target: string
|
||||||
type?: string
|
type?: string
|
||||||
properties: Record<string, any>
|
properties: Record<string, any>
|
||||||
|
// dynamicId: key for sigmaGraph
|
||||||
dynamicId: string
|
dynamicId: string
|
||||||
}
|
}
|
||||||
|
|
||||||
export class RawGraph {
|
export class RawGraph {
|
||||||
nodes: RawNodeType[] = []
|
nodes: RawNodeType[] = []
|
||||||
edges: RawEdgeType[] = []
|
edges: RawEdgeType[] = []
|
||||||
|
// nodeIDMap: map node id to index in nodes array (SigmaGraph has nodeId as key)
|
||||||
nodeIdMap: Record<string, number> = {}
|
nodeIdMap: Record<string, number> = {}
|
||||||
|
// edgeIDMap: map edge id to index in edges array (SigmaGraph not use id as key)
|
||||||
edgeIdMap: Record<string, number> = {}
|
edgeIdMap: Record<string, number> = {}
|
||||||
|
// edgeDynamicIdMap: map edge dynamic id to index in edges array (SigmaGraph has DynamicId as key)
|
||||||
edgeDynamicIdMap: Record<string, number> = {}
|
edgeDynamicIdMap: Record<string, number> = {}
|
||||||
|
|
||||||
getNode = (nodeId: string) => {
|
getNode = (nodeId: string) => {
|
||||||
|
@@ -17,30 +17,32 @@ interface EdgeToUpdate {
|
|||||||
* @param propertyName - Name of the property being updated
|
* @param propertyName - Name of the property being updated
|
||||||
* @param newValue - New value for the property
|
* @param newValue - New value for the property
|
||||||
*/
|
*/
|
||||||
export const updateGraphNode = async (nodeId: string, propertyName: string, newValue: string) => {
|
export const updateGraphNode = async (nodeId: string, entityId:string, propertyName: string, newValue: string) => {
|
||||||
// Get graph state from store
|
// Get graph state from store
|
||||||
const sigmaGraph = useGraphStore.getState().sigmaGraph
|
const sigmaGraph = useGraphStore.getState().sigmaGraph
|
||||||
const rawGraph = useGraphStore.getState().rawGraph
|
const rawGraph = useGraphStore.getState().rawGraph
|
||||||
|
|
||||||
// Validate graph state
|
// Validate graph state
|
||||||
if (!sigmaGraph || !rawGraph || !sigmaGraph.hasNode(String(nodeId))) {
|
if (!sigmaGraph || !rawGraph || !sigmaGraph.hasNode(nodeId)) {
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
try {
|
try {
|
||||||
const nodeAttributes = sigmaGraph.getNodeAttributes(String(nodeId))
|
const nodeAttributes = sigmaGraph.getNodeAttributes(nodeId)
|
||||||
|
|
||||||
// Special handling for entity_id changes (node renaming)
|
console.log('updateGraphNode', nodeId, entityId, propertyName, newValue)
|
||||||
if (propertyName === 'entity_id') {
|
|
||||||
|
// For entity_id changes (node renaming) with NetworkX graph storage
|
||||||
|
if ((nodeId === entityId) && (propertyName === 'entity_id')) {
|
||||||
// Create new node with updated ID but same attributes
|
// Create new node with updated ID but same attributes
|
||||||
sigmaGraph.addNode(newValue, { ...nodeAttributes, label: newValue })
|
sigmaGraph.addNode(newValue, { ...nodeAttributes, label: newValue })
|
||||||
|
|
||||||
const edgesToUpdate: EdgeToUpdate[] = []
|
const edgesToUpdate: EdgeToUpdate[] = []
|
||||||
|
|
||||||
// Process all edges connected to this node
|
// Process all edges connected to this node
|
||||||
sigmaGraph.forEachEdge(String(nodeId), (edge, attributes, source, target) => {
|
sigmaGraph.forEachEdge(nodeId, (edge, attributes, source, target) => {
|
||||||
const otherNode = source === String(nodeId) ? target : source
|
const otherNode = source === nodeId ? target : source
|
||||||
const isOutgoing = source === String(nodeId)
|
const isOutgoing = source === nodeId
|
||||||
|
|
||||||
// Get original edge dynamic ID for later reference
|
// Get original edge dynamic ID for later reference
|
||||||
const originalEdgeDynamicId = edge
|
const originalEdgeDynamicId = edge
|
||||||
@@ -67,14 +69,15 @@ export const updateGraphNode = async (nodeId: string, propertyName: string, newV
|
|||||||
})
|
})
|
||||||
|
|
||||||
// Remove the old node after all edges are processed
|
// Remove the old node after all edges are processed
|
||||||
sigmaGraph.dropNode(String(nodeId))
|
sigmaGraph.dropNode(nodeId)
|
||||||
|
|
||||||
// Update node reference in raw graph data
|
// Update node reference in raw graph data
|
||||||
const nodeIndex = rawGraph.nodeIdMap[String(nodeId)]
|
const nodeIndex = rawGraph.nodeIdMap[nodeId]
|
||||||
if (nodeIndex !== undefined) {
|
if (nodeIndex !== undefined) {
|
||||||
rawGraph.nodes[nodeIndex].id = newValue
|
rawGraph.nodes[nodeIndex].id = newValue
|
||||||
|
rawGraph.nodes[nodeIndex].labels = [newValue]
|
||||||
rawGraph.nodes[nodeIndex].properties.entity_id = newValue
|
rawGraph.nodes[nodeIndex].properties.entity_id = newValue
|
||||||
delete rawGraph.nodeIdMap[String(nodeId)]
|
delete rawGraph.nodeIdMap[nodeId]
|
||||||
rawGraph.nodeIdMap[newValue] = nodeIndex
|
rawGraph.nodeIdMap[newValue] = nodeIndex
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -82,10 +85,10 @@ export const updateGraphNode = async (nodeId: string, propertyName: string, newV
|
|||||||
edgesToUpdate.forEach(({ originalDynamicId, newEdgeId, edgeIndex }) => {
|
edgesToUpdate.forEach(({ originalDynamicId, newEdgeId, edgeIndex }) => {
|
||||||
if (rawGraph.edges[edgeIndex]) {
|
if (rawGraph.edges[edgeIndex]) {
|
||||||
// Update source/target references
|
// Update source/target references
|
||||||
if (rawGraph.edges[edgeIndex].source === String(nodeId)) {
|
if (rawGraph.edges[edgeIndex].source === nodeId) {
|
||||||
rawGraph.edges[edgeIndex].source = newValue
|
rawGraph.edges[edgeIndex].source = newValue
|
||||||
}
|
}
|
||||||
if (rawGraph.edges[edgeIndex].target === String(nodeId)) {
|
if (rawGraph.edges[edgeIndex].target === nodeId) {
|
||||||
rawGraph.edges[edgeIndex].target = newValue
|
rawGraph.edges[edgeIndex].target = newValue
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -99,10 +102,14 @@ export const updateGraphNode = async (nodeId: string, propertyName: string, newV
|
|||||||
// Update selected node in store
|
// Update selected node in store
|
||||||
useGraphStore.getState().setSelectedNode(newValue)
|
useGraphStore.getState().setSelectedNode(newValue)
|
||||||
} else {
|
} else {
|
||||||
// For other properties, just update the property in raw graph
|
// for none NetworkX nodes or none entity_id changes
|
||||||
const nodeIndex = rawGraph.nodeIdMap[String(nodeId)]
|
const nodeIndex = rawGraph.nodeIdMap[String(nodeId)]
|
||||||
if (nodeIndex !== undefined) {
|
if (nodeIndex !== undefined) {
|
||||||
rawGraph.nodes[nodeIndex].properties[propertyName] = newValue
|
rawGraph.nodes[nodeIndex].properties[propertyName] = newValue
|
||||||
|
if (propertyName === 'entity_id') {
|
||||||
|
rawGraph.nodes[nodeIndex].labels = [newValue]
|
||||||
|
sigmaGraph.setNodeAttribute(String(nodeId), 'label', newValue)
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
} catch (error) {
|
} catch (error) {
|
||||||
@@ -119,7 +126,7 @@ export const updateGraphNode = async (nodeId: string, propertyName: string, newV
|
|||||||
* @param propertyName - Name of the property being updated
|
* @param propertyName - Name of the property being updated
|
||||||
* @param newValue - New value for the property
|
* @param newValue - New value for the property
|
||||||
*/
|
*/
|
||||||
export const updateGraphEdge = async (sourceId: string, targetId: string, propertyName: string, newValue: string) => {
|
export const updateGraphEdge = async (edgeId: string, dynamicId: string, sourceId: string, targetId: string, propertyName: string, newValue: string) => {
|
||||||
// Get graph state from store
|
// Get graph state from store
|
||||||
const sigmaGraph = useGraphStore.getState().sigmaGraph
|
const sigmaGraph = useGraphStore.getState().sigmaGraph
|
||||||
const rawGraph = useGraphStore.getState().rawGraph
|
const rawGraph = useGraphStore.getState().rawGraph
|
||||||
@@ -130,44 +137,15 @@ export const updateGraphEdge = async (sourceId: string, targetId: string, proper
|
|||||||
}
|
}
|
||||||
|
|
||||||
try {
|
try {
|
||||||
// Find the edge between source and target nodes
|
|
||||||
const allEdges = sigmaGraph.edges()
|
|
||||||
let keyToUse = null
|
|
||||||
|
|
||||||
for (const edge of allEdges) {
|
const edgeIndex = rawGraph.edgeIdMap[String(edgeId)]
|
||||||
const edgeSource = sigmaGraph.source(edge)
|
if (edgeIndex !== undefined && rawGraph.edges[edgeIndex]) {
|
||||||
const edgeTarget = sigmaGraph.target(edge)
|
|
||||||
|
|
||||||
// Match edge in either direction (undirected graph support)
|
|
||||||
if ((edgeSource === sourceId && edgeTarget === targetId) ||
|
|
||||||
(edgeSource === targetId && edgeTarget === sourceId)) {
|
|
||||||
keyToUse = edge
|
|
||||||
break
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
if (keyToUse !== null) {
|
|
||||||
// Special handling for keywords property (updates edge label)
|
|
||||||
if(propertyName === 'keywords') {
|
|
||||||
sigmaGraph.setEdgeAttribute(keyToUse, 'label', newValue)
|
|
||||||
} else {
|
|
||||||
sigmaGraph.setEdgeAttribute(keyToUse, propertyName, newValue)
|
|
||||||
}
|
|
||||||
|
|
||||||
// Update edge in raw graph data using dynamic ID mapping
|
|
||||||
if (keyToUse && rawGraph.edgeDynamicIdMap[keyToUse] !== undefined) {
|
|
||||||
const edgeIndex = rawGraph.edgeDynamicIdMap[keyToUse]
|
|
||||||
if (rawGraph.edges[edgeIndex]) {
|
|
||||||
rawGraph.edges[edgeIndex].properties[propertyName] = newValue
|
rawGraph.edges[edgeIndex].properties[propertyName] = newValue
|
||||||
}
|
if(dynamicId !== undefined && propertyName === 'keywords') {
|
||||||
} else if (keyToUse !== null) {
|
sigmaGraph.setEdgeAttribute(dynamicId, 'label', newValue)
|
||||||
// Fallback: try to find edge by key in edge ID map
|
|
||||||
const edgeIndexByKey = rawGraph.edgeIdMap[keyToUse]
|
|
||||||
if (edgeIndexByKey !== undefined && rawGraph.edges[edgeIndexByKey]) {
|
|
||||||
rawGraph.edges[edgeIndexByKey].properties[propertyName] = newValue
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
} catch (error) {
|
} catch (error) {
|
||||||
console.error(`Error updating edge ${sourceId}->${targetId} in graph:`, error)
|
console.error(`Error updating edge ${sourceId}->${targetId} in graph:`, error)
|
||||||
throw new Error('Failed to update edge in graph')
|
throw new Error('Failed to update edge in graph')
|
||||||
|
Reference in New Issue
Block a user