Method waitForBlocked

internal/cli/cli_integration_test.go:4043–4062

(sessionID string, timeout time.Duration)

}

func (d *integrationDaemon) waitForBlocked(sessionID string, timeout time.Duration) bool {
	d.mu.Lock()
	driver := d.driver
	manager := d.manager
	d.mu.Unlock()
	if driver == nil {
		return false
	}
	target := sessionID
	if manager != nil {
		if info, err := manager.Status(
			context.Background(),
			sessionID,
		); err == nil &&
			strings.TrimSpace(info.ACPSessionID) != "" {
			target = info.ACPSessionID
		}
	}
	return driver.waitForBlocked(target, timeout)
}

func (d *integrationDaemon) blockSession(sessionID string) (<-chan acp.AgentEvent, error) {
	d.mu.Lock()