rbytes_consulta_cep 0.1.0

Consulta de CEP brasileiro com multi-provedores (ViaCEP, BrasilAPI, etc). Inclui fallback automático, timeout configurável e formatação de endereços.
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

// src/providers/viacep.rs
use crate::{models::Endereco, error::CepError, validacao::normalizar_cep};
use reqwest::{Client, StatusCode}; // Adicione StatusCode aqui
use serde::Deserialize;
use std::time::Duration;
use serde_json::Value;

#[derive(Debug, Deserialize)]
struct ViaCepResponse {
    cep: String,
    logradouro: String,
    complemento: String,
    bairro: String,
    localidade: String,
    uf: String,
    ibge: Option<String>,
    gia: Option<String>,
    ddd: Option<String>,
    siafi: Option<String>,
    #[serde(default)]
    erro: bool,
}

pub async fn consultar(cep: &str) -> Result<Endereco, CepError> {
    let cep_normalizado = normalizar_cep(cep)?;
    let url = format!("https://viacep.com.br/ws/{}/json/", cep_normalizado);
    
    let response = Client::new()
        .get(&url)
        .timeout(Duration::from_secs(2))
        .send()
        .await?;

    match response.status() {
        StatusCode::OK => {
            let viacep_response: ViaCepResponse = response.json().await?;
            
            if viacep_response.erro {
                return Err(CepError::CepNaoEncontrado);
            }

            Ok(Endereco {
                cep: viacep_response.cep,
                logradouro: Some(viacep_response.logradouro)
                    .filter(|s| !s.is_empty()),
                complemento: Some(viacep_response.complemento)
                    .filter(|s| !s.is_empty()),
                bairro: Some(viacep_response.bairro)
                    .filter(|s| !s.is_empty()),
                localidade: viacep_response.localidade,
                uf: viacep_response.uf,
                ibge: viacep_response.ibge,
                gia: viacep_response.gia,
                ddd: viacep_response.ddd,
                siafi: viacep_response.siafi,
            })
        },
        StatusCode::BAD_REQUEST => Err(CepError::CepInvalido),
        StatusCode::TOO_MANY_REQUESTS => Err(CepError::RateLimitExcedido("ViaCEP".into())),
        _ => Err(CepError::ProvedorIndisponivel("ViaCEP".into())),
    }
}