git-svn-id: https://rathena.svn.sourceforge.net/svnroot/rathena/trunk@5202 54d463be-8e91-2dee-dedb-b68131a5f0ec

2 files changed, 302 insertions, 0 deletions

diff --git a/src/map/irc.c b/src/map/irc.c
new file mode 100644
index 000000000..e72af4d0d
--- /dev/null
+++ b/src/map/irc.c
@@ -0,0 +1,275 @@
+#include <sys/socket.h>

+#include <netinet/in.h>

+#include <sys/time.h>

+#include <sys/ioctl.h>

+#include <arpa/inet.h>

+#include <netdb.h>

+#include <unistd.h>

+#include <lcms.h>

+#include <ctype.h>

+#include <strings.h>

+

+#include "../common/core.h"

+#include "../common/socket.h"

+#include "../common/malloc.h"

+#include "../common/db.h"

+#include "../common/timer.h"

+#include "../common/strlib.h"

+#include "../common/mmo.h"

+#include "../common/showmsg.h"

+#include "../common/version.h"

+

+#include "nullpo.h"

+#include "map.h"

+#include "pc.h"

+#include "irc.h"

+

+short use_irc=0;

+

+short irc_announce_flag=1;

+short irc_announce_mvp_flag=1;

+short irc_announce_jobchange_flag=1;

+short irc_announce_shop_flag=1;

+

+IRC_SI *irc_si=NULL;

+

+char irc_nick[30]="";

+char irc_password[32]="";

+

+char irc_channel[32]="";

+char irc_trade_channel[32]="";

+

+unsigned char irc_ip_str[128]="";

+unsigned long irc_ip=0;

+unsigned short irc_port = 6667;

+int irc_fd=0;

+

+int irc_connect_timer(int tid, unsigned int tick, int id, int data)

+{

+	if(irc_si && session[irc_si->fd])

+		return 0;

+	irc_fd = make_connection(irc_ip,irc_port);

+	if(irc_fd > 0){

+		session[irc_fd]->func_parse = irc_parse;

+	}

+	return 0;

+}

+

+void irc_announce(char *buf)

+{

+	char send_string[256];

+	memset(send_string,'\0',256);

+

+	sprintf(send_string,"PRIVMSG %s :%s",irc_channel, buf);

+	irc_send(send_string);

+}

+

+void irc_announce_jobchange(struct map_session_data *sd)

+{

+	nullpo_retv(sd);

+	char send_string[256];

+	memset(send_string,'\0',256);

+

+	sprintf(send_string,"PRIVMSG %s :%s has changed into a %s.",irc_channel,sd->status.name,job_name(sd->status.class_));

+	irc_send(send_string);

+}

+

+void irc_announce_shop(struct map_session_data *sd, int flag)

+{

+	nullpo_retv(sd);

+

+	char send_string[256];

+	char mapname[16];

+	memset(send_string,'\0',256);

+	memset(mapname,'\0',16);

+	int maplen = 0;

+

+	if(flag){

+		strcpy(mapname, map[sd->bl.m].name);

+		maplen = strcspn(mapname,".");

+		mapname[maplen] = '\0';

+		mapname[0]=toupper(mapname[0]);

+

+		sprintf(send_string,"PRIVMSG %s :%s has opened a shop, %s, at <%d,%d> in %s.",irc_trade_channel,sd->status.name,sd->message,sd->bl.x,sd->bl.y,mapname);

+	} else

+		sprintf(send_string,"PRIVMSG %s :%s has closed their shop.",irc_trade_channel,sd->status.name);

+

+	irc_send(send_string);

+}

+

+void irc_announce_mvp(struct map_session_data *sd, struct mob_data *md)

+{

+	nullpo_retv(sd);

+	nullpo_retv(md);

+

+	char send_string[256];

+	char mapname[16];

+	memset(send_string,'\0',256);

+	memset(mapname,'\0',16);

+	mapname[16]='\0';

+	int maplen = 0;

+

+	strcpy(mapname, map[md->bl.m].name);

+	maplen = strcspn(mapname,".");

+	mapname[maplen] = '\0';

+	mapname[0]=toupper(mapname[0]);

+

+	sprintf(send_string,"PRIVMSG %s :%s the %s has MVP'd %s in %s.",irc_channel,sd->status.name,job_name(sd->status.class_),md->name, mapname);

+	irc_send(send_string);

+}

+

+int irc_parse(int fd)

+{

+	if (session[fd]->eof){

+		do_close(fd);

+		add_timer(gettick() + 15000, irc_connect_timer, 0, 0);

+      	return 0;

+	}

+	if (session[fd]->session_data == NULL){

+		irc_si = (struct IRC_Session_Info*)aCalloc(1, sizeof(struct IRC_Session_Info));

+		irc_si->fd = fd;

+		irc_si->state = 0;

+		session[fd]->session_data = irc_si;

+	}

+	irc_si = (struct IRC_Session_Info*)session[fd]->session_data;

+	if(RFIFOREST(fd) > 0){

+		char *incoming_string=aCalloc(RFIFOREST(fd),sizeof(char));

+		memcpy(incoming_string,RFIFOP(fd,0),RFIFOREST(fd));

+		send_to_parser(fd,incoming_string,"\n");

+		RFIFOSKIP(fd,RFIFOREST(fd));

+		aFree(incoming_string);

+	}

+	return 0;

+}

+

+int irc_keepalive_timer(int tid, unsigned int tick, int id, int data)

+{

+	char send_string[128];

+	memset(send_string,'\0',128);

+

+	sprintf(send_string,"PRIVMSG %s : ", irc_nick);

+	irc_send(send_string);

+	add_timer(gettick() + 45000, irc_keepalive_timer, 0, 0);

+	return 0;

+}

