1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006 |
- /*
- * uclient - ustream based protocol client library
- *
- * Copyright (C) 2014 Felix Fietkau <nbd@openwrt.org>
- *
- * Permission to use, copy, modify, and/or distribute this software for any
- * purpose with or without fee is hereby granted, provided that the above
- * copyright notice and this permission notice appear in all copies.
- *
- * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
- * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
- * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
- * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
- * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
- * ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
- * OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
- */
- #include <stdio.h>
- #include <ctype.h>
- #include <unistd.h>
- #include <stdint.h>
- #include <libubox/ustream.h>
- #include <libubox/ustream-ssl.h>
- #include <libubox/usock.h>
- #include <libubox/blobmsg.h>
- #include "uclient.h"
- #include "uclient-utils.h"
- #include "uclient-backend.h"
- enum auth_type {
- AUTH_TYPE_UNKNOWN,
- AUTH_TYPE_NONE,
- AUTH_TYPE_BASIC,
- AUTH_TYPE_DIGEST,
- };
- enum request_type {
- REQ_GET,
- REQ_HEAD,
- REQ_POST,
- __REQ_MAX
- };
- enum http_state {
- HTTP_STATE_INIT,
- HTTP_STATE_HEADERS_SENT,
- HTTP_STATE_REQUEST_DONE,
- HTTP_STATE_RECV_HEADERS,
- HTTP_STATE_RECV_DATA,
- HTTP_STATE_ERROR,
- };
- static const char * const request_types[__REQ_MAX] = {
- [REQ_GET] = "GET",
- [REQ_HEAD] = "HEAD",
- [REQ_POST] = "POST",
- };
- struct uclient_http {
- struct uclient uc;
- struct ustream_ssl_ctx *ssl_ctx;
- struct ustream *us;
- struct ustream_fd ufd;
- struct ustream_ssl ussl;
- bool ssl_require_validation;
- bool ssl_ctx_ext;
- bool ssl;
- bool eof;
- bool connection_close;
- enum request_type req_type;
- enum http_state state;
- enum auth_type auth_type;
- char *auth_str;
- long read_chunked;
- long content_length;
- uint32_t nc;
- struct blob_buf headers;
- struct blob_buf meta;
- };
- enum {
- PREFIX_HTTP,
- PREFIX_HTTPS,
- __PREFIX_MAX,
- };
- static const char * const uclient_http_prefix[] = {
- [PREFIX_HTTP] = "http://",
- [PREFIX_HTTPS] = "https://",
- [__PREFIX_MAX] = NULL
- };
- static int uclient_do_connect(struct uclient_http *uh, const char *port)
- {
- int fd;
- if (uh->uc.url->port)
- port = uh->uc.url->port;
- fd = usock(USOCK_TCP | USOCK_NONBLOCK, uh->uc.url->host, port);
- if (fd < 0)
- return -1;
- ustream_fd_init(&uh->ufd, fd);
- return 0;
- }
- static void uclient_http_disconnect(struct uclient_http *uh)
- {
- if (!uh->us)
- return;
- if (uh->ssl)
- ustream_free(&uh->ussl.stream);
- ustream_free(&uh->ufd.stream);
- close(uh->ufd.fd.fd);
- uh->us = NULL;
- }
- static void uclient_http_free_url_state(struct uclient *cl)
- {
- struct uclient_http *uh = container_of(cl, struct uclient_http, uc);
- uh->auth_type = AUTH_TYPE_UNKNOWN;
- free(uh->auth_str);
- uh->auth_str = NULL;
- uclient_http_disconnect(uh);
- }
- static void uclient_http_error(struct uclient_http *uh, int code)
- {
- uh->state = HTTP_STATE_ERROR;
- uh->us->eof = true;
- ustream_state_change(uh->us);
- uclient_backend_set_error(&uh->uc, code);
- }
- static void uclient_notify_eof(struct uclient_http *uh)
- {
- struct ustream *us = uh->us;
- if (!uh->eof) {
- if (!us->eof && !us->write_error)
- return;
- if (ustream_pending_data(us, false))
- return;
- }
- uclient_backend_set_eof(&uh->uc);
- if (uh->connection_close)
- uclient_http_disconnect(uh);
- }
- static void uclient_http_reset_state(struct uclient_http *uh)
- {
- uclient_backend_reset_state(&uh->uc);
- uh->read_chunked = -1;
- uh->content_length = -1;
- uh->eof = false;
- uh->connection_close = false;
- uh->state = HTTP_STATE_INIT;
- if (uh->auth_type == AUTH_TYPE_UNKNOWN && !uh->uc.url->auth)
- uh->auth_type = AUTH_TYPE_NONE;
- }
- static void uclient_http_init_request(struct uclient_http *uh)
- {
- uclient_http_reset_state(uh);
- blob_buf_init(&uh->meta, 0);
- }
- static enum auth_type
- uclient_http_update_auth_type(struct uclient_http *uh)
- {
- if (!uh->auth_str)
- return AUTH_TYPE_NONE;
- if (!strncasecmp(uh->auth_str, "basic", 5))
- return AUTH_TYPE_BASIC;
- if (!strncasecmp(uh->auth_str, "digest", 6))
- return AUTH_TYPE_DIGEST;
- return AUTH_TYPE_NONE;
- }
- static void uclient_http_process_headers(struct uclient_http *uh)
- {
- enum {
- HTTP_HDR_TRANSFER_ENCODING,
- HTTP_HDR_CONNECTION,
- HTTP_HDR_CONTENT_LENGTH,
- HTTP_HDR_AUTH,
- __HTTP_HDR_MAX,
- };
- static const struct blobmsg_policy hdr_policy[__HTTP_HDR_MAX] = {
- #define hdr(_name) { .name = _name, .type = BLOBMSG_TYPE_STRING }
- [HTTP_HDR_TRANSFER_ENCODING] = hdr("transfer-encoding"),
- [HTTP_HDR_CONNECTION] = hdr("connection"),
- [HTTP_HDR_CONTENT_LENGTH] = hdr("content-length"),
- [HTTP_HDR_AUTH] = hdr("www-authenticate"),
- #undef hdr
- };
- struct blob_attr *tb[__HTTP_HDR_MAX];
- struct blob_attr *cur;
- blobmsg_parse(hdr_policy, __HTTP_HDR_MAX, tb, blob_data(uh->meta.head), blob_len(uh->meta.head));
- cur = tb[HTTP_HDR_TRANSFER_ENCODING];
- if (cur && strstr(blobmsg_data(cur), "chunked"))
- uh->read_chunked = 0;
- cur = tb[HTTP_HDR_CONNECTION];
- if (cur && strstr(blobmsg_data(cur), "close"))
- uh->connection_close = true;
- cur = tb[HTTP_HDR_CONTENT_LENGTH];
- if (cur)
- uh->content_length = strtoul(blobmsg_data(cur), NULL, 10);
- cur = tb[HTTP_HDR_AUTH];
- if (cur) {
- free(uh->auth_str);
- uh->auth_str = strdup(blobmsg_data(cur));
- }
- uh->auth_type = uclient_http_update_auth_type(uh);
- }
- static void
- uclient_http_add_auth_basic(struct uclient_http *uh)
- {
- struct uclient_url *url = uh->uc.url;
- int auth_len = strlen(url->auth);
- char *auth_buf;
- if (auth_len > 512)
- return;
- auth_buf = alloca(base64_len(auth_len) + 1);
- base64_encode(url->auth, auth_len, auth_buf);
- ustream_printf(uh->us, "Authorization: Basic %s\r\n", auth_buf);
- }
- static char *digest_unquote_sep(char **str)
- {
- char *cur = *str + 1;
- char *start = cur;
- char *out;
- if (**str != '"')
- return NULL;
- out = cur;
- while (1) {
- if (!*cur)
- return NULL;
- if (*cur == '"') {
- cur++;
- break;
- }
- if (*cur == '\\')
- cur++;
- *(out++) = *(cur++);
- }
- if (*cur == ',')
- cur++;
- *out = 0;
- *str = cur;
- return start;
- }
- static bool strmatch(char **str, const char *prefix)
- {
- int len = strlen(prefix);
- if (strncmp(*str, prefix, len) != 0 || (*str)[len] != '=')
- return false;
- *str += len + 1;
- return true;
- }
- static void
- get_cnonce(char *dest)
- {
- uint32_t val = 0;
- FILE *f;
- f = fopen("/dev/urandom", "r");
- if (f) {
- fread(&val, sizeof(val), 1, f);
- fclose(f);
- }
- bin_to_hex(dest, &val, sizeof(val));
- }
- static void add_field(char **buf, int *ofs, int *len, const char *name, const char *val)
- {
- int available = *len - *ofs;
- int required;
- const char *next;
- char *cur;
- if (*len && !*buf)
- return;
- required = strlen(name) + 4 + strlen(val) * 2;
- if (required > available)
- *len += required - available + 64;
- *buf = realloc(*buf, *len);
- if (!*buf)
- return;
- cur = *buf + *ofs;
- cur += sprintf(cur, ", %s=\"", name);
- while ((next = strchr(val, '"'))) {
- if (next > val) {
- memcpy(cur, val, next - val);
- cur += next - val;
- }
- cur += sprintf(cur, "\\\"");
- val = next + 1;
- }
- cur += sprintf(cur, "%s\"", val);
- *ofs = cur - *buf;
- }
- static void
- uclient_http_add_auth_digest(struct uclient_http *uh)
- {
- struct uclient_url *url = uh->uc.url;
- const char *realm = NULL, *opaque = NULL;
- const char *user, *password;
- char *buf, *next;
- int len, ofs;
- char cnonce_str[9];
- char nc_str[9];
- char ahash[33];
- char hash[33];
- struct http_digest_data data = {
- .nc = nc_str,
- .cnonce = cnonce_str,
- .auth_hash = ahash,
- };
- len = strlen(uh->auth_str) + 1;
- if (len > 512)
- return;
- buf = alloca(len);
- strcpy(buf, uh->auth_str);
- /* skip auth type */
- strsep(&buf, " ");
- next = buf;
- while (*next) {
- const char **dest = NULL;
- while (isspace(*next))
- next++;
- if (strmatch(&next, "realm"))
- dest = &realm;
- else if (strmatch(&next, "qop"))
- dest = &data.qop;
- else if (strmatch(&next, "nonce"))
- dest = &data.nonce;
- else if (strmatch(&next, "opaque"))
- dest = &opaque;
- else
- return;
- *dest = digest_unquote_sep(&next);
- }
- if (!realm || !data.qop || !data.nonce)
- return;
- sprintf(nc_str, "%08x", uh->nc++);
- get_cnonce(cnonce_str);
- data.qop = "auth";
- data.uri = url->location;
- data.method = request_types[uh->req_type];
- password = strchr(url->auth, ':');
- if (password) {
- char *user_buf;
- len = password - url->auth;
- if (len > 256)
- return;
- user_buf = alloca(len + 1);
- strncpy(user_buf, url->auth, len);
- user_buf[len] = 0;
- user = user_buf;
- password++;
- } else {
- user = url->auth;
- password = "";
- }
- http_digest_calculate_auth_hash(ahash, user, realm, password);
- http_digest_calculate_response(hash, &data);
- buf = NULL;
- len = 0;
- ofs = 0;
- add_field(&buf, &ofs, &len, "username", user);
- add_field(&buf, &ofs, &len, "realm", realm);
- add_field(&buf, &ofs, &len, "nonce", data.nonce);
- add_field(&buf, &ofs, &len, "uri", data.uri);
- add_field(&buf, &ofs, &len, "cnonce", data.cnonce);
- add_field(&buf, &ofs, &len, "response", hash);
- if (opaque)
- add_field(&buf, &ofs, &len, "opaque", opaque);
- ustream_printf(uh->us, "Authorization: Digest nc=%s, qop=%s%s\r\n", data.nc, data.qop, buf);
- free(buf);
- }
- static void
- uclient_http_add_auth_header(struct uclient_http *uh)
- {
- if (!uh->uc.url->auth)
- return;
- switch (uh->auth_type) {
- case AUTH_TYPE_UNKNOWN:
- case AUTH_TYPE_NONE:
- break;
- case AUTH_TYPE_BASIC:
- uclient_http_add_auth_basic(uh);
- break;
- case AUTH_TYPE_DIGEST:
- uclient_http_add_auth_digest(uh);
- break;
- }
- }
- static void
- uclient_http_send_headers(struct uclient_http *uh)
- {
- struct uclient_url *url = uh->uc.url;
- struct blob_attr *cur;
- enum request_type req_type = uh->req_type;
- int rem;
- if (uh->state >= HTTP_STATE_HEADERS_SENT)
- return;
- if (uh->auth_type == AUTH_TYPE_UNKNOWN)
- req_type = REQ_HEAD;
- ustream_printf(uh->us,
- "%s %s HTTP/1.1\r\n"
- "Host: %s\r\n",
- request_types[req_type],
- url->location, url->host);
- blobmsg_for_each_attr(cur, uh->headers.head, rem)
- ustream_printf(uh->us, "%s: %s\n", blobmsg_name(cur), (char *) blobmsg_data(cur));
- if (uh->req_type == REQ_POST)
- ustream_printf(uh->us, "Transfer-Encoding: chunked\r\n");
- uclient_http_add_auth_header(uh);
- ustream_printf(uh->us, "\r\n");
- uh->state = HTTP_STATE_HEADERS_SENT;
- }
- static void uclient_http_headers_complete(struct uclient_http *uh)
- {
- enum auth_type auth_type = uh->auth_type;
- socklen_t sl;
- uh->state = HTTP_STATE_RECV_DATA;
- uh->uc.meta = uh->meta.head;
- uclient_http_process_headers(uh);
- if (auth_type == AUTH_TYPE_UNKNOWN) {
- uclient_http_init_request(uh);
- uclient_http_send_headers(uh);
- uh->state = HTTP_STATE_REQUEST_DONE;
- return;
- }
- memset(&uh->uc.local_addr, 0, sizeof(uh->uc.local_addr));
- memset(&uh->uc.remote_addr, 0, sizeof(uh->uc.remote_addr));
- sl = sizeof(uh->uc.local_addr);
- getsockname(uh->ufd.fd.fd, &uh->uc.local_addr.sa, &sl);
- getpeername(uh->ufd.fd.fd, &uh->uc.remote_addr.sa, &sl);
- if (uh->uc.cb->header_done)
- uh->uc.cb->header_done(&uh->uc);
- if (uh->req_type == REQ_HEAD || uh->uc.status_code == 204) {
- uh->eof = true;
- uclient_notify_eof(uh);
- }
- }
- static void uclient_parse_http_line(struct uclient_http *uh, char *data)
- {
- char *name;
- char *sep;
- if (uh->state == HTTP_STATE_REQUEST_DONE) {
- char *code;
- /* HTTP/1.1 */
- strsep(&data, " ");
- code = strsep(&data, " ");
- if (!code)
- goto error;
- uh->uc.status_code = strtoul(code, &sep, 10);
- if (sep && *sep)
- goto error;
- uh->state = HTTP_STATE_RECV_HEADERS;
- return;
- }
- if (!*data) {
- uclient_http_headers_complete(uh);
- return;
- }
- sep = strchr(data, ':');
- if (!sep)
- return;
- *(sep++) = 0;
- for (name = data; *name; name++)
- *name = tolower(*name);
- name = data;
- while (isspace(*sep))
- sep++;
- blobmsg_add_string(&uh->meta, name, sep);
- return;
- error:
- uh->uc.status_code = 400;
- uh->eof = true;
- uclient_notify_eof(uh);
- }
- static void __uclient_notify_read(struct uclient_http *uh)
- {
- struct uclient *uc = &uh->uc;
- char *data;
- int len;
- if (uh->state < HTTP_STATE_REQUEST_DONE || uh->state == HTTP_STATE_ERROR)
- return;
- data = ustream_get_read_buf(uh->us, &len);
- if (!data || !len)
- return;
- if (uh->state < HTTP_STATE_RECV_DATA) {
- char *sep;
- int cur_len;
- do {
- sep = strstr(data, "\r\n");
- if (!sep)
- break;
- /* Check for multi-line HTTP headers */
- if (sep > data) {
- if (!sep[2])
- return;
- if (isspace(sep[2]) && sep[2] != '\r') {
- sep[0] = ' ';
- sep[1] = ' ';
- continue;
- }
- }
- *sep = 0;
- cur_len = sep + 2 - data;
- uclient_parse_http_line(uh, data);
- ustream_consume(uh->us, cur_len);
- len -= cur_len;
- data = ustream_get_read_buf(uh->us, &len);
- } while (data && uh->state < HTTP_STATE_RECV_DATA);
- if (!len)
- return;
- }
- if (uh->state == HTTP_STATE_RECV_DATA && uc->cb->data_read)
- uc->cb->data_read(uc);
- }
- static void uclient_notify_read(struct ustream *us, int bytes)
- {
- struct uclient_http *uh = container_of(us, struct uclient_http, ufd.stream);
- __uclient_notify_read(uh);
- }
- static void uclient_notify_state(struct ustream *us)
- {
- struct uclient_http *uh = container_of(us, struct uclient_http, ufd.stream);
- uclient_notify_eof(uh);
- }
- static int uclient_setup_http(struct uclient_http *uh)
- {
- struct ustream *us = &uh->ufd.stream;
- int ret;
- uh->us = us;
- us->string_data = true;
- us->notify_state = uclient_notify_state;
- us->notify_read = uclient_notify_read;
- ret = uclient_do_connect(uh, "80");
- if (ret)
- return ret;
- return 0;
- }
- static void uclient_ssl_notify_read(struct ustream *us, int bytes)
- {
- struct uclient_http *uh = container_of(us, struct uclient_http, ussl.stream);
- __uclient_notify_read(uh);
- }
- static void uclient_ssl_notify_state(struct ustream *us)
- {
- struct uclient_http *uh = container_of(us, struct uclient_http, ussl.stream);
- uclient_notify_eof(uh);
- }
- static void uclient_ssl_notify_error(struct ustream_ssl *ssl, int error, const char *str)
- {
- struct uclient_http *uh = container_of(ssl, struct uclient_http, ussl);
- uclient_http_error(uh, UCLIENT_ERROR_CONNECT);
- }
- static void uclient_ssl_notify_verify_error(struct ustream_ssl *ssl, int error, const char *str)
- {
- struct uclient_http *uh = container_of(ssl, struct uclient_http, ussl);
- if (!uh->ssl_require_validation)
- return;
- uclient_http_error(uh, UCLIENT_ERROR_SSL_INVALID_CERT);
- }
- static void uclient_ssl_notify_connected(struct ustream_ssl *ssl)
- {
- struct uclient_http *uh = container_of(ssl, struct uclient_http, ussl);
- if (!uh->ssl_require_validation)
- return;
- if (!uh->ussl.valid_cn)
- uclient_http_error(uh, UCLIENT_ERROR_SSL_CN_MISMATCH);
- }
- static int uclient_setup_https(struct uclient_http *uh)
- {
- struct ustream *us = &uh->ussl.stream;
- int ret;
- uh->ssl = true;
- uh->us = us;
- ret = uclient_do_connect(uh, "443");
- if (ret)
- return ret;
- if (!uh->ssl_ctx)
- uh->ssl_ctx = ustream_ssl_context_new(false);
- us->string_data = true;
- us->notify_state = uclient_ssl_notify_state;
- us->notify_read = uclient_ssl_notify_read;
- uh->ussl.notify_error = uclient_ssl_notify_error;
- uh->ussl.notify_verify_error = uclient_ssl_notify_verify_error;
- uh->ussl.notify_connected = uclient_ssl_notify_connected;
- ustream_ssl_init(&uh->ussl, &uh->ufd.stream, uh->ssl_ctx, false);
- ustream_ssl_set_peer_cn(&uh->ussl, uh->uc.url->host);
- return 0;
- }
- static int uclient_http_connect(struct uclient *cl)
- {
- struct uclient_http *uh = container_of(cl, struct uclient_http, uc);
- int ret;
- uclient_http_init_request(uh);
- if (uh->us)
- return 0;
- uh->ssl = cl->url->prefix == PREFIX_HTTPS;
- if (uh->ssl)
- ret = uclient_setup_https(uh);
- else
- ret = uclient_setup_http(uh);
- if (ret)
- uclient_http_error(uh, UCLIENT_ERROR_CONNECT);
- return ret;
- }
- static struct uclient *uclient_http_alloc(void)
- {
- struct uclient_http *uh;
- uh = calloc_a(sizeof(*uh));
- blob_buf_init(&uh->headers, 0);
- return &uh->uc;
- }
- static void uclient_http_free_ssl_ctx(struct uclient_http *uh)
- {
- if (uh->ssl_ctx && !uh->ssl_ctx_ext)
- ustream_ssl_context_free(uh->ssl_ctx);
- uh->ssl_ctx_ext = false;
- }
- static void uclient_http_free(struct uclient *cl)
- {
- struct uclient_http *uh = container_of(cl, struct uclient_http, uc);
- uclient_http_free_ssl_ctx(uh);
- uclient_http_free_url_state(cl);
- blob_buf_free(&uh->headers);
- blob_buf_free(&uh->meta);
- free(uh);
- }
- int
- uclient_http_set_request_type(struct uclient *cl, const char *type)
- {
- struct uclient_http *uh = container_of(cl, struct uclient_http, uc);
- int i;
- if (cl->backend != &uclient_backend_http)
- return -1;
- if (uh->state > HTTP_STATE_INIT)
- return -1;
- for (i = 0; i < ARRAY_SIZE(request_types); i++) {
- if (strcmp(request_types[i], type) != 0)
- continue;
- uh->req_type = i;
- return 0;
- }
- return -1;
- }
- int
- uclient_http_reset_headers(struct uclient *cl)
- {
- struct uclient_http *uh = container_of(cl, struct uclient_http, uc);
- blob_buf_init(&uh->headers, 0);
- return 0;
- }
- int
- uclient_http_set_header(struct uclient *cl, const char *name, const char *value)
- {
- struct uclient_http *uh = container_of(cl, struct uclient_http, uc);
- if (cl->backend != &uclient_backend_http)
- return -1;
- if (uh->state > HTTP_STATE_INIT)
- return -1;
- blobmsg_add_string(&uh->headers, name, value);
- return 0;
- }
- static int
- uclient_http_send_data(struct uclient *cl, char *buf, unsigned int len)
- {
- struct uclient_http *uh = container_of(cl, struct uclient_http, uc);
- if (uh->state >= HTTP_STATE_REQUEST_DONE)
- return -1;
- uclient_http_send_headers(uh);
- if (len > 0) {
- ustream_printf(uh->us, "%X\r\n", len);
- ustream_write(uh->us, buf, len, false);
- ustream_printf(uh->us, "\r\n");
- }
- return len;
- }
- static int
- uclient_http_request_done(struct uclient *cl)
- {
- struct uclient_http *uh = container_of(cl, struct uclient_http, uc);
- if (uh->state >= HTTP_STATE_REQUEST_DONE)
- return -1;
- uclient_http_send_headers(uh);
- if (uh->req_type == REQ_POST)
- ustream_printf(uh->us, "0\r\n\r\n");
- uh->state = HTTP_STATE_REQUEST_DONE;
- return 0;
- }
- static int
- uclient_http_read(struct uclient *cl, char *buf, unsigned int len)
- {
- struct uclient_http *uh = container_of(cl, struct uclient_http, uc);
- int read_len = 0;
- char *data, *data_end;
- if (uh->state < HTTP_STATE_RECV_DATA || !uh->us)
- return 0;
- data = ustream_get_read_buf(uh->us, &read_len);
- if (!data || !read_len)
- return 0;
- data_end = data + read_len;
- read_len = 0;
- if (uh->read_chunked == 0) {
- char *sep;
- if (data[0] == '\r' && data[1] == '\n') {
- data += 2;
- read_len += 2;
- }
- sep = strstr(data, "\r\n");
- if (!sep)
- return 0;
- *sep = 0;
- uh->read_chunked = strtoul(data, NULL, 16);
- read_len += sep + 2 - data;
- data = sep + 2;
- if (!uh->read_chunked)
- uh->eof = true;
- }
- if (len > data_end - data)
- len = data_end - data;
- if (uh->read_chunked >= 0) {
- if (len > uh->read_chunked)
- len = uh->read_chunked;
- uh->read_chunked -= len;
- } else if (uh->content_length >= 0) {
- if (len > uh->content_length)
- len = uh->content_length;
- uh->content_length -= len;
- if (!uh->content_length)
- uh->eof = true;
- }
- if (len > 0) {
- read_len += len;
- memcpy(buf, data, len);
- }
- if (read_len > 0)
- ustream_consume(uh->us, read_len);
- uclient_notify_eof(uh);
- return len;
- }
- bool uclient_http_redirect(struct uclient *cl)
- {
- struct uclient_http *uh = container_of(cl, struct uclient_http, uc);
- struct blobmsg_policy location = {
- .name = "location",
- .type = BLOBMSG_TYPE_STRING,
- };
- struct uclient_url *url = cl->url;
- struct blob_attr *tb;
- if (cl->backend != &uclient_backend_http)
- return false;
- switch (cl->status_code) {
- case 301:
- case 302:
- case 307:
- break;
- default:
- return false;
- }
- blobmsg_parse(&location, 1, &tb, blob_data(uh->meta.head), blob_len(uh->meta.head));
- if (!tb)
- return false;
- url = uclient_get_url(blobmsg_data(tb), url->auth);
- if (!url)
- return false;
- free(cl->url);
- cl->url = url;
- uclient_http_connect(cl);
- uclient_http_request_done(cl);
- return true;
- }
- int uclient_http_set_ssl_ctx(struct uclient *cl, struct ustream_ssl_ctx *ctx, bool require_validation)
- {
- struct uclient_http *uh = container_of(cl, struct uclient_http, uc);
- if (cl->backend != &uclient_backend_http)
- return -1;
- uclient_http_free_url_state(cl);
- uclient_http_free_ssl_ctx(uh);
- uh->ssl_ctx = ctx;
- uh->ssl_ctx_ext = !!ctx;
- uh->ssl_require_validation = !!ctx && require_validation;
- return 0;
- }
- const struct uclient_backend uclient_backend_http = {
- .prefix = uclient_http_prefix,
- .alloc = uclient_http_alloc,
- .free = uclient_http_free,
- .connect = uclient_http_connect,
- .update_url = uclient_http_free_url_state,
- .read = uclient_http_read,
- .write = uclient_http_send_data,
- .request = uclient_http_request_done,
- };
|