warp-tech/warpgate
1
1
Fork 0
mirror of https://github.com/warp-tech/warpgate.git synced 2025-09-22 22:46:42 +08:00
Code Issues Projects Releases Packages Wiki Activity

added missing channel success messages - fixes #349, fixes #364 - Termius, WinSCP and Filezilla access

Browse source
This commit is contained in:
Eugene Pankov 2022-09-26 22:49:36 +02:00
parent 06c0a3dae8
commit 773bf19823
No known key found for this signature in database
GPG key ID: 5896FCBBDD1CF4F4
1 changed files with 13 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

17
warpgate-protocol-ssh/src/server/russh_handler.rs
View file

@ -119,7 +119,7 @@ impl russh::server::Handler for ServerHandler {
self,
channel: ChannelId,
name: &str,
session: Session,
mut session: Session,
) -> Self::FutureUnit {
let name = name.to_string();
async move {
@ -132,6 +132,7 @@ impl russh::server::Handler for ServerHandler {
))?;
let _ = rx.await;
session.channel_success(channel);
Ok((self, session))
}
.boxed()
@ -146,7 +147,7 @@ impl russh::server::Handler for ServerHandler {
pix_width: u32,
pix_height: u32,
modes: &[(Pty, u32)],
session: Session,
mut session: Session,
) -> Self::FutureUnit {
let term = term.to_string();
let modes = modes
@ -172,12 +173,13 @@ impl russh::server::Handler for ServerHandler {
))?;
let _ = rx.await;
session.channel_success(channel);
Ok((self, session))
}
.boxed()
}
fn shell_request(self, channel: ChannelId, session: Session) -> Self::FutureUnit {
fn shell_request(self, channel: ChannelId, mut session: Session) -> Self::FutureUnit {
async move {
let (tx, rx) = oneshot::channel();
@ -187,6 +189,7 @@ impl russh::server::Handler for ServerHandler {
))?;
let _ = rx.await;
session.channel_success(channel);
Ok((self, session))
}
.boxed()
@ -355,7 +358,12 @@ impl russh::server::Handler for ServerHandler {
.boxed()
}
fn exec_request(self, channel: ChannelId, data: &[u8], session: Session) -> Self::FutureUnit {
fn exec_request(
self,
channel: ChannelId,
data: &[u8],
mut session: Session,
) -> Self::FutureUnit {
let data = Bytes::from(data.to_vec());
async move {
let (tx, rx) = oneshot::channel();
@ -365,6 +373,7 @@ impl russh::server::Handler for ServerHandler {
tx,
))?;
let _ = rx.await;
session.channel_success(channel);
Ok((self, session))
}
.boxed()