mercuryworkshop-mirror/epoxy-tls
1
0
Fork 0
mirror of https://github.com/MercuryWorkshop/epoxy-tls.git synced 2025-05-12 22:10:01 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions

actually add wsproxy udp, clean up some stuff

Browse source
This commit is contained in:
Toshit Chawda 2024-07-21 21:38:25 -07:00
parent 04b8feaaf3
commit 5400ae32cc
No known key found for this signature in database
GPG key ID: 91480ED99E2B3D9D
2 changed files with 32 additions and 19 deletions
Download patch file Download diff file Expand all files Collapse all files

10
server/src/handle/wisp.rs
View file

@ -91,16 +91,6 @@ async fn handle_stream(connect: ConnectPacket, muxstream: MuxStream, id: String)
let closer = muxstream.get_close_handle();
let ret: anyhow::Result<()> = async {
/*
let (muxread, muxwrite) = muxstream.into_io().into_asyncrw().into_split();
let (mut tcpread, tcpwrite) = stream.into_split();
let mut muxwrite = muxwrite.compat_write();
select! {
x = copy_read_fast(muxread, tcpwrite) => x?,
x = copy(&mut tcpread, &mut muxwrite) => {x?;},
}
*/
// TODO why is copy_write_fast not working?
let (muxread, muxwrite) = muxstream.into_split();
let muxread = muxread.into_stream().into_asyncread();
let (tcpread, tcpwrite) = stream.into_split();

41
server/src/handle/wsproxy.rs
View file

@ -91,12 +91,7 @@ pub async fn handle_wsproxy(
ClientStream::Tcp(stream) => {
let mut stream = BufReader::new(stream);
let ret: anyhow::Result<()> = async {
let mut to_consume = 0usize;
loop {
if to_consume != 0 {
stream.consume(to_consume);
to_consume = 0;
}
select! {
x = ws.read() => {
match x? {
@ -112,7 +107,8 @@ pub async fn handle_wsproxy(
x = stream.fill_buf() => {
let x = x?;
ws.write(x).await?;
to_consume += x.len();
let len = x.len();
stream.consume(len);
}
}
}
@ -129,9 +125,36 @@ pub async fn handle_wsproxy(
}
}
}
ClientStream::Udp(_stream) => {
// TODO
let _ = ws.close(CloseCode::Error.into(), b"coming soon").await;
ClientStream::Udp(stream) => {
let ret: anyhow::Result<()> = async {
let mut data = vec![0u8; 65507];
loop {
select! {
x = ws.read() => {
match x? {
WebSocketFrame::Data(data) => {
stream.send(&data).await?;
}
WebSocketFrame::Close | WebSocketFrame::Ignore => {}
}
}
size = stream.recv(&mut data) => {
ws.write(&data[..size?]).await?;
}
}
}
}
.await;
match ret {
Ok(_) => {
let _ = ws.close(CloseCode::Normal.into(), b"").await;
}
Err(x) => {
let _ = ws
.close(CloseCode::Normal.into(), x.to_string().as_bytes())
.await;
}
}
}
ClientStream::Blocked => {
let _ = ws.close(CloseCode::Error.into(), b"host is blocked").await;