gruberb/protohackers
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Cleanup

Browse source
This commit is contained in:
Bastian Gruber 2023-05-02 17:42:09 +02:00
parent aaeac5c830
commit f61b30e26d
No known key found for this signature in database
GPG key ID: BE9F8C772B188CBF
1 changed files with 5 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
problem_05/bin/server.rs
View file

@ -1,10 +1,10 @@
use futures::{SinkExt, StreamExt}; use futures::{SinkExt, StreamExt};
use regex::Regex;
use tokio::net::{TcpListener, TcpStream}; use tokio::net::{TcpListener, TcpStream};
use tokio_util::codec::{FramedRead, FramedWrite, LinesCodec}; use tokio_util::codec::{FramedRead, FramedWrite, LinesCodec};
use tracing::info; use tracing::info;
use regex::Regex;
const DEFAULT_IP: &str = "127.0.0.1"; const DEFAULT_IP: &str = "0.0.0.0";
const DEFAULT_PORT: &str = "1222"; const DEFAULT_PORT: &str = "1222";
const UPSTREAM_IP: &str = "206.189.113.124"; const UPSTREAM_IP: &str = "206.189.113.124";
@ -66,7 +66,9 @@ pub async fn handle_request(socket: TcpStream, upstream: TcpStream) -> Result<()
let read_upstream_write_client = tokio::spawn(async move { let read_upstream_write_client = tokio::spawn(async move {
while let Some(Ok(response)) = farmed_server_read.next().await { while let Some(Ok(response)) = farmed_server_read.next().await {
info!("Send to client: {response}"); info!("Send to client: {response}");
let _ = framed_client_write.send(response).await; let result = re.replace_all(&response, replacement);
info!("Updated message: {result}");
let _ = framed_client_write.send(result).await;
} }
}); });