opendal/services/sftp/
error.rs

1// Licensed to the Apache Software Foundation (ASF) under one
2// or more contributor license agreements.  See the NOTICE file
3// distributed with this work for additional information
4// regarding copyright ownership.  The ASF licenses this file
5// to you under the Apache License, Version 2.0 (the
6// "License"); you may not use this file except in compliance
7// with the License.  You may obtain a copy of the License at
8//
9//   http://www.apache.org/licenses/LICENSE-2.0
10//
11// Unless required by applicable law or agreed to in writing,
12// software distributed under the License is distributed on an
13// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
14// KIND, either express or implied.  See the License for the
15// specific language governing permissions and limitations
16// under the License.
17
18use openssh::Error as SshError;
19use openssh_sftp_client::error::SftpErrorKind;
20use openssh_sftp_client::Error as SftpClientError;
21
22use crate::Error;
23use crate::ErrorKind;
24
25pub fn parse_sftp_error(e: SftpClientError) -> Error {
26    let kind = match &e {
27        SftpClientError::UnsupportedSftpProtocol { version: _ } => ErrorKind::Unsupported,
28        SftpClientError::SftpError(kind, _msg) => match kind {
29            SftpErrorKind::NoSuchFile => ErrorKind::NotFound,
30            SftpErrorKind::PermDenied => ErrorKind::PermissionDenied,
31            SftpErrorKind::OpUnsupported => ErrorKind::Unsupported,
32            _ => ErrorKind::Unexpected,
33        },
34        _ => ErrorKind::Unexpected,
35    };
36
37    let mut err = Error::new(kind, "sftp error").set_source(e);
38
39    // Mark error as temporary if it's unexpected.
40    if kind == ErrorKind::Unexpected {
41        err = err.set_temporary();
42    }
43
44    err
45}
46
47pub fn parse_ssh_error(e: SshError) -> Error {
48    Error::new(ErrorKind::Unexpected, "ssh error").set_source(e)
49}
50
51pub(super) fn is_not_found(e: &SftpClientError) -> bool {
52    matches!(e, SftpClientError::SftpError(SftpErrorKind::NoSuchFile, _))
53}
54
55pub(super) fn is_sftp_protocol_error(e: &SftpClientError) -> bool {
56    matches!(e, SftpClientError::SftpError(_, _))
57}
opendal/services/sftp/error.rs

opendal/services/sftp/
error.rs
