modules/proxy/http.c File Reference

#include <eggdrop/eggdrop.h>
#include <errno.h>
#include <netinet/in.h>
#include "proxy.h"

Go to the source code of this file.

Data Structures
struct	proxy_info_t
Functions
static int	http_on_connect (void *client_data, int idx, const char *peer_ip, int peer_port)
static int	http_on_eof (void *client_data, int idx, int err, const char *errmsg)
static int	http_on_read (void *client_data, int idx, char *data, int len)
static int	http_on_delete (event_owner_t *owner, void *client_data)
static int	http_on_their_delete (void *client_data, int idx)
static void	http_err (proxy_info_t *info, int err, const char *errmsg)
static char *	make_password (proxy_info_t *info)
int	http_reconnect (int idx, const char *host, int port)
Variables
event_owner_t	http_owner
static sockbuf_handler_t	http_events
static sockbuf_filter_t	delete_listener

---

Function Documentation

static void http_err	(	proxy_info_t *	info,
		int	err,
		const char *	errmsg
	)			[static]

Definition at line 42 of file http.c.

References proxy_info_t::our_idx, sockbuf_delete(), SOCKBUF_LEVEL_INTERNAL, sockbuf_on_eof(), and proxy_info_t::their_idx.

Referenced by http_on_eof(), and http_on_read().

{
  int idx = info->their_idx;
  errno = err;
  sockbuf_delete(info->our_idx);
  sockbuf_on_eof(idx, SOCKBUF_LEVEL_INTERNAL, err, errmsg);
}

static int http_on_connect	(	void *	client_data,
		int	idx,
		const char *	peer_ip,
		int	peer_port
	)			[static]

Definition at line 121 of file http.c.

References egg_iprintf(), proxy_info_t::host, proxy_info_t::http_host, make_password(), proxy_info_t::password, proxy_info_t::port, and proxy_info_t::username.

{
  proxy_info_t *info = client_data;

  egg_iprintf(idx, "CONNECT %s:%d HTTP/1.0\r\n", info->host, info->port);
  egg_iprintf(idx, "Host: %s\r\n", info->http_host);
  if (info->username && info->password && strlen(info->username)) {
    char *auth;

    auth = make_password(info);
    egg_iprintf(idx, "Proxy-authenticate: basic %s\r\n", auth);
    free(auth);
  }
  egg_iprintf(idx, "\r\n");

  return(0);
}

static int http_on_delete	(	event_owner_t *	owner,
		void *	client_data
	)			[static]

Definition at line 50 of file http.c.

References proxy_info_t::host, proxy_info_t::password, sockbuf_detach_filter(), proxy_info_t::their_idx, and proxy_info_t::username.

{
  proxy_info_t *info = client_data;
  sockbuf_detach_filter(info->their_idx, &delete_listener, info);
  if (info->host) free(info->host);
  if (info->username) free(info->username);
  if (info->password) free(info->password);
  free(info);
  return(0);
}

static int http_on_eof	(	void *	client_data,
		int	idx,
		int	err,
		const char *	errmsg
	)			[static]

Definition at line 97 of file http.c.

References http_err().

{
  proxy_info_t *info = client_data;

  if (!err) err = ECONNREFUSED;
  http_err(info, err, "Unexpected EOF from HTTP server");
  return(0);
}

static int http_on_read	(	void *	client_data,
		int	idx,
		char *	data,
		int	len
	)			[static]

Definition at line 61 of file http.c.

References proxy_info_t::host, http_err(), proxy_info_t::our_idx, proxy_info_t::port, sockbuf_delete(), sockbuf_detach_filter(), sockbuf_get_sock(), SOCKBUF_LEVEL_INTERNAL, sockbuf_on_connect(), sockbuf_set_sock(), proxy_info_t::status, and proxy_info_t::their_idx.

