diff --git a/src/api.rs b/src/api.rs index 38926a8..3756ef5 100644 --- a/src/api.rs +++ b/src/api.rs @@ -2,7 +2,6 @@ use anyhow::Result as AnyhowResult; use futures::TryStreamExt; use hyper::http::HeaderValue; use hyper::{Body, Request, HeaderMap, Response, StatusCode}; -use hyper::body::Bytes; /// NB: This much match the shape of SpeakRequest in the 'voder/tts_service' code. /// This is used for both /speak and /speak_spectrogram requests. diff --git a/src/main.rs b/src/main.rs index ccd3b28..4e6b4de 100644 --- a/src/main.rs +++ b/src/main.rs @@ -1,5 +1,3 @@ -#![feature(toowned_clone_into)] - #[macro_use] extern crate anyhow; #[macro_use] extern crate log; #[macro_use] extern crate serde_derive; @@ -9,22 +7,19 @@ pub mod newrelic_logger; pub mod speak_proxy; use anyhow::Result as AnyhowResult; -use crate::newrelic_logger::{NewRelicLogger, MaybeNewRelicTransaction}; +use crate::newrelic_logger::NewRelicLogger; use crate::speak_proxy::speak_proxy_with_retry; -use futures::future::{self, Future}; -use hyper::header::HeaderValue; -use hyper::http::header::HeaderName; +use hyper::StatusCode; use hyper::server::conn::AddrStream; use hyper::service::{service_fn, make_service_fn}; use hyper::{Body, Request, Response, Server}; -use hyper::{Method, StatusCode}; use rand::seq::IteratorRandom; use std::collections::HashMap; use std::convert::Infallible; use std::env; use std::fmt::Debug; use std::fmt::Display; -use std::net::{SocketAddr, IpAddr}; +use std::net::IpAddr; use std::str::FromStr; use std::sync::Arc; @@ -114,10 +109,10 @@ impl Router { } } -fn debug_request(req: Request) -> Result, Infallible> { - let body_str = format!("{:?}", req); - Ok(Response::new(Body::from(body_str))) -} +// fn debug_request(req: Request) -> Result, Infallible> { +// let body_str = format!("{:?}", req); +// Ok(Response::new(Body::from(body_str))) +// } fn health_check_response(_req: Request) -> Result, Infallible> { Ok(Response::new(Body::from("healthy"))) diff --git a/src/speak_proxy.rs b/src/speak_proxy.rs index 2824591..98a689d 100644 --- a/src/speak_proxy.rs +++ b/src/speak_proxy.rs @@ -1,26 +1,15 @@ -use anyhow::Result as AnyhowResult; use crate::Router; -use crate::api::{ExternalSpeakRequest, ExternalHttpRequest, InternalSpeakRequest, ErrorResponse, ErrorType}; -use crate::newrelic_logger::{NewRelicLogger, MaybeNewRelicTransaction}; -use futures::TryStreamExt; -use futures::future::{self, Future}; +use crate::api::{ExternalHttpRequest, InternalSpeakRequest, ErrorResponse, ErrorType}; +use crate::newrelic_logger::{MaybeNewRelicTransaction}; +use hyper::Method; use hyper::header::HeaderValue; use hyper::http::header::HeaderName; -use hyper::server::conn::AddrStream; -use hyper::service::{service_fn, make_service_fn}; -use hyper::{Body, Request, Response, Server, HeaderMap}; -use hyper::{Method, StatusCode}; -use hyper_reverse_proxy::ProxyError; -use rand::seq::IteratorRandom; -use std::collections::HashMap; -use std::convert::Infallible; +use hyper::{Body, Request, Response, HeaderMap}; use std::fmt::Debug; -use std::fmt::Display; -use std::net::{SocketAddr, IpAddr}; -use std::str::FromStr; +use std::net::IpAddr; use std::sync::Arc; +use std::thread; use std::time::Duration; -use std::{env, thread}; pub async fn speak_proxy_with_retry( ip_addr: IpAddr,