nu-command 0.112.1

Nushell's built-in commands
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35

//! Ureq 3.0.12 converts timeout errors into std::io::ErrorKind::Other: <https://github.com/algesten/ureq/blob/3.0.12/src/error.rs#L193>
//! But Nushell infrastructure expects std::io::ErrorKind::Timeout when an operation times out.
//! This is an adapter that converts former into latter.

use std::io::Read;

/// Convert errors io errors with [std::io::ErrorKind::Other] and [ureq::Error::Timeout]
/// into io errors with [std::io::ErrorKind::Timeout]
pub struct UreqTimeoutExtractorReader<R> {
    pub r: R,
}

impl<R: Read> Read for UreqTimeoutExtractorReader<R> {
    fn read(&mut self, buf: &mut [u8]) -> std::io::Result<usize> {
        self.r.read(buf).map_err(|e| {
            // TODO: if-let chains when rust 1.88

            // ureq packages time-outs into "other"
            if e.kind() != std::io::ErrorKind::Other {
                return e;
            }
            let ureq_err = match e.downcast::<ureq::Error>() {
                Err(e) => return e,
                Ok(e) => e,
            };
            match ureq_err {
                ureq::Error::Timeout(..) => {
                    std::io::Error::new(std::io::ErrorKind::TimedOut, ureq_err)
                }
                // package it back
                e => std::io::Error::other(e),
            }
        })
    }
}