/** @file nanohttp-admin.c Administrator application */ /****************************************************************** * $Id: nanohttp-admin.c,v 1.13 2007/11/03 22:40:10 m0gg Exp $ * * CSOAP Project: A SOAP client/server library in C * Copyright (C) 2003 Ferhat Ayaz * * This library is free software; you can redistribute it and/or * modify it under the terms of the GNU Library General Public * License as published by the Free Software Foundation; either * version 2 of the License, or (at your option) any later version. * * This library 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 * Library General Public License for more details. * * You should have received a copy of the GNU Library General Public * License along with this library; if not, write to the * Free Software Foundation, Inc., 59 Temple Place - Suite 330, * Boston, MA 02111-1307, USA. * * Email: ayaz@jprogrammer.net ******************************************************************/ #ifdef HAVE_CONFIG_H #include #endif #ifdef HAVE_SYS_TIME_H #include #endif #ifdef HAVE_STDIO_H #include #endif #ifdef HAVE_STRING_H #include #endif #ifdef HAVE_PTHREAD_H #include #endif #include "nanohttp-error.h" #include "nanohttp-logging.h" #include "nanohttp-common.h" #include "nanohttp-stream.h" #include "nanohttp-request.h" #include "nanohttp-server.h" #include "nanohttp-admin.h" static void _httpd_admin_send_title(httpd_conn_t *conn, const char *title) { httpd_send_header(conn, 200, HTTP_STATUS_200_REASON_PHRASE); http_output_stream_write_string(conn->out, "" ""); http_output_stream_write_string(conn->out, ""); http_output_stream_write_string(conn->out, "" "" "nhttpd "); http_output_stream_write_string(conn->out, title); http_output_stream_write_string(conn->out, "

"); } static inline void _httpd_admin_send_footer(httpd_conn_t *conn) { http_output_stream_write_string(conn->out, "

" "Admin page " "cSOAP Home" "" ""); } static void _httpd_admin_list_services(httpd_conn_t *conn) { char buffer[1024]; hservice_t *node; _httpd_admin_send_title(conn, "Available services"); http_output_stream_write_string(conn->out, "

" "%s " "[Activate] " "[Statistics]" "
" "%s " "[Passivate] " "[Statistics] " "

