Context Navigation

source: irc_im.c @ a7baf40

Last change on this file since a7baf40 was 30093fa, checked in by dequis <dx@…>, at 2016-11-12T02:30:32Z
otr: word_wrap long system messages ("unencrypted message received")
Property mode set to `100644`
File size: 27.9 KB

Line
1	/********************************************************************\
2	* BitlBee -- An IRC to other IM-networks gateway *
3	* *
4	* Copyright 2002-2012 Wilmer van der Gaast and others *
5	\********************************************************************/
6
7	/* Some glue to put the IRC and the IM stuff together. */
8
9	/*
10	This program is free software; you can redistribute it and/or modify
11	it under the terms of the GNU General Public License as published by
12	the Free Software Foundation; either version 2 of the License, or
13	(at your option) any later version.
14
15	This program is distributed in the hope that it will be useful,
16	but WITHOUT ANY WARRANTY; without even the implied warranty of
17	MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
18	GNU General Public License for more details.
19
20	You should have received a copy of the GNU General Public License with
21	the Debian GNU/Linux distribution in /usr/share/common-licenses/GPL;
22	if not, write to the Free Software Foundation, Inc., 51 Franklin St.,
23	Fifth Floor, Boston, MA 02110-1301 USA
24	*/
25
26	#include "bitlbee.h"
27	#include "dcc.h"
28
29	/* IM->IRC callbacks: Simple IM/buddy-related stuff. */
30
31	static const struct irc_user_funcs irc_user_im_funcs;
32
33	static void bee_irc_imc_connected(struct im_connection *ic)
34	{
35	irc_t irc = (irc_t ) ic->bee->ui_data;
36
37	irc_channel_auto_joins(irc, ic->acc);
38	}
39
40	static void bee_irc_imc_disconnected(struct im_connection *ic)
41	{
42	/* Maybe try to send /QUITs here instead of later on. */
43	}
44
45	static gboolean bee_irc_user_new(bee_t bee, bee_user_t bu)
46	{
47	irc_user_t *iu;
48	irc_t irc = (irc_t ) bee->ui_data;
49	char nick[MAX_NICK_LENGTH + 1], *s;
50
51	memset(nick, 0, MAX_NICK_LENGTH + 1);
52	strncpy(nick, nick_get(bu), MAX_NICK_LENGTH);
53
54	bu->ui_data = iu = irc_user_new(irc, nick);
55	iu->bu = bu;
56
57	if (set_getbool(&irc->b->set, "private")) {
58	iu->last_channel = NULL;
59	} else {
60	iu->last_channel = irc_channel_with_user(irc, iu);
61	}
62
63	if ((s = strchr(bu->handle, '@'))) {
64	iu->host = g_strdup(s + 1);
65	iu->user = g_strndup(bu->handle, s - bu->handle);
66	} else {
67	iu->user = g_strdup(bu->handle);
68	if (bu->ic->acc->server) {
69	iu->host = g_strdup(bu->ic->acc->server);
70	} else {
71	char *s;
72	for (s = bu->ic->acc->tag; g_ascii_isalnum(*s); s++) {
73	;
74	}
75	/* Only use the tag if we got to the end of the string.
76	(So allow alphanumerics only. Hopefully not too
77	restrictive.) */
78	if (*s) {
79	iu->host = g_strdup(bu->ic->acc->prpl->name);
80	} else {
81	iu->host = g_strdup(bu->ic->acc->tag);
82	}
83	}
84	}
85
86	/* Sanitize */
87	str_reject_chars(iu->user, " ", '_');
88	str_reject_chars(iu->host, " ", '_');
89
90	if (bu->flags & BEE_USER_LOCAL) {
91	char *s = set_getstr(&bee->set, "handle_unknown");
92
93	if (strcmp(s, "add_private") == 0) {
94	iu->last_channel = NULL;
95	} else if (strcmp(s, "add_channel") == 0) {
96	iu->last_channel = irc->default_channel;
97	}
98	}
99
100	iu->f = &irc_user_im_funcs;
101
102	return TRUE;
103	}
104
105	static gboolean bee_irc_user_free(bee_t bee, bee_user_t bu)
106	{
107	return irc_user_free(bee->ui_data, (irc_user_t *) bu->ui_data);
108	}
109
110	static gboolean bee_irc_user_status(bee_t bee, bee_user_t bu, bee_user_t *old)
111	{
112	irc_t *irc = bee->ui_data;
113	irc_user_t *iu = bu->ui_data;
114
115	/* Do this outside the if below since away state can change without
116	the online state changing. */
117	iu->flags &= ~IRC_USER_AWAY;
118	if (bu->flags & BEE_USER_AWAY \|\| !(bu->flags & BEE_USER_ONLINE)) {
119	iu->flags \|= IRC_USER_AWAY;
120	}
121
122	if ((bu->flags & BEE_USER_ONLINE) != (old->flags & BEE_USER_ONLINE)) {
123	if (bu->flags & BEE_USER_ONLINE) {
124	if (g_hash_table_lookup(irc->watches, iu->key)) {
125	irc_send_num(irc, 600, "%s %s %s %d :%s", iu->nick, iu->user,
126	iu->host, (int) time(NULL), "logged online");
127	}
128	} else {
129	if (g_hash_table_lookup(irc->watches, iu->key)) {
130	irc_send_num(irc, 601, "%s %s %s %d :%s", iu->nick, iu->user,
131	iu->host, (int) time(NULL), "logged offline");
132	}
133
134	/* Send a QUIT since those will also show up in any
135	query windows the user may have, plus it's only
136	one QUIT instead of possibly many (in case of
137	multiple control chans). If there's a channel that
138	shows offline people, a JOIN will follow. */
139	if (set_getbool(&bee->set, "offline_user_quits")) {
140	irc_user_quit(iu, "Leaving...");
141	}
142	}
143	}
144
145	/* Reset this one since the info may have changed. */
146	iu->away_reply_timeout = 0;
147
148	bee_irc_channel_update(irc, NULL, iu);
149
150	/* If away-notify enabled, send status updates when:
151	* Away or Online state changes
152	* Status changes (e.g. "Away" to "Mobile")
153	* Status message changes
154	*/
155	if ((irc->caps & CAP_AWAY_NOTIFY) &&
156	((bu->flags & BEE_USER_AWAY) != (old->flags & BEE_USER_AWAY) \|\|
157	(bu->flags & BEE_USER_ONLINE) != (old->flags & BEE_USER_ONLINE) \|\|
158	(g_strcmp0(bu->status, old->status) != 0) \|\|
159	(g_strcmp0(bu->status_msg, old->status_msg) != 0))) {
160	irc_send_away_notify(iu);
161	}
162
163	return TRUE;
164	}
165
166	void bee_irc_channel_update(irc_t irc, irc_channel_t ic, irc_user_t *iu)
167	{
168	GSList *l;
169
170	if (ic == NULL) {
171	for (l = irc->channels; l; l = l->next) {
172	ic = l->data;
173	/* TODO: Just add a type flag or so.. */
174	if (ic->f == irc->default_channel->f &&
175	(ic->flags & IRC_CHANNEL_JOINED)) {
176	bee_irc_channel_update(irc, ic, iu);
177	}
178	}
179	return;
180	}
181	if (iu == NULL) {
182	for (l = irc->users; l; l = l->next) {
183	iu = l->data;
184	if (iu->bu) {
185	bee_irc_channel_update(irc, ic, l->data);
186	}
187	}
188	return;
189	}
190
191	if (!irc_channel_wants_user(ic, iu)) {
192	irc_channel_del_user(ic, iu, IRC_CDU_PART, NULL);
193	} else {
194	struct irc_control_channel *icc = ic->data;
195	int mode = 0;
196
197	if (!(iu->bu->flags & BEE_USER_ONLINE)) {
198	mode = icc->modes[0];
199	} else if (iu->bu->flags & BEE_USER_AWAY) {
200	mode = icc->modes[1];
201	} else if (iu->bu->flags & BEE_USER_SPECIAL) {
202	mode = icc->modes[2];
203	} else {
204	mode = icc->modes[3];
205	}
206
207	if (!mode) {
208	irc_channel_del_user(ic, iu, IRC_CDU_PART, NULL);
209	} else {
210	irc_channel_add_user(ic, iu);
211	irc_channel_user_set_mode(ic, iu, mode);
212	}
213	}
214	}
215
216	static gboolean bee_irc_user_msg(bee_t bee, bee_user_t bu, const char *msg_, guint32 flags, time_t sent_at)
217	{
218	irc_t *irc = bee->ui_data;
219	irc_user_t iu = (irc_user_t ) bu->ui_data;
220	irc_user_t *src_iu = iu;
221	irc_user_t *dst_iu = irc->user;
222	const char *dst;
223	char *prefix = NULL;
224	char wrapped, ts = NULL;
225	char *msg = g_strdup(msg_);
226	char *message_type = "PRIVMSG";
227	GSList *l;
228
229	if (sent_at > 0 && set_getbool(&irc->b->set, "display_timestamps")) {
230	ts = irc_format_timestamp(irc, sent_at);
231	}
232
233	dst = irc_user_msgdest(iu);
234
235	if (flags & OPT_SELFMESSAGE) {
236	char *setting = set_getstr(&irc->b->set, "self_messages");
237
238	if (is_bool(setting)) {
239	if (bool2int(setting)) {
240	/* set to true, send it with src/dst flipped */
241
242	dst_iu = iu;
243	src_iu = irc->user;
244
245	if (dst == irc->user->nick) {
246	dst = dst_iu->nick;
247	}
248	} else {
249	/* set to false, skip the message completely */
250	goto cleanup;
251	}
252	} else if (g_strncasecmp(setting, "prefix", 6) == 0) {
253	/* third state, prefix, loosely imitates the znc privmsg_prefix module */
254
255	g_free(msg);
256	if (g_strncasecmp(msg_, "/me ", 4) == 0) {
257	msg = g_strdup_printf("/me -> %s", msg_ + 4);
258	} else {
259	msg = g_strdup_printf("-> %s", msg_);
260	}
261
262	if (g_strcasecmp(setting, "prefix_notice") == 0) {
263	message_type = "NOTICE";
264	}
265	}
266
267	}
268
269	if (dst != dst_iu->nick) {
270	/* if not messaging directly (control channel), call user by name */
271	prefix = g_strdup_printf("%s%s%s", dst_iu->nick, set_getstr(&bee->set, "to_char"), ts ? : "");
272	} else {
273	prefix = ts;
274	ts = NULL; /* don't double-free */
275	}
276
277	for (l = irc_plugins; l; l = l->next) {
278	irc_plugin_t *p = l->data;
279	if (p->filter_msg_in) {
280	char *s = p->filter_msg_in(iu, msg, 0);
281	if (s) {
282	if (s != msg) {
283	g_free(msg);
284	}
285	msg = s;
286	} else {
287	/* Modules can swallow messages. */
288	goto cleanup;
289	}
290	}
291	}
292
293	if ((g_strcasecmp(set_getstr(&bee->set, "strip_html"), "always") == 0) \|\|
294	((bu->ic->flags & OPT_DOES_HTML) && set_getbool(&bee->set, "strip_html"))) {
295	char *s = g_strdup(msg);
296	strip_html(s);
297	g_free(msg);
298	msg = s;
299	}
300
301	wrapped = word_wrap(msg, IRC_WORD_WRAP);
302	irc_send_msg(src_iu, message_type, dst, wrapped, prefix);
303	g_free(wrapped);
304
305	cleanup:
306	g_free(prefix);
307	g_free(msg);
308	g_free(ts);
309
310	return TRUE;
311	}
312
313	static gboolean bee_irc_user_typing(bee_t bee, bee_user_t bu, guint32 flags)
314	{
315	irc_t irc = (irc_t ) bee->ui_data;
316
317	if (set_getbool(&bee->set, "typing_notice")) {
318	irc_send_msg_f((irc_user_t *) bu->ui_data, "PRIVMSG", irc->user->nick,
319	"\001TYPING %d\001", (flags >> 8) & 3);
320	} else {
321	return FALSE;
322	}
323
324	return TRUE;
325	}
326
327	static gboolean bee_irc_user_action_response(bee_t bee, bee_user_t bu, const char action, char const args[],
328	void *data)
329	{
330	irc_t irc = (irc_t ) bee->ui_data;
331	GString *msg = g_string_new("\001");
332
333	g_string_append(msg, action);
334	while (*args) {
335	if (strchr(*args, ' ')) {
336	g_string_append_printf(msg, " \"%s\"", *args);
337	} else {
338	g_string_append_printf(msg, " %s", *args);
339	}
340	args++;
341	}
342	g_string_append_c(msg, '\001');
343
344	irc_send_msg((irc_user_t *) bu->ui_data, "NOTICE", irc->user->nick, msg->str, NULL);
345
346	g_string_free(msg, TRUE);
347
348	return TRUE;
349	}
350
351	static gboolean bee_irc_user_nick_update(irc_user_t *iu, gboolean offline_only);
352
353	static gboolean bee_irc_user_fullname(bee_t bee, bee_user_t bu)
354	{
355	irc_user_t iu = (irc_user_t ) bu->ui_data;
356	char *s;
357
358	if (iu->fullname != iu->nick) {
359	g_free(iu->fullname);
360	}
361	iu->fullname = g_strdup(bu->fullname);
362
363	/* Strip newlines (unlikely, but IRC-unfriendly so they must go)
364	TODO(wilmer): Do the same with away msgs again! */
365	for (s = iu->fullname; *s; s++) {
366	if (g_ascii_isspace(*s)) {
367	*s = ' ';
368	}
369	}
370
371	if ((bu->ic->flags & OPT_LOGGED_IN) && set_getbool(&bee->set, "display_namechanges")) {
372	/* People don't like this /NOTICE. Meh, let's go back to the old one.
373	char *msg = g_strdup_printf( "<< \002BitlBee\002 - Changed name to `%s' >>", iu->fullname );
374	irc_send_msg( iu, "NOTICE", irc->user->nick, msg, NULL );
375	*/
376	imcb_log(bu->ic, "User `%s' changed name to `%s'", iu->nick, iu->fullname);
377	}
378
379	bee_irc_user_nick_update(iu, TRUE);
380
381	return TRUE;
382	}
383
384	static gboolean bee_irc_user_nick_hint(bee_t bee, bee_user_t bu, const char *hint)
385	{
386	bee_irc_user_nick_update((irc_user_t *) bu->ui_data, TRUE);
387
388	return TRUE;
389	}
390
391	static gboolean bee_irc_user_nick_change(bee_t bee, bee_user_t bu, const char *nick)
392	{
393	bee_irc_user_nick_update((irc_user_t *) bu->ui_data, FALSE);
394
395	return TRUE;
396	}
397
398	static gboolean bee_irc_user_group(bee_t bee, bee_user_t bu)
399	{
400	irc_user_t iu = (irc_user_t ) bu->ui_data;
401	irc_t irc = (irc_t ) bee->ui_data;
402
403	bee_irc_channel_update(irc, NULL, iu);
404	bee_irc_user_nick_update(iu, FALSE);
405
406	return TRUE;
407	}
408
409	static gboolean bee_irc_user_nick_update(irc_user_t *iu, gboolean offline_only)
410	{
411	bee_user_t *bu = iu->bu;
412	char *newnick;
413
414	if (offline_only && bu->flags & BEE_USER_ONLINE) {
415	/* Ignore if the user is visible already. */
416	return TRUE;
417	}
418
419	if (nick_saved(bu)) {
420	/* The user already assigned a nickname to this person. */
421	return TRUE;
422	}
423
424	newnick = nick_get(bu);
425
426	if (strcmp(iu->nick, newnick) != 0) {
427	nick_dedupe(bu, newnick);
428	irc_user_set_nick(iu, newnick);
429	}
430
431	return TRUE;
432	}
433
434	void bee_irc_user_nick_reset(irc_user_t *iu)
435	{
436	bee_user_t *bu = iu->bu;
437
438	if (bu == FALSE) {
439	return;
440	}
441
442	nick_del(bu);
443	bee_irc_user_nick_update(iu, FALSE);
444
445	}
446
447	/* IRC->IM calls */
448
449	static gboolean bee_irc_user_privmsg_cb(gpointer data, gint fd, b_input_condition cond);
450
451	static gboolean bee_irc_user_privmsg(irc_user_t iu, const char msg)
452	{
453	const char *away;
454
455	if (iu->bu == NULL) {
456	return FALSE;
457	}
458
459	if (iu->last_channel == NULL &&
460	(away = irc_user_get_away(iu)) &&
461	time(NULL) >= iu->away_reply_timeout) {
462	irc_send_num(iu->irc, 301, "%s :%s", iu->nick, away);
463	iu->away_reply_timeout = time(NULL) +
464	set_getint(&iu->irc->b->set, "away_reply_timeout");
465	}
466
467	if (iu->pastebuf == NULL) {
468	iu->pastebuf = g_string_new(msg);
469	} else {
470	b_event_remove(iu->pastebuf_timer);
471	g_string_append_printf(iu->pastebuf, "\n%s", msg);
472	}
473
474	if (set_getbool(&iu->irc->b->set, "paste_buffer")) {
475	int delay;
476
477	if ((delay = set_getint(&iu->irc->b->set, "paste_buffer_delay")) <= 5) {
478	delay *= 1000;
479	}
480
481	iu->pastebuf_timer = b_timeout_add(delay, bee_irc_user_privmsg_cb, iu);
482
483	return TRUE;
484	} else {
485	bee_irc_user_privmsg_cb(iu, 0, 0);
486
487	return TRUE;
488	}
489	}
490
491	static gboolean bee_irc_user_privmsg_cb(gpointer data, gint fd, b_input_condition cond)
492	{
493	irc_user_t *iu = data;
494	char *msg;
495	GSList *l;
496
497	msg = g_string_free(iu->pastebuf, FALSE);
498	iu->pastebuf = NULL;
499	iu->pastebuf_timer = 0;
500
501	for (l = irc_plugins; l; l = l->next) {
502	irc_plugin_t *p = l->data;
503	if (p->filter_msg_out) {
504	char *s = p->filter_msg_out(iu, msg, 0);
505	if (s) {
506	if (s != msg) {
507	g_free(msg);
508	}
509	msg = s;
510	} else {
511	/* Modules can swallow messages. */
512	iu->pastebuf = NULL;
513	g_free(msg);
514	return FALSE;
515	}
516	}
517	}
518
519	bee_user_msg(iu->irc->b, iu->bu, msg, 0);
520
521	g_free(msg);
522
523	return FALSE;
524	}
525
526	static gboolean bee_irc_user_ctcp(irc_user_t iu, char const *ctcp)
527	{
528	if (ctcp[1] && g_strcasecmp(ctcp[0], "DCC") == 0
529	&& g_strcasecmp(ctcp[1], "SEND") == 0) {
530	if (iu->bu && iu->bu->ic && iu->bu->ic->acc->prpl->transfer_request) {
531	file_transfer_t *ft = dcc_request(iu->bu->ic, ctcp);
532	if (ft) {
533	iu->bu->ic->acc->prpl->transfer_request(iu->bu->ic, ft, iu->bu->handle);
534	}
535
536	return TRUE;
537	}
538	} else if (g_strcasecmp(ctcp[0], "TYPING") == 0) {
539	if (iu->bu && iu->bu->ic && iu->bu->ic->acc->prpl->send_typing && ctcp[1]) {
540	int st = ctcp[1][0];
541	if (st >= '0' && st <= '2') {
542	st <<= 8;
543	iu->bu->ic->acc->prpl->send_typing(iu->bu->ic, iu->bu->handle, st);
544	}
545
546	return TRUE;
547	}
548	} else if (g_strcasecmp(ctcp[0], "HELP") == 0 && iu->bu) {
549	GString *supp = g_string_new("Supported CTCPs:");
550	GList *l;
551
552	if (iu->bu->ic && iu->bu->ic->acc->prpl->transfer_request) {
553	g_string_append(supp, " DCC SEND,");
554	}
555	if (iu->bu->ic && iu->bu->ic->acc->prpl->send_typing) {
556	g_string_append(supp, " TYPING,");
557	}
558	if (iu->bu->ic->acc->prpl->buddy_action_list) {
559	for (l = iu->bu->ic->acc->prpl->buddy_action_list(iu->bu); l; l = l->next) {
560	struct buddy_action *ba = l->data;
561	g_string_append_printf(supp, " %s (%s),",
562	ba->name, ba->description);
563	}
564	}
565	g_string_truncate(supp, supp->len - 1);
566	irc_send_msg_f(iu, "NOTICE", iu->irc->user->nick, "\001HELP %s\001", supp->str);
567	g_string_free(supp, TRUE);
568	} else if (iu->bu && iu->bu->ic && iu->bu->ic->acc->prpl->buddy_action) {
569	iu->bu->ic->acc->prpl->buddy_action(iu->bu, ctcp[0], ctcp + 1, NULL);
570	}
571
572	return FALSE;
573	}
574
575	static const struct irc_user_funcs irc_user_im_funcs = {
576	bee_irc_user_privmsg,
577	bee_irc_user_ctcp,
578	};
579
580
581	/* IM->IRC: Groupchats */
582	const struct irc_channel_funcs irc_channel_im_chat_funcs;
583
584	static gboolean bee_irc_chat_new(bee_t bee, struct groupchat c)
585	{
586	irc_t *irc = bee->ui_data;
587	irc_channel_t *ic;
588	char *topic;
589	GSList *l;
590	int i;
591
592	/* Try to find a channel that expects to receive a groupchat.
593	This flag is set earlier in our current call trace. */
594	for (l = irc->channels; l; l = l->next) {
595	ic = l->data;
596	if (ic->flags & IRC_CHANNEL_CHAT_PICKME) {
597	break;
598	}
599	}
600
601	/* If we found none, just generate some stupid name. */
602	if (l == NULL) {
603	for (i = 0; i <= 999; i++) {
604	char name[16];
605	sprintf(name, "#chat_%03d", i);
606	if ((ic = irc_channel_new(irc, name))) {
607	break;
608	}
609	}
610	}
611
612	if (ic == NULL) {
613	return FALSE;
614	}
615
616	c->ui_data = ic;
617	ic->data = c;
618
619	topic = g_strdup_printf(
620	"BitlBee groupchat: \"%s\". Please keep in mind that root-commands won't work here. Have fun!",
621	c->title);
622	irc_channel_set_topic(ic, topic, irc->root);
623	g_free(topic);
624
625	return TRUE;
626	}
627
628	static gboolean bee_irc_chat_free(bee_t bee, struct groupchat c)
629	{
630	irc_channel_t *ic = c->ui_data;
631
632	if (ic == NULL) {
633	return FALSE;
634	}
635
636	if (ic->flags & IRC_CHANNEL_JOINED) {
637	irc_channel_printf(ic, "Cleaning up channel, bye!");
638	}
639
640	ic->data = NULL;
641	c->ui_data = NULL;
642	irc_channel_del_user(ic, ic->irc->user, IRC_CDU_KICK, "Chatroom closed by server");
643
644	return TRUE;
645	}
646
647	static gboolean bee_irc_chat_log(bee_t bee, struct groupchat c, const char *text)
648	{
649	irc_channel_t *ic = c->ui_data;
650
651	if (ic == NULL) {
652	return FALSE;
653	}
654
655	irc_channel_printf(ic, "%s", text);
656
657	return TRUE;
658	}
659
660	static gboolean bee_irc_chat_msg(bee_t bee, struct groupchat c, bee_user_t bu, const char msg, guint32 flags, time_t sent_at)
661	{
662	irc_t *irc = bee->ui_data;
663	irc_user_t *iu = flags & OPT_SELFMESSAGE ? irc->user : bu->ui_data;
664	irc_channel_t *ic = c->ui_data;
665	char wrapped, ts = NULL;
666
667	if (ic == NULL) {
668	return FALSE;
669	}
670
671	if (sent_at > 0 && set_getbool(&bee->set, "display_timestamps")) {
672	ts = irc_format_timestamp(irc, sent_at);
673	}
674
675	wrapped = word_wrap(msg, IRC_WORD_WRAP);
676	irc_send_msg(iu, "PRIVMSG", ic->name, wrapped, ts);
677	g_free(ts);
678	g_free(wrapped);
679
680	return TRUE;
681	}
682
683	static gboolean bee_irc_chat_add_user(bee_t bee, struct groupchat c, bee_user_t *bu)
684	{
685	irc_t *irc = bee->ui_data;
686	irc_channel_t *ic = c->ui_data;
687
688	if (ic == NULL) {
689	return FALSE;
690	}
691
692	irc_channel_add_user(ic, bu == bee->user ? irc->user : bu->ui_data);
693
694	return TRUE;
695	}
696
697	static gboolean bee_irc_chat_remove_user(bee_t bee, struct groupchat c, bee_user_t bu, const char reason)
698	{
699	irc_t *irc = bee->ui_data;
700	irc_channel_t *ic = c->ui_data;
701
702	if (ic == NULL \|\| bu == NULL) {
703	return FALSE;
704	}
705
706	/* TODO: Possible bug here: If a module removes $user here instead of just
707	using imcb_chat_free() and the channel was IRC_CHANNEL_TEMP, we get into
708	a broken state around here. */
709	irc_channel_del_user(ic, bu == bee->user ? irc->user : bu->ui_data, IRC_CDU_PART, reason);
710
711	return TRUE;
712	}
713
714	static gboolean bee_irc_chat_topic(bee_t bee, struct groupchat c, const char new, bee_user_t bu)
715	{
716	irc_channel_t *ic = c->ui_data;
717	irc_t *irc = bee->ui_data;
718	irc_user_t *iu;
719
720	if (ic == NULL) {
721	return FALSE;
722	}
723
724	if (bu == NULL) {
725	iu = irc->root;
726	} else if (bu == bee->user) {
727	iu = irc->user;
728	} else {
729	iu = bu->ui_data;
730	}
731
732	irc_channel_set_topic(ic, new, iu);
733
734	return TRUE;
735	}
736
737	static gboolean bee_irc_chat_name_hint(bee_t bee, struct groupchat c, const char *name)
738	{
739	return irc_channel_name_hint(c->ui_data, name);
740	}
741
742	static gboolean bee_irc_chat_invite(bee_t bee, bee_user_t bu, const char name, const char msg)
743	{
744	char channel, s;
745	irc_t *irc = bee->ui_data;
746	irc_user_t *iu = bu->ui_data;
747	irc_channel_t *chan;
748
749	if (strchr(CTYPES, name[0])) {
750	channel = g_strdup(name);
751	} else {
752	channel = g_strdup_printf("#%s", name);
753	}
754
755	if ((s = strchr(channel, '@'))) {
756	*s = '\0';
757	}
758
759	if (strlen(channel) > MAX_NICK_LENGTH) {
760	/* If the channel name is very long (like those insane GTalk
761	UUID names), try if we can use the inviter's nick. */
762	s = g_strdup_printf("#%s", iu->nick);
763	if (irc_channel_by_name(irc, s) == NULL) {
764	g_free(channel);
765	channel = s;
766	} else {
767	g_free(s);
768	}
769	}
770
771	if ((chan = irc_channel_new(irc, channel)) &&
772	set_setstr(&chan->set, "type", "chat") &&
773	set_setstr(&chan->set, "chat_type", "room") &&
774	set_setstr(&chan->set, "account", bu->ic->acc->tag) &&
775	set_setstr(&chan->set, "room", (char *) name)) {
776	/* I'm assuming that if the user didn't "chat add" the room
777	himself but got invited, it's temporary, so make this a
778	temporary mapping that is removed as soon as we /PART. */
779	chan->flags \|= IRC_CHANNEL_TEMP;
780	} else {
781	irc_channel_free(chan);
782	chan = NULL;
783	}
784	g_free(channel);
785
786	irc_send_msg_f(iu, "PRIVMSG", irc->user->nick, "<< \002BitlBee\002 - Invitation to chatroom %s >>", name);
787	if (msg) {
788	irc_send_msg(iu, "PRIVMSG", irc->user->nick, msg, NULL);
789	}
790	if (chan) {
791	irc_send_msg_f(iu, "PRIVMSG", irc->user->nick, "To join the room, just /join %s", chan->name);
792	irc_send_invite(iu, chan);
793	}
794
795	return TRUE;
796	}
797
798	/* IRC->IM */
799	static gboolean bee_irc_channel_chat_privmsg_cb(gpointer data, gint fd, b_input_condition cond);
800
801	static gboolean bee_irc_channel_chat_privmsg(irc_channel_t ic, const char msg)
802	{
803	struct groupchat *c = ic->data;
804	char trans = NULL, s;
805
806	if (c == NULL) {
807	return FALSE;
808	}
809
810	if (set_getbool(&ic->set, "translate_to_nicks")) {
811	char nick[MAX_NICK_LENGTH + 1];
812	irc_user_t *iu;
813
814	strncpy(nick, msg, MAX_NICK_LENGTH);
815	nick[MAX_NICK_LENGTH] = '\0';
816	if ((s = strchr(nick, ':')) \|\| (s = strchr(nick, ','))) {
817	*s = '\0';
818	if ((iu = irc_user_by_name(ic->irc, nick)) && iu->bu &&
819	iu->bu->nick && irc_channel_has_user(ic, iu)) {
820	trans = g_strconcat(iu->bu->nick, msg + (s - nick), NULL);
821	msg = trans;
822	}
823	}
824	}
825
826	if (set_getbool(&ic->irc->b->set, "paste_buffer")) {
827	int delay;
828
829	if (ic->pastebuf == NULL) {
830	ic->pastebuf = g_string_new(msg);
831	} else {
832	b_event_remove(ic->pastebuf_timer);
833	g_string_append_printf(ic->pastebuf, "\n%s", msg);
834	}
835
836	if ((delay = set_getint(&ic->irc->b->set, "paste_buffer_delay")) <= 5) {
837	delay *= 1000;
838	}
839
840	ic->pastebuf_timer = b_timeout_add(delay, bee_irc_channel_chat_privmsg_cb, ic);
841
842	g_free(trans);
843	return TRUE;
844	} else {
845	bee_chat_msg(ic->irc->b, c, msg, 0);
846	}
847
848	g_free(trans);
849	return TRUE;
850	}
851
852	static gboolean bee_irc_channel_chat_privmsg_cb(gpointer data, gint fd, b_input_condition cond)
853	{
854	irc_channel_t *ic = data;
855
856	if (ic->data) {
857	bee_chat_msg(ic->irc->b, ic->data, ic->pastebuf->str, 0);
858	}
859
860	g_string_free(ic->pastebuf, TRUE);
861	ic->pastebuf = 0;
862	ic->pastebuf_timer = 0;
863
864	return FALSE;
865	}
866
867	static gboolean bee_irc_channel_chat_join(irc_channel_t *ic)
868	{
869	char acc_s, room;
870	account_t *acc;
871
872	if (strcmp(set_getstr(&ic->set, "chat_type"), "room") != 0) {
873	return TRUE;
874	}
875
876	if ((acc_s = set_getstr(&ic->set, "account")) &&
877	(room = set_getstr(&ic->set, "room")) &&
878	(acc = account_get(ic->irc->b, acc_s)) &&
879	acc->ic && (acc->ic->flags & OPT_LOGGED_IN) &&
880	acc->prpl->chat_join) {
881	char *nick;
882	struct groupchat *gc;
883
884	if (!(nick = set_getstr(&ic->set, "nick"))) {
885	nick = ic->irc->user->nick;
886	}
887
888	ic->flags \|= IRC_CHANNEL_CHAT_PICKME;
889	gc = acc->prpl->chat_join(acc->ic, room, nick, NULL, &ic->set);
890	ic->flags &= ~IRC_CHANNEL_CHAT_PICKME;
891
892	if (!gc) {
893	irc_send_num(ic->irc, 403, "%s :Error joining channel (check control channel?)", ic->name);
894	}
895
896	return FALSE;
897	} else {
898	irc_send_num(ic->irc, 403, "%s :Can't join channel, account offline?", ic->name);
899	return FALSE;
900	}
901	}
902
903	static gboolean bee_irc_channel_chat_part(irc_channel_t ic, const char msg)
904	{
905	struct groupchat *c = ic->data;
906
907	if (c && c->ic->acc->prpl->chat_leave) {
908	c->ic->acc->prpl->chat_leave(c);
909	}
910
911	if (!(ic->flags & IRC_CHANNEL_TEMP)) {
912	/* Remove the reference.
913	* We only need it for temp channels that are being freed */
914	ic->data = NULL;
915	}
916
917	return TRUE;
918	}
919
920	static gboolean bee_irc_channel_chat_topic(irc_channel_t ic, const char new)
921	{
922	struct groupchat *c = ic->data;
923
924	if (c == NULL) {
925	return FALSE;
926	}
927
928	if (c->ic->acc->prpl->chat_topic == NULL) {
929	irc_send_num(ic->irc, 482, "%s :IM network does not support channel topics", ic->name);
930	} else {
931	/* TODO: Need more const goodness here, sigh */
932	char *topic = g_strdup(new);
933	c->ic->acc->prpl->chat_topic(c, topic);
934	g_free(topic);
935	}
936
937	/* Whatever happened, the IM module should ack the topic change. */
938	return FALSE;
939	}
940
941	static gboolean bee_irc_channel_chat_invite(irc_channel_t ic, irc_user_t iu)
942	{
943	struct groupchat *c = ic->data;
944	bee_user_t *bu = iu->bu;
945
946	if (bu == NULL) {
947	return FALSE;
948	}
949
950	if (c) {
951	if (iu->bu->ic != c->ic) {
952	irc_send_num(ic->irc, 482, "%s :Can't mix different IM networks in one groupchat", ic->name);
953	} else if (c->ic->acc->prpl->chat_invite) {
954	c->ic->acc->prpl->chat_invite(c, iu->bu->handle, NULL);
955	} else {
956	irc_send_num(ic->irc, 482, "%s :IM protocol does not support room invitations", ic->name);
957	}
958	} else if (bu->ic->acc->prpl->chat_with &&
959	strcmp(set_getstr(&ic->set, "chat_type"), "groupchat") == 0) {
960	ic->flags \|= IRC_CHANNEL_CHAT_PICKME;
961	iu->bu->ic->acc->prpl->chat_with(bu->ic, bu->handle);
962	ic->flags &= ~IRC_CHANNEL_CHAT_PICKME;
963	} else {
964	irc_send_num(ic->irc, 482, "%s :IM protocol does not support room invitations", ic->name);
965	}
966
967	return TRUE;
968	}
969
970	static void bee_irc_channel_chat_kick(irc_channel_t ic, irc_user_t iu, const char *msg)
971	{
972	struct groupchat *c = ic->data;
973	bee_user_t *bu = iu->bu;
974
975	if ((c == NULL) \|\| (bu == NULL)) {
976	return;
977	}
978
979	if (!c->ic->acc->prpl->chat_kick) {
980	irc_send_num(ic->irc, 482, "%s :IM protocol does not support room kicking", ic->name);
981	return;
982	}
983
984	c->ic->acc->prpl->chat_kick(c, iu->bu->handle, msg);
985	}
986
987	static char set_eval_room_account(set_t set, char *value);
988	static char set_eval_chat_type(set_t set, char *value);
989
990	static gboolean bee_irc_channel_init(irc_channel_t *ic)
991	{
992	set_t *s;
993
994	set_add(&ic->set, "account", NULL, set_eval_room_account, ic);
995	set_add(&ic->set, "chat_type", "groupchat", set_eval_chat_type, ic);
996
997	s = set_add(&ic->set, "nick", NULL, NULL, ic);
998	s->flags \|= SET_NULL_OK;
999
1000	set_add(&ic->set, "room", NULL, NULL, ic);
1001	set_add(&ic->set, "translate_to_nicks", "true", set_eval_bool, ic);
1002
1003	/* chat_type == groupchat */
1004	ic->flags \|= IRC_CHANNEL_TEMP;
1005
1006	return TRUE;
1007	}
1008
1009	static char set_eval_room_account(set_t set, char *value)
1010	{
1011	struct irc_channel *ic = set->data;
1012	account_t acc, oa;
1013
1014	if (!(acc = account_get(ic->irc->b, value))) {
1015	return SET_INVALID;
1016	} else if (!acc->prpl->chat_join) {
1017	irc_rootmsg(ic->irc, "Named chatrooms not supported on that account.");
1018	return SET_INVALID;
1019	}
1020
1021	if (set->value && (oa = account_get(ic->irc->b, set->value)) &&
1022	oa->prpl->chat_free_settings) {
1023	oa->prpl->chat_free_settings(oa, &ic->set);
1024	}
1025
1026	if (acc->prpl->chat_add_settings) {
1027	acc->prpl->chat_add_settings(acc, &ic->set);
1028	}
1029
1030	return g_strdup(acc->tag);
1031	}
1032
1033	static char set_eval_chat_type(set_t set, char *value)
1034	{
1035	struct irc_channel *ic = set->data;
1036
1037	if (strcmp(value, "groupchat") == 0) {
1038	ic->flags \|= IRC_CHANNEL_TEMP;
1039	} else if (strcmp(value, "room") == 0) {
1040	ic->flags &= ~IRC_CHANNEL_TEMP;
1041	} else {
1042	return NULL;
1043	}
1044
1045	return value;
1046	}
1047
1048	static gboolean bee_irc_channel_free(irc_channel_t *ic)
1049	{
1050	struct groupchat *c = ic->data;
1051
1052	set_del(&ic->set, "account");
1053	set_del(&ic->set, "chat_type");
1054	set_del(&ic->set, "nick");
1055	set_del(&ic->set, "room");
1056	set_del(&ic->set, "translate_to_nicks");
1057
1058	ic->flags &= ~IRC_CHANNEL_TEMP;
1059
1060	/* That one still points at this channel. Don't. */
1061	if (c) {
1062	c->ui_data = NULL;
1063	}
1064
1065	return TRUE;
1066	}
1067
1068	const struct irc_channel_funcs irc_channel_im_chat_funcs = {
1069	bee_irc_channel_chat_privmsg,
1070	bee_irc_channel_chat_join,
1071	bee_irc_channel_chat_part,
1072	bee_irc_channel_chat_topic,
1073	bee_irc_channel_chat_invite,
1074	bee_irc_channel_chat_kick,
1075
1076	bee_irc_channel_init,
1077	bee_irc_channel_free,
1078	};
1079
1080
1081	/* IM->IRC: File transfers */
1082	static file_transfer_t bee_irc_ft_in_start(bee_t bee, bee_user_t bu, const char file_name, size_t file_size)
1083	{
1084	return dccs_send_start(bu->ic, (irc_user_t *) bu->ui_data, file_name, file_size);
1085	}
1086
1087	static gboolean bee_irc_ft_out_start(struct im_connection ic, file_transfer_t ft)
1088	{
1089	return dccs_recv_start(ft);
1090	}
1091
1092	static void bee_irc_ft_close(struct im_connection ic, file_transfer_t ft)
1093	{
1094	return dcc_close(ft);
1095	}
1096
1097	static void bee_irc_ft_finished(struct im_connection ic, file_transfer_t file)
1098	{
1099	dcc_file_transfer_t *df = file->priv;
1100
1101	if (file->bytes_transferred >= file->file_size) {
1102	dcc_finish(file);
1103	} else {
1104	df->proto_finished = TRUE;
1105	}
1106	}
1107
1108	static void bee_irc_log(bee_t bee, const char tag, const char *msg)
1109	{
1110	irc_t irc = (irc_t ) bee->ui_data;
1111
1112	irc_rootmsg(irc, "%s - %s", tag, msg);
1113	}
1114
1115	const struct bee_ui_funcs irc_ui_funcs = {
1116	bee_irc_imc_connected,
1117	bee_irc_imc_disconnected,
1118
1119	bee_irc_user_new,
1120	bee_irc_user_free,
1121	bee_irc_user_fullname,
1122	bee_irc_user_nick_hint,
1123	bee_irc_user_group,
1124	bee_irc_user_status,
1125	bee_irc_user_msg,
1126	bee_irc_user_typing,
1127	bee_irc_user_action_response,
1128
1129	bee_irc_chat_new,
1130	bee_irc_chat_free,
1131	bee_irc_chat_log,
1132	bee_irc_chat_msg,
1133	bee_irc_chat_add_user,
1134	bee_irc_chat_remove_user,
1135	bee_irc_chat_topic,
1136	bee_irc_chat_name_hint,
1137	bee_irc_chat_invite,
1138
1139	bee_irc_ft_in_start,
1140	bee_irc_ft_out_start,
1141	bee_irc_ft_close,
1142	bee_irc_ft_finished,
1143
1144	bee_irc_log,
1145	bee_irc_user_nick_change,
1146	};

Note: See TracBrowser for help on using the repository browser.

Download in other formats: