RafayAhmad/flux-sftp
1
0
Fork 0
Code Issues Pull requests Projects Releases 3 Packages Wiki Activity Actions

rm mkdir and rmdir pooog

Browse source
This commit is contained in:
RafayAhmad7548 2025-07-06 07:56:51 +05:00
parent 2840b5bed7
commit 2328982583
1 changed files with 83 additions and 13 deletions
Download patch file Download diff file Expand all files Collapse all files

96
src/sftp.rs
View file

@ -209,13 +209,14 @@ impl SftpHandler for SftpSession {
longname: longname, longname: longname,
attrs: FileAttributes { attrs: FileAttributes {
size: Some(metadata.size()), size: Some(metadata.size()),
uid: Some(metadata.uid()), // uid: Some(metadata.uid()),
user: None, // user: None,
gid: Some(metadata.gid()), // gid: Some(metadata.gid()),
group: None, // group: None,
permissions: Some(metadata.mode()), permissions: Some(metadata.mode()),
atime: Some(metadata.atime() as u32), atime: Some(metadata.atime() as u32),
mtime: Some(metadata.mtime() as u32), mtime: Some(metadata.mtime() as u32),
..Default::default()
} }
} }
] }) ] })
@ -258,13 +259,14 @@ impl SftpHandler for SftpSession {
match fs::metadata(path).await { match fs::metadata(path).await {
Ok(metadata) => Ok(Attrs { id, attrs: FileAttributes { Ok(metadata) => Ok(Attrs { id, attrs: FileAttributes {
size: Some(metadata.size()), size: Some(metadata.size()),
uid: Some(metadata.uid()), // uid: Some(metadata.uid()),
user: None, // user: None,
gid: Some(metadata.gid()), // gid: Some(metadata.gid()),
group: None, // group: None,
permissions: Some(metadata.mode()), permissions: Some(metadata.mode()),
atime: Some(metadata.atime() as u32), atime: Some(metadata.atime() as u32),
mtime: Some(metadata.mtime() as u32), mtime: Some(metadata.mtime() as u32),
..Default::default()
}}), }}),
Err(_) => Err(StatusCode::NoSuchFile) Err(_) => Err(StatusCode::NoSuchFile)
} }
@ -280,13 +282,14 @@ impl SftpHandler for SftpSession {
match fs::symlink_metadata(path).await { match fs::symlink_metadata(path).await {
Ok(metadata) => Ok(Attrs { id, attrs: FileAttributes { Ok(metadata) => Ok(Attrs { id, attrs: FileAttributes {
size: Some(metadata.size()), size: Some(metadata.size()),
uid: Some(metadata.uid()), // uid: Some(metadata.uid()),
user: None, // user: None,
gid: Some(metadata.gid()), // gid: Some(metadata.gid()),
group: None, // group: None,
permissions: Some(metadata.mode()), permissions: Some(metadata.mode()),
atime: Some(metadata.atime() as u32), atime: Some(metadata.atime() as u32),
mtime: Some(metadata.mtime() as u32) mtime: Some(metadata.mtime() as u32),
..Default::default()
}}), }}),
Err(_) => Err(StatusCode::OpUnsupported) Err(_) => Err(StatusCode::OpUnsupported)
} }
@ -302,5 +305,72 @@ impl SftpHandler for SftpSession {
self.stat(id, handle).await self.stat(id, handle).await
} }
async fn remove(
&mut self,
id: u32,
filename: String,
) -> Result<Status, Self::Error> {
println!("remove called: {}", filename);
let filename = format!("{}/{}", self.jail_dir, filename);
match fs::remove_file(filename).await {
Ok(()) => Ok(Status { id, status_code: StatusCode::Ok, error_message: "Ok".to_string(), language_tag: "en-US".to_string() }),
Err(e) => {
println!("error removing file: {}", e);
match e.kind() {
ErrorKind::NotFound => Ok(Status { id, status_code: StatusCode::NoSuchFile, error_message: e.to_string(), language_tag: "en-US".to_string() }),
ErrorKind::PermissionDenied => Ok(Status { id, status_code: StatusCode::PermissionDenied, error_message: e.to_string(), language_tag: "en-US".to_string() }),
ErrorKind::ConnectionReset => Ok(Status { id, status_code: StatusCode::ConnectionLost, error_message: e.to_string(), language_tag: "en-US".to_string() }),
ErrorKind::NotConnected => Ok(Status { id, status_code: StatusCode::NoConnection, error_message: e.to_string(), language_tag: "en-US".to_string() }),
_ => Ok(Status { id, status_code: StatusCode::Failure, error_message: e.to_string(), language_tag: "en-US".to_string() })
}
}
}
}
async fn mkdir(
&mut self,
id: u32,
path: String,
_attrs: FileAttributes,
) -> Result<Status, Self::Error> {
println!("mkdir called: {}", path);
let path = format!("{}/{}", self.jail_dir, path);
match fs::create_dir(&path).await {
Ok(()) => Ok(Status { id, status_code: StatusCode::Ok, error_message: "Ok".to_string(), language_tag: "en-US".to_string() }),
Err(e) => {
println!("error removing file: {}", e);
match e.kind() {
ErrorKind::PermissionDenied => Ok(Status { id, status_code: StatusCode::PermissionDenied, error_message: e.to_string(), language_tag: "en-US".to_string() }),
ErrorKind::ConnectionReset => Ok(Status { id, status_code: StatusCode::ConnectionLost, error_message: e.to_string(), language_tag: "en-US".to_string() }),
ErrorKind::NotConnected => Ok(Status { id, status_code: StatusCode::NoConnection, error_message: e.to_string(), language_tag: "en-US".to_string() }),
_ => Ok(Status { id, status_code: StatusCode::Failure, error_message: e.to_string(), language_tag: "en-US".to_string() })
}
}
}
}
async fn rmdir(
&mut self,
id: u32,
path: String,
) -> Result<Status, Self::Error> {
println!("rmdir called: {}", path);
let path = format!("{}/{}", self.jail_dir, path);
match fs::remove_dir(path).await {
Ok(()) => Ok(Status { id, status_code: StatusCode::Ok, error_message: "Ok".to_string(), language_tag: "en-US".to_string() }),
Err(e) => {
println!("error removing file: {}", e);
match e.kind() {
ErrorKind::NotFound => Ok(Status { id, status_code: StatusCode::NoSuchFile, error_message: e.to_string(), language_tag: "en-US".to_string() }),
ErrorKind::PermissionDenied => Ok(Status { id, status_code: StatusCode::PermissionDenied, error_message: e.to_string(), language_tag: "en-US".to_string() }),
ErrorKind::ConnectionReset => Ok(Status { id, status_code: StatusCode::ConnectionLost, error_message: e.to_string(), language_tag: "en-US".to_string() }),
ErrorKind::NotConnected => Ok(Status { id, status_code: StatusCode::NoConnection, error_message: e.to_string(), language_tag: "en-US".to_string() }),
_ => Ok(Status { id, status_code: StatusCode::Failure, error_message: e.to_string(), language_tag: "en-US".to_string() })
}
}
}
}
} }