"); _httpd_admin_send_footer(conn); } static void _httpd_admin_list_statistics(httpd_conn_t *conn, const char *service_name) { char buffer[1024]; hservice_t *service; log_verbose("Client requested statistics for \"%s\"", service_name); sprintf(buffer, "Listing statistics for service %s", service_name); _httpd_admin_send_title(conn, buffer); if (!service_name || !(service = httpd_find_service(service_name))) { http_output_stream_write_string(conn->out, "

" "Service not found!" "

"); _httpd_admin_send_footer(conn); return; } pthread_rwlock_rdlock(&(service->statistics->lock)); sprintf(buffer, "

Requests served: %lu
Bytes read: %lu
Bytes sent: %lu
Time used: %li.%li sec

", service->statistics->requests, service->statistics->bytes_received, service->statistics->bytes_transmitted, service->statistics->time.tv_sec, service->statistics->time.tv_usec); pthread_rwlock_unlock(&(service->statistics->lock)); http_output_stream_write_string(conn->out, buffer); _httpd_admin_send_footer(conn); } static void _httpd_admin_enable_service(httpd_conn_t *conn, const char *service_name) { hservice_t *service; char buffer[1024]; sprintf(buffer, "Activating service %s", service_name); _httpd_admin_send_title(conn, buffer); if (!(service = httpd_find_service(service_name))) { http_output_stream_write_string(conn->out, "

" "Service not found!" "

"); _httpd_admin_send_footer(conn); return; } httpd_enable_service(service); http_output_stream_write_string(conn->out, "

" "Service is up" "

"); _httpd_admin_send_footer(conn); } static void _httpd_admin_disable_service(httpd_conn_t *conn, const char *service_name) { hservice_t *service; char buffer[1024]; sprintf(buffer, "Passivating service %s", service_name); _httpd_admin_send_title(conn, buffer); if (!(service = httpd_find_service(service_name))) { http_output_stream_write_string(conn->out, "

" "Service not found!" "

"); _httpd_admin_send_footer(conn); return; } httpd_disable_service(service); http_output_stream_write_string(conn->out, "

" "Service is down" "

"); _httpd_admin_send_footer(conn); } static void _httpd_admin_set_loglevel(httpd_conn_t *conn, const char *loglevel) { nanohttp_loglevel_t old; char buffer[256]; char *tmp; if (strcmp(loglevel, NANOHTTP_LOG_LEVEL_OFF_STRING) == 0) { old = nanohttp_log_set_loglevel(NANOHTTP_LOG_OFF); } else if (strcmp(loglevel, NANOHTTP_LOG_LEVEL_VERBOSE_STRING) == 0) { old = nanohttp_log_set_loglevel(NANOHTTP_LOG_VERBOSE); } else if (strcmp(loglevel, NANOHTTP_LOG_LEVEL_DEBUG_STRING) == 0) { old = nanohttp_log_set_loglevel(NANOHTTP_LOG_DEBUG); } else if (strcmp(loglevel, NANOHTTP_LOG_LEVEL_INFO_STRING) == 0) { old = nanohttp_log_set_loglevel(NANOHTTP_LOG_INFO); } else if (strcmp(loglevel, NANOHTTP_LOG_LEVEL_WARN_STRING) == 0) { old = nanohttp_log_set_loglevel(NANOHTTP_LOG_WARN); } else if (strcmp(loglevel, NANOHTTP_LOG_LEVEL_ERROR_STRING) == 0) { old = nanohttp_log_set_loglevel(NANOHTTP_LOG_ERROR); } else if (strcmp(loglevel, NANOHTTP_LOG_LEVEL_FATAL_STRING) == 0) { old = nanohttp_log_set_loglevel(NANOHTTP_LOG_FATAL); } else { old = nanohttp_log_get_loglevel(); loglevel = NANOHTTP_LOG_LEVEL_UNKNOWN_STRING; log_error("unknown loglevel requested"); } switch (old) { case NANOHTTP_LOG_OFF: tmp = NANOHTTP_LOG_LEVEL_OFF_STRING; break; case NANOHTTP_LOG_VERBOSE: tmp = NANOHTTP_LOG_LEVEL_VERBOSE_STRING; break; case NANOHTTP_LOG_DEBUG: tmp = NANOHTTP_LOG_LEVEL_DEBUG_STRING; break; case NANOHTTP_LOG_INFO: tmp = NANOHTTP_LOG_LEVEL_INFO_STRING; break; case NANOHTTP_LOG_WARN: tmp = NANOHTTP_LOG_LEVEL_WARN_STRING; break; case NANOHTTP_LOG_ERROR: tmp = NANOHTTP_LOG_LEVEL_ERROR_STRING; break; case NANOHTTP_LOG_FATAL: tmp = NANOHTTP_LOG_LEVEL_FATAL_STRING; break; default: tmp = NANOHTTP_LOG_LEVEL_UNKNOWN_STRING; break; } _httpd_admin_send_title(conn, "Adjusting loglevel"); sprintf(buffer, "

Switching from %s to %s

", tmp, loglevel); http_output_stream_write_string(conn->out, buffer); _httpd_admin_send_footer(conn); } static void _httpd_admin_handle_get(httpd_conn_t * conn, struct hrequest_t *req) { char *param; if ((param = hpairnode_get_ignore_case(req->query, NHTTPD_ADMIN_QUERY_SERVICES))) { _httpd_admin_list_services(conn); } else if ((param = hpairnode_get_ignore_case(req->query, NHTTPD_ADMIN_QUERY_STATISTICS))) { _httpd_admin_list_statistics(conn, param); } else if ((param = hpairnode_get_ignore_case(req->query, NHTTPD_ADMIN_QUERY_ACTIVATE_SERVICE))) { _httpd_admin_enable_service(conn, param); } else if ((param = hpairnode_get_ignore_case(req->query, NHTTPD_ADMIN_QUERY_PASSIVATE_SERVICE))) { _httpd_admin_disable_service(conn, param); } else if ((param = hpairnode_get_ignore_case(req->query, NHTTPD_ADMIN_QUERY_SET_LOGLEVEL))) { _httpd_admin_set_loglevel(conn, param); } else { _httpd_admin_send_title(conn, "Welcome to the admin page"); http_output_stream_write_string(conn->out, "

" "Services" "
" "Statistics" "
Set loglevel: " "OFF " "VERBOSE " "DEBUG " "INFO " "WARN " "ERROR " "FATAL " "

"); _httpd_admin_send_footer(conn); } } static void _httpd_admin_entry(httpd_conn_t * conn, struct hrequest_t *req) { if (req->method == HTTP_REQUEST_GET) { _httpd_admin_handle_get(conn, req); } else { httpd_send_header(conn, 501, HTTP_STATUS_501_REASON_PHRASE); http_output_stream_write_string(conn->out, "" "" "" "" "

Sorry!

" "

Only GET method is implemented now. Use your browser.

" "" ""); } } herror_t httpd_admin_init_args(int argc, char **argv) { int i; for (i=0; i