Function discoverTools

packages/plugins/mcp/src/sdk/discover.ts:95–132

(
  connector: McpConnector,
  timeoutMs: number = Duration.toMillis(DEFAULT_DISCOVER_TIMEOUT),
)

 * interrupted fiber).
 */
export const discoverTools = (
  connector: McpConnector,
  timeoutMs: number = Duration.toMillis(DEFAULT_DISCOVER_TIMEOUT),
): Effect.Effect<McpToolManifest, McpToolDiscoveryError> =>
  Effect.gen(function* () {
    // Acquire connection
    const connection = yield* connector.pipe(
      Effect.mapError((failure) => {
        // Preserve the handshake HTTP status (401/403 = auth wall) so the
        // liveness health check can classify structurally.
        const httpStatus = Predicate.isTagged(failure, "McpConnectionError")
          ? failure.httpStatus
          : undefined;
        return new McpToolDiscoveryError({
          stage: "connect",
          message: `Failed connecting to MCP server: ${failure.message}`,
          ...(httpStatus !== undefined ? { httpStatus } : {}),
        });
      }),
    );

    const manifest = yield* listAllTools(connection).pipe(
      Effect.onExit(() => closeConnection(connection)),
    );

    return manifest;
  }).pipe(
    Effect.timeoutOrElse({
      duration: Duration.millis(timeoutMs),
      orElse: () =>
        Effect.fail(
          new McpToolDiscoveryError({
            stage: "connect",
            message: `MCP discovery timed out after ${timeoutMs}ms`,
          }),
        ),
    }),
  );

const closeConnection = (connection: {
  readonly close: () => Promise<void>;