/* * Copyright (C) 2017 Jianhui Zhao * * This program is free software: you can redistribute it and/or modify * it under the terms of the GNU General Public License as published by * the Free Software Foundation, either version 3 of the License, or * (at your option) any later version. * * This program is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * GNU General Public License for more details. * * You should have received a copy of the GNU General Public License * along with this program. If not, see . */ #ifndef _CLIENT_H_ #define _CLIENT_H_ #include "common.h" #if (UHTTPD_SSL_SUPPORT) #include #endif #define UHTTPD_CONNECTION_TIMEOUT 30 enum http_method { UH_HTTP_MSG_GET, UH_HTTP_MSG_POST, UH_HTTP_MSG_HEAD }; enum http_version { UH_HTTP_VER_0_9, UH_HTTP_VER_1_0, UH_HTTP_VER_1_1 }; enum client_state { CLIENT_STATE_INIT, CLIENT_STATE_HEADER, CLIENT_STATE_DATA, CLIENT_STATE_DONE, CLIENT_STATE_CLOSE }; struct http_request { enum http_method method; enum http_version version; int content_length; bool chunked; struct kvlist hdr; }; struct uh_client; struct dispatch { int (*data_send)(struct uh_client *cl, const char *data, int len); void (*data_done)(struct uh_client *cl); void (*write_cb)(struct uh_client *cl); void (*free)(struct uh_client *cl); union { struct { int fd; } file; struct { int post_len; char *body; struct uh_action *a; } action; }; }; struct uh_client { struct list_head list; struct uh_server *srv; struct ustream *us; struct ustream_fd sfd; #if (UHTTPD_SSL_SUPPORT) struct ustream_ssl ssl; #endif struct uloop_timeout timeout; enum client_state state; struct http_request request; struct sockaddr_in peer_addr; struct dispatch dispatch; bool connection_close; void (*free)(struct uh_client *cl); void (*send_error)(struct uh_client *cl, int code, const char *summary, const char *fmt, ...); void (*send_header)(struct uh_client *cl, int code, const char *summary, int length); void (*append_header)(struct uh_client *cl, const char *name, const char *value); void (*header_end)(struct uh_client *cl); void (*request_done)(struct uh_client *cl); void (*send)(struct uh_client *cl, const void *data, int len); void (*printf)(struct uh_client *cl, const char *format, ...); void (*vprintf)(struct uh_client *cl, const char *format, va_list arg); void (*chunk_send)(struct uh_client *cl, const void *data, int len); void (*chunk_printf)(struct uh_client *cl, const char *format, ...); void (*chunk_vprintf)(struct uh_client *cl, const char *format, va_list arg); const char *(*get_peer_addr)(struct uh_client *cl); const char *(*get_path)(struct uh_client *cl); const char *(*get_query)(struct uh_client *cl); const char *(*get_header)(struct uh_client *cl, const char *name); const char *(*get_body)(struct uh_client *cl, int *len); }; void uh_client_read_cb(struct uh_client *cl); void uh_client_notify_state(struct uh_client *cl); void uh_accept_client(struct uh_server *srv, bool ssl); #endif