(ctx context.Context)
| 275 | |
| 276 | event := NewStreamEvent("permission_needed", "mcp_project_trust", map[string]any{ |
| 277 | "mcp_trust_request": pending, |
| 278 | "dangerous": true, |
| 279 | "risk": "high", |
| 280 | }) |
| 281 | if !sendStream(ctx, out, event) { |
| 282 | e.clearMCPTrustFuture(ch) |
| 283 | return |
| 284 | } |
| 285 | |
| 286 | granted := false |
| 287 | select { |
| 288 | case granted = <-ch: |
| 289 | case <-ctx.Done(): |
no test coverage detected