modules/proxy/socks5.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	socks5_on_read (void *client_data, int idx, char *data, int len)
static int	socks5_on_eof (void *client_data, int idx, int err, const char *errmsg)
static int	socks5_on_connect (void *client_data, int idx, const char *peer_ip, int peer_port)
static int	socks5_on_delete (event_owner_t *owner, void *client_data)
static int	socks5_on_their_eof (void *client_data, int idx, int err, const char *errmsg)
static int	socks5_on_their_delete (void *client_data, int idx)
static void	socks5_err (proxy_info_t *info, int err, const char *errmsg)
static void	send_connect_request (proxy_info_t *info)
static void	socks5_auth_method (char *data, int len, proxy_info_t *info)
static void	socks5_auth_reply (char *data, int len, proxy_info_t *info)
static void	socks5_connect_reply (char *data, int len, proxy_info_t *info)
int	socks5_reconnect (int idx, const char *host, int port)
Variables
proxy_config_t	proxy_config
event_owner_t	socks5_owner
static sockbuf_handler_t	socks5_events
static sockbuf_filter_t	delete_listener

---

Function Documentation

static void send_connect_request

(

proxy_info_t *

info

)

[static]

Definition at line 60 of file socks5.c.

References proxy_info_t::host, proxy_info_t::our_idx, proxy_info_t::port, and sockbuf_write().

Referenced by socks5_auth_method(), and socks5_auth_reply().

{
  char buf[512];
  int len;
  unsigned short port;
  struct sockaddr_in addr;
  #ifdef IPV6
  struct sockaddr_in6 addr6;
  #endif

  /* VER        CMD        RESERVED  */
  buf[0] = 5; buf[1] = 1; buf[2] = 0;

  /* Try a regular ipv4 address first. */
  /* FIXME: Check DO_IPV4 here? */
  if (inet_pton(AF_INET, info->host, &addr) > 0) {
    buf[3] = 1;
    memcpy(buf+4, &addr.sin_addr, 4);
    len = 8;
  }
  #ifdef IPV6
  else if (inet_pton(AF_INET6, info->host, &addr6) > 0) {
    buf[3] = 4;
    memcpy(buf+4, &addr6.sin6_addr, 16);
    len = 20;
  }
  #endif
  else {
    buf[3] = 3;
    len = strlen(info->host) % 255;
    buf[4] = len;
    memcpy(buf+5, info->host, len);
    len += 5;
  }

  port = htons(info->port);
  memcpy(buf+len, &port, 2);
  len += 2;

  sockbuf_write(info->our_idx, buf, len);
}

static void socks5_auth_method	(	char *	data,
		int	len,
		proxy_info_t *	info
	)			[static]

Definition at line 106 of file socks5.c.

References proxy_info_t::our_idx, proxy_info_t::password, send_connect_request(), sockbuf_write(), socks5_err(), proxy_info_t::status, and proxy_info_t::username.

Referenced by socks5_on_read().

{
  /* If it's a bad reply, abort. */
  if (len < 2) {
    socks5_err(info, ECONNABORTED, "Invalid reply from SOCKS5 server");
    return;
  }

  if (data[0] != 5) {
    socks5_err(info, ECONNABORTED, "SOCKS5 server replied with SOCKS4 protocol");
    return;
  }

  if (data[1] == 0) {
    /* No auth required. */
    send_connect_request(info);
    info->status = 3;
  }
  else if (data[1] == 2) {
    /* User/password authentication */
    int ulen, plen;
    char buf[520];

    /* Username and password can be 255 max. */
    if (info->username) ulen = strlen(info->username) % 255;
    else ulen = 0;
    if (info->password) plen = strlen(info->password) % 255;
    else plen = 0;

    buf[0] = 1;
    buf[1] = ulen;
    memcpy(buf+2, info->username, ulen);
    buf[2+ulen] = plen;
    memcpy(buf+2+ulen+1, info->password, plen);
    sockbuf_write(info->our_idx, buf, 1+1+ulen+1+plen);
    info->status = 2;
  }
  else {
    /* We can't authenticate with this server, boo. */
    socks5_err(info, ECONNABORTED, "SOCKS5 server doesn't accept our methods of authentication");
  }
  return;
}

static void socks5_auth_reply	(	char *	data,
		int	len,
		proxy_info_t *	info
	)			[static]

Definition at line 152 of file socks5.c.

References send_connect_request(), socks5_err(), and proxy_info_t::status.

Referenced by socks5_on_read().

{
  /* Abort if it's an invalid reply. */
  if (len < 2) {
    socks5_err(info, ECONNABORTED, "Invalid reply from SOCKS5 server");
    return;
  }

  if (data[1] != 0) {
    /* Authentication failed! */
    socks5_err(info, ECONNREFUSED, "SOCKS5 authentication failed");
  }
  else {
    /* Send the connection request. */
    send_connect_request(info);
    info->status = 3;
  }
}

static void socks5_connect_reply	(	char *	data,
		int	len,
		proxy_info_t *	info
	)			[static]

Definition at line 175 of file socks5.c.

References proxy_info_t::host, NULL, 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(), socks5_err(), and proxy_info_t::their_idx.

Referenced by socks5_on_read().

