|
import { FC, useCallback, useMemo } from 'react' |
|
import { |
|
EdgeById, |
|
NodeById, |
|
GraphSearchInputProps, |
|
GraphSearchContextProviderProps |
|
} from '@react-sigma/graph-search' |
|
import { AsyncSearch } from '@/components/ui/AsyncSearch' |
|
import { searchResultLimit } from '@/lib/constants' |
|
import { useGraphStore } from '@/stores/graph' |
|
import MiniSearch from 'minisearch' |
|
|
|
interface OptionItem { |
|
id: string |
|
type: 'nodes' | 'edges' | 'message' |
|
message?: string |
|
} |
|
|
|
function OptionComponent(item: OptionItem) { |
|
return ( |
|
<div> |
|
{item.type === 'nodes' && <NodeById id={item.id} />} |
|
{item.type === 'edges' && <EdgeById id={item.id} />} |
|
{item.type === 'message' && <div>{item.message}</div>} |
|
</div> |
|
) |
|
} |
|
|
|
const messageId = '__message_item' |
|
const lastGraph: any = { |
|
graph: null, |
|
searchEngine: null |
|
} |
|
|
|
|
|
|
|
|
|
export const GraphSearchInput = ({ |
|
onChange, |
|
onFocus, |
|
value |
|
}: { |
|
onChange: GraphSearchInputProps['onChange'] |
|
onFocus?: GraphSearchInputProps['onFocus'] |
|
value?: GraphSearchInputProps['value'] |
|
}) => { |
|
const graph = useGraphStore.use.sigmaGraph() |
|
|
|
const search = useMemo(() => { |
|
if (lastGraph.graph == graph) { |
|
return lastGraph.searchEngine |
|
} |
|
if (!graph || graph.nodes().length == 0) return |
|
|
|
lastGraph.graph = graph |
|
|
|
const searchEngine = new MiniSearch({ |
|
idField: 'id', |
|
fields: ['label'], |
|
searchOptions: { |
|
prefix: true, |
|
fuzzy: 0.2, |
|
boost: { |
|
label: 2 |
|
} |
|
} |
|
}) |
|
|
|
|
|
const documents = graph.nodes().map((id: string) => ({ |
|
id: id, |
|
label: graph.getNodeAttribute(id, 'label') |
|
})) |
|
searchEngine.addAll(documents) |
|
|
|
lastGraph.searchEngine = searchEngine |
|
return searchEngine |
|
}, [graph]) |
|
|
|
|
|
|
|
|
|
const loadOptions = useCallback( |
|
async (query?: string): Promise<OptionItem[]> => { |
|
if (onFocus) onFocus(null) |
|
if (!query || !search) return [] |
|
const result: OptionItem[] = search.search(query).map((result) => ({ |
|
id: result.id, |
|
type: 'nodes' |
|
})) |
|
|
|
|
|
return result.length <= searchResultLimit |
|
? result |
|
: [ |
|
...result.slice(0, searchResultLimit), |
|
{ |
|
type: 'message', |
|
id: messageId, |
|
message: `And ${result.length - searchResultLimit} others` |
|
} |
|
] |
|
}, |
|
[search, onFocus] |
|
) |
|
|
|
return ( |
|
<AsyncSearch |
|
className="bg-background/60 w-24 rounded-xl border-1 opacity-60 backdrop-blur-lg transition-all hover:w-fit hover:opacity-100" |
|
fetcher={loadOptions} |
|
renderOption={OptionComponent} |
|
getOptionValue={(item) => item.id} |
|
value={value && value.type !== 'message' ? value.id : null} |
|
onChange={(id) => { |
|
if (id !== messageId) onChange(id ? { id, type: 'nodes' } : null) |
|
}} |
|
onFocus={(id) => { |
|
if (id !== messageId && onFocus) onFocus(id ? { id, type: 'nodes' } : null) |
|
}} |
|
label={'item'} |
|
placeholder="Search nodes..." |
|
/> |
|
) |
|
} |
|
|
|
|
|
|
|
|
|
const GraphSearch: FC<GraphSearchInputProps & GraphSearchContextProviderProps> = ({ ...props }) => { |
|
return <GraphSearchInput {...props} /> |
|
} |
|
|
|
export default GraphSearch |
|
|