dfe 0.6.1

DFE - Documentos Fiscais Eletrônicos Brasileiros
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
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120

mod endpoint;
mod parser;
mod service;
mod validation;
mod xml;

use serde::Serialize;

/// Resposta da consulta de status do webservice SEFAZ.
#[derive(Debug, Serialize)]
pub struct NFeServiceResponse {
    /// Código de status (`"107"` = serviço em operação).
    pub c_stat: String,
    /// Descrição do status retornado pela SEFAZ.
    pub x_motivo: String,
    /// XML enviado na requisição SOAP.
    pub sent_xml: String,
    /// XML recebido da SEFAZ.
    pub received_xml: String,
    /// URL do endpoint consultado.
    pub url: String,
}

/// Builder fluente para consulta de status do webservice SEFAZ.
///
/// # Exemplo
///
/// ```no_run
/// use dfe::NFeService;
///
/// # async fn example() -> Result<(), String> {
/// let r = NFeService::new()
///     .cert_path("./cert.pfx")
///     .cert_pass("senha")
///     .uf("SP")
///     .environment(2)
///     .send()
///     .await?;
///
/// println!("{} — {}", r.c_stat, r.x_motivo);
/// # Ok(())
/// # }
/// ```
#[derive(Debug)]
pub struct NFeService {
    /// Caminho do certificado A1 (`.pfx`).
    pub cert_path: String,
    /// Senha do certificado.
    pub cert_pass: String,
    /// Sigla da UF (ex.: `"SP"`, `"RJ"`).
    pub uf: String,
    /// Ambiente: `1` = Produção · `2` = Homologação.
    pub environment: u8,
}

impl NFeService {
    /// Cria um builder vazio.
    pub fn new() -> Self {
        Self {
            cert_path: String::new(),
            cert_pass: String::new(),
            uf: String::new(),
            environment: 0,
        }
    }

    /// Caminho do certificado A1 (`.pfx`).
    pub fn cert_path(mut self, cert_path: &str) -> Self {
        self.cert_path = cert_path.to_string();
        self
    }

    /// Senha do certificado.
    pub fn cert_pass(mut self, cert_pass: &str) -> Self {
        self.cert_pass = cert_pass.to_string();
        self
    }

    /// Sigla da UF (ex.: `"SP"`, `"RJ"`).
    pub fn uf(mut self, uf: &str) -> Self {
        self.uf = uf.to_string();
        self
    }

    /// Ambiente: `1` = Produção · `2` = Homologação.
    pub fn environment(mut self, environment: u8) -> Self {
        self.environment = environment;
        self
    }

    /// Valida os campos sem enviar a requisição. Retorna `Err` se algum campo obrigatório estiver vazio.
    pub fn build(self) -> Result<Self, String> {
        validation::validate_nfe_service(&self)?;

        Ok(self)
    }

    /// Consulta o status do webservice SEFAZ e retorna [`NFeServiceResponse`].
    ///
    /// # Erros
    ///
    /// Retorna `Err(String)` se a requisição SOAP falhar ou a UF não for suportada.
    pub async fn send(self) -> Result<NFeServiceResponse, String> {
        validation::validate_nfe_service(&self)?;

        let url = endpoint::status_url(self.environment, &self.uf)?;
        let xml = xml::status_request_xml(self.environment, &self.uf)?;
        let body =
            service::send_status_request(&self.cert_path, &self.cert_pass, &url, &xml).await?;
        let status = parser::parse_status_response(&body)?;

        Ok(NFeServiceResponse {
            c_stat: status.c_stat,
            x_motivo: status.x_motivo,
            sent_xml: xml,
            received_xml: body,
            url,
        })
    }
}