{
  int sock;

  /* Abort if it's an invalid reply or the connection failed. */
  /* It's actually supposed to be more than 2 bytes, but we only care
    about the 2nd field (status). */

  /* Here are the reply field definitions (from rfc1928)
    0 - success
    1 - general SOCKS server failure
    2 - connection not allowed by ruleset
    3 - network unreachable
    4 - host unreachable
    5 - connection refused
    6 - ttl expired
    7 - command not supported
    8 - address type not supported
  */
  if (len < 2 || data[1] != 0) {
    char *errmsg;

    if (len < 2) errmsg = "Invalid reply from SOCKS5 server";
    else switch (data[1]) {
      case 1: errmsg = "SOCKS5 general server failure"; break;
      case 2: errmsg = "SOCKS5 connection now allowed by ruleset"; break;
      case 3: errmsg = "SOCKS5 network unreachable"; break;
      case 4: errmsg = "SOCKS5 host unreachable"; break;
      case 5: errmsg = "SOCKS5 connection refused"; break;
      case 6: errmsg = "SOCKS5 TTL expired"; break;
      case 7: errmsg = "SOCKS5 command not supported"; break;
      case 8: errmsg = "SOCKS5 address type not supported"; break;
      default: errmsg = "SOCKS5 unknown error";
    }
    socks5_err(info, ECONNABORTED, errmsg);
    return;
  }

  /* We're connected! Simulate a CONNECT event for the other idx. */
  /* putlog(LOG_MISC, "*", "socks5 connected"); */
  sockbuf_detach_filter(info->their_idx, &delete_listener, NULL);
  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;
}

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

Definition at line 47 of file socks5.c.

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

Referenced by socks5_auth_method(), socks5_auth_reply(), socks5_connect_reply(), and socks5_on_eof().

{
  /* putlog(LOG_MISC, "*", "socks5 err"); */
  sockbuf_detach_filter(info->their_idx, &delete_listener, NULL);
  errno = err;
  sockbuf_on_eof(info->their_idx, SOCKBUF_LEVEL_INTERNAL, err, errmsg);
  info->their_idx = -1;
  sockbuf_delete(info->our_idx);
}

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

Definition at line 300 of file socks5.c.

References proxy_info_t::password, sockbuf_write(), proxy_info_t::status, and proxy_info_t::username.

{
  proxy_info_t *info = client_data;
  char both[] = "\005\002\002\000";
  char anon[] = "\005\001\000";

  /* putlog(LOG_MISC, "*", "socks5 connected!"); */
  /* Send the accepted auth methods (user/pass and/or none). */
  if (info->username && info->password) sockbuf_write(idx, both, 4);
  else sockbuf_write(idx, anon, 3);
  info->status = 1;
  return(0);
}

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

Definition at line 259 of file socks5.c.

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

{
  proxy_info_t *info = client_data;

  /* putlog(LOG_MISC, "*", "socks5 deleted"); */
  if (info->their_idx != -1) {
    int their_idx = info->their_idx;
    sockbuf_detach_filter(their_idx, &delete_listener, NULL);
    sockbuf_on_eof(their_idx, SOCKBUF_LEVEL_INTERNAL, ECONNREFUSED, "socks5 idx deleted unexpectedly!");
  }
  free(info->host);
  if (info->username) free(info->username);
  if (info->password) free(info->password);
  free(info);
  return(0);
}

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

Definition at line 248 of file socks5.c.

References socks5_err().

{
  proxy_info_t *info = client_data;
  if (!err) err = ECONNREFUSED;
  if (!errmsg) errmsg = "Unexpected EOF from SOCKS5 server";
  socks5_err(info, err, errmsg);
  return(0);
}

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

Definition at line 227 of file socks5.c.

References socks5_auth_method(), socks5_auth_reply(), socks5_connect_reply(), and proxy_info_t::status.

{
  proxy_info_t *info = client_data;

  /* putlog(LOG_MISC, "*", "socks5 read, status = %d", info->status); */
  switch (info->status) {
    case 1:
      socks5_auth_method(data, len, info);
      break;
    case 2:
      socks5_auth_reply(data, len, info);
      break;
    case 3:
      socks5_connect_reply(data, len, info);
      break;
  }
  return(0);
}

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

Definition at line 277 of file socks5.c.

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

{
  proxy_info_t *info = client_data;

  info->their_idx = -1;
  sockbuf_delete(info->our_idx);
  return(0);
}

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

Definition at line 287 of file socks5.c.

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

{
  proxy_info_t *info = client_data;

  info->their_idx = -1;
  sockbuf_delete(info->our_idx);
  return(0);
}

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

Definition at line 314 of file socks5.c.

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

{
  proxy_info_t *info;
  int our_idx;

  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);

  info = (proxy_info_t *)calloc(1, sizeof(*info));
  info->host = strdup(host);
  info->port = port;
  str_redup(&info->username, proxy_config.username);
  str_redup(&info->password, proxy_config.password);
  info->status = 0;

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

  sockbuf_set_handler(info->our_idx, &socks5_events, info, &socks5_owner);
  sockbuf_attach_filter(info->their_idx, &delete_listener, info);

  return(info->their_idx);
}

---

Variable Documentation

sockbuf_filter_t delete_listener [static]

Initial value:

 {
  "socks5 proxy",
  SOCKBUF_LEVEL_PROXY,
  NULL, socks5_on_their_eof, NULL,
  NULL, NULL, NULL,
  NULL, socks5_on_their_delete
}

Definition at line 37 of file socks5.c.

proxy_config_t proxy_config

Definition at line 8 of file proxy.c.

Referenced by http_reconnect().

sockbuf_handler_t socks5_events [static]

Initial value:

 {
  "socks5 proxy",
  socks5_on_connect, socks5_on_eof, NULL,
  socks5_on_read, NULL
}

Definition at line 31 of file socks5.c.

event_owner_t socks5_owner

Initial value:

 {
  "proxy", NULL,
  NULL, NULL,
  socks5_on_delete
}

Definition at line 25 of file socks5.c.