Skip to content

M
mongoose
Commit 27fe9c8f authored by Joe Mucchiello's avatar Joe Mucchiello
Browse files
Options

Add http_error callback 

Allows user code to display its own error status responses or just log
the errors. Is called even in cases where begin_request is not called.
parent 9178fbd1
Hide whitespace changes
Inline Side-by-side
Showing with 5479 additions and 5475 deletions
mongoose.c
View file @ 27fe9c8f
This source diff could not be displayed because it is too large. You can view the blob instead.
mongoose.h
View file @ 27fe9c8f
// Copyright (c) 2004-2012 Sergey Lyubka // Copyright (c) 2004-2012 Sergey Lyubka
// //
// Permission is hereby granted, free of charge, to any person obtaining a copy // Permission is hereby granted, free of charge, to any person obtaining a copy
// of this software and associated documentation files (the "Software"), to deal // of this software and associated documentation files (the "Software"), to deal
// in the Software without restriction, including without limitation the rights // in the Software without restriction, including without limitation the rights
// to use, copy, modify, merge, publish, distribute, sublicense, and/or sell // to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
// copies of the Software, and to permit persons to whom the Software is // copies of the Software, and to permit persons to whom the Software is
// furnished to do so, subject to the following conditions: // furnished to do so, subject to the following conditions:
// //
// The above copyright notice and this permission notice shall be included in // The above copyright notice and this permission notice shall be included in
// all copies or substantial portions of the Software. // all copies or substantial portions of the Software.
// //
// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
// IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, // IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
// FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE // FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
// AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER // AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
// LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, // LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
// OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN // OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
// THE SOFTWARE. // THE SOFTWARE.
#ifndef MONGOOSE_HEADER_INCLUDED #ifndef MONGOOSE_HEADER_INCLUDED
#define MONGOOSE_HEADER_INCLUDED #define MONGOOSE_HEADER_INCLUDED
#include <stdio.h> #include <stdio.h>
#include <stddef.h> #include <stddef.h>
#ifdef __cplusplus #ifdef __cplusplus
extern "C" { extern "C" {
#endif // __cplusplus #endif // __cplusplus
struct mg_context; // Handle for the HTTP service itself struct mg_context; // Handle for the HTTP service itself
struct mg_connection; // Handle for the individual connection struct mg_connection; // Handle for the individual connection
// This structure contains information about the HTTP request. // This structure contains information about the HTTP request.
struct mg_request_info { struct mg_request_info {
const char *request_method; // "GET", "POST", etc const char *request_method; // "GET", "POST", etc
const char *uri; // URL-decoded URI const char *uri; // URL-decoded URI
const char *http_version; // E.g. "1.0", "1.1" const char *http_version; // E.g. "1.0", "1.1"
const char *query_string; // URL part after '?', not including '?', or NULL const char *query_string; // URL part after '?', not including '?', or NULL
const char *remote_user; // Authenticated user, or NULL if no auth used const char *remote_user; // Authenticated user, or NULL if no auth used
long remote_ip; // Client's IP address long remote_ip; // Client's IP address
int remote_port; // Client's port int remote_port; // Client's port
int is_ssl; // 1 if SSL-ed, 0 if not int is_ssl; // 1 if SSL-ed, 0 if not
void *user_data; // User data pointer passed to mg_start() void *user_data; // User data pointer passed to mg_start()
int num_headers; // Number of HTTP headers int num_headers; // Number of HTTP headers
struct mg_header { struct mg_header {
const char *name; // HTTP header name const char *name; // HTTP header name
const char *value; // HTTP header value const char *value; // HTTP header value
} http_headers[64]; // Maximum 64 headers } http_headers[64]; // Maximum 64 headers
}; };
// This structure needs to be passed to mg_start(), to let mongoose know // This structure needs to be passed to mg_start(), to let mongoose know
// which callbacks to invoke. For detailed description, see // which callbacks to invoke. For detailed description, see
// https://github.com/valenok/mongoose/blob/master/UserManual.md // https://github.com/valenok/mongoose/blob/master/UserManual.md
struct mg_callbacks { struct mg_callbacks {
int (*begin_request)(struct mg_connection *); int (*begin_request)(struct mg_connection *);
void (*end_request)(const struct mg_connection *, int reply_status_code); void (*end_request)(const struct mg_connection *, int reply_status_code);
int (*log_message)(const struct mg_connection *, const char *message); int (*log_message)(const struct mg_connection *, const char *message);
int (*init_ssl)(void *ssl_context); int (*init_ssl)(void *ssl_context);
int (*websocket_connect)(const struct mg_connection *); int (*websocket_connect)(const struct mg_connection *);
void (*websocket_ready)(struct mg_connection *); void (*websocket_ready)(struct mg_connection *);
int (*websocket_data)(struct mg_connection *); int (*websocket_data)(struct mg_connection *);
const char * (*open_file)(const struct mg_connection *, const char * (*open_file)(const struct mg_connection *,
const char *path, size_t *data_len); const char *path, size_t *data_len);
void (*init_lua)(struct mg_connection *, void *lua_context); void (*init_lua)(struct mg_connection *, void *lua_context);
void (*upload)(struct mg_connection *, const char *file_name); void (*upload)(struct mg_connection *, const char *file_name);
}; int (*http_error)(struct mg_connection *, int status);
};
// Start web server.
// // Start web server.
// Parameters: //
// callbacks: mg_callbacks structure with user-defined callbacks. // Parameters:
// options: NULL terminated list of option_name, option_value pairs that // callbacks: mg_callbacks structure with user-defined callbacks.
// specify Mongoose configuration parameters. // options: NULL terminated list of option_name, option_value pairs that
// // specify Mongoose configuration parameters.
// Side-effects: on UNIX, ignores SIGCHLD and SIGPIPE signals. If custom //
// processing is required for these, signal handlers must be set up // Side-effects: on UNIX, ignores SIGCHLD and SIGPIPE signals. If custom
// after calling mg_start(). // processing is required for these, signal handlers must be set up
// // after calling mg_start().
// //
// Example: //
// const char *options[] = { // Example:
// "document_root", "/var/www", // const char *options[] = {
// "listening_ports", "80,443s", // "document_root", "/var/www",
// NULL // "listening_ports", "80,443s",
// }; // NULL
// struct mg_context *ctx = mg_start(&my_func, NULL, options); // };
// // struct mg_context *ctx = mg_start(&my_func, NULL, options);
// Please refer to http://code.google.com/p/mongoose/wiki/MongooseManual //
// for the list of valid option and their possible values. // Please refer to http://code.google.com/p/mongoose/wiki/MongooseManual
// // for the list of valid option and their possible values.
// Return: //
// web server context, or NULL on error. // Return:
struct mg_context *mg_start(const struct mg_callbacks *callbacks, // web server context, or NULL on error.
void *user_data, struct mg_context *mg_start(const struct mg_callbacks *callbacks,
const char **configuration_options); void *user_data,
const char **configuration_options);
// Stop the web server.
// // Stop the web server.
// Must be called last, when an application wants to stop the web server and //
// release all associated resources. This function blocks until all Mongoose // Must be called last, when an application wants to stop the web server and
// threads are stopped. Context pointer becomes invalid. // release all associated resources. This function blocks until all Mongoose
void mg_stop(struct mg_context *); // threads are stopped. Context pointer becomes invalid.
void mg_stop(struct mg_context *);
// Get the value of particular configuration parameter.
// The value returned is read-only. Mongoose does not allow changing // Get the value of particular configuration parameter.
// configuration at run time. // The value returned is read-only. Mongoose does not allow changing
// If given parameter name is not valid, NULL is returned. For valid // configuration at run time.
// names, return value is guaranteed to be non-NULL. If parameter is not // If given parameter name is not valid, NULL is returned. For valid
// set, zero-length string is returned. // names, return value is guaranteed to be non-NULL. If parameter is not
const char *mg_get_option(const struct mg_context *ctx, const char *name); // set, zero-length string is returned.
const char *mg_get_option(const struct mg_context *ctx, const char *name);
// Return array of strings that represent valid configuration options.
// For each option, a short name, long name, and default value is returned. // Return array of strings that represent valid configuration options.
// Array is NULL terminated. // For each option, a short name, long name, and default value is returned.
const char **mg_get_valid_option_names(void); // Array is NULL terminated.
const char **mg_get_valid_option_names(void);
// Add, edit or delete the entry in the passwords file.
// // 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 // This function allows an application to manipulate .htpasswd files on the
// several ways of implementing authentication on the server side. For another, // fly by adding, deleting and changing user records. This is one of the
// cookie-based way please refer to the examples/chat.c in the source tree. // 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. // If password is not NULL, entry is added (or modified if already exists).
// // If password is NULL, entry is deleted.
// Return: //
// 1 on success, 0 on error. // Return:
int mg_modify_passwords_file(const char *passwords_file_name, // 1 on success, 0 on error.
const char *domain, int mg_modify_passwords_file(const char *passwords_file_name,
const char *user, const char *domain,
const char *password); const char *user,
const char *password);
// Return information associated with the request.
struct mg_request_info *mg_get_request_info(struct mg_connection *); // Return information associated with the request.
struct mg_request_info *mg_get_request_info(struct mg_connection *);
// Send data to the client.
// Return: // Send data to the client.
// 0 when the connection has been closed // Return:
// -1 on error // 0 when the connection has been closed
// number of bytes written on success // -1 on error
int mg_write(struct mg_connection *, const void *buf, size_t len); // number of bytes written on success
int mg_write(struct mg_connection *, const void *buf, size_t len);
#undef PRINTF_FORMAT_STRING
#if _MSC_VER >= 1400 #undef PRINTF_FORMAT_STRING
#include <sal.h> #if _MSC_VER >= 1400
#if _MSC_VER > 1400 #include <sal.h>
#define PRINTF_FORMAT_STRING(s) _Printf_format_string_ s #if _MSC_VER > 1400
#else #define PRINTF_FORMAT_STRING(s) _Printf_format_string_ s
#define PRINTF_FORMAT_STRING(s) __format_string s #else
#endif #define PRINTF_FORMAT_STRING(s) __format_string s
#else #endif
#define PRINTF_FORMAT_STRING(s) s #else
#endif #define PRINTF_FORMAT_STRING(s) s
#endif
#ifdef __GNUC__
#define PRINTF_ARGS(x, y) __attribute__((format(printf, x, y))) #ifdef __GNUC__
#else #define PRINTF_ARGS(x, y) __attribute__((format(printf, x, y)))
#define PRINTF_ARGS(x, y) #else
#endif #define PRINTF_ARGS(x, y)
#endif
// Send data to the browser using printf() semantics.
// // Send data to the browser using printf() semantics.
// Works exactly like mg_write(), but allows to do message formatting. //
// Below are the macros for enabling compiler-specific checks for // Works exactly like mg_write(), but allows to do message formatting.
// printf-like arguments. // Below are the macros for enabling compiler-specific checks for
int mg_printf(struct mg_connection *, // printf-like arguments.
PRINTF_FORMAT_STRING(const char *fmt), ...) PRINTF_ARGS(2, 3); int mg_printf(struct mg_connection *,
PRINTF_FORMAT_STRING(const char *fmt), ...) PRINTF_ARGS(2, 3);
// Send contents of the entire file together with HTTP headers.
void mg_send_file(struct mg_connection *conn, const char *path); // Send contents of the entire file together with HTTP headers.
void mg_send_file(struct mg_connection *conn, const char *path);
// Read data from the remote end, return number of bytes read.
int mg_read(struct mg_connection *, void *buf, size_t len); // Read data from the remote end, return number of bytes read.
int mg_read(struct mg_connection *, void *buf, size_t len);
// Get the value of particular HTTP header.
// // 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 // This is a helper function. It traverses request_info->http_headers array,
// not present, NULL is returned. // and if the header is present in the array, returns its value. If it is
const char *mg_get_header(const struct mg_connection *, const char *name); // not present, NULL is returned.
const char *mg_get_header(const struct mg_connection *, const char *name);
// Get a value of particular form variable.
// // Get a value of particular form variable.
// Parameters: //
// data: pointer to form-uri-encoded buffer. This could be either POST data, // Parameters:
// or request_info.query_string. // data: pointer to form-uri-encoded buffer. This could be either POST data,
// data_len: length of the encoded data. // or request_info.query_string.
// var_name: variable name to decode from the buffer // data_len: length of the encoded data.
// dst: destination buffer for the decoded variable // var_name: variable name to decode from the buffer
// dst_len: length of the destination buffer // dst: destination buffer for the decoded variable
// // dst_len: length of the destination buffer
// Return: //
// On success, length of the decoded variable. // Return:
// On error: // On success, length of the decoded variable.
// -1 (variable not found). // On error:
// -2 (destination buffer is NULL, zero length or too small to hold the decoded variable). // -1 (variable not found).
// // -2 (destination buffer is NULL, zero length or too small to hold the decoded variable).
// Destination buffer is guaranteed to be '\0' - terminated if it is not //
// NULL or zero length. // Destination buffer is guaranteed to be '\0' - terminated if it is not
int mg_get_var(const char *data, size_t data_len, // NULL or zero length.
const char *var_name, char *dst, size_t dst_len); int mg_get_var(const char *data, size_t data_len,
const char *var_name, char *dst, size_t dst_len);
// Fetch value of certain cookie variable into the destination buffer.
// // Fetch value of certain cookie variable into the destination buffer.
// Destination buffer is guaranteed to be '\0' - terminated. In case of //
// failure, dst[0] == '\0'. Note that RFC allows many occurrences of the same // Destination buffer is guaranteed to be '\0' - terminated. In case of
// parameter. This function returns only first occurrence. // failure, dst[0] == '\0'. Note that RFC allows many occurrences of the same
// // parameter. This function returns only first occurrence.
// Return: //
// On success, value length. // Return:
// On error: // On success, value length.
// -1 (either "Cookie:" header is not present at all or the requested parameter is not found). // On error:
// -2 (destination buffer is NULL, zero length or too small to hold the value). // -1 (either "Cookie:" header is not present at all or the requested parameter is not found).
int mg_get_cookie(const struct mg_connection *, // -2 (destination buffer is NULL, zero length or too small to hold the value).
const char *cookie_name, char *buf, size_t buf_len); int mg_get_cookie(const struct mg_connection *,
const char *cookie_name, char *buf, size_t buf_len);
// Download data from the remote web server.
// host: host name to connect to, e.g. "foo.com", or "10.12.40.1". // Download data from the remote web server.
// port: port number, e.g. 80. // host: host name to connect to, e.g. "foo.com", or "10.12.40.1".
// use_ssl: wether to use SSL connection. // port: port number, e.g. 80.
// error_buffer, error_buffer_size: error message placeholder. // use_ssl: wether to use SSL connection.
// request_fmt,...: HTTP request. // error_buffer, error_buffer_size: error message placeholder.
// Return: // request_fmt,...: HTTP request.
// On success, valid pointer to the new connection, suitable for mg_read(). // Return:
// On error, NULL. error_buffer contains error message. // On success, valid pointer to the new connection, suitable for mg_read().
// Example: // On error, NULL. error_buffer contains error message.
// char ebuf[100]; // Example:
// struct mg_connection *conn; // char ebuf[100];
// conn = mg_download("google.com", 80, 0, ebuf, sizeof(ebuf), // struct mg_connection *conn;
// "%s", "GET / HTTP/1.0\r\nHost: google.com\r\n\r\n"); // conn = mg_download("google.com", 80, 0, ebuf, sizeof(ebuf),
struct mg_connection *mg_download(const char *host, int port, int use_ssl, // "%s", "GET / HTTP/1.0\r\nHost: google.com\r\n\r\n");
char *error_buffer, size_t error_buffer_size, struct mg_connection *mg_download(const char *host, int port, int use_ssl,
PRINTF_FORMAT_STRING(const char *request_fmt), char *error_buffer, size_t error_buffer_size,
...) PRINTF_ARGS(6, 7); PRINTF_FORMAT_STRING(const char *request_fmt),
...) PRINTF_ARGS(6, 7);
// Close the connection opened by mg_download().
void mg_close_connection(struct mg_connection *conn); // Close the connection opened by mg_download().
void mg_close_connection(struct mg_connection *conn);
// File upload functionality. Each uploaded file gets saved into a temporary
// file and MG_UPLOAD event is sent. // File upload functionality. Each uploaded file gets saved into a temporary
// Return number of uploaded files. // file and MG_UPLOAD event is sent.
int mg_upload(struct mg_connection *conn, const char *destination_dir); // Return number of uploaded files.
int mg_upload(struct mg_connection *conn, const char *destination_dir);
// Convenience function -- create detached thread.
// Return: 0 on success, non-0 on error. // Convenience function -- create detached thread.
typedef void * (*mg_thread_func_t)(void *); // Return: 0 on success, non-0 on error.
int mg_start_thread(mg_thread_func_t f, void *p); typedef void * (*mg_thread_func_t)(void *);
int mg_start_thread(mg_thread_func_t f, void *p);
// Return builtin mime type for the given file name.
// For unrecognized extensions, "text/plain" is returned. // Return builtin mime type for the given file name.
const char *mg_get_builtin_mime_type(const char *file_name); // For unrecognized extensions, "text/plain" is returned.
const char *mg_get_builtin_mime_type(const char *file_name);
// Return Mongoose version.
const char *mg_version(void); // Return Mongoose version.
const char *mg_version(void);
// MD5 hash given strings.
// Buffer 'buf' must be 33 bytes long. Varargs is a NULL terminated list of // MD5 hash given strings.
// ASCIIz strings. When function returns, buf will contain human-readable // Buffer 'buf' must be 33 bytes long. Varargs is a NULL terminated list of
// MD5 hash. Example: // ASCIIz strings. When function returns, buf will contain human-readable
// char buf[33]; // MD5 hash. Example:
// mg_md5(buf, "aa", "bb", NULL); // char buf[33];
void mg_md5(char buf[33], ...); // mg_md5(buf, "aa", "bb", NULL);
void mg_md5(char buf[33], ...);
#ifdef __cplusplus
} #ifdef __cplusplus
#endif // __cplusplus }
#endif // __cplusplus
#endif // MONGOOSE_HEADER_INCLUDED
#endif // MONGOOSE_HEADER_INCLUDED
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment