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
121
|
/*
* (C) Copyright 2018
* Stefano Babic, stefano.babic@swupdate.org.
*
* SPDX-License-Identifier: GPL-2.0-only
*/
#include <errno.h>
#include <unistd.h>
#include <stdbool.h>
#include <stdlib.h>
#include <swupdate_dict.h>
#include <channel.h>
#include <util.h>
#include <parselib.h>
#include <swupdate_settings.h>
#include <channel_curl.h>
#include "server_utils.h"
int channel_settings(void *elem, void *data)
{
char tmp[128];
bool tmp_bool;
channel_data_t *chan = (channel_data_t *)data;
GET_FIELD_INT(LIBCFG_PARSER, elem, "retry",
(int *)&chan->retries);
GET_FIELD_STRING_RESET(LIBCFG_PARSER, elem, "max-download-speed", tmp);
if (strlen(tmp)) {
chan->max_download_speed = (unsigned int)ustrtoull(tmp, NULL, 10);
if (errno)
WARN("max-download-speed setting %s: ustrtoull failed", tmp);
}
GET_FIELD_STRING_RESET(LIBCFG_PARSER, elem, "retrywait", tmp);
if (strlen(tmp))
chan->retry_sleep =
(unsigned int)strtoul(tmp, NULL, 10);
GET_FIELD_BOOL(LIBCFG_PARSER, elem, "nocheckcert", &tmp_bool);
chan->strictssl = !tmp_bool;
GET_FIELD_STRING_RESET(LIBCFG_PARSER, elem, "cafile", tmp);
if (strlen(tmp))
SETSTRING(chan->cafile, tmp);
GET_FIELD_STRING_RESET(LIBCFG_PARSER, elem, "sslkey", tmp);
if (strlen(tmp))
SETSTRING(chan->sslkey, tmp);
GET_FIELD_STRING_RESET(LIBCFG_PARSER, elem, "sslkeypassword", tmp);
if (strlen(tmp))
SETSTRING(chan->sslkeypassword, tmp);
GET_FIELD_STRING_RESET(LIBCFG_PARSER, elem, "ciphers", tmp);
if (strlen(tmp))
SETSTRING(chan->ciphers, tmp);
GET_FIELD_STRING_RESET(LIBCFG_PARSER, elem, "sslcert", tmp);
if (strlen(tmp))
SETSTRING(chan->sslcert, tmp);
GET_FIELD_STRING_RESET(LIBCFG_PARSER, elem, "proxy", tmp);
if (strlen(tmp))
SETSTRING(chan->proxy, tmp);
GET_FIELD_STRING_RESET(LIBCFG_PARSER, elem, "interface", tmp);
if (strlen(tmp))
SETSTRING(chan->iface, tmp);
GET_FIELD_STRING_RESET(LIBCFG_PARSER, elem, "api_key_header", tmp);
if (strlen(tmp))
SETSTRING(chan->api_key_header, tmp);
GET_FIELD_STRING_RESET(LIBCFG_PARSER, elem, "api_key", tmp);
if (strlen(tmp))
SETSTRING(chan->api_key, tmp);
return 0;
}
server_op_res_t map_channel_retcode(channel_op_res_t response)
{
switch (response) {
case CHANNEL_ENONET:
case CHANNEL_EAGAIN:
case CHANNEL_ESSLCERT:
case CHANNEL_ESSLCONNECT:
case CHANNEL_REQUEST_PENDING:
return SERVER_EAGAIN;
case CHANNEL_EACCES:
return SERVER_EACCES;
case CHANNEL_ENOENT:
case CHANNEL_EIO:
case CHANNEL_EILSEQ:
case CHANNEL_ENOMEM:
case CHANNEL_EINIT:
case CHANNEL_ELOOP:
return SERVER_EERR;
case CHANNEL_EBADMSG:
case CHANNEL_ENOTFOUND:
return SERVER_EBADMSG;
case CHANNEL_OK:
case CHANNEL_EREDIRECT:
return SERVER_OK;
}
return SERVER_EERR;
}
struct json_object *server_tokenize_msg(char *buf, size_t size)
{
struct json_tokener *json_tokenizer = json_tokener_new();
enum json_tokener_error json_res;
struct json_object *json_root;
do {
json_root = json_tokener_parse_ex(
json_tokenizer, buf, size);
} while ((json_res = json_tokener_get_error(json_tokenizer)) ==
json_tokener_continue);
if (json_res != json_tokener_success) {
ERROR("Error while parsing channel's returned JSON data: %s",
json_tokener_error_desc(json_res));
json_tokener_free(json_tokenizer);
return NULL;
}
json_tokener_free(json_tokenizer);
return json_root;
}
|
