comparison libpurple/protocols/msn/directconn.h @ 30433:119bd7b072eb

Initial support for direct connections. Preliminary patch from ticket #247 by G���bor Szuromi. Still needs lots of testing and fixes. References #247. committer: Elliott Sales de Andrade <[e-mail]>

30001:bfaf039aed87

#ifndef MSN_DIRECTCONN_H
#define MSN_DIRECTCONN_H

typedef struct _MsnDirectConn MsnDirectConn;

#include "msg.h"
#include "slp.h"
#include "slplink.h"

struct _MsnDirectConn
{
	MsnSlpLink *slplink;
	MsnSlpCall *initial_call;

	PurpleProxyConnectData *connect_data;

	gboolean acked;

	char *nonce;

	int fd;

	int port;
	int inpa;

	int c;
};

MsnDirectConn *msn_directconn_new(MsnSlpLink *slplink);
gboolean msn_directconn_connect(MsnDirectConn *directconn,
								const char *host, int port);
void msn_directconn_listen(MsnDirectConn *directconn);
void msn_directconn_send_msg(MsnDirectConn *directconn, MsnMessage *msg);
void msn_directconn_parse_nonce(MsnDirectConn *directconn, const char *nonce);
void msn_directconn_destroy(MsnDirectConn *directconn);
void msn_directconn_send_handshake(MsnDirectConn *directconn);

#endif /* MSN_DIRECTCONN_H */

30433:119bd7b072eb

#ifndef MSN_DIRECTCONN_H
#define MSN_DIRECTCONN_H

typedef struct _MsnDirectConn MsnDirectConn;

#include "network.h"
#include "proxy.h"
#include "circbuffer.h"

#include "msg.h"
#include "slp.h"
#include "slplink.h"
#include "slpmsg.h"

typedef enum
{
	DC_STATE_CLOSED,		/*< No socket opened yet */
	DC_STATE_FOO,			/*< Waiting for FOO message */
	DC_STATE_HANDSHAKE,		/*< Waiting for handshake message */
	DC_STATE_HANDSHAKE_REPLY,	/*< Waiting for handshake reply message */
	DC_STATE_ESTABILISHED		/*< Handshake complete */
} MsnDirectConnState;

typedef enum
{
	DC_PROCESS_OK = 0,
	DC_PROCESS_ERROR,
	DC_PROCESS_FALLBACK,
	DC_PROCESS_CLOSE

} MsnDirectConnProcessResult;

typedef struct _MsnDirectConnPacket MsnDirectConnPacket;

struct _MsnDirectConnPacket {
	guint32		length;
	guchar		*data;

	void		(*sent_cb)(struct _MsnDirectConnPacket*);
	MsnMessage	*msg;
};

struct _MsnDirectConn
{
	MsnDirectConnState	state;			/**< Direct connection status */
	MsnSlpLink 		*slplink;		/**< The slplink using this direct connection */
	MsnSlpCall		*slpcall;		/**< The slpcall which initiated the direct connection */
	char			*msg_body;		/**< The body of message sent by send_connection_info_msg_cb */
	MsnSlpMessage		*prev_ack;		/**< The saved SLP ACK message */

	guchar			nonce[16];		/**< The nonce used for direct connection handshake */
	gchar			nonce_hash[37];		/**< The hash of nonce */

	PurpleNetworkListenData	*listen_data;		/**< The pending socket creation request */
	PurpleProxyConnectData	*connect_data;		/**< The pending connection attempt */
	int			listenfd;		/**< The socket we're listening for incoming connections */
	guint			listenfd_handle;	/**< The timeout handle for incoming connection */
	guint			connect_timeout_handle;	/**< The timeout handle for outgoing connection */

	int			fd;			/**< The direct connection socket */
	guint			recv_handle;		/**< The incoming data callback handle */
	guint			send_handle;		/**< The outgoing data callback handle */

	gchar			*in_buffer;		/**< The receive buffer */
	int			in_size;		/**< The receive buffer size */
	int			in_pos;			/**< The first free position in receive buffer */
	GQueue			*out_queue;		/**< The outgoing packet queue */
	int			msg_pos;		/**< The position of next byte to be sent in the actual packet */

	MsnSlpHeader		header;			/**< SLP header for parsing / serializing */
	
							/**< The callback used for sending information to the peer about the opened scoket */
	void			(*send_connection_info_msg_cb)(struct _MsnDirectConn*);

	gchar			*ext_ip;		/**< Our external IP address */
	int			ext_port;		/**< Our external port */

	guint			timeout_handle;
	gboolean		progress;

	//int			num_calls;		/**< The number of slpcalls using this direct connection */
};

#define DC_CONNECT_TIMEOUT 	5
#define DC_TIMEOUT 		60

/*
 * Queues an MSN message to be sent via direct connection.
 */
void
msn_dc_enqueue_msg(MsnDirectConn *dc, MsnMessage *msg);

/*
 * Creates initializes and returns a new MsnDirectConn structure.
 */
MsnDirectConn*
msn_dc_new(MsnSlpCall *slplink);

/*
 * Destroys an MsnDirectConn structure. Frees every buffer allocated earlier
 * restores saved callbacks, etc.
 */
void
msn_dc_destroy(MsnDirectConn *dc);

/*
 * Increases the slpcall counter in DC. The direct connection remains open
 * until all slpcalls using it are destroyed.
 */
void
msn_dc_ref(MsnDirectConn *dc);

/*
 * Decrease the slpcall counter in DC. The direct connection remains open
 * until all slpcalls using it are destroyed.
 */
void
msn_dc_unref(MsnDirectConn *dc);

/*
 * Sends a direct connect INVITE message on the associated slplink
 * with the corresponding connection type and information.
 */
void
msn_dc_send_invite(MsnDirectConn *dc);

/*
 * Sends a direct connect OK message as a response to an INVITE received earliaer
 * on the corresponding slplink.
 */
void
msn_dc_send_ok(MsnDirectConn *dc);

/*
 * This callback will be called when we're successfully connected to
 * the remote host.
 */
void
msn_dc_connected_to_peer_cb(gpointer data, gint fd, const gchar *error_msg);

/*
 * This callback will be called when we're unable to connect to
 * the remote host in DC_CONNECT_TIMEOUT seconds.
 */
gboolean
msn_dc_outgoing_connection_timeout_cb(gpointer data);

/*
 * This callback will be called when the listening socket is successfully
 * created and it's parameters (IP/port) are available.
 */
void
msn_dc_listen_socket_created_cb(int listenfd, gpointer data);

#endif /* MSN_DIRECTCONN_H */