@@ -78,46 +78,6 @@ async def read_repository_by_id(
7878    return  record [0 ] if  record  else  None 
7979
8080
81- async  def  read_graphs_by_owner_name_for_sigma (owner : str , name : str ) ->  dict [str , Any ]:
82-     query  =  """ 
83-     match (r: Repository{owner: $owner, name: $name}) 
84-     call apoc.path.subgraphAll(r, {relationshipFilter: '>', limit: 20}) yield nodes, relationships 
85-     unwind nodes as node 
86-         with case labels(node)[0] 
87-             when 'Version' then { 
88-                 id: elementid(node), 
89-                 label: node.name + '\n ' + apoc.text.join(node.cves, ' ') 
90-             } 
91-             else { 
92-                 id: elementid(node), 
93-                 label: node.name 
94-             } 
95-         end as sigma_nodes, relationships 
96-     unwind relationships as relationship 
97-         with case type(relationship) 
98-             when 'Requires' then { 
99-                 source: elementid(startnode(relationship)), 
100-                 target: elementid(endnode(relationship)), 
101-                 label: relationship.constraints 
102-             } 
103-             else { 
104-                 source: elementid(startnode(relationship)), 
105-                 target: elementid(endnode(relationship)), 
106-                 label: type(relationship) 
107-             } 
108-         end as sigma_relationships, sigma_nodes 
109-     return {nodes: apoc.coll.toSet(collect(sigma_nodes)), relationships: apoc.coll.toSet(collect(sigma_relationships))} 
110-     """ 
111-     graphs : dict [str , Any ] =  {}
112-     for  package_manager  in  "PIP" :
113-         driver  =  get_graph_db_driver (package_manager )
114-         async  with  driver .session () as  session :
115-             result  =  await  session .run (query , owner = owner , name = name )
116-             record  =  await  result .single ()
117-         graphs [package_manager ] =  record  if  record  else  None 
118-     return  graphs 
119- 
120- 
12181async  def  read_graph_for_info_operation (
12282    file_info_request : dict [str , Any ]
12383) ->  dict [str , Any ]:
0 commit comments