summaryrefslogtreecommitdiffstats
path: root/polyp/protocol-http.c
diff options
context:
space:
mode:
Diffstat (limited to 'polyp/protocol-http.c')
-rw-r--r--polyp/protocol-http.c265
1 files changed, 0 insertions, 265 deletions
diff --git a/polyp/protocol-http.c b/polyp/protocol-http.c
deleted file mode 100644
index 3e55df03..00000000
--- a/polyp/protocol-http.c
+++ /dev/null
@@ -1,265 +0,0 @@
-/* $Id$ */
-
-/***
- This file is part of polypaudio.
-
- polypaudio is free software; you can redistribute it and/or modify
- it under the terms of the GNU Lesser General Public License as published
- by the Free Software Foundation; either version 2 of the License,
- or (at your option) any later version.
-
- polypaudio 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 Lesser General Public License
- along with polypaudio; if not, write to the Free Software
- Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307
- USA.
-***/
-
-#ifdef HAVE_CONFIG_H
-#include <config.h>
-#endif
-
-#include <assert.h>
-#include <stdlib.h>
-#include <stdio.h>
-#include <string.h>
-
-#include "protocol-http.h"
-#include "ioline.h"
-#include "xmalloc.h"
-#include "log.h"
-#include "namereg.h"
-#include "cli-text.h"
-
-/* Don't allow more than this many concurrent connections */
-#define MAX_CONNECTIONS 10
-
-#define internal_server_error(c) http_message((c), 500, "Internal Server Error", NULL)
-
-#define URL_ROOT "/"
-#define URL_CSS "/style"
-#define URL_STATUS "/status"
-
-struct connection {
- pa_protocol_http *protocol;
- pa_ioline *line;
- enum { REQUEST_LINE, MIME_HEADER, DATA } state;
- char *url;
-};
-
-struct pa_protocol_http {
- pa_module *module;
- pa_core *core;
- pa_socket_server*server;
- pa_idxset *connections;
-};
-
-static void http_response(struct connection *c, int code, const char *msg, const char *mime) {
- char s[256];
- assert(c);
- assert(msg);
- assert(mime);
-
- snprintf(s, sizeof(s),
- "HTTP/1.0 %i %s\n"
- "Connection: close\n"
- "Content-Type: %s\n"
- "Cache-Control: no-cache\n"
- "Expires: 0\n"
- "Server: "PACKAGE_NAME"/"PACKAGE_VERSION"\n"
- "\n", code, msg, mime);
-
- pa_ioline_puts(c->line, s);
-}
-
-static void http_message(struct connection *c, int code, const char *msg, const char *text) {
- char s[256];
- assert(c);
-
- http_response(c, code, msg, "text/html");
-
- if (!text)
- text = msg;
-
- snprintf(s, sizeof(s),
- "<?xml version=\"1.0\"?>\n"
- "<!DOCTYPE html PUBLIC \"-//W3C//DTD XHTML 1.0 Strict//EN\" \"http://www.w3.org/TR/xhtml1/DTD/xhtml1-strict.dtd\">\n"
- "<html xmlns=\"http://www.w3.org/1999/xhtml\"><head><title>%s</title></head>\n"
- "<body>%s</body></html>\n",
- text, text);
-
- pa_ioline_puts(c->line, s);
- pa_ioline_defer_close(c->line);
-}
-
-
-static void connection_free(struct connection *c, int del) {
- assert(c);
-
- if (c->url)
- pa_xfree(c->url);
-
- if (del)
- pa_idxset_remove_by_data(c->protocol->connections, c, NULL);
- pa_ioline_unref(c->line);
- pa_xfree(c);
-}
-
-static void line_callback(pa_ioline *line, const char *s, void *userdata) {
- struct connection *c = userdata;
- assert(line);
- assert(c);
-
- if (!s) {
- /* EOF */
- connection_free(c, 1);
- return;
- }
-
- switch (c->state) {
- case REQUEST_LINE: {
- if (memcmp(s, "GET ", 4))
- goto fail;
-
- s +=4;
-
- c->url = pa_xstrndup(s, strcspn(s, " \r\n\t?"));
- c->state = MIME_HEADER;
- break;
-
- }
-
- case MIME_HEADER: {
-
- /* Ignore MIME headers */
- if (strcspn(s, " \r\n") != 0)
- break;
-
- /* We're done */
- c->state = DATA;
-
- pa_log_info(__FILE__": request for %s\n", c->url);
-
- if (!strcmp(c->url, URL_ROOT)) {
- char txt[256];
- http_response(c, 200, "OK", "text/html");
-
- pa_ioline_puts(c->line,
- "<?xml version=\"1.0\"?>\n"
- "<!DOCTYPE html PUBLIC \"-//W3C//DTD XHTML 1.0 Strict//EN\" \"http://www.w3.org/TR/xhtml1/DTD/xhtml1-strict.dtd\">\n"
- "<html xmlns=\"http://www.w3.org/1999/xhtml\"><title>"PACKAGE_NAME" "PACKAGE_VERSION"</title>\n"
- "<link rel=\"stylesheet\" type=\"text/css\" href=\"style\"/></head><body>\n");
-
- pa_ioline_puts(c->line,
- "<h1>"PACKAGE_NAME" "PACKAGE_VERSION"</h1>\n"
- "<table>");
-
-#define PRINTF_FIELD(a,b) pa_ioline_printf(c->line, "<tr><td><b>%s</b></td><td>%s</td></tr>\n",(a),(b))
-
- PRINTF_FIELD("User Name:", pa_get_user_name(txt, sizeof(txt)));
- PRINTF_FIELD("Fully Qualified Domain Name:", pa_get_fqdn(txt, sizeof(txt)));
- PRINTF_FIELD("Default Sample Specification:", pa_sample_spec_snprint(txt, sizeof(txt), &c->protocol->core->default_sample_spec));
- PRINTF_FIELD("Default Sink:", pa_namereg_get_default_sink_name(c->protocol->core));
- PRINTF_FIELD("Default Source:", pa_namereg_get_default_source_name(c->protocol->core));
-
- pa_ioline_puts(c->line, "</table>");
-
- pa_ioline_puts(c->line, "<p><a href=\"/status\">Click here</a> for an extensive server status report.</p>");
-
- pa_ioline_puts(c->line, "</body></html>\n");
-
- pa_ioline_defer_close(c->line);
- } else if (!strcmp(c->url, URL_CSS)) {
- http_response(c, 200, "OK", "text/css");
-
- pa_ioline_puts(c->line,
- "body { color: black; background-color: white; margin: 0.5cm; }\n"
- "a:link, a:visited { color: #900000; }\n"
- "p { margin-left: 0.5cm; margin-right: 0.5cm; }\n"
- "h1 { color: #00009F; }\n"
- "h2 { color: #00009F; }\n"
- "ul { margin-left: .5cm; }\n"
- "ol { margin-left: .5cm; }\n"
- "pre { margin-left: .5cm; background-color: #f0f0f0; padding: 0.4cm;}\n"
- ".grey { color: #afafaf; }\n"
- "table { margin-left: 1cm; border:1px solid lightgrey; padding: 0.2cm; }\n"
- "td { padding-left:10px; padding-right:10px; }\n");
-
- pa_ioline_defer_close(c->line);
- } else if (!strcmp(c->url, URL_STATUS)) {
- char *r;
-
- http_response(c, 200, "OK", "text/plain");
- r = pa_full_status_string(c->protocol->core);
- pa_ioline_puts(c->line, r);
- pa_xfree(r);
-
- pa_ioline_defer_close(c->line);
- } else
- http_message(c, 404, "Not Found", NULL);
-
- break;
- }
-
- default:
- ;
- }
-
- return;
-
-fail:
- internal_server_error(c);
-}
-
-static void on_connection(pa_socket_server*s, pa_iochannel *io, void *userdata) {
- pa_protocol_http *p = userdata;
- struct connection *c;
- assert(s && io && p);
-
- if (pa_idxset_size(p->connections)+1 > MAX_CONNECTIONS) {
- pa_log_warn(__FILE__": Warning! Too many connections (%u), dropping incoming connection.\n", MAX_CONNECTIONS);
- pa_iochannel_free(io);
- return;
- }
-
- c = pa_xmalloc(sizeof(struct connection));
- c->protocol = p;
- c->line = pa_ioline_new(io);
- c->state = REQUEST_LINE;
- c->url = NULL;
-
- pa_ioline_set_callback(c->line, line_callback, c);
- pa_idxset_put(p->connections, c, NULL);
-}
-
-pa_protocol_http* pa_protocol_http_new(pa_core *core, pa_socket_server *server, pa_module *m, PA_GCC_UNUSED pa_modargs *ma) {
- pa_protocol_http* p;
- assert(core && server);
-
- p = pa_xmalloc(sizeof(pa_protocol_http));
- p->module = m;
- p->core = core;
- p->server = server;
- p->connections = pa_idxset_new(NULL, NULL);
-
- pa_socket_server_set_callback(p->server, on_connection, p);
-
- return p;
-}
-
-static void free_connection(void *p, PA_GCC_UNUSED void *userdata) {
- assert(p);
- connection_free(p, 0);
-}
-
-void pa_protocol_http_free(pa_protocol_http *p) {
- assert(p);
-
- pa_idxset_free(p->connections, free_connection, NULL);
- pa_socket_server_unref(p->server);
- pa_xfree(p);
-}
generated by cgit (git 2.34.1) at 2024-05-05 09:00:45 +0000