(
&self,
context_assembly: &ContextAssembly,
event_tx: &Option<mpsc::Sender<AgentEvent>>,
)
| 189 | } |
| 190 | |
| 191 | async fn emit_context_resolved( |
| 192 | &self, |
| 193 | context_assembly: &ContextAssembly, |
| 194 | event_tx: &Option<mpsc::Sender<AgentEvent>>, |
| 195 | ) { |
| 196 | let Some(tx) = event_tx else { |
| 197 | return; |
| 198 | }; |
| 199 | |
| 200 | let total_items = context_assembly.items.len(); |
| 201 | let total_tokens = context_assembly.total_tokens; |
| 202 | |
| 203 | tracing::info!( |
| 204 | context_items = total_items, |
| 205 | context_tokens = total_tokens, |
| 206 | context_truncated = context_assembly.truncated, |
| 207 | "Context resolution completed" |
| 208 | ); |
| 209 | |
| 210 | tx.send(AgentEvent::ContextResolved { |
| 211 | total_items, |
| 212 | total_tokens, |
| 213 | }) |
| 214 | .await |
| 215 | .ok(); |
| 216 | } |
| 217 | |
| 218 | /// Resolve context from all providers for a given prompt |
| 219 | /// |
no test coverage detected