Check for responses and send second message.
[cascardo/libreceita.git] / rnet_encode.c
1 /*
2  *  Copyright (C) 2013  Thadeu Lima de Souza Cascardo <cascardo@minaslivre.org>
3  *
4  *  This program is free software; you can redistribute it and/or modify
5  *  it under the terms of the GNU General Public License as published by
6  *  the Free Software Foundation; either version 3 of the License, or
7  *  (at your option) any later version.
8  *
9  *  This program is distributed in the hope that it will be useful,
10  *  but WITHOUT ANY WARRANTY; without even the implied warranty of
11  *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
12  *  GNU General Public License for more details.
13  *
14  *  You should have received a copy of the GNU General Public License along
15  *  with this program; if not, write to the Free Software Foundation, Inc.,
16  *  51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
17  */
18
19 #include "rnet_encode.h"
20 #include <unistd.h>
21 #include <stdio.h>
22 #include <stdlib.h>
23 #include <string.h>
24 #include <errno.h>
25 #include <fcntl.h>
26 #include "rnet_message.h"
27 #include "decfile.h"
28
29 int rnet_encode(struct rnet_decfile *decfile, struct rnet_message **msg)
30 {
31         int r;
32
33         uint32_t tp_arq;
34         uint32_t id_dec;
35         char *cpf;
36         char *codigo_recnet;
37         char *ano;
38         char *exerc;
39         char *uf;
40         uint16_t versao_pgd;
41         uint64_t file_len;
42         char *hash;
43         char *header;
44
45         *msg = rnet_message_new();
46         if (*msg == NULL) {
47                 return -ENOMEM;
48         }
49
50         file_len = rnet_decfile_get_file(decfile)->len;
51         hash = rnet_decfile_get_file_hash(decfile);
52         if (!hash)
53                 return -1;
54         header = rnet_decfile_get_header(decfile);
55
56         codigo_recnet = rnet_decfile_get_header_field(decfile, "codigo_recnet");
57         tp_arq = strtoul(codigo_recnet, NULL, 10);
58         id_dec = strtoul(rnet_decfile_get_header_field(decfile, "hash"), NULL, 10);
59         cpf = rnet_decfile_get_header_field(decfile, "cpf");
60         ano = rnet_decfile_get_header_field(decfile, "ano");
61         exerc = rnet_decfile_get_header_field(decfile, "exerc");
62         uf = rnet_decfile_get_header_field(decfile, "uf");
63         versao_pgd = strtoul(rnet_decfile_get_header_field(decfile, "nr_versao"), NULL, 10);
64
65         (*msg)->buffer[0] = 0x40;
66         (*msg)->len = 1;
67         r = rnet_message_add_u32(msg, "a_comp", 0);
68         r = rnet_message_add_u32(msg, "tp_arq", tp_arq);
69         r = rnet_message_add_u32(msg, "id_dec", id_dec);
70         r = rnet_message_add_ascii(msg, "exercicio", ano);
71         r = rnet_message_add_ascii(msg, "exercicio_pgd", exerc);
72         r = rnet_message_add_buffer(msg, "hash_arq", hash, 16);
73         r = rnet_message_add_buffer(msg, "hash_trans", hash, 16);
74         r = rnet_message_add_ascii(msg, "ni", cpf);
75         r = rnet_message_add_ascii(msg, "tp_ni", "CPF");
76         r = rnet_message_add_u8(msg, "num_ass", 0);
77         r = rnet_message_add_u32(msg, "p_comp", 0);
78         r = rnet_message_add_u8(msg, "ret", 0);
79         r = rnet_message_add_u64(msg, "tam_arq", file_len);
80         r = rnet_message_add_u64(msg, "tam_assinado", file_len);
81         r = rnet_message_add_u64(msg, "tam_trans", file_len);
82         r = rnet_message_add_ascii(msg, "uf", uf);
83         r = rnet_message_add_u8(msg, "vrs_des_pa", 0);
84         r = rnet_message_add_u16(msg, "versao_pgd", versao_pgd);
85         r = rnet_message_add_u8(msg, "critica_validador", 0x06);
86         r = rnet_message_add_ascii(msg, "ip_loc", "127.0.0.1");
87         r = rnet_message_add_ascii(msg, "versao_java", "1.7.0_03-icedtea;OpenJDK Runtime Environment");
88         r = rnet_message_add_ascii(msg, "origem", "JA2R");
89         r = rnet_message_add_ascii(msg, "so", "GNU");
90         r = rnet_message_add_ascii(msg, "cliente", "201104");
91         r = rnet_message_add_buffer(msg, "dados_val", header + 111, 750 - 111);
92         r = rnet_message_add_u32(msg, "tam_dados_val", 0);
93         r = rnet_message_add_u32(msg, "tam_dados_val_chave", 0);
94         r = rnet_message_add_u32(msg, "arquivos_restantes", 0);
95
96         free(hash);
97
98         if (r < 0)
99                 return r;
100         return 0;
101 }