examples: move examples from tests/ to examples/

get, simple-httpd, and simple-proxy are more example code than test
programs, so move them into a separate directory.

Also, remove "dns", which was once a sort-of test of SoupAddress, but
is now just a redundant sort-of test of GResolver.

4 files changed, 683 insertions, 0 deletions

diff --git a/examples/Makefile.am b/examples/Makefile.am
new file mode 100644
index 00000000..69e5b550
--- /dev/null
+++ b/examples/Makefile.am
@@ -0,0 +1,14 @@
+INCLUDES =		\
+	-I$(top_srcdir)	\
+	-DSRCDIR=\""$(abs_srcdir)"\" \
+	-DBUILDDIR=\""$(builddir)"\" \
+	$(GLIB_CFLAGS)
+
+LIBS =			\
+	$(top_builddir)/libsoup/libsoup-2.4.la \
+	$(GLIB_LIBS)
+
+noinst_PROGRAMS =		\
+	get			\
+	simple-httpd		\
+	simple-proxy
diff --git a/examples/get.c b/examples/get.c
new file mode 100644
index 00000000..f28e5357
--- /dev/null
+++ b/examples/get.c
@@ -0,0 +1,193 @@
+/* -*- Mode: C; tab-width: 8; indent-tabs-mode: t; c-basic-offset: 8 -*- */
+/*
+ * Copyright (C) 2001-2003, Ximian, Inc.
+ */
+
+#include <stdio.h>
+#include <stdlib.h>
+
+#ifdef G_OS_WIN32
+#include <getopt.h>
+#endif
+
+#include <libsoup/soup.h>
+
+static SoupSession *session;
+static GMainLoop *loop;
+static gboolean debug = FALSE, quiet = FALSE;
+static const char *method;
+
+static void
+get_url (const char *url)
+{
+	const char *name;
+	SoupMessage *msg;
+	const char *header;
+
+	msg = soup_message_new (method, url);
+	soup_message_set_flags (msg, SOUP_MESSAGE_NO_REDIRECT);
+
+	soup_session_send_message (session, msg);
+
+	name = soup_message_get_uri (msg)->path;
+
+	if (debug) {
+		SoupMessageHeadersIter iter;
+		const char *hname, *value;
+		char *path = soup_uri_to_string (soup_message_get_uri (msg), TRUE);
+
+		g_print ("%s %s HTTP/1.%d\n", method, path,
+			 soup_message_get_http_version (msg));
+		soup_message_headers_iter_init (&iter, msg->request_headers);
+		while (soup_message_headers_iter_next (&iter, &hname, &value))
+			g_print ("%s: %s\r\n", hname, value);
+		g_print ("\n");
+
+		g_print ("HTTP/1.%d %d %s\n",
+			 soup_message_get_http_version (msg),
+			 msg->status_code, msg->reason_phrase);
+
+		soup_message_headers_iter_init (&iter, msg->response_headers);
+		while (soup_message_headers_iter_next (&iter, &hname, &value))
+			g_print ("%s: %s\r\n", hname, value);
+		g_print ("\n");
+	} else if (msg->status_code == SOUP_STATUS_SSL_FAILED) {
+		GTlsCertificateFlags flags;
+
+		if (soup_message_get_https_status (msg, NULL, &flags))
+			g_print ("%s: %d %s (0x%x)\n", name, msg->status_code, msg->reason_phrase, flags);
+		else
+			g_print ("%s: %d %s (no handshake status)\n", name, msg->status_code, msg->reason_phrase);
+	} else if (!quiet || SOUP_STATUS_IS_TRANSPORT_ERROR (msg->status_code))
+		g_print ("%s: %d %s\n", name, msg->status_code, msg->reason_phrase);
+
+	if (SOUP_STATUS_IS_REDIRECTION (msg->status_code)) {
+		header = soup_message_headers_get_one (msg->response_headers,
+						       "Location");
+		if (header) {
+			SoupURI *uri;
+			char *uri_string;
+
+			if (!debug && !quiet)
+				g_print ("  -> %s\n", header);
+
+			uri = soup_uri_new_with_base (soup_message_get_uri (msg), header);
+			uri_string = soup_uri_to_string (uri, FALSE);
+			get_url (uri_string);
+			g_free (uri_string);
+			soup_uri_free (uri);
+		}
+	} else if (SOUP_STATUS_IS_SUCCESSFUL (msg->status_code)) {
+		fwrite (msg->response_body->data, 1,
+			msg->response_body->length, stdout);
+	}
+}
+
+static void
+usage (void)
+{
+	g_printerr ("Usage: get [-c CAfile] [-p proxy URL] [-h] [-d] URL\n");
+	exit (1);
+}
+
+int
+main (int argc, char **argv)
+{
+	const char *cafile = NULL, *url;
+	SoupURI *proxy = NULL, *parsed;
+	gboolean synchronous = FALSE, ntlm = FALSE;
+	int opt;
+
+	method = SOUP_METHOD_GET;
+
+	while ((opt = getopt (argc, argv, "c:dhnp:qs")) != -1) {
+		switch (opt) {
+		case 'c':
+			cafile = optarg;
+			break;
+
+		case 'd':
+			debug = TRUE;
+			break;
+
+		case 'h':
+			method = SOUP_METHOD_HEAD;
+			debug = TRUE;
+			break;
+
+		case 'n':
+			ntlm = TRUE;
+			break;
+
+		case 'p':
+			proxy = soup_uri_new (optarg);
+			if (!proxy) {
+				g_printerr ("Could not parse %s as URI\n",
+					    optarg);
+				exit (1);
+			}
+			break;
+
+		case 'q':
+			quiet = TRUE;
+			break;
+
+		case 's':
+			synchronous = TRUE;
+			break;
+
+		case '?':
+			usage ();
+			break;
+		}
+	}
+	argc -= optind;
+	argv += optind;
+
+	if (argc != 1)
+		usage ();
+	url = argv[0];
+	parsed = soup_uri_new (url);
+	if (!parsed) {
+		g_printerr ("Could not parse '%s' as a URL\n", url);
+		exit (1);
+	}
+	soup_uri_free (parsed);
+
+	if (synchronous) {
+		session = soup_session_sync_new_with_options (
+			SOUP_SESSION_SSL_CA_FILE, cafile,
+			SOUP_SESSION_ADD_FEATURE_BY_TYPE, SOUP_TYPE_CONTENT_DECODER,
+			SOUP_SESSION_ADD_FEATURE_BY_TYPE, SOUP_TYPE_COOKIE_JAR,
+			SOUP_SESSION_USER_AGENT, "get ",
+			SOUP_SESSION_ACCEPT_LANGUAGE_AUTO, TRUE,
+			SOUP_SESSION_USE_NTLM, ntlm,
+			NULL);
+	} else {
+		session = soup_session_async_new_with_options (
+			SOUP_SESSION_SSL_CA_FILE, cafile,
+			SOUP_SESSION_ADD_FEATURE_BY_TYPE, SOUP_TYPE_CONTENT_DECODER,
+			SOUP_SESSION_ADD_FEATURE_BY_TYPE, SOUP_TYPE_COOKIE_JAR,
+			SOUP_SESSION_USER_AGENT, "get ",
+			SOUP_SESSION_ACCEPT_LANGUAGE_AUTO, TRUE,
+			SOUP_SESSION_USE_NTLM, ntlm,
+			NULL);
+	}
+
+	if (proxy) {
+		g_object_set (G_OBJECT (session), 
+			      SOUP_SESSION_PROXY_URI, proxy,
+			      NULL);
+	} else
+		soup_session_add_feature_by_type (session, SOUP_TYPE_PROXY_RESOLVER_DEFAULT);
+
+	if (!synchronous)
+		loop = g_main_loop_new (NULL, TRUE);
+
+	get_url (url);
+
+	if (!synchronous)
+		g_main_loop_unref (loop);
+
+	return 0;
+}
diff --git a/examples/simple-httpd.c b/examples/simple-httpd.c
new file mode 100644
index 00000000..3d05c2a1
--- /dev/null
+++ b/examples/simple-httpd.c
@@ -0,0 +1,291 @@
+/* -*- Mode: C; tab-width: 8; indent-tabs-mode: t; c-basic-offset: 8 -*- */
+/*
+ * Copyright (C) 2001-2003, Ximian, Inc.
+ */
+
+#include <dirent.h>
+#include <errno.h>
+#include <fcntl.h>
+#include <stdio.h>
+#include <stdlib.h>
+#include <string.h>
+#include <sys/stat.h>
+
+#ifdef G_OS_WIN32
+#include <getopt.h>
+#endif
+
+#include <libsoup/soup.h>
+
+static int
+compare_strings (gconstpointer a, gconstpointer b)
+{
+	const char **sa = (const char **)a;
+	const char **sb = (const char **)b;
+
+	return strcmp (*sa, *sb);
+}
+
+static GString *
+get_directory_listing (const char *path)
+{
+	GPtrArray *entries;
+	GString *listing;
+	char *escaped;
+	DIR *dir;
+	struct dirent *dent;
+	int i;
+
+	entries = g_ptr_array_new ();
+	dir = opendir (path);
+	if (dir) {
+		while ((dent = readdir (dir))) {
+			if (!strcmp (dent->d_name, ".") ||
+			    (!strcmp (dent->d_name, "..") &&
+			     !strcmp (path, "./")))
+				continue;
+			escaped = g_markup_escape_text (dent->d_name, -1);
+			g_ptr_array_add (entries, escaped);
+		}
+		closedir (dir);
+	}
+
+	g_ptr_array_sort (entries, (GCompareFunc)compare_strings);
+
+	listing = g_string_new ("<html>\r\n");
+	escaped = g_markup_escape_text (strchr (path, '/'), -1);
+	g_string_append_printf (listing, "<head><title>Index of %s</title></head>\r\n", escaped);
+	g_string_append_printf (listing, "<body><h1>Index of %s</h1>\r\n<p>\r\n", escaped);
+	g_free (escaped);
+	for (i = 0; i < entries->len; i++) {
+		g_string_append_printf (listing, "<a href=\"%s\">%s</a><br>\r\n",
+					(char *)entries->pdata[i], 
+					(char *)entries->pdata[i]);
+		g_free (entries->pdata[i]);
+	}
+	g_string_append (listing, "</body>\r\n</html>\r\n");
+
+	g_ptr_array_free (entries, TRUE);
+	return listing;
+}
+
+static void
+do_get (SoupServer *server, SoupMessage *msg, const char *path)
+{
+	char *slash;
+	struct stat st;
+
+	if (stat (path, &st) == -1) {
+		if (errno == EPERM)
+			soup_message_set_status (msg, SOUP_STATUS_FORBIDDEN);
+		else if (errno == ENOENT)
+			soup_message_set_status (msg, SOUP_STATUS_NOT_FOUND);
+		else
+			soup_message_set_status (msg, SOUP_STATUS_INTERNAL_SERVER_ERROR);
+		return;
+	}
+
+	if (S_ISDIR (st.st_mode)) {
+		GString *listing;
+		char *index_path;
+
+		slash = strrchr (path, '/');
+		if (!slash || slash[1]) {
+			char *redir_uri;
+
+			redir_uri = g_strdup_printf ("%s/", soup_message_get_uri (msg)->path);
+			soup_message_set_redirect (msg, SOUP_STATUS_MOVED_PERMANENTLY,
+						   redir_uri);
+			g_free (redir_uri);
+			return;
+		}
+
+		index_path = g_strdup_printf ("%s/index.html", path);
+		if (stat (index_path, &st) != -1) {
+			do_get (server, msg, index_path);
+			g_free (index_path);
+			return;
+		}
+		g_free (index_path);
+
+		listing = get_directory_listing (path);
+		soup_message_set_response (msg, "text/html",
+					   SOUP_MEMORY_TAKE,
+					   listing->str, listing->len);
+		g_string_free (listing, FALSE);
+		return;
+	}
+
+	if (msg->method == SOUP_METHOD_GET) {
+		GMappedFile *mapping;
+		SoupBuffer *buffer;
+
+		mapping = g_mapped_file_new (path, FALSE, NULL);
+		if (!mapping) {
+			soup_message_set_status (msg, SOUP_STATUS_INTERNAL_SERVER_ERROR);
+			return;
+		}
+
+		buffer = soup_buffer_new_with_owner (g_mapped_file_get_contents (mapping),
+						     g_mapped_file_get_length (mapping),
+						     mapping, (GDestroyNotify)g_mapped_file_unref);
+		soup_message_body_append_buffer (msg->response_body, buffer);
+		soup_buffer_free (buffer);
+	} else /* msg->method == SOUP_METHOD_HEAD */ {
+		char *length;
+
+		/* We could just use the same code for both GET and
+		 * HEAD (soup-message-server-io.c will fix things up).
+		 * But we'll optimize and avoid the extra I/O.
+		 */
+		length = g_strdup_printf ("%lu", (gulong)st.st_size);
+		soup_message_headers_append (msg->response_headers,
+					     "Content-Length", length);
+		g_free (length);
+	}
+
+	soup_message_set_status (msg, SOUP_STATUS_OK);
+}
+
+static void
+do_put (SoupServer *server, SoupMessage *msg, const char *path)
+{
+	struct stat st;
+	FILE *f;
+	gboolean created = TRUE;
+
+	if (stat (path, &st) != -1) {
+		const char *match = soup_message_headers_get_one (msg->request_headers, "If-None-Match");
+		if (match && !strcmp (match, "*")) {
+			soup_message_set_status (msg, SOUP_STATUS_CONFLICT);
+			return;
+		}
+
+		if (!S_ISREG (st.st_mode)) {
+			soup_message_set_status (msg, SOUP_STATUS_FORBIDDEN);
+			return;
+		}
+
+		created = FALSE;
+	}
+
+	f = fopen (path, "w");
+	if (!f) {
+		soup_message_set_status (msg, SOUP_STATUS_INTERNAL_SERVER_ERROR);
+		return;
+	}
+
+	fwrite (msg->request_body->data, 1, msg->request_body->length, f);
+	fclose (f);
+
+	soup_message_set_status (msg, created ? SOUP_STATUS_CREATED : SOUP_STATUS_OK);
+}
+
+static void
+server_callback (SoupServer *server, SoupMessage *msg,
+		 const char *path, GHashTable *query,
+		 SoupClientContext *context, gpointer data)
+{
+	char *file_path;
+	SoupMessageHeadersIter iter;
+	const char *name, *value;
+
+	g_print ("%s %s HTTP/1.%d\n", msg->method, path,
+		 soup_message_get_http_version (msg));
+	soup_message_headers_iter_init (&iter, msg->request_headers);
+	while (soup_message_headers_iter_next (&iter, &name, &value))
+		g_print ("%s: %s\n", name, value);
+	if (msg->request_body->length)
+		g_print ("%s\n", msg->request_body->data);
+
+	file_path = g_strdup_printf (".%s", path);
+
+	if (msg->method == SOUP_METHOD_GET || msg->method == SOUP_METHOD_HEAD)
+		do_get (server, msg, file_path);
+	else if (msg->method == SOUP_METHOD_PUT)
+		do_put (server, msg, file_path);
+	else
+		soup_message_set_status (msg, SOUP_STATUS_NOT_IMPLEMENTED);
+
+	g_free (file_path);
+	g_print ("  -> %d %s\n\n", msg->status_code, msg->reason_phrase);
+}
+
+static void
+quit (int sig)
+{
+	/* Exit cleanly on ^C in case we're valgrinding. */
+	exit (0);
+}
+
+int
+main (int argc, char **argv)
+{
+	GMainLoop *loop;
+	SoupServer *server, *ssl_server;
+	int opt;
+	int port = SOUP_ADDRESS_ANY_PORT;
+	int ssl_port = SOUP_ADDRESS_ANY_PORT;
+	const char *ssl_cert_file = NULL, *ssl_key_file = NULL;
+
+	signal (SIGINT, quit);
+
+	while ((opt = getopt (argc, argv, "p:k:c:s:")) != -1) {
+		switch (opt) {
+		case 'p':
+			port = atoi (optarg);
+			break;
+		case 'k':
+			ssl_key_file = optarg;
+			break;
+		case 'c':
+			ssl_cert_file = optarg;
+			break;
+		case 's':
+			ssl_port = atoi (optarg);
+			break;
+		default:
+			g_printerr ("Usage: %s [-p port] [-c ssl-cert-file -k ssl-key-file [-s ssl-port]]\n",
+				    argv[0]);
+			exit (1);
+		}
+	}
+
+	server = soup_server_new (SOUP_SERVER_PORT, port,
+				  SOUP_SERVER_SERVER_HEADER, "simple-httpd ",
+				  NULL);
+	if (!server) {
+		g_printerr ("Unable to bind to server port %d\n", port);
+		exit (1);
+	}
+	soup_server_add_handler (server, NULL,
+				 server_callback, NULL, NULL);
+	g_print ("\nStarting Server on port %d\n",
+		 soup_server_get_port (server));
+	soup_server_run_async (server);
+
+	if (ssl_cert_file && ssl_key_file) {
+		ssl_server = soup_server_new (
+			SOUP_SERVER_PORT, ssl_port,
+			SOUP_SERVER_SSL_CERT_FILE, ssl_cert_file,
+			SOUP_SERVER_SSL_KEY_FILE, ssl_key_file,
+			NULL);
+
+		if (!ssl_server) {
+			g_printerr ("Unable to bind to SSL server port %d\n", ssl_port);
+			exit (1);
+		}
+		soup_server_add_handler (ssl_server, NULL,
+					 server_callback, NULL, NULL);
+		g_print ("Starting SSL Server on port %d\n", 
+			 soup_server_get_port (ssl_server));
+		soup_server_run_async (ssl_server);
+	}
+
+	g_print ("\nWaiting for requests...\n");
+
+	loop = g_main_loop_new (NULL, TRUE);
+	g_main_loop_run (loop);
+
+	return 0;
+}
diff --git a/examples/simple-proxy.c b/examples/simple-proxy.c
new file mode 100644
index 00000000..1a9e0ed3
--- /dev/null
+++ b/examples/simple-proxy.c
@@ -0,0 +1,185 @@
+/* -*- Mode: C; tab-width: 8; indent-tabs-mode: t; c-basic-offset: 8 -*- */
+/*
+ * Copyright (C) 2001-2003, Ximian, Inc.
+ */
+
+#include <stdlib.h>
+#include <string.h>
+
+#ifdef G_OS_WIN32
+#include <getopt.h>
+#endif
+
+#include <libsoup/soup.h>
+
+/* WARNING: this is really really really not especially compliant with
+ * RFC 2616. But it does work for basic stuff.
+ */
+
+static SoupSession *session;
+static SoupServer *server;
+
+static void
+copy_header (const char *name, const char *value, gpointer dest_headers)
+{
+	soup_message_headers_append (dest_headers, name, value);
+}
+
+static void
+send_headers (SoupMessage *from, SoupMessage *to)
+{
+	g_print ("[%p] HTTP/1.%d %d %s\n", to,
+		 soup_message_get_http_version (from),
+		 from->status_code, from->reason_phrase);
+
+	soup_message_set_status_full (to, from->status_code,
+				      from->reason_phrase);
+	soup_message_headers_foreach (from->response_headers, copy_header,
+				      to->response_headers);
+	soup_message_headers_remove (to->response_headers, "Content-Length");
+	soup_server_unpause_message (server, to);
+}
+
+static void
+send_chunk (SoupMessage *from, SoupBuffer *chunk, SoupMessage *to)
+{
+	g_print ("[%p]   writing chunk of %lu bytes\n", to,
+		 (unsigned long)chunk->length);
+
+	soup_message_body_append_buffer (to->response_body, chunk);
+	soup_server_unpause_message (server, to);
+}
+
+static void
+client_msg_failed (SoupMessage *msg, gpointer msg2)
+{
+	soup_session_cancel_message (session, msg2, SOUP_STATUS_IO_ERROR);
+}
+
+static void
+finish_msg (SoupSession *session, SoupMessage *msg2, gpointer data)
+{
+	SoupMessage *msg = data;
+
+	g_print ("[%p]   done\n\n", msg);
+	g_signal_handlers_disconnect_by_func (msg, client_msg_failed, msg2);
+
+	soup_message_body_complete (msg->response_body);
+	soup_server_unpause_message (server, msg);
+	g_object_unref (msg);
+}
+
+static void
+server_callback (SoupServer *server, SoupMessage *msg,
+		 const char *path, GHashTable *query,
+		 SoupClientContext *context, gpointer data)
+{
+	SoupMessage *msg2;
+	char *uristr;
+
+	uristr = soup_uri_to_string (soup_message_get_uri (msg), FALSE);
+	g_print ("[%p] %s %s HTTP/1.%d\n", msg, msg->method, uristr,
+		 soup_message_get_http_version (msg));
+
+	if (msg->method == SOUP_METHOD_CONNECT) {
+		soup_message_set_status (msg, SOUP_STATUS_NOT_IMPLEMENTED);
+		return;
+	}
+
+        msg2 = soup_message_new (msg->method, uristr);
+	soup_message_headers_foreach (msg->request_headers, copy_header,
+				      msg2->request_headers);
+	soup_message_headers_remove (msg2->request_headers, "Host");
+	soup_message_headers_remove (msg2->request_headers, "Connection");
+
+	if (msg->request_body->length) {
+		SoupBuffer *request = soup_message_body_flatten (msg->request_body);
+		soup_message_body_append_buffer (msg2->request_body, request);
+		soup_buffer_free (request);
+	}
+	soup_message_headers_set_encoding (msg->response_headers,
+					   SOUP_ENCODING_CHUNKED);
+
+	g_signal_connect (msg2, "got_headers",
+			  G_CALLBACK (send_headers), msg);
+	g_signal_connect (msg2, "got_chunk",
+			  G_CALLBACK (send_chunk), msg);
+
+	g_signal_connect (msg, "finished", G_CALLBACK (client_msg_failed), msg2);
+
+	soup_session_queue_message (session, msg2, finish_msg, msg);
+
+	g_object_ref (msg);
+	soup_server_pause_message (server, msg);
+}
+
+static gboolean
+auth_callback (SoupAuthDomain *auth_domain, SoupMessage *msg,
+	       const char *username, const char *password, gpointer data)
+{
+	return !strcmp (username, "user") && !strcmp (password, "password");
+}
+
+static void
+quit (int sig)
+{
+	/* Exit cleanly on ^C in case we're valgrinding. */
+	exit (0);
+}
+
+int
+main (int argc, char **argv)
+{
+	GMainLoop *loop;
+	int opt;
+	int port = SOUP_ADDRESS_ANY_PORT;
+	SoupAuthDomain *auth_domain = NULL;
+
+	signal (SIGINT, quit);
+
+	while ((opt = getopt (argc, argv, "ap:")) != -1) {
+		switch (opt) {
+		case 'a':
+			auth_domain = soup_auth_domain_basic_new (
+				SOUP_AUTH_DOMAIN_REALM, "simple-proxy",
+				SOUP_AUTH_DOMAIN_PROXY, TRUE,
+				SOUP_AUTH_DOMAIN_BASIC_AUTH_CALLBACK, auth_callback,
+				NULL);
+			break;
+		case 'p':
+			port = atoi (optarg);
+			break;
+		default:
+			g_printerr ("Usage: %s [-p port] [-n]\n",
+				    argv[0]);
+			exit (1);
+		}
+	}
+
+	server = soup_server_new (SOUP_SERVER_PORT, port,
+				  NULL);
+	if (!server) {
+		g_printerr ("Unable to bind to server port %d\n", port);
+		exit (1);
+	}
+	soup_server_add_handler (server, NULL,
+				 server_callback, NULL, NULL);
+	if (auth_domain) {
+		soup_server_add_auth_domain (server, auth_domain);
+		g_object_unref (auth_domain);
+	}
+
+	g_print ("\nStarting proxy on port %d\n",
+		 soup_server_get_port (server));
+	soup_server_run_async (server);
+
+	session = soup_session_async_new ();
+
+	g_print ("\nWaiting for requests...\n");
+
+	loop = g_main_loop_new (NULL, TRUE);
+	g_main_loop_run (loop);
+	g_main_loop_unref (loop);
+
+	return 0;
+}