Method requestPromptDetailed

src/node/services/sshPromptService.ts:132–180

* Called from SSH pool when a prompt is detected. * Blocks until the user responds or timeout fires. * Responder admission only applies to new prompts; deduped callers can still * join an existing pending prompt even during transient responder gaps.

(params: SshPromptRequestParams)

   * join an existing pending prompt even during transient responder gaps.
   */
  async requestPromptDetailed(params: SshPromptRequestParams): Promise<SshPromptResolution> {
    const dedupeKey = params.kind === "host-key" ? (params.dedupeKey ?? params.host) : null;

    if (dedupeKey) {
      const joinedPending = this.joinPendingByDedupeKey(dedupeKey);
      if (joinedPending) {
        return joinedPending;
      }
    }

    if (!this.hasInteractiveResponder()) {
      return { response: "", reason: "no_responder" };
    }

    const requestId = crypto.randomUUID();
    if (dedupeKey) {
      this.inflightByDedupeKey.set(dedupeKey, requestId);
    }

    const requestWithoutId =
      params.kind === "host-key"
        ? {
            kind: "host-key" as const,
            host: params.host,
            keyType: params.keyType,
            fingerprint: params.fingerprint,
            prompt: params.prompt,
          }
        : {
            kind: "credential" as const,
            prompt: params.prompt,
            secret: params.secret,
          };

    return new Promise<SshPromptResolution>((resolve) => {
      const request: SshPromptRequest = { requestId, ...requestWithoutId };
      const entry: PendingEntry = {
        request,
        dedupeKey,
        timer: setTimeout(() => {
          this.finalizeRequest(requestId, { response: "", reason: "timeout" });
        }, this.timeoutMs),
        waiters: [resolve],
      };

      this.pending.set(requestId, entry);
      this.emit("request", request);
    });
  }

  async requestPrompt(params: SshPromptRequestParams): Promise<string> {
    const resolution = await this.requestPromptDetailed(params);