2013-08-16 18:18:16 +08:00
|
|
|
// Copyright (c) 2004-2013 Sergey Lyubka <valenok@gmail.com>
|
|
|
|
// Copyright (c) 2013 Cesanta Software Limited
|
|
|
|
// All rights reserved
|
2010-07-07 06:15:14 +08:00
|
|
|
//
|
2013-08-16 18:18:16 +08:00
|
|
|
// This library is dual-licensed: you can redistribute it and/or modify
|
|
|
|
// it under the terms of the GNU General Public License version 2 as
|
|
|
|
// published by the Free Software Foundation. For the terms of this
|
|
|
|
// license, see <http://www.gnu.org/licenses/>.
|
2010-07-07 06:15:14 +08:00
|
|
|
//
|
2013-08-16 18:18:16 +08:00
|
|
|
// You are free to use this library under the terms of the GNU General
|
|
|
|
// Public License, 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.
|
2010-07-07 06:15:14 +08:00
|
|
|
//
|
2013-08-16 18:18:16 +08:00
|
|
|
// Alternatively, you can license this library under a commercial
|
|
|
|
// license, as set out in <http://cesanta.com/products.html>.
|
2010-05-04 04:46:42 +08:00
|
|
|
|
|
|
|
#ifndef MONGOOSE_HEADER_INCLUDED
|
2010-07-07 06:15:14 +08:00
|
|
|
#define MONGOOSE_HEADER_INCLUDED
|
2010-05-04 04:46:42 +08:00
|
|
|
|
2012-08-15 04:26:49 +08:00
|
|
|
#include <stdio.h>
|
2011-05-02 16:09:58 +08:00
|
|
|
#include <stddef.h>
|
|
|
|
|
2010-05-04 04:46:42 +08:00
|
|
|
#ifdef __cplusplus
|
|
|
|
extern "C" {
|
2010-07-07 06:15:14 +08:00
|
|
|
#endif // __cplusplus
|
2010-05-04 04:46:42 +08:00
|
|
|
|
2010-07-07 06:15:14 +08:00
|
|
|
struct mg_context; // Handle for the HTTP service itself
|
|
|
|
struct mg_connection; // Handle for the individual connection
|
2010-05-04 04:46:42 +08:00
|
|
|
|
|
|
|
|
2010-08-30 05:30:49 +08:00
|
|
|
// This structure contains information about the HTTP request.
|
2010-05-04 04:46:42 +08:00
|
|
|
struct mg_request_info {
|
2012-09-28 04:48:05 +08:00
|
|
|
const char *request_method; // "GET", "POST", etc
|
|
|
|
const char *uri; // URL-decoded URI
|
|
|
|
const char *http_version; // E.g. "1.0", "1.1"
|
|
|
|
const char *query_string; // URL part after '?', not including '?', or NULL
|
|
|
|
const char *remote_user; // Authenticated user, or NULL if no auth used
|
|
|
|
long remote_ip; // Client's IP address
|
|
|
|
int remote_port; // Client's port
|
|
|
|
int is_ssl; // 1 if SSL-ed, 0 if not
|
2013-02-02 00:48:30 +08:00
|
|
|
void *user_data; // User data pointer passed to mg_start()
|
2013-08-26 19:22:38 +08:00
|
|
|
void *conn_data; // Connection-specific, per-thread user data.
|
2013-02-02 00:48:30 +08:00
|
|
|
|
|
|
|
int num_headers; // Number of HTTP headers
|
2010-07-07 06:15:14 +08:00
|
|
|
struct mg_header {
|
2012-09-28 04:48:05 +08:00
|
|
|
const char *name; // HTTP header name
|
|
|
|
const char *value; // HTTP header value
|
|
|
|
} http_headers[64]; // Maximum 64 headers
|
2010-05-04 04:46:42 +08:00
|
|
|
};
|
|
|
|
|
2012-09-19 19:23:54 +08:00
|
|
|
|
2013-02-01 02:29:22 +08:00
|
|
|
struct mg_callbacks {
|
2013-02-02 00:48:30 +08:00
|
|
|
int (*begin_request)(struct mg_connection *);
|
|
|
|
void (*end_request)(const struct mg_connection *, int reply_status_code);
|
|
|
|
int (*log_message)(const struct mg_connection *, const char *message);
|
2013-02-28 17:12:52 +08:00
|
|
|
int (*init_ssl)(void *ssl_context, void *user_data);
|
2013-02-02 00:48:30 +08:00
|
|
|
int (*websocket_connect)(const struct mg_connection *);
|
2013-02-01 02:29:22 +08:00
|
|
|
void (*websocket_ready)(struct mg_connection *);
|
2013-03-09 21:01:02 +08:00
|
|
|
int (*websocket_data)(struct mg_connection *, int bits,
|
2013-03-09 00:03:23 +08:00
|
|
|
char *data, size_t data_len);
|
2013-02-02 00:48:30 +08:00
|
|
|
const char * (*open_file)(const struct mg_connection *,
|
|
|
|
const char *path, size_t *data_len);
|
2013-02-01 02:29:22 +08:00
|
|
|
void (*init_lua)(struct mg_connection *, void *lua_context);
|
|
|
|
void (*upload)(struct mg_connection *, const char *file_name);
|
2013-08-26 19:22:38 +08:00
|
|
|
void (*thread_start)(void *user_data, void **conn_data);
|
|
|
|
void (*thread_stop)(void *user_data, void **conn_data);
|
2013-02-01 02:29:22 +08:00
|
|
|
};
|
|
|
|
|
2013-02-02 00:48:30 +08:00
|
|
|
struct mg_context *mg_start(const struct mg_callbacks *callbacks,
|
|
|
|
void *user_data,
|
|
|
|
const char **configuration_options);
|
2010-05-04 04:46:42 +08:00
|
|
|
void mg_stop(struct mg_context *);
|
|
|
|
|
|
|
|
|
2010-08-30 05:30:49 +08:00
|
|
|
// Get the value of particular configuration parameter.
|
|
|
|
// The value returned is read-only. Mongoose does not allow changing
|
|
|
|
// configuration at run time.
|
|
|
|
// If given parameter name is not valid, NULL is returned. For valid
|
|
|
|
// names, return value is guaranteed to be non-NULL. If parameter is not
|
|
|
|
// set, zero-length string is returned.
|
|
|
|
const char *mg_get_option(const struct mg_context *ctx, const char *name);
|
|
|
|
|
|
|
|
|
2010-08-31 15:01:14 +08:00
|
|
|
// Return array of strings that represent valid configuration options.
|
2013-07-20 14:12:49 +08:00
|
|
|
// For each option, option name and default value is returned, i.e. the
|
|
|
|
// number of entries in the array equals to number_of_options x 2.
|
2010-08-31 15:01:14 +08:00
|
|
|
// Array is NULL terminated.
|
2010-08-30 05:30:49 +08:00
|
|
|
const char **mg_get_valid_option_names(void);
|
|
|
|
|
|
|
|
|
2010-07-07 06:15:14 +08:00
|
|
|
// Add, edit or delete the entry in the passwords file.
|
|
|
|
//
|
|
|
|
// This function allows an application to manipulate .htpasswd files on the
|
|
|
|
// fly by adding, deleting and changing user records. This is one of the
|
|
|
|
// several ways of implementing authentication on the server side. For another,
|
|
|
|
// cookie-based way please refer to the examples/chat.c in the source tree.
|
|
|
|
//
|
|
|
|
// If password is not NULL, entry is added (or modified if already exists).
|
|
|
|
// If password is NULL, entry is deleted.
|
|
|
|
//
|
|
|
|
// Return:
|
2010-08-30 05:30:49 +08:00
|
|
|
// 1 on success, 0 on error.
|
2011-02-19 00:40:58 +08:00
|
|
|
int mg_modify_passwords_file(const char *passwords_file_name,
|
|
|
|
const char *domain,
|
|
|
|
const char *user,
|
|
|
|
const char *password);
|
2010-05-04 04:46:42 +08:00
|
|
|
|
2012-08-03 18:15:38 +08:00
|
|
|
|
2012-09-18 02:38:19 +08:00
|
|
|
// Return information associated with the request.
|
2012-09-28 04:48:05 +08:00
|
|
|
struct mg_request_info *mg_get_request_info(struct mg_connection *);
|
2012-08-03 18:15:38 +08:00
|
|
|
|
|
|
|
|
2010-07-07 06:15:14 +08:00
|
|
|
// Send data to the client.
|
2012-08-26 05:02:51 +08:00
|
|
|
// Return:
|
|
|
|
// 0 when the connection has been closed
|
|
|
|
// -1 on error
|
2013-02-13 05:03:54 +08:00
|
|
|
// >0 number of bytes written on success
|
2010-05-04 04:46:42 +08:00
|
|
|
int mg_write(struct mg_connection *, const void *buf, size_t len);
|
|
|
|
|
|
|
|
|
2013-07-12 19:25:25 +08:00
|
|
|
// Send data to a websocket client wrapped in a websocket frame.
|
|
|
|
// It is unsafe to read/write to this connection from another thread.
|
|
|
|
// This function is available when mongoose is compiled with -DUSE_WEBSOCKET
|
|
|
|
//
|
|
|
|
// Return:
|
|
|
|
// 0 when the connection has been closed
|
|
|
|
// -1 on error
|
|
|
|
// >0 number of bytes written on success
|
|
|
|
int mg_websocket_write(struct mg_connection* conn, int opcode,
|
|
|
|
const char *data, size_t data_len);
|
|
|
|
|
|
|
|
// Opcodes, from http://tools.ietf.org/html/rfc6455
|
|
|
|
enum {
|
|
|
|
WEBSOCKET_OPCODE_CONTINUATION = 0x0,
|
|
|
|
WEBSOCKET_OPCODE_TEXT = 0x1,
|
|
|
|
WEBSOCKET_OPCODE_BINARY = 0x2,
|
|
|
|
WEBSOCKET_OPCODE_CONNECTION_CLOSE = 0x8,
|
|
|
|
WEBSOCKET_OPCODE_PING = 0x9,
|
|
|
|
WEBSOCKET_OPCODE_PONG = 0xa
|
|
|
|
};
|
|
|
|
|
|
|
|
|
2013-02-13 05:03:54 +08:00
|
|
|
// Macros for enabling compiler-specific checks for printf-like arguments.
|
2012-08-19 19:08:33 +08:00
|
|
|
#undef PRINTF_FORMAT_STRING
|
2013-08-09 11:08:00 +08:00
|
|
|
#if defined(_MSC_VER) && _MSC_VER >= 1400
|
2012-08-19 19:08:33 +08:00
|
|
|
#include <sal.h>
|
2013-08-09 11:08:00 +08:00
|
|
|
#if defined(_MSC_VER) && _MSC_VER > 1400
|
2012-08-19 19:08:33 +08:00
|
|
|
#define PRINTF_FORMAT_STRING(s) _Printf_format_string_ s
|
|
|
|
#else
|
|
|
|
#define PRINTF_FORMAT_STRING(s) __format_string s
|
|
|
|
#endif
|
|
|
|
#else
|
|
|
|
#define PRINTF_FORMAT_STRING(s) s
|
|
|
|
#endif
|
|
|
|
|
2012-01-25 00:05:07 +08:00
|
|
|
#ifdef __GNUC__
|
2012-08-19 19:08:33 +08:00
|
|
|
#define PRINTF_ARGS(x, y) __attribute__((format(printf, x, y)))
|
|
|
|
#else
|
|
|
|
#define PRINTF_ARGS(x, y)
|
2012-01-25 00:05:07 +08:00
|
|
|
#endif
|
2012-08-19 19:08:33 +08:00
|
|
|
|
2013-02-13 05:03:54 +08:00
|
|
|
// Send data to the client using printf() semantics.
|
2013-01-24 05:54:27 +08:00
|
|
|
//
|
|
|
|
// Works exactly like mg_write(), but allows to do message formatting.
|
2012-08-19 19:08:33 +08:00
|
|
|
int mg_printf(struct mg_connection *,
|
|
|
|
PRINTF_FORMAT_STRING(const char *fmt), ...) PRINTF_ARGS(2, 3);
|
2010-05-04 04:46:42 +08:00
|
|
|
|
|
|
|
|
2011-06-20 00:45:52 +08:00
|
|
|
// Send contents of the entire file together with HTTP headers.
|
|
|
|
void mg_send_file(struct mg_connection *conn, const char *path);
|
|
|
|
|
|
|
|
|
2010-08-23 14:10:15 +08:00
|
|
|
// Read data from the remote end, return number of bytes read.
|
2013-05-19 15:00:12 +08:00
|
|
|
// Return:
|
|
|
|
// 0 connection has been closed by peer. No more data could be read.
|
|
|
|
// < 0 read error. No more data could be read from the connection.
|
|
|
|
// > 0 number of bytes read into the buffer.
|
2010-05-04 04:46:42 +08:00
|
|
|
int mg_read(struct mg_connection *, void *buf, size_t len);
|
|
|
|
|
2010-06-25 23:23:17 +08:00
|
|
|
|
2010-07-07 06:15:14 +08:00
|
|
|
// Get the value of particular HTTP header.
|
|
|
|
//
|
|
|
|
// This is a helper function. It traverses request_info->http_headers array,
|
|
|
|
// and if the header is present in the array, returns its value. If it is
|
|
|
|
// not present, NULL is returned.
|
2010-05-04 04:46:42 +08:00
|
|
|
const char *mg_get_header(const struct mg_connection *, const char *name);
|
|
|
|
|
|
|
|
|
2010-07-07 06:15:14 +08:00
|
|
|
// Get a value of particular form variable.
|
|
|
|
//
|
2010-08-30 05:30:49 +08:00
|
|
|
// Parameters:
|
|
|
|
// data: pointer to form-uri-encoded buffer. This could be either POST data,
|
|
|
|
// or request_info.query_string.
|
|
|
|
// data_len: length of the encoded data.
|
|
|
|
// var_name: variable name to decode from the buffer
|
2012-12-16 19:27:53 +08:00
|
|
|
// dst: destination buffer for the decoded variable
|
|
|
|
// dst_len: length of the destination buffer
|
2010-07-07 06:15:14 +08:00
|
|
|
//
|
|
|
|
// Return:
|
2010-08-30 05:30:49 +08:00
|
|
|
// On success, length of the decoded variable.
|
2012-08-26 05:02:51 +08:00
|
|
|
// On error:
|
2012-12-16 19:27:53 +08:00
|
|
|
// -1 (variable not found).
|
2013-02-13 05:03:54 +08:00
|
|
|
// -2 (destination buffer is NULL, zero length or too small to hold the
|
|
|
|
// decoded variable).
|
2010-08-30 05:30:49 +08:00
|
|
|
//
|
2012-08-26 05:02:51 +08:00
|
|
|
// Destination buffer is guaranteed to be '\0' - terminated if it is not
|
2012-12-16 19:27:53 +08:00
|
|
|
// NULL or zero length.
|
2010-08-30 05:30:49 +08:00
|
|
|
int mg_get_var(const char *data, size_t data_len,
|
2012-12-16 19:27:53 +08:00
|
|
|
const char *var_name, char *dst, size_t dst_len);
|
2010-07-07 06:15:14 +08:00
|
|
|
|
|
|
|
// Fetch value of certain cookie variable into the destination buffer.
|
|
|
|
//
|
|
|
|
// Destination buffer is guaranteed to be '\0' - terminated. In case of
|
2010-08-30 05:30:49 +08:00
|
|
|
// failure, dst[0] == '\0'. Note that RFC allows many occurrences of the same
|
|
|
|
// parameter. This function returns only first occurrence.
|
2010-07-07 06:15:14 +08:00
|
|
|
//
|
|
|
|
// Return:
|
2010-08-30 05:30:49 +08:00
|
|
|
// On success, value length.
|
2012-12-17 05:20:21 +08:00
|
|
|
// On error:
|
2013-02-13 05:03:54 +08:00
|
|
|
// -1 (either "Cookie:" header is not present at all or the requested
|
|
|
|
// parameter is not found).
|
|
|
|
// -2 (destination buffer is NULL, zero length or too small to hold the
|
|
|
|
// value).
|
2013-04-12 03:49:41 +08:00
|
|
|
int mg_get_cookie(const char *cookie, const char *var_name,
|
|
|
|
char *buf, size_t buf_len);
|
2010-07-07 06:15:14 +08:00
|
|
|
|
2010-05-04 04:46:42 +08:00
|
|
|
|
2013-01-24 05:54:27 +08:00
|
|
|
// Download data from the remote web server.
|
|
|
|
// host: host name to connect to, e.g. "foo.com", or "10.12.40.1".
|
|
|
|
// port: port number, e.g. 80.
|
|
|
|
// use_ssl: wether to use SSL connection.
|
|
|
|
// error_buffer, error_buffer_size: error message placeholder.
|
|
|
|
// request_fmt,...: HTTP request.
|
2012-07-28 18:04:03 +08:00
|
|
|
// Return:
|
2013-01-24 05:54:27 +08:00
|
|
|
// On success, valid pointer to the new connection, suitable for mg_read().
|
2013-02-01 02:29:22 +08:00
|
|
|
// On error, NULL. error_buffer contains error message.
|
2013-01-24 05:54:27 +08:00
|
|
|
// Example:
|
|
|
|
// char ebuf[100];
|
|
|
|
// struct mg_connection *conn;
|
|
|
|
// conn = mg_download("google.com", 80, 0, ebuf, sizeof(ebuf),
|
2013-01-24 09:16:23 +08:00
|
|
|
// "%s", "GET / HTTP/1.0\r\nHost: google.com\r\n\r\n");
|
2013-01-24 05:54:27 +08:00
|
|
|
struct mg_connection *mg_download(const char *host, int port, int use_ssl,
|
|
|
|
char *error_buffer, size_t error_buffer_size,
|
2013-01-24 17:35:54 +08:00
|
|
|
PRINTF_FORMAT_STRING(const char *request_fmt),
|
|
|
|
...) PRINTF_ARGS(6, 7);
|
2012-07-28 18:04:03 +08:00
|
|
|
|
|
|
|
|
2013-01-24 05:54:27 +08:00
|
|
|
// Close the connection opened by mg_download().
|
2012-07-29 01:57:04 +08:00
|
|
|
void mg_close_connection(struct mg_connection *conn);
|
|
|
|
|
|
|
|
|
2012-12-07 09:50:47 +08:00
|
|
|
// File upload functionality. Each uploaded file gets saved into a temporary
|
|
|
|
// file and MG_UPLOAD event is sent.
|
|
|
|
// Return number of uploaded files.
|
|
|
|
int mg_upload(struct mg_connection *conn, const char *destination_dir);
|
|
|
|
|
|
|
|
|
2012-07-28 19:06:26 +08:00
|
|
|
// Convenience function -- create detached thread.
|
|
|
|
// Return: 0 on success, non-0 on error.
|
|
|
|
typedef void * (*mg_thread_func_t)(void *);
|
|
|
|
int mg_start_thread(mg_thread_func_t f, void *p);
|
|
|
|
|
|
|
|
|
2012-07-31 15:58:44 +08:00
|
|
|
// Return builtin mime type for the given file name.
|
|
|
|
// For unrecognized extensions, "text/plain" is returned.
|
|
|
|
const char *mg_get_builtin_mime_type(const char *file_name);
|
|
|
|
|
|
|
|
|
2010-07-07 06:15:14 +08:00
|
|
|
// Return Mongoose version.
|
2010-05-04 04:46:42 +08:00
|
|
|
const char *mg_version(void);
|
|
|
|
|
2013-05-08 18:36:38 +08:00
|
|
|
// URL-decode input buffer into destination buffer.
|
|
|
|
// 0-terminate the destination buffer.
|
|
|
|
// form-url-encoded data differs from URI encoding in a way that it
|
|
|
|
// uses '+' as character for space, see RFC 1866 section 8.2.1
|
|
|
|
// http://ftp.ics.uci.edu/pub/ietf/html/rfc1866.txt
|
|
|
|
// Return: length of the decoded data, or -1 if dst buffer is too small.
|
|
|
|
int mg_url_decode(const char *src, int src_len, char *dst,
|
|
|
|
int dst_len, int is_form_url_encoded);
|
2010-05-04 04:46:42 +08:00
|
|
|
|
2010-07-07 06:15:14 +08:00
|
|
|
// MD5 hash given strings.
|
|
|
|
// Buffer 'buf' must be 33 bytes long. Varargs is a NULL terminated list of
|
2012-08-26 05:02:51 +08:00
|
|
|
// ASCIIz strings. When function returns, buf will contain human-readable
|
2010-07-07 06:15:14 +08:00
|
|
|
// MD5 hash. Example:
|
|
|
|
// char buf[33];
|
|
|
|
// mg_md5(buf, "aa", "bb", NULL);
|
2013-03-27 16:31:12 +08:00
|
|
|
char *mg_md5(char buf[33], ...);
|
2010-05-05 07:39:36 +08:00
|
|
|
|
|
|
|
|
2010-05-04 04:46:42 +08:00
|
|
|
#ifdef __cplusplus
|
|
|
|
}
|
2010-07-07 06:15:14 +08:00
|
|
|
#endif // __cplusplus
|
2010-05-04 04:46:42 +08:00
|
|
|
|
2010-07-07 06:15:14 +08:00
|
|
|
#endif // MONGOOSE_HEADER_INCLUDED
|