Method handle_this_node

gateway/src/proxy/tls_terminate.rs:154–207

(
        &self,
        inbound: TcpStream,
        buffer: Vec<u8>,
        port: u16,
        h2: bool,
    )

impl Proxy {
    pub(crate) async fn handle_this_node(
        &self,
        inbound: TcpStream,
        buffer: Vec<u8>,
        port: u16,
        h2: bool,
    ) -> Result<()> {
        if port != 80 {
            bail!("Only port 80 is supported for this node");
        }
        let stream = self.tls_accept(inbound, buffer, h2).await?;
        let io = TokioIo::new(stream);

        let service = service_fn(|req: Request<Incoming>| async move {
            // Only respond to GET / requests
            if req.method() != hyper::Method::GET {
                return empty_response(StatusCode::METHOD_NOT_ALLOWED);
            }
            if req.uri().path() == "/health" {
                return empty_response(StatusCode::OK);
            }
            let path = req.uri().path().trim_start_matches("/.dstack");
            match path {
                "/index" => {
                    let body = serde_json::json!({
                        "type": "dstack gateway",
                        "paths": [
                            "/index",
                            "/app-info",
                            "/acme-info",
                        ],
                    });
                    json_response(&body)
                }
                "/app-info" => {
                    let agent = crate::dstack_agent().context("Failed to get dstack agent")?;
                    let app_info = agent.info().await.context("Failed to get app info")?;
                    json_response(&app_info)
                }
                "/acme-info" => {
                    let acme_info = self.acme_info(None).context("Failed to get acme info")?;
                    json_response(&acme_info)
                }
                _ => empty_response(StatusCode::NOT_FOUND),
            }
        });

        http1::Builder::new()
            .serve_connection(io, service)
            .await
            .context("Failed to serve HTTP connection")?;

        Ok(())
    }

    /// Deprecated legacy endpoint
    pub(crate) async fn handle_health_check(