{
  proxy_info_t *info = client_data;
  int sock;

  if (!strncasecmp("HTTP/1.0 200", data, 12)) {
    /* Yay, we're approved. */
    info->status = 1;
    return(0);
  }

  if (len != 0) {
    /* Just some header that we don't care about. */
    return(0);
  }

  /* It's the blank line, so the http response is done. */

  if (info->status != 1) {
    /* Boo, we weren't approved. */
    http_err(info, ECONNREFUSED, "HTTP server refused to relay connection");
    return(0);
  }

  /* Successful, switch it over. */
  sockbuf_detach_filter(info->their_idx, &delete_listener, info);
  sock = sockbuf_get_sock(info->our_idx);
  sockbuf_set_sock(info->our_idx, -1, 0);
  sockbuf_set_sock(info->their_idx, sock, 0);
  sockbuf_on_connect(info->their_idx, SOCKBUF_LEVEL_INTERNAL, info->host, info->port);
  info->their_idx = -1;
  sockbuf_delete(info->our_idx);

  return(0);
}

static int http_on_their_delete	(	void *	client_data,
		int	idx
	)			[static]

Definition at line 140 of file http.c.

References proxy_info_t::our_idx, and sockbuf_delete().

{
  proxy_info_t *info = client_data;
  sockbuf_delete(info->our_idx);
  return(0);
}

int http_reconnect	(	int	idx,
		const char *	host,
		int	port
	)

Definition at line 147 of file http.c.

References egg_client(), proxy_info_t::host, proxy_config_t::host, proxy_info_t::http_host, linemode_on(), NULL, proxy_info_t::our_idx, proxy_info_t::password, proxy_config_t::password, proxy_info_t::port, proxy_config_t::port, proxy_config, sockbuf_attach_filter(), sockbuf_new(), sockbuf_set_handler(), proxy_info_t::status, proxy_info_t::their_idx, proxy_info_t::username, and proxy_config_t::username.

{
  int our_idx;
  proxy_info_t *info;

  if (!proxy_config.host) return(-1);

  our_idx = egg_client(-1, proxy_config.host, proxy_config.port, NULL, 0, -1);
  if (our_idx < 0) return(-1);

  /* Save our destination. */
  info = (proxy_info_t *)calloc(1, sizeof(*info));
  info->host = strdup(host);
  info->port = port;
  /* Also save the proxy info, in case the config changes while we're
   * connecting. */
  info->http_host = strdup(proxy_config.host);
  if (proxy_config.username) info->username = strdup(proxy_config.username);
  if (proxy_config.password) info->password = strdup(proxy_config.password);

  info->our_idx = our_idx;
  linemode_on(info->our_idx);

  if (idx >= 0) info->their_idx = idx;
  else info->their_idx = sockbuf_new();

  info->status = 0;

  sockbuf_set_handler(info->our_idx, &http_events, info, &http_owner);
  sockbuf_attach_filter(info->their_idx, &delete_listener, info);

  return(info->their_idx);
}

static char* make_password

(

proxy_info_t *

info

)

[static]

Definition at line 106 of file http.c.

References b64enc_buf(), egg_mprintf(), proxy_info_t::password, and proxy_info_t::username.

Referenced by http_on_connect().

{
  char *buf, *dest;
  int len;

  buf = egg_mprintf("%s %s", info->username, info->password);
  len = strlen(buf);
  dest = malloc(len * 4 + 1);
  b64enc_buf(buf, len, dest);
  free(buf);
  return(dest);
}

---

Variable Documentation

sockbuf_filter_t delete_listener [static]

Initial value:

 {
  "http proxy",
  SOCKBUF_LEVEL_PROXY,
  NULL, NULL, NULL,
  NULL, NULL, NULL,
  NULL, http_on_their_delete
}

Definition at line 34 of file http.c.

sockbuf_handler_t http_events [static]

Initial value:

 {
  "http proxy",
  http_on_connect, http_on_eof, NULL,
  http_on_read, NULL
}

Definition at line 28 of file http.c.

event_owner_t http_owner

Initial value:

 {
  "proxy", NULL,
  NULL, NULL,
  http_on_delete
}

Definition at line 22 of file http.c.