earthmc 2.0.1

Async client for interacting with the EarthMC API
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
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62

use thiserror::Error;

/// Errors that can occur when interacting with the EarthMC client.
#[derive(Error, Debug)]
pub enum Error {
    #[error("HTTP error: {0}")]
    Http(#[from] reqwest::Error),
    #[error("JSON deserialization error: {0}")]
    Deserialization(#[from] serde_json::Error),
    #[error("JSON deserialization failed: {source}\nSnippet:\n{snippet}")]
    DeserializationWithSnippet {
        source: serde_json::Error,
        snippet: String,
    },
    #[error("SSE event did not include an event type")]
    MissingSseEventType,
    #[error("SSE event did not include data")]
    MissingSseData,
    #[error("Unknown SSE event type: {0}")]
    UnknownSseEventType(String),
    #[error("Too many retries")]
    TooManyRetry(Vec<Error>),
}

pub type Result<T> = core::result::Result<T, Error>;

/// Given a piece of text and a line/column, return a small snippet
pub fn snippet_around(
    full: &str,
    line: usize,
    column: usize,
    context: usize,
) -> String {
    let mut current_line = 1;
    let mut idx = 0;
    let bytes = full.as_bytes();

    while current_line < line && idx < bytes.len() {
        if bytes[idx] == b'\n' {
            current_line += 1;
        }
        idx += 1;
    }

    let mut error_byte = idx.saturating_add(column.saturating_sub(1));
    if error_byte > bytes.len() {
        error_byte = bytes.len();
    }

    let start = error_byte.saturating_sub(context);
    let end = (error_byte + context).min(full.len());

    let mut result = String::new();
    if start > 0 {
        result.push('…');
    }
    result.push_str(&full[start..end]);
    if end < full.len() {
        result.push('…');
    }
    result
}