/* * Copyright (C) 2003-2010 Sebastien Helleu * * This file is part of WeeChat, the extensible chat client. * * WeeChat is free software; you can redistribute it and/or modify * it under the terms of the GNU General Public License as published by * the Free Software Foundation; either version 3 of the License, or * (at your option) any later version. * * WeeChat is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * GNU General Public License for more details. * * You should have received a copy of the GNU General Public License * along with WeeChat. If not, see . */ /* * xfer-chat.c: chat with direct connection to remote host */ #include #include #include #include #include #include #include "../weechat-plugin.h" #include "xfer.h" #include "xfer-chat.h" #include "xfer-buffer.h" /* * xfer_chat_send: send data to remote host via xfer chat */ int xfer_chat_send (struct t_xfer *xfer, const char *buffer, int size_buf) { if (!xfer) return -1; return send (xfer->sock, buffer, size_buf, 0); } /* * xfer_chat_sendf: send formatted data to remote host via DCC CHAT */ void xfer_chat_sendf (struct t_xfer *xfer, const char *format, ...) { va_list args; static char buffer[4096]; int size_buf; char *ptr_msg, *msg_encoded; if (!xfer || (xfer->sock < 0)) return; va_start (args, format); size_buf = vsnprintf (buffer, sizeof (buffer) - 1, format, args); va_end (args); if (size_buf == 0) return; buffer[sizeof (buffer) - 1] = '\0'; msg_encoded = (xfer->charset_modifier) ? weechat_hook_modifier_exec ("charset_encode", xfer->charset_modifier, buffer) : NULL; ptr_msg = (msg_encoded) ? msg_encoded : buffer; if (xfer_chat_send (xfer, ptr_msg, strlen (ptr_msg)) <= 0) { weechat_printf (NULL, _("%s%s: error sending data to \"%s\" via xfer chat"), weechat_prefix ("error"), XFER_PLUGIN_NAME, xfer->remote_nick); xfer_close (xfer, XFER_STATUS_FAILED); } if (msg_encoded) free (msg_encoded); } /* * xfer_chat_recv_cb: receive data from xfer chat remote host */ int xfer_chat_recv_cb (void *arg_xfer, int fd) { struct t_xfer *xfer; static char buffer[4096 + 2]; char *buf2, *pos, *ptr_buf, *ptr_buf2, *next_ptr_buf; char *ptr_buf_decoded, *ptr_buf_without_weechat_colors, *ptr_buf_color; int num_read, length, ctcp_action; /* make C compiler happy */ (void) fd; xfer = (struct t_xfer *)arg_xfer; num_read = recv (xfer->sock, buffer, sizeof (buffer) - 2, 0); if (num_read > 0) { buffer[num_read] = '\0'; buf2 = NULL; ptr_buf = buffer; if (xfer->unterminated_message) { buf2 = malloc (strlen (xfer->unterminated_message) + strlen (buffer) + 1); if (buf2) { strcpy (buf2, xfer->unterminated_message); strcat (buf2, buffer); } ptr_buf = buf2; free (xfer->unterminated_message); xfer->unterminated_message = NULL; } while (ptr_buf && ptr_buf[0]) { next_ptr_buf = NULL; pos = strstr (ptr_buf, "\n"); if (pos) { pos[0] = '\0'; next_ptr_buf = pos + 1; } else { xfer->unterminated_message = strdup (ptr_buf); ptr_buf = NULL; next_ptr_buf = NULL; } if (ptr_buf) { ctcp_action = 0; length = strlen (ptr_buf); if ((ptr_buf[0] == '\01') && (ptr_buf[length - 1] == '\01')) { ptr_buf[length - 1] = '\0'; ptr_buf++; if (strncmp (ptr_buf, "ACTION ", 7) == 0) { ptr_buf += 7; ctcp_action = 1; } } ptr_buf_decoded = (xfer->charset_modifier) ? weechat_hook_modifier_exec ("charset_decode", xfer->charset_modifier, ptr_buf) : NULL; ptr_buf_without_weechat_colors = weechat_string_remove_color ((ptr_buf_decoded) ? ptr_buf_decoded : ptr_buf, "?"); ptr_buf_color = weechat_hook_modifier_exec ("irc_color_decode", "1", (ptr_buf_without_weechat_colors) ? ptr_buf_without_weechat_colors : ((ptr_buf_decoded) ? ptr_buf_decoded : ptr_buf)); ptr_buf2 = (ptr_buf_color) ? ptr_buf_color : ((ptr_buf_without_weechat_colors) ? ptr_buf_without_weechat_colors : ((ptr_buf_decoded) ? ptr_buf_decoded : ptr_buf)); if (ctcp_action) { weechat_printf_tags (xfer->buffer, "irc_privmsg,irc_action,notify_message", "%s%s%s%s%s%s", weechat_prefix ("action"), (xfer->remote_nick_color) ? xfer->remote_nick_color : weechat_color ("chat_nick_other"), xfer->remote_nick, weechat_color ("chat"), (ptr_buf2[0]) ? " " : "", ptr_buf2); } else { weechat_printf_tags (xfer->buffer, "irc_privmsg,notify_message", "%s%s\t%s", (xfer->remote_nick_color) ? xfer->remote_nick_color : weechat_color ("chat_nick_other"), xfer->remote_nick, ptr_buf2); } if (ptr_buf_decoded) free (ptr_buf_decoded); if (ptr_buf_without_weechat_colors) free (ptr_buf_without_weechat_colors); if (ptr_buf_color) free (ptr_buf_color); } ptr_buf = next_ptr_buf; } if (buf2) free (buf2); } else { xfer_close (xfer, XFER_STATUS_ABORTED); xfer_buffer_refresh (WEECHAT_HOTLIST_MESSAGE); } return WEECHAT_RC_OK; } /* * xfer_chat_buffer_input_cb: callback called when user send data to xfer chat * buffer */ int xfer_chat_buffer_input_cb (void *data, struct t_gui_buffer *buffer, const char *input_data) { struct t_xfer *ptr_xfer; char *input_data_color; /* make C compiler happy */ (void) data; ptr_xfer = xfer_search_by_buffer (buffer); if (!ptr_xfer) { weechat_printf (NULL, _("%s%s: can't find xfer for buffer \"%s\""), weechat_prefix ("error"), XFER_PLUGIN_NAME, weechat_buffer_get_string (buffer, "name")); return WEECHAT_RC_OK; } if (!XFER_HAS_ENDED(ptr_xfer->status)) { xfer_chat_sendf (ptr_xfer, "%s\n", input_data); if (!XFER_HAS_ENDED(ptr_xfer->status)) { input_data_color = weechat_hook_modifier_exec ("irc_color_decode", "1", input_data); weechat_printf_tags (buffer, "irc_privmsg,no_highlight", "%s%s\t%s", weechat_color ("chat_nick_self"), ptr_xfer->local_nick, (input_data_color) ? input_data_color : input_data); if (input_data_color) free (input_data_color); } } return WEECHAT_RC_OK; } /* * xfer_chat_close_buffer_cb: callback called when a buffer with direct chat * is closed */ int xfer_chat_buffer_close_cb (void *data, struct t_gui_buffer *buffer) { struct t_xfer *ptr_xfer; /* make C compiler happy */ (void) data; (void) buffer; for (ptr_xfer = xfer_list; ptr_xfer; ptr_xfer = ptr_xfer->next_xfer) { if (ptr_xfer->buffer == buffer) { if (!XFER_HAS_ENDED(ptr_xfer->status)) { xfer_close (ptr_xfer, XFER_STATUS_ABORTED); xfer_buffer_refresh (WEECHAT_HOTLIST_MESSAGE); } ptr_xfer->buffer = NULL; } } return WEECHAT_RC_OK; } /* * xfer_chat_open_buffer: create buffer for DCC chat */ void xfer_chat_open_buffer (struct t_xfer *xfer) { char *name; int length, buffer_created; buffer_created = 0; length = strlen (xfer->plugin_name) + 8 + strlen (xfer->remote_nick) + 1; name = malloc (length); if (name) { snprintf (name, length, "%s_dcc_%s", xfer->plugin_name, xfer->remote_nick); xfer->buffer = weechat_buffer_search (XFER_PLUGIN_NAME, name); if (!xfer->buffer) { xfer->buffer = weechat_buffer_new (name, &xfer_chat_buffer_input_cb, NULL, &xfer_chat_buffer_close_cb, NULL); buffer_created = 1; /* failed to create buffer ? then return */ if (!xfer->buffer) return; } if (buffer_created) { weechat_buffer_set (xfer->buffer, "title", _("xfer chat")); weechat_buffer_set (xfer->buffer, "short_name", xfer->remote_nick); weechat_buffer_set (xfer->buffer, "localvar_set_type", "private"); weechat_buffer_set (xfer->buffer, "localvar_set_nick", xfer->local_nick); weechat_buffer_set (xfer->buffer, "localvar_set_channel", xfer->remote_nick); weechat_buffer_set (xfer->buffer, "highlight_words_add", "$nick"); weechat_printf (xfer->buffer, _("Connected to %s (%d.%d.%d.%d) via " "xfer chat"), xfer->remote_nick, xfer->address >> 24, (xfer->address >> 16) & 0xff, (xfer->address >> 8) & 0xff, xfer->address & 0xff); } free (name); } }