comparison src/protocols/irc/irc.c @ 3630:9682c0e022c6

[gaim-migrate @ 3753] Yeah this will probably break a lot of shit knowing my luck. But hey, I really don't care what people thnk. committer: Tailor Script <[e-mail]>

3629:afc5bb164c5a

 *
 */

#include <config.h>

#include <fcntl.h>
#include <unistd.h>
#include <errno.h>
#include <string.h>
#include <stdlib.h>
#include <stdio.h>
#include <time.h>

#include "multi.h"
#include "prpl.h"
#include "gaim.h"
#include "proxy.h"

#include "pixmaps/protocols/irc/irc_icon.xpm"

#define IRC_BUF_LEN 4096
#define PDIWORDS 32

#define USEROPT_SERV      0
#define USEROPT_PORT      1

struct dcc_chat
{
	struct gaim_connection *gc;	
	char ip_address[12];	

		struct file_transfer *xfer;
		char *sn;
		char *name;
		int len;
		int watcher;
		char ip[12];
		int port;
		int fd;
		int cur;
		struct gaim_connection *gc;

}

static int irc_write(int fd, char *data, int len)
{
	debug_printf("IRC C: %s", data);
	return write(fd, data, len);
}

static struct conversation *irc_find_chat(struct gaim_connection *gc, char *name)
{
	GSList *bcs = gc->buddy_chats;

	gchar buffer[IRC_BUF_LEN];
	gchar buf[128];
	int n = 0, l;
	struct conversation *convo;
	debug_printf("THIS IS TOO MUCH EFFORT\n");
	n = read (chat->fd, buffer, IRC_BUF_LEN);
	if (n > 0)
	  {
		  
		  /* Strip the terminating \n */
		  l = 0;

		dcc_chat_cancel (NULL,chat);
	}
}

static void irc_file_transfer_do(struct gaim_connection *gc, struct irc_file_transfer *ift) {
	struct irc_data *id = (struct irc_data *)gc->proto_data;

	/* Ok, we better be receiving some crap here boyeee */
	if (transfer_in_do(ift->xfer, ift->fd, ift->name, ift->len)) {
			gaim_input_remove(ift->watcher);
			ift->watcher = 0;
	}
}


void dcc_send_callback (gpointer data, gint source, GaimInputCondition condition) {
		struct irc_file_transfer *ift = data;
		struct irc_data *id = (struct irc_data *)ift->gc->proto_data;
		struct sockaddr_in addr;

		if (!ift->fd) {
				/* FIXME: Handle this gracefully XXX */
				printf("Something bad happened here, bubba!");
				return;
		}
		
		if (transfer_out_do(ift->xfer, ift->fd, 0)) {
				gaim_input_remove(ift->watcher);
				ift->watcher = 0;
		}

	struct irc_data *idata = gc->proto_data;
	int i = 0;
	gchar buf[1024];
	gboolean off;

	i = read(idata->fd, buf, 1024);
	if (i <= 0) {
		hide_login_progress_error(gc, "Read error");
		signoff(gc);
		return;
	}

	struct irc_data *idata;
	char hostname[256];
	char buf[IRC_BUF_LEN];

	if (!g_slist_find(connections, gc)) {
		close(source);
		return;
	}

	idata = gc->proto_data;

		g_source_remove(idata->timer);

	if (gc->inpa)
		gaim_input_remove(gc->inpa);

	close(idata->fd);
	g_free(gc->proto_data);
}

static void set_mode_3(struct gaim_connection *gc, char *who, int sign, int mode,
			int start, int end, char *word[])

		id->file_transfers = g_slist_append(id->file_transfers, ift);

		ift->xfer = transfer_out_add(gc, ift->sn);
}


static struct irc_file_transfer *find_ift_by_xfer(struct gaim_connection *gc, 
				struct file_transfer *xfer) {
		
		GSList *g = ((struct irc_data *)gc->proto_data)->file_transfers;
		struct irc_file_transfer *f = NULL;

		return f;
}

static void irc_file_transfer_data_chunk(struct gaim_connection *gc, struct file_transfer *xfer, const char *data, int len) {
	struct irc_data *id = (struct irc_data *)gc->proto_data;
	struct irc_file_transfer *ift = find_ift_by_xfer(gc, xfer);
	guint32 pos;
	
	ift->cur += len;
	pos = htonl(ift->cur);

}