+

+void irc_send_sub(int fd, char transmit[4096])

+{

+	sprintf(transmit,"%s%c",transmit,10);

+	WFIFOHEAD(fd,strlen(transmit));

+	memcpy(WFIFOP(fd,0),transmit, strlen(transmit));

+	WFIFOSET(fd,strlen(transmit));

+}

+

+void irc_send(char *buf)

+{

+	if(!irc_si || !session[irc_si->fd])

+		return;

+

+	char transmit[4096];

+	memset(transmit,'\0',4096);

+

+	sprintf(transmit,buf);

+	irc_send_sub(irc_si->fd,transmit);

+}

+

+void irc_parse_sub(int fd, char *incoming_string)

+{

+	char source[256];

+	char command[256];

+	char target[256];

+	char message[8192];

+	char send_string[8192];

+	char *source_nick=NULL;

+	char *source_ident=NULL;

+	char *source_host=NULL;

+	char *state_mgr=NULL;

+	memset(source,'\0',256);

+	memset(command,'\0',256);

+	memset(target,'\0',256);

+	memset(message,'\0',8192);

+	memset(send_string,'\0',8192);

+

+	sscanf(incoming_string, ":%255s %255s %255s :%4095[^\n]", source, command, target, message);

+	if (source != NULL) {

+		if (strstr(source,"!") != NULL) {

+			source_nick = strtok_r(source,"!",&state_mgr);

+			source_ident = strtok_r(NULL,"@",&state_mgr);

+			source_host = strtok_r(NULL,"%%",&state_mgr);

+		}

+	}

+	if (irc_si->state == 0){

+		sprintf(send_string, "NICK %s", irc_nick);

+		irc_send(send_string);

+		sprintf(send_string, "USER eABot 8 * : eABot");

+		irc_send(send_string);

+		irc_si->state = 1;

+	}

+	else if (irc_si->state == 1){

+		if(!strcmp(command,"001")){

+			ShowStatus("IRC: Connected to IRC.\n");

+			sprintf(send_string, "PRIVMSG nickserv :identify %s", irc_password);

+			irc_send(send_string);

+			sprintf(send_string, "JOIN %s", irc_channel);

+			irc_send(send_string);

+			irc_si->state = 2;

+		}

+		else if(!strcmp(command,"433")){

+	            ShowError("IRC: Nickname %s is already taken, IRC Client unable to connect.\n", irc_nick);

+	        	sprintf(send_string, "QUIT");

+			irc_send(send_string);

+			if(session[fd])

+				session[fd]->eof=1;

+		}

+	}

+	else if (irc_si->state == 2){

+		if(!strcmp(source, "PING")){

+	        	sprintf(send_string, "PONG %s", command);

+			irc_send(send_string);

+		}

+	}

+

+	return;

+}

+

+int send_to_parser(int fd, char *input,char key[2])

+{

+	char *temp_string=NULL;

+	char *state_mgr=NULL;

+	int total_loops=0;

+

+	temp_string = strtok_r(input,key,&state_mgr);

+	while (temp_string != NULL){

+		total_loops = total_loops+1;

+		irc_parse_sub(fd,temp_string);

+		temp_string = strtok_r(NULL,key,&state_mgr);

+	}

+	return total_loops;

+}

+

+void do_final_irc()

+{

+

+}

+

+void do_init_irc()

+{

+	if(!use_irc)

+		return;

+	if (irc_ip_str[strlen(irc_ip_str)-1] == '\n') 

+		irc_ip_str[strlen(irc_ip_str)-1] = '\0'; 

+	struct hostent *irc_hostname;

+	irc_hostname=gethostbyname(irc_ip_str);

+	irc_ip_str[0]='\0';

+	sprintf(irc_ip_str, "%d.%d.%d.%d", (unsigned char)irc_hostname->h_addr[0], (unsigned char)irc_hostname->h_addr[1],

+					   (unsigned char)irc_hostname->h_addr[2], (unsigned char)irc_hostname->h_addr[3]);

+

+	irc_ip=inet_addr(irc_ip_str);

+

+	irc_connect_timer(0, 0, 0, 0);

+

+	add_timer_func_list(irc_connect_timer, "irc_connect_timer");

+	add_timer_func_list(irc_keepalive_timer, "irc_keepalive_timer");

+	add_timer(gettick() + 45000, irc_keepalive_timer, 0, 0);

+}

+

diff --git a/src/map/irc.h b/src/map/irc.h
new file mode 100644
index 000000000..575b93301
--- /dev/null
+++ b/src/map/irc.h
@@ -0,0 +1,27 @@
+#include "map.h"

+

+extern short use_irc;

+

+extern short irc_announce_flag;

+extern short irc_announce_mvp_flag;

+extern short irc_announce_shop_flag;

+extern short irc_announce_jobchange_flag;

+

+void irc_announce(char *buf);

+void irc_announce_jobchange(struct map_session_data *sd);

+void irc_announce_shop(struct map_session_data *sd,int flag);

+void irc_announce_mvp(struct map_session_data *sd, struct mob_data *md);

+

+int irc_parse(int fd);

+void do_final_irc();

+void do_init_irc();

+void irc_send(char *buf);

+void irc_parse_sub(int fd, char *incoming_string);

+int send_to_parser(int fd, char *input,char key[2]);

+struct IRC_Session_Info {

+    int state;

+    int fd;

+    char username[30];

+    char password[33];

+};

+typedef struct IRC_Session_Info IRC_SI;