1 /* -*- Mode: C; tab-width: 8; indent-tabs-mode: t; c-basic-offset: 8 -*- */
3 * Copyright (C) 2001-2003, Ximian, Inc.
17 #include <libsoup/soup.h>
19 /* WARNING: this is really really really not especially compliant with
20 * RFC 2616. But it does work for basic stuff.
23 static SoupSession *session;
24 static SoupServer *server;
27 copy_header (const char *name, const char *value, gpointer dest_headers)
29 soup_message_headers_append (dest_headers, name, value);
33 send_headers (SoupMessage *from, SoupMessage *to)
35 printf ("[%p] HTTP/1.%d %d %s\n", to,
36 soup_message_get_http_version (from),
37 from->status_code, from->reason_phrase);
39 soup_message_set_status_full (to, from->status_code,
41 soup_message_headers_foreach (from->response_headers, copy_header,
42 to->response_headers);
43 soup_message_headers_remove (to->response_headers, "Content-Length");
44 soup_server_unpause_message (server, to);
48 send_chunk (SoupMessage *from, SoupBuffer *chunk, SoupMessage *to)
50 printf ("[%p] writing chunk of %lu bytes\n", to,
51 (unsigned long)chunk->length);
53 soup_message_body_append_buffer (to->response_body, chunk);
54 soup_server_unpause_message (server, to);
58 client_msg_failed (SoupMessage *msg, gpointer msg2)
60 soup_session_cancel_message (session, msg2, SOUP_STATUS_IO_ERROR);
64 finish_msg (SoupSession *session, SoupMessage *msg2, gpointer data)
66 SoupMessage *msg = data;
68 printf ("[%p] done\n\n", msg);
69 g_signal_handlers_disconnect_by_func (msg, client_msg_failed, msg2);
71 soup_message_body_complete (msg->response_body);
72 soup_server_unpause_message (server, msg);
77 server_callback (SoupServer *server, SoupMessage *msg,
78 const char *path, GHashTable *query,
79 SoupClientContext *context, gpointer data)
84 uristr = soup_uri_to_string (soup_message_get_uri (msg), FALSE);
85 printf ("[%p] %s %s HTTP/1.%d\n", msg, msg->method, uristr,
86 soup_message_get_http_version (msg));
88 if (msg->method == SOUP_METHOD_CONNECT) {
89 soup_message_set_status (msg, SOUP_STATUS_NOT_IMPLEMENTED);
93 msg2 = soup_message_new (msg->method, uristr);
94 soup_message_headers_foreach (msg->request_headers, copy_header,
95 msg2->request_headers);
96 soup_message_headers_remove (msg2->request_headers, "Host");
97 soup_message_headers_remove (msg2->request_headers, "Connection");
99 if (msg->request_body->length) {
100 SoupBuffer *request = soup_message_body_flatten (msg->request_body);
101 soup_message_body_append_buffer (msg2->request_body, request);
102 soup_buffer_free (request);
104 soup_message_headers_set_encoding (msg->response_headers,
105 SOUP_ENCODING_CHUNKED);
107 g_signal_connect (msg2, "got_headers",
108 G_CALLBACK (send_headers), msg);
109 g_signal_connect (msg2, "got_chunk",
110 G_CALLBACK (send_chunk), msg);
112 g_signal_connect (msg, "finished", G_CALLBACK (client_msg_failed), msg2);
114 soup_session_queue_message (session, msg2, finish_msg, msg);
117 soup_server_pause_message (server, msg);
121 auth_callback (SoupAuthDomain *auth_domain, SoupMessage *msg,
122 const char *username, const char *password, gpointer data)
124 return !strcmp (username, "user") && !strcmp (password, "password");
130 /* Exit cleanly on ^C in case we're valgrinding. */
135 main (int argc, char **argv)
139 int port = SOUP_ADDRESS_ANY_PORT;
140 SoupAuthDomain *auth_domain = NULL;
143 signal (SIGINT, quit);
145 while ((opt = getopt (argc, argv, "ap:")) != -1) {
148 auth_domain = soup_auth_domain_basic_new (
149 SOUP_AUTH_DOMAIN_REALM, "simple-proxy",
150 SOUP_AUTH_DOMAIN_PROXY, TRUE,
151 SOUP_AUTH_DOMAIN_BASIC_AUTH_CALLBACK, auth_callback,
155 port = atoi (optarg);
158 fprintf (stderr, "Usage: %s [-p port] [-n]\n",
164 server = soup_server_new (SOUP_SERVER_PORT, port,
167 fprintf (stderr, "Unable to bind to server port %d\n", port);
170 soup_server_add_handler (server, NULL,
171 server_callback, NULL, NULL);
173 soup_server_add_auth_domain (server, auth_domain);
174 g_object_unref (auth_domain);
177 printf ("\nStarting proxy on port %d\n",
178 soup_server_get_port (server));
179 soup_server_run_async (server);
181 session = soup_session_async_new ();
183 printf ("\nWaiting for requests...\n");
185 loop = g_main_loop_new (NULL, TRUE);
186 g_main_loop_run (loop);
187 g_main_loop_unref (loop);