static void irc_file_transfer_in(struct gaim_connection *gc,
				struct file_transfer *xfer, int offset) {

	struct irc_data *id = (struct irc_data *)gc->proto_data;
	struct irc_file_transfer *ift = find_ift_by_xfer(gc, xfer);
	struct sockaddr_in addr;
	char *ip = (char *)malloc(32);

	ift->xfer = xfer;
	proxy_connect(ift->ip, ift->port, dcc_recv_callback, ift);
}

	chat->port = ntohs (addr.sin_port);
	getlocalip(chat->ip_address);
	chat->inpa =
		gaim_input_add (chat->fd, GAIM_INPUT_READ, dcc_chat_connected,
			       chat);
	snprintf (buf, sizeof buf, "\001DCC CHAT chat %s %d\001\n",
		  chat->ip_address, chat->port);
	irc_send_im (gc, who, buf, -1, 0);
}

static void irc_get_info(struct gaim_connection *gc, char *who)

	return m;
}

static struct prpl *my_protocol = NULL;

void irc_init(struct prpl *ret)
{
	struct proto_user_opt *puo;
	ret->protocol = PROTO_IRC;
	ret->options = OPT_PROTO_CHAT_TOPIC | OPT_PROTO_NO_PASSWORD;
	ret->name = g_strdup("IRC");

	my_protocol = ret;
}

#ifndef STATIC

void *gaim_prpl_init(struct prpl* prpl)
{
	irc_init(prpl);
	prpl->plug->desc.api_version = PLUGIN_API_VERSION;
}

3630:9682c0e022c6

 *
 */

#include <config.h>

#ifndef _WIN32
#include <unistd.h>
#else
#include <winsock.h>
#endif

#include <fcntl.h>
#include <errno.h>
#include <string.h>
#include <stdlib.h>
#include <stdio.h>
#include <time.h>

#include "multi.h"
#include "prpl.h"
#include "gaim.h"
#include "proxy.h"

#ifdef _WIN32
#include "win32dep.h"
#endif

#include "pixmaps/protocols/irc/irc_icon.xpm"

#define IRC_BUF_LEN 4096
#define PDIWORDS 32

#define USEROPT_SERV      0
#define USEROPT_PORT      1

/* for win32 compatability */
G_MODULE_IMPORT GSList *connections;


struct dcc_chat
{
	struct gaim_connection *gc;	
	char ip_address[12];	

		struct file_transfer *xfer;
		char *sn;
		char *name;
		int len;
		int watcher;
		int awatcher;
		char ip[12];
		int port;
		int fd;
		int cur;
		struct gaim_connection *gc;

}

static int irc_write(int fd, char *data, int len)
{
	debug_printf("IRC C: %s", data);
#ifndef _WIN32
	return write(fd, data, len);
#else
	return send(fd, data, len, 0);
#endif
}

static struct conversation *irc_find_chat(struct gaim_connection *gc, char *name)
{
	GSList *bcs = gc->buddy_chats;

	gchar buffer[IRC_BUF_LEN];
	gchar buf[128];
	int n = 0, l;
	struct conversation *convo;
	debug_printf("THIS IS TOO MUCH EFFORT\n");
#ifndef _WIN32
	n = read (chat->fd, buffer, IRC_BUF_LEN);
#else
	n = recv (chat->fd, buffer, IRC_BUF_LEN, 0);
#endif
	if (n > 0)
	  {
		  
		  /* Strip the terminating \n */
		  l = 0;

		dcc_chat_cancel (NULL,chat);
	}
}

static void irc_file_transfer_do(struct gaim_connection *gc, struct irc_file_transfer *ift) {
	/* Ok, we better be receiving some crap here boyeee */
	if (transfer_in_do(ift->xfer, ift->fd, ift->name, ift->len)) {
			gaim_input_remove(ift->watcher);
			ift->watcher = 0;
	}
}


void irc_read_dcc_ack (gpointer data, gint source, GaimInputCondition condition) {
		struct irc_file_transfer *ift = data;
		struct irc_data *id = (struct irc_data *)ift->gc->proto_data;
		int len;
		guint32 ack;
		
		printf("I got here.\n");
		len = recv(source, (char *)&ack, 4, MSG_PEEK);
		printf("Len is: %d\n", len);
		printf("Ack is: %d\n", ack);
		recv(source, (char *)&ack, 4, 0);
}

void dcc_send_callback (gpointer data, gint source, GaimInputCondition condition) {
		struct irc_file_transfer *ift = data;
		struct irc_data *id = (struct irc_data *)ift->gc->proto_data;
		struct sockaddr_in addr;

		if (!ift->fd) {
				/* FIXME: Handle this gracefully XXX */
				printf("Something bad happened here, bubba!");
				return;
		}
		
//		ift->awatcher = gaim_input_add(ift->fd, GAIM_INPUT_READ, irc_read_dcc_ack, ift);
		
		if (transfer_out_do(ift->xfer, ift->fd, 0)) {
				gaim_input_remove(ift->watcher);
				ift->watcher = 0;
		}

	struct irc_data *idata = gc->proto_data;
	int i = 0;
	gchar buf[1024];
	gboolean off;

#ifndef _WIN32
	i = read(idata->fd, buf, 1024);
#else
	i = recv(idata->fd, buf, 1024, 0);
#endif
	if (i <= 0) {
		hide_login_progress_error(gc, "Read error");
		signoff(gc);
		return;
	}

	struct irc_data *idata;
	char hostname[256];
	char buf[IRC_BUF_LEN];

	if (!g_slist_find(connections, gc)) {
#ifndef _WIN32
		close(source);
#else
		closesocket(source);
#endif
		return;
	}

	idata = gc->proto_data;

		g_source_remove(idata->timer);

	if (gc->inpa)
		gaim_input_remove(gc->inpa);

#ifndef _WIN32
	close(idata->fd);
#else
	closesocket(idata->fd);
#endif
	g_free(gc->proto_data);
}

static void set_mode_3(struct gaim_connection *gc, char *who, int sign, int mode,
			int start, int end, char *word[])

		id->file_transfers = g_slist_append(id->file_transfers, ift);

		ift->xfer = transfer_out_add(gc, ift->sn);
}

static struct irc_file_transfer *find_ift_by_xfer(struct gaim_connection *gc, 
				struct file_transfer *xfer) {
		
		GSList *g = ((struct irc_data *)gc->proto_data)->file_transfers;
		struct irc_file_transfer *f = NULL;

		return f;
}

static void irc_file_transfer_data_chunk(struct gaim_connection *gc, struct file_transfer *xfer, const char *data, int len) {
	struct irc_file_transfer *ift = find_ift_by_xfer(gc, xfer);
	guint32 pos;
	
	ift->cur += len;
	pos = htonl(ift->cur);

}

static void irc_file_transfer_in(struct gaim_connection *gc,
				struct file_transfer *xfer, int offset) {

	struct irc_file_transfer *ift = find_ift_by_xfer(gc, xfer);

	ift->xfer = xfer;
	proxy_connect(ift->ip, ift->port, dcc_recv_callback, ift);
}

	chat->port = ntohs (addr.sin_port);
	getlocalip(chat->ip_address);
	chat->inpa =
		gaim_input_add (chat->fd, GAIM_INPUT_READ, dcc_chat_connected,
			       chat);
	g_snprintf (buf, sizeof buf, "\001DCC CHAT chat %s %d\001\n",
		  chat->ip_address, chat->port);
	irc_send_im (gc, who, buf, -1, 0);
}

static void irc_get_info(struct gaim_connection *gc, char *who)

	return m;
}

static struct prpl *my_protocol = NULL;

G_MODULE_EXPORT void irc_init(struct prpl *ret)
{
	struct proto_user_opt *puo;
	ret->protocol = PROTO_IRC;
	ret->options = OPT_PROTO_CHAT_TOPIC | OPT_PROTO_NO_PASSWORD;
	ret->name = g_strdup("IRC");

	my_protocol = ret;
}

#ifndef STATIC
G_MODULE_EXPORT void gaim_prpl_init(struct prpl* prpl)
{
	irc_init(prpl);
	prpl->plug->desc.api_version = PLUGIN_API_VERSION;
}