KidZddlmZddlmZddlmZddlmZm Z ddl m Z m Z dd l mZ d dd Z d dd Zy )z#Tools 10, 11: list_flows, get_flow.) annotations)Path)Any)get_flow_by_id get_flows)generate_hints get_session) _get_storeNc>t|\}} |s|n|dz}t|||}|rJg} |D]>} | jd} | |j| } | |k(s.| j | @| d|}|dk(r|D cgc]} | d| d| dd }} d d t |d |d } t d| t| d<| |jScc} w#t$r(}dt|dcYd}~|jSd}~wwxYw#|jwxYw)a'List execution flows in the codebase, sorted by criticality. [EXPLORE] Retrieves stored execution flows from the knowledge graph. Each flow represents a call chain starting from an entry point (e.g. HTTP handler, CLI command, test function). Args: repo_root: Repository root path. Auto-detected if omitted. sort_by: Sort column: criticality, depth, node_count, file_count, or name. limit: Maximum flows to return (default: 50). kind: Optional filter by entry point kind (e.g. "Test", "Function"). detail_level: "standard" (default) returns full flow data; "minimal" returns only name, criticality, and node_count per flow. Returns: List of flows with criticality scores. sort_bylimitentry_point_idNminimalname criticality node_count)rrrokzFound z execution flow(s))statussummaryflows list_flows_hintserrorrr) r rgetget_node_kind_by_idappendlenr r close Exceptionstr) repo_rootrrkind detail_levelstoreroot fetch_limitrfilteredfep_id node_kindresultexcs o/home/jay/workspace/scripts/.codegraph-venv/lib/python3.12/site-packages/code_review_graph/tools/flows_tools.pyrrs[4Y'KE4&E52: % D H +./$ % 9 9% @I D( *  + Ve$E 9 $   fI#$]#3"#L/EE |+=>%  * &+- x  +$ 6!CH55 6  sM3CC!C<C.CC D D,D-D DD Dc Tt|\}} d}| t||}nK|It|dd}|D]6}|j|djvs't||d}n|ddd |j S|rd |vr|d D]} | j d rt | d nd} | | js|| z } | } | s@| jsQ | jd jtd| j dxsddz } tt| j dxs t} djfdt| | D| d<dd|dd|dd|dd|dd|d}t%d|t'|d <||j S#t t"f$r d| d<YNwxYw#t($r(}d!t+|d"cYd}~|j Sd}~wwxYw#|j wxYw)#ahGet details of a single execution flow. [EXPLORE] Retrieves full path details for a flow, including each step's function name, file, and line numbers. Optionally includes source snippets for every step in the path. Args: flow_id: Database ID of the flow (from list_flows). flow_name: Name to search for (partial match). Ignored if flow_id given. include_source: If True, include source code snippets for each step. repo_root: Repository root path. Auto-detected if omitted. Returns: Flow details with steps, or not_found status. Nrirrid not_foundz*No flow found matching the given criteria.)rrstepsfilereplace)errorsr line_startr line_end c38K|]}|dzd|yw)r z: N).0iliness r2 zget_flow..s,3 ! !1ugRaz23ssourcez(could not read file)rzFlow 'z': rz nodes, depth depthz, criticality z.4f)rrflowget_flowrrr)r rrlowerr#rr is_absoluteis_file read_text splitlinesmaxminr"joinrangeOSErrorUnicodeDecodeErrorr r r$r%)flow_id flow_nameinclude_sourcer&r)r*rE all_flowsr-stepfp file_pathstartendr0r1rAs @r2rFrFZsr,Y'KE4?   !%1D  "!}CI ??$& (99)%49D  <%G^  S goW  A+/88F+;T$v,'>"..*:B !2!2!4A ) 3 3#,!4!$*,!$ 6 ;!q@!"J HHZ0>CJ*.3%*5#%63*X# A2fc$|*<)=>g(#M2379 *   x  '$%78A)@XA 6!CH55 6  shA G!G!A G!G!!BG;:G!GG!GG!! H* H 7H8H HHH')Nr2Nstandard) r& str | Nonerr%rintr'r]r(r%returndict[str, Any])NNFN) rRz int | NonerSr]rTboolr&r]r_r`)__doc__ __future__rpathlibrtypingrrrrhintsr r _commonr rrFr>r2ris)"-/! " AA A A  A  A  AT   V VVV V  Vrh