(sessionID string)
| 4062 | } |
| 4063 | |
| 4064 | func (d *integrationDaemon) blockSession(sessionID string) (<-chan acp.AgentEvent, error) { |
| 4065 | d.mu.Lock() |
| 4066 | manager := d.manager |
| 4067 | d.mu.Unlock() |
| 4068 | if manager == nil { |
| 4069 | return nil, errors.New("integration daemon session manager is not ready") |
| 4070 | } |
| 4071 | return manager.Prompt(context.Background(), sessionID, "__block__") |
| 4072 | } |
| 4073 | |
| 4074 | func discardLogger() *slog.Logger { |
| 4075 | return slog.New(slog.NewTextHandler(io.Discard, nil)) |
no test coverage detected