rbytes_consulta_cep 0.1.0

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

#[derive(Debug, Deserialize)]
struct OpenCepResponse {
    cep: String,
    logradouro: String,
    complemento: String,
    bairro: String,
    localidade: String,
    uf: String,
    ibge: Option<String>,
}

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

    match response.status() {
        StatusCode::OK => {
            let opencep_response: OpenCepResponse = response.json().await?;
            
            Ok(Endereco {
                cep: opencep_response.cep,
                logradouro: Some(opencep_response.logradouro)
                    .filter(|s| !s.is_empty()),
                complemento: Some(opencep_response.complemento)
                    .filter(|s| !s.is_empty()),
                bairro: Some(opencep_response.bairro)
                    .filter(|s| !s.is_empty()),
                localidade: opencep_response.localidade,
                uf: opencep_response.uf,
                ibge: opencep_response.ibge,
                gia: None,
                ddd: None,
                siafi: None,
            })
        },
        StatusCode::NOT_FOUND => Err(CepError::CepNaoEncontrado),
        StatusCode::TOO_MANY_REQUESTS => Err(CepError::RateLimitExcedido("OpenCEP".into())),
        _ => Err(CepError::ProvedorIndisponivel("OpenCEP".into())), // Corrigido aqui
    }
}