123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375 |
- /*
- * Copyright (c) 2000-2004 Niels Provos <provos@citi.umich.edu>
- * All rights reserved.
- *
- * Redistribution and use in source and binary forms, with or without
- * modification, are permitted provided that the following conditions
- * are met:
- * 1. Redistributions of source code must retain the above copyright
- * notice, this list of conditions and the following disclaimer.
- * 2. Redistributions in binary form must reproduce the above copyright
- * notice, this list of conditions and the following disclaimer in the
- * documentation and/or other materials provided with the distribution.
- * 3. The name of the author may not be used to endorse or promote products
- * derived from this software without specific prior written permission.
- *
- * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
- * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
- * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
- * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
- * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
- * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
- * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
- * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
- * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
- * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
- */
- #ifndef _EVHTTP_H_
- #define _EVHTTP_H_
- #include "event.h"
- #ifdef __cplusplus
- extern "C" {
- #endif
- #ifdef WIN32
- #define WIN32_LEAN_AND_MEAN
- #include <winsock2.h>
- #include <windows.h>
- #undef WIN32_LEAN_AND_MEAN
- #endif
- /** @file evhttp.h
- *
- * Basic support for HTTP serving.
- *
- * As libevent is a library for dealing with event notification and most
- * interesting applications are networked today, I have often found the
- * need to write HTTP code. The following prototypes and definitions provide
- * an application with a minimal interface for making HTTP requests and for
- * creating a very simple HTTP server.
- */
- /* Response codes */
- #define HTTP_OK 200
- #define HTTP_NOCONTENT 204
- #define HTTP_MOVEPERM 301
- #define HTTP_MOVETEMP 302
- #define HTTP_NOTMODIFIED 304
- #define HTTP_BADREQUEST 400
- #define HTTP_NOTFOUND 404
- #define HTTP_SERVUNAVAIL 503
- struct evhttp;
- struct evhttp_request;
- struct evkeyvalq;
- /** Create a new HTTP server
- *
- * @param base (optional) the event base to receive the HTTP events
- * @return a pointer to a newly initialized evhttp server structure
- */
- struct evhttp *evhttp_new(struct event_base *base);
- /**
- * Binds an HTTP server on the specified address and port.
- *
- * Can be called multiple times to bind the same http server
- * to multiple different ports.
- *
- * @param http a pointer to an evhttp object
- * @param address a string containing the IP address to listen(2) on
- * @param port the port number to listen on
- * @return 0 on success, -1 on failure
- * @see evhttp_free()
- */
- int evhttp_bind_socket(struct evhttp *http, const char *address, u_short port);
- /**
- * Makes an HTTP server accept connections on the specified socket
- *
- * This may be useful to create a socket and then fork multiple instances
- * of an http server, or when a socket has been communicated via file
- * descriptor passing in situations where an http servers does not have
- * permissions to bind to a low-numbered port.
- *
- * Can be called multiple times to have the http server listen to
- * multiple different sockets.
- *
- * @param http a pointer to an evhttp object
- * @param fd a socket fd that is ready for accepting connections
- * @return 0 on success, -1 on failure.
- * @see evhttp_free(), evhttp_bind_socket()
- */
- int evhttp_accept_socket(struct evhttp *http, int fd);
- /**
- * Free the previously created HTTP server.
- *
- * Works only if no requests are currently being served.
- *
- * @param http the evhttp server object to be freed
- * @see evhttp_start()
- */
- void evhttp_free(struct evhttp* http);
- /** Set a callback for a specified URI */
- void evhttp_set_cb(struct evhttp *, const char *,
- void (*)(struct evhttp_request *, void *), void *);
- /** Removes the callback for a specified URI */
- int evhttp_del_cb(struct evhttp *, const char *);
- /** Set a callback for all requests that are not caught by specific callbacks
- */
- void evhttp_set_gencb(struct evhttp *,
- void (*)(struct evhttp_request *, void *), void *);
- /**
- * Set the timeout for an HTTP request.
- *
- * @param http an evhttp object
- * @param timeout_in_secs the timeout, in seconds
- */
- void evhttp_set_timeout(struct evhttp *, int timeout_in_secs);
- /* Request/Response functionality */
- /**
- * Send an HTML error message to the client.
- *
- * @param req a request object
- * @param error the HTTP error code
- * @param reason a brief explanation of the error
- */
- void evhttp_send_error(struct evhttp_request *req, int error,
- const char *reason);
- /**
- * Send an HTML reply to the client.
- *
- * @param req a request object
- * @param code the HTTP response code to send
- * @param reason a brief message to send with the response code
- * @param databuf the body of the response
- */
- void evhttp_send_reply(struct evhttp_request *req, int code,
- const char *reason, struct evbuffer *databuf);
- /* Low-level response interface, for streaming/chunked replies */
- void evhttp_send_reply_start(struct evhttp_request *, int, const char *);
- void evhttp_send_reply_chunk(struct evhttp_request *, struct evbuffer *);
- void evhttp_send_reply_end(struct evhttp_request *);
- /**
- * Start an HTTP server on the specified address and port
- *
- * DEPRECATED: it does not allow an event base to be specified
- *
- * @param address the address to which the HTTP server should be bound
- * @param port the port number on which the HTTP server should listen
- * @return an struct evhttp object
- */
- struct evhttp *evhttp_start(const char *address, u_short port);
- /*
- * Interfaces for making requests
- */
- enum evhttp_cmd_type { EVHTTP_REQ_GET, EVHTTP_REQ_POST, EVHTTP_REQ_HEAD };
- enum evhttp_request_kind { EVHTTP_REQUEST, EVHTTP_RESPONSE };
- /**
- * the request structure that a server receives.
- * WARNING: expect this structure to change. I will try to provide
- * reasonable accessors.
- */
- struct evhttp_request {
- #if defined(TAILQ_ENTRY)
- TAILQ_ENTRY(evhttp_request) next;
- #else
- struct {
- struct evhttp_request *tqe_next;
- struct evhttp_request **tqe_prev;
- } next;
- #endif
- /* the connection object that this request belongs to */
- struct evhttp_connection *evcon;
- int flags;
- #define EVHTTP_REQ_OWN_CONNECTION 0x0001
- #define EVHTTP_PROXY_REQUEST 0x0002
- struct evkeyvalq *input_headers;
- struct evkeyvalq *output_headers;
- /* address of the remote host and the port connection came from */
- char *remote_host;
- u_short remote_port;
- enum evhttp_request_kind kind;
- enum evhttp_cmd_type type;
- char *uri; /* uri after HTTP request was parsed */
- char major; /* HTTP Major number */
- char minor; /* HTTP Minor number */
- int response_code; /* HTTP Response code */
- char *response_code_line; /* Readable response */
- struct evbuffer *input_buffer; /* read data */
- ev_int64_t ntoread;
- int chunked:1, /* a chunked request */
- userdone:1; /* the user has sent all data */
- struct evbuffer *output_buffer; /* outgoing post or data */
- /* Callback */
- void (*cb)(struct evhttp_request *, void *);
- void *cb_arg;
- /*
- * Chunked data callback - call for each completed chunk if
- * specified. If not specified, all the data is delivered via
- * the regular callback.
- */
- void (*chunk_cb)(struct evhttp_request *, void *);
- };
- /**
- * Creates a new request object that needs to be filled in with the request
- * parameters. The callback is executed when the request completed or an
- * error occurred.
- */
- struct evhttp_request *evhttp_request_new(
- void (*cb)(struct evhttp_request *, void *), void *arg);
- /** enable delivery of chunks to requestor */
- void evhttp_request_set_chunked_cb(struct evhttp_request *,
- void (*cb)(struct evhttp_request *, void *));
- /** Frees the request object and removes associated events. */
- void evhttp_request_free(struct evhttp_request *req);
- /** Returns the connection object associated with the request or NULL */
- struct evhttp_connection *evhttp_request_get_connection(struct evhttp_request *req);
- /**
- * A connection object that can be used to for making HTTP requests. The
- * connection object tries to establish the connection when it is given an
- * http request object.
- */
- struct evhttp_connection *evhttp_connection_new(
- const char *address, unsigned short port);
- /** Frees an http connection */
- void evhttp_connection_free(struct evhttp_connection *evcon);
- /** sets the ip address from which http connections are made */
- void evhttp_connection_set_local_address(struct evhttp_connection *evcon,
- const char *address);
- /** sets the local port from which http connections are made */
- void evhttp_connection_set_local_port(struct evhttp_connection *evcon,
- unsigned short port);
- /** Sets the timeout for events related to this connection */
- void evhttp_connection_set_timeout(struct evhttp_connection *evcon,
- int timeout_in_secs);
- /** Sets the retry limit for this connection - -1 repeats indefnitely */
- void evhttp_connection_set_retries(struct evhttp_connection *evcon,
- int retry_max);
- /** Set a callback for connection close. */
- void evhttp_connection_set_closecb(struct evhttp_connection *evcon,
- void (*)(struct evhttp_connection *, void *), void *);
- /**
- * Associates an event base with the connection - can only be called
- * on a freshly created connection object that has not been used yet.
- */
- void evhttp_connection_set_base(struct evhttp_connection *evcon,
- struct event_base *base);
- /** Get the remote address and port associated with this connection. */
- void evhttp_connection_get_peer(struct evhttp_connection *evcon,
- char **address, u_short *port);
- /** The connection gets ownership of the request */
- int evhttp_make_request(struct evhttp_connection *evcon,
- struct evhttp_request *req,
- enum evhttp_cmd_type type, const char *uri);
- const char *evhttp_request_uri(struct evhttp_request *req);
- /* Interfaces for dealing with HTTP headers */
- const char *evhttp_find_header(const struct evkeyvalq *, const char *);
- int evhttp_remove_header(struct evkeyvalq *, const char *);
- int evhttp_add_header(struct evkeyvalq *, const char *, const char *);
- void evhttp_clear_headers(struct evkeyvalq *);
- /* Miscellaneous utility functions */
- /**
- Helper function to encode a URI.
- The returned string must be freed by the caller.
- @param uri an unencoded URI
- @return a newly allocated URI-encoded string
- */
- char *evhttp_encode_uri(const char *uri);
- /**
- Helper function to decode a URI.
- The returned string must be freed by the caller.
- @param uri an encoded URI
- @return a newly allocated unencoded URI
- */
- char *evhttp_decode_uri(const char *uri);
- /**
- * Helper function to parse out arguments in a query.
- *
- * Parsing a uri like
- *
- * http://foo.com/?q=test&s=some+thing
- *
- * will result in two entries in the key value queue.
- * The first entry is: key="q", value="test"
- * The second entry is: key="s", value="some thing"
- *
- * @param uri the request URI
- * @param headers the head of the evkeyval queue
- */
- void evhttp_parse_query(const char *uri, struct evkeyvalq *headers);
- /**
- * Escape HTML character entities in a string.
- *
- * Replaces <, >, ", ' and & with <, >, ",
- * ' and & correspondingly.
- *
- * The returned string needs to be freed by the caller.
- *
- * @param html an unescaped HTML string
- * @return an escaped HTML string
- */
- char *evhttp_htmlescape(const char *html);
- #ifdef __cplusplus
- }
- #endif
- #endif /* _EVHTTP_H_ */
|