Mercurial > pidgin
view src/server.c @ 1021:90e8714bf95b
[gaim-migrate @ 1031]
Fixed a few little memory leaks.
committer: Tailor Script <tailor@pidgin.im>
author | Rob Flynn <gaim@robflynn.com> |
---|---|
date | Tue, 24 Oct 2000 01:10:30 +0000 |
parents | c3579d03a0c1 |
children | 5bad25457843 |
line wrap: on
line source
/* * gaim * * Copyright (C) 1998-1999, Mark Spencer <markster@marko.net> * * This program 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 2 of the License, or * (at your option) any later version. * * This program 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 this program; if not, write to the Free Software * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA * */ #ifdef HAVE_CONFIG_H #include "../config.h" #endif #include <time.h> #include <stdio.h> #include <string.h> #include <sys/types.h> #include <sys/stat.h> #include <sys/time.h> #include <unistd.h> #include <gtk/gtk.h> #include <aim.h> extern int gaim_caps; #include "prpl.h" #include "multi.h" #include "gaim.h" #include "pixmaps/ok.xpm" #include "pixmaps/cancel.xpm" int correction_time = 0; void serv_login(struct aim_user *user) { struct prpl *p = find_prpl(user->protocol); if (p && p->login) { debug_printf("Logging in using %s\n", (*p->name)()); (*p->login)(user); } } void serv_close(struct gaim_connection *gc) { if (gc->prpl && gc->prpl->close) (*gc->prpl->close)(gc); account_offline(gc); destroy_gaim_conn(gc); if (connections) return; if (gc->idle_timer > 0) gtk_timeout_remove(gc->idle_timer); gc->idle_timer = -1; } void serv_touch_idle(struct gaim_connection *gc) { /* Are we idle? If so, not anymore */ if (gc->is_idle > 0) { gc->is_idle = 0; serv_set_idle(gc, 0); } time(&gc->lastsent); } static gint check_idle(struct gaim_connection *gc) { time_t t; /* Not idle, really... :) */ update_all_buddies(); plugin_event(event_blist_update, 0, 0, 0, 0); time(&t); if (report_idle != IDLE_GAIM) return TRUE; if (gc->is_idle) return TRUE; if ((t - gc->lastsent) > 600) { /* 15 minutes! */ serv_set_idle(gc, (int)t - gc->lastsent); gc->is_idle = 1; } return TRUE; } void serv_finish_login(struct gaim_connection *gc) { char *buf; if (strlen(gc->user_info)) { buf = g_malloc(strlen(gc->user_info) * 4); strcpy(buf, gc->user_info); serv_set_info(gc, buf); g_free(buf); } if (gc->idle_timer > 0) gtk_timeout_remove(gc->idle_timer); gc->idle_timer = gtk_timeout_add(20000, (GtkFunction)check_idle, gc); serv_touch_idle(gc); time(&gc->login_time); serv_add_buddy(gc->username); } void serv_send_im(struct gaim_connection *gc, char *name, char *message, int away) { if (gc->prpl && gc->prpl->send_im) (*gc->prpl->send_im)(gc, name, message, away); if (!away) serv_touch_idle(gc); } void serv_get_info(char *name) { /* FIXME: getting someone's info? how do you decide something like that? I think that * the buddy list/UI needs to be really changed before this gets fixed*/ struct gaim_connection *g; if (!connections) return; g = connections->data; if (g && g->prpl && g->prpl->get_info) (*g->prpl->get_info)(g, name); } void serv_get_away_msg(char *name) { /* FIXME: see the serv_get_info comment above :-P */ struct gaim_connection *g; if (!connections) return; g = connections->data; if (g && g->prpl && g->prpl->get_info) (*g->prpl->get_away_msg)(g, name); } void serv_get_dir(char *name) { /* FIXME: see the serv_get_info comment above :-P */ struct gaim_connection *g; if (!connections) return; g = connections->data; if (g && g->prpl && g->prpl->get_dir) (*g->prpl->get_dir)(g, name); } void serv_set_dir(char *first, char *middle, char *last, char *maiden, char *city, char *state, char *country, int web) { /* FIXME */ struct gaim_connection *g; if (!connections) return; g = connections->data; if (g && g->prpl && g->prpl->set_dir) (*g->prpl->set_dir)(g, first, middle, last, maiden, city, state, country, web); } void serv_dir_search(char *first, char *middle, char *last, char *maiden, char *city, char *state, char *country, char *email) { /* FIXME */ struct gaim_connection *g; if (!connections) return; g = connections->data; if (g && g->prpl && g->prpl->dir_search) (*g->prpl->dir_search)(g, first, middle, last, maiden, city, state, country, email); } void serv_set_away(char *message) { GSList *c = connections; struct gaim_connection *g; while (c) { g = (struct gaim_connection *)c->data; if (g->prpl && g->prpl->set_away) (*g->prpl->set_away)(g, message); c = c->next; } } void serv_set_info(struct gaim_connection *g, char *info) { if (g->prpl && g->prpl->set_info) (*g->prpl->set_info)(g, info); } void serv_change_passwd(struct gaim_connection *g, char *orig, char *new) { if (g->prpl && g->prpl->change_passwd) (*g->prpl->change_passwd)(g, orig, new); } void serv_add_buddy(char *name) { /* FIXME: this will need to be changed. for now all buddies will be added to * all connections :-P */ GSList *c = connections; struct gaim_connection *g; while (c) { g = (struct gaim_connection *)c->data; if (g->prpl && g->prpl->add_buddy) (*g->prpl->add_buddy)(g, name); c = c->next; } } void serv_add_buddies(GList *buddies) { /* FIXME: see the comment above for adding one buddy :-P */ GSList *c = connections; struct gaim_connection *g; while (c) { g = (struct gaim_connection *)c->data; if (g->prpl && g->prpl->add_buddies) (*g->prpl->add_buddies)(g, buddies); c = c->next; } } void serv_remove_buddy(char *name) { /* FIXME: since we added them to all conns, we need to remove them from all conns */ GSList *c = connections; struct gaim_connection *g; while (c) { g = (struct gaim_connection *)c->data; if (g->prpl && g->prpl->remove_buddy) (*g->prpl->remove_buddy)(g, name); c = c->next; } } void serv_add_permit(char *name) { permdeny = 3; build_permit_tree(); serv_set_permit_deny(); } void serv_add_deny(char *name) { permdeny = 4; build_permit_tree(); serv_set_permit_deny(); } void serv_set_permit_deny() { /* FIXME */ struct gaim_connection *g; if (!connections) return; g = connections->data; if (g && g->protocol == PROTO_TOC) { char buf[MSG_LEN]; int at; GList *list; switch (permdeny) { case PERMIT_ALL: sprintf(buf, "toc_add_permit %s", g->username); sflap_send(g, buf, -1, TYPE_DATA); sprintf(buf, "toc_add_deny"); sflap_send(g, buf, -1, TYPE_DATA); break; case PERMIT_NONE: sprintf(buf, "toc_add_deny %s", g->username); sflap_send(g, buf, -1, TYPE_DATA); sprintf(buf, "toc_add_permit"); sflap_send(g, buf, -1, TYPE_DATA); break; case PERMIT_SOME: at = g_snprintf(buf, sizeof(buf), "toc_add_permit"); list = permit; while (list) { at += g_snprintf(&buf[at], sizeof(buf) - at, " %s", normalize(list->data)); list = list->next; } buf[at] = 0; /* is this necessary? */ sflap_send(g, buf, -1, TYPE_DATA); break; case DENY_SOME: /* you'll still see people as being online, but they won't see you, and you * won't get updates for them. that's why i thought this was broken. */ at = g_snprintf(buf, sizeof(buf), "toc_add_deny"); list = deny; while (list) { at += g_snprintf(&buf[at], sizeof(buf) - at, " %s", normalize(list->data)); list = list->next; } buf[at] = 0; /* is this necessary? */ sflap_send(g, buf, -1, TYPE_DATA); break; } } else if (g->protocol == PROTO_OSCAR) { /* int at; GList *list; char buf[MSG_LEN]; switch (permdeny) { case PERMIT_ALL: aim_bos_changevisibility(gaim_sess, gaim_conn, AIM_VISIBILITYCHANGE_DENYADD, current_user->username); break; case PERMIT_NONE: aim_bos_changevisibility(gaim_sess, gaim_conn, AIM_VISIBILITYCHANGE_PERMITADD, current_user->username); break; case PERMIT_SOME: at = g_snprintf(buf, sizeof(buf), "%s", current_user->username); list = permit; while (list) { at += g_snprintf(&buf[at], sizeof(buf) - at, "&"); at += g_snprintf(&buf[at], sizeof(buf) - at, "%s", list->data); list = list->next; } aim_bos_changevisibility(gaim_sess, gaim_conn, AIM_VISIBILITYCHANGE_PERMITADD, buf); break; case DENY_SOME: if (deny) { at = 0; list = deny; while (list) { at += g_snprintf(&buf[at], sizeof(buf) - at, "%s", list->data); list = list->next; if (list) at += g_snprintf(&buf[at], sizeof(buf) - at, "&"); } sprintf(debug_buff, "denying %s\n", buf); debug_print(debug_buff); aim_bos_changevisibility(gaim_sess, gaim_conn, AIM_VISIBILITYCHANGE_DENYADD, buf); } else { aim_bos_changevisibility(gaim_sess, gaim_conn, AIM_VISIBILITYCHANGE_DENYADD, current_user->username); } break; } */ } do_export(0, 0); serv_save_config(); } void serv_set_idle(struct gaim_connection *g, int time) { if (g->prpl && g->prpl->set_idle) (*g->prpl->set_idle)(g, time); } void serv_warn(struct gaim_connection *g, char *name, int anon) { if (g->prpl && g->prpl->warn) (*g->prpl->warn)(g, name, anon); } void serv_build_config(char *buf, int len, gboolean show) { toc_build_config(buf, len, show); } void serv_save_config() { /* FIXME */ struct gaim_connection *g; if (!connections) return; g = connections->data; if (g && g->protocol == PROTO_TOC) { char *buf = g_malloc(BUF_LONG); char *buf2 = g_malloc(MSG_LEN); serv_build_config(buf, BUF_LONG / 2, FALSE); g_snprintf(buf2, MSG_LEN, "toc_set_config {%s}", buf); sflap_send(g, buf2, -1, TYPE_DATA); g_free(buf2); g_free(buf); } } void serv_accept_chat(struct gaim_connection *g, int i) { if (g->prpl && g->prpl->accept_chat) (*g->prpl->accept_chat)(g, i); } void serv_join_chat(struct gaim_connection *g, int exchange, char *name) { if (g->prpl && g->prpl->join_chat) (*g->prpl->join_chat)(g, exchange, name); } void serv_chat_invite(struct gaim_connection *g, int id, char *message, char *name) { if (g->prpl && g->prpl->chat_invite) (*g->prpl->chat_invite)(g, id, message, name); } void serv_chat_leave(struct gaim_connection *g, int id) { /* i think this is the only one this should be necessary for since this is the * only thing that could possibly get called after the connection is closed */ if (!g_slist_find(connections, g)) return; if (g->prpl && g->prpl->chat_leave) (*g->prpl->chat_leave)(g, id); } void serv_chat_whisper(struct gaim_connection *g, int id, char *who, char *message) { if (g->prpl && g->prpl->chat_whisper) (*g->prpl->chat_whisper)(g, id, who, message); } void serv_chat_send(struct gaim_connection *g, int id, char *message) { if (g->prpl && g->prpl->chat_send) (*g->prpl->chat_send)(g, id, message); serv_touch_idle(g); } void serv_got_im(struct gaim_connection *gc, char *name, char *message, int away) { struct conversation *cnv; int is_idle = -1; int new_conv = 0; char *buffy = g_strdup(message); char *angel = g_strdup(name); plugin_event(event_im_recv, gc, &angel, &buffy, 0); if (!buffy || !angel) return; g_snprintf(message, strlen(message) + 1, "%s", buffy); g_free(buffy); g_snprintf(name, strlen(name) + 1, "%s", angel); g_free(angel); if ((general_options & OPT_GEN_TIK_HACK) && awaymessage && !strcmp(message, ">>>Automated Message: Getting Away Message<<<")) { char *tmpmsg = stylize(awaymessage->message, MSG_LEN); serv_send_im(gc, name, tmpmsg, 1); g_free(tmpmsg); return; } cnv = find_conversation(name); if (general_options & OPT_GEN_SEND_LINKS) { linkify_text(message); } if (away) away = WFLAG_AUTO; if (awaymessage != NULL) { if (!(general_options & OPT_GEN_DISCARD_WHEN_AWAY)) { if (cnv == NULL) { new_conv = 1; cnv = new_conversation(name); } } if (cnv != NULL) { if (sound_options & OPT_SOUND_WHEN_AWAY) play_sound(RECEIVE); write_to_conv(cnv, message, away | WFLAG_RECV, NULL); } } else { if (cnv == NULL) { new_conv = 1; cnv = new_conversation(name); } if (new_conv && (sound_options & OPT_SOUND_FIRST_RCV)) { play_sound(FIRST_RECEIVE); } else { if (cnv->makesound && (sound_options & OPT_SOUND_RECV)) play_sound(RECEIVE); } write_to_conv(cnv, message, away | WFLAG_RECV, NULL); } cnv->gc = gc; gtk_option_menu_set_history(GTK_OPTION_MENU(cnv->menu), g_slist_index(connections, gc)); if (awaymessage != NULL) { time_t t; char *tmpmsg; struct buddy *b = find_buddy(name); char *alias = b ? b->show : name; time(&t); if ((cnv == NULL) || (t - cnv->sent_away) < 120) return; cnv->sent_away = t; if (is_idle) is_idle = -1; /* apply default fonts and colors */ tmpmsg = stylize(awaymessage->message, MSG_LEN); /* PRPL */ if (gc->protocol == PROTO_TOC) { escape_text(tmpmsg); escape_message(tmpmsg); } serv_send_im(gc, name, away_subs(tmpmsg, alias), 1); g_free(tmpmsg); tmpmsg = stylize(awaymessage->message, MSG_LEN); if (is_idle == -1) is_idle = 1; if (cnv != NULL) write_to_conv(cnv, away_subs(tmpmsg, alias), WFLAG_SEND | WFLAG_AUTO, NULL); g_free(tmpmsg); } } void serv_got_update(char *name, int loggedin, int evil, time_t signon, time_t idle, int type, u_short caps) { struct buddy *b = find_buddy(name); struct gaim_connection *gc = find_gaim_conn_by_name(name); if (gc) { correction_time = (int)(signon - gc->login_time); update_all_buddies(); if (!b) { return; } } if (!b) { sprintf(debug_buff,"Error, no such person\n"); debug_print(debug_buff); return; } /* This code will 'align' the name from the TOC */ /* server with what's in our record. We want to */ /* store things how THEY want it... */ if (strcmp(name, b->name)) { GList *cnv = conversations; struct conversation *cv; char *who = g_malloc(80); strcpy(who, normalize(name)); while(cnv) { cv = (struct conversation *)cnv->data; if (!strcasecmp(who, normalize(cv->name))) { g_snprintf(cv->name, sizeof(cv->name), "%s", name); if (find_log_info(name) || (general_options & OPT_GEN_LOG_ALL)) g_snprintf(who, 63, LOG_CONVERSATION_TITLE, name); else g_snprintf(who, 63, CONVERSATION_TITLE, name); gtk_window_set_title(GTK_WINDOW(cv->window), who); /* was g_free(buf), but break gives us that * and freeing twice is not good --Sumner */ break; } cnv = cnv->next; } g_free(who); g_snprintf(b->name, sizeof(b->name), "%s", name); /*gtk_label_set_text(GTK_LABEL(b->label), b->name);*/ /* okay lets save the new config... */ } if (!b->idle && idle) plugin_event(event_buddy_idle, b->name, 0, 0, 0); if (b->idle && !idle) plugin_event(event_buddy_unidle, b->name, 0, 0, 0); b->idle = idle; b->evil = evil; if ((b->uc & UC_UNAVAILABLE) && !(type & UC_UNAVAILABLE)) { plugin_event(event_buddy_back, b->name, 0, 0, 0); } else if (!(b->uc & UC_UNAVAILABLE) && (type & UC_UNAVAILABLE)) { plugin_event(event_buddy_away, b->name, 0, 0, 0); } b->uc = type; if (caps) b->caps = caps; b->signon = signon; if (loggedin) { if (!b->present) { b->present = 1; do_pounce(b->name); } } else b->present = 0; set_buddy(b); } static void close_warned(GtkWidget *w, GtkWidget *w2) { gtk_widget_destroy(w2); } void serv_got_eviled(char *name, int lev) { char *buf2 = g_malloc(1024); GtkWidget *d, *label, *close; plugin_event(event_warned, name, (void *)lev, 0, 0); g_snprintf(buf2, 1023, "You have just been warned by %s.\nYour new warning level is %d%%", ((name == NULL) ? "an anonymous person" : name) , lev); d = gtk_dialog_new(); gtk_widget_realize(d); aol_icon(d->window); label = gtk_label_new(buf2); gtk_widget_show(label); close = gtk_button_new_with_label("Close"); if (display_options & OPT_DISP_COOL_LOOK) gtk_button_set_relief(GTK_BUTTON(close), GTK_RELIEF_NONE); gtk_widget_show(close); gtk_box_pack_start(GTK_BOX(GTK_DIALOG(d)->vbox), label, FALSE, FALSE, 5); gtk_box_pack_start(GTK_BOX(GTK_DIALOG(d)->action_area), close, FALSE, FALSE, 5); gtk_window_set_title(GTK_WINDOW(d), "Warned"); gtk_signal_connect(GTK_OBJECT(close), "clicked", GTK_SIGNAL_FUNC(close_warned), d); gtk_widget_show(d); } static void close_invite(GtkWidget *w, GtkWidget *w2) { gtk_widget_destroy(w2); } static void chat_invite_callback(GtkWidget *w, GtkWidget *w2) { struct gaim_connection *g = (struct gaim_connection *) gtk_object_get_user_data(GTK_OBJECT(GTK_DIALOG(w2)->vbox)); if (g->protocol == PROTO_TOC) { int i = (int)gtk_object_get_user_data(GTK_OBJECT(w2)); serv_accept_chat(g, i); gtk_widget_destroy(w2); } else if (g->protocol == PROTO_OSCAR) { char *i = (char *)gtk_object_get_user_data(GTK_OBJECT(w2)); int id = (int)gtk_object_get_user_data(GTK_OBJECT(w)); serv_join_chat(g, id, i); g_free(i); gtk_widget_destroy(w2); } } void serv_got_chat_invite(struct gaim_connection *g, char *name, int id, char *who, char *message) { GtkWidget *d; GtkWidget *label; GtkWidget *yesbtn; GtkWidget *nobtn; char buf2[BUF_LONG]; plugin_event(event_chat_invited, g, who, name, message); if (message) g_snprintf(buf2, sizeof(buf2), "User '%s' invites %s to buddy chat room: '%s'\n%s", who, g->username, name, message); else g_snprintf(buf2, sizeof(buf2), "User '%s' invites %s to buddy chat room: '%s'\n", who, g->username, name); d = gtk_dialog_new(); gtk_widget_realize(d); aol_icon(d->window); label = gtk_label_new(buf2); gtk_widget_show(label); yesbtn = picture_button(d, _("Yes"), ok_xpm); nobtn = picture_button(d, _("No"), cancel_xpm); gtk_widget_show(nobtn); gtk_box_pack_start(GTK_BOX(GTK_DIALOG(d)->vbox), label, FALSE, FALSE, 5); gtk_box_pack_start(GTK_BOX(GTK_DIALOG(d)->action_area), yesbtn, FALSE, FALSE, 5); gtk_box_pack_start(GTK_BOX(GTK_DIALOG(d)->action_area), nobtn, FALSE, FALSE, 5); gtk_object_set_user_data(GTK_OBJECT(GTK_DIALOG(d)->vbox), g); if (g->protocol == PROTO_TOC) { gtk_object_set_user_data(GTK_OBJECT(d), (void *)id); gtk_object_set_user_data(GTK_OBJECT(GTK_DIALOG(d)->vbox), g); } else if (g->protocol == PROTO_OSCAR) { gtk_object_set_user_data(GTK_OBJECT(d), (void *)g_strdup(name)); gtk_object_set_user_data(GTK_OBJECT(yesbtn), (void *)id); } gtk_window_set_title(GTK_WINDOW(d), "Buddy chat invite"); gtk_signal_connect(GTK_OBJECT(nobtn), "clicked", GTK_SIGNAL_FUNC(close_invite), d); gtk_signal_connect(GTK_OBJECT(yesbtn), "clicked", GTK_SIGNAL_FUNC(chat_invite_callback), d); gtk_widget_show(d); } void serv_got_joined_chat(struct gaim_connection *gc, int id, char *name) { struct conversation *b; plugin_event(event_chat_join, gc, name, 0, 0); b = (struct conversation *)g_new0(struct conversation, 1); gc->buddy_chats = g_slist_append(gc->buddy_chats, b); b->is_chat = TRUE; b->ignored = NULL; b->in_room = NULL; b->id = id; b->gc = gc; g_snprintf(b->name, 80, "%s", name); if ((general_options & OPT_GEN_LOG_ALL) || find_log_info(b->name)) { FILE *fd; char *filename; filename = (char *)malloc(100); snprintf(filename, 100, "%s.chat", b->name); fd = open_log_file(filename); if (!(general_options & OPT_GEN_STRIP_HTML)) fprintf(fd, "<HR><BR><H3 Align=Center> ---- New Conversation @ %s ----</H3><BR>\n", full_date()); else fprintf(fd, "---- New Conversation @ %s ----\n", full_date()); fclose(fd); free(filename); } show_new_buddy_chat(b); } void serv_got_chat_left(struct gaim_connection *g, int id) { GSList *bcs = g->buddy_chats; struct conversation *b = NULL; while(bcs) { b = (struct conversation *)bcs->data; if (id == b->id) { break; } b = NULL; bcs = bcs->next; } if (!b) return; plugin_event(event_chat_leave, g, b->name, 0, 0); sprintf(debug_buff, "Leaving room %s.\n", b->name); debug_print(debug_buff); g->buddy_chats = g_slist_remove(g->buddy_chats, b); g_free(b); } void serv_got_chat_in(struct gaim_connection *g, int id, char *who, int whisper, char *message) { int w; GSList *bcs = g->buddy_chats; struct conversation *b = NULL; while(bcs) { b = (struct conversation *)bcs->data; if (id == b->id) break; bcs = bcs->next; b = NULL; } if (!b) return; plugin_event(event_chat_recv, g, b->name, who, message); if (whisper) w = WFLAG_WHISPER; else w = 0; chat_write(b, who, w, message); } void serv_rvous_accept(struct gaim_connection *g, char *name, char *cookie, char *uid) { /* Oscar doesn't matter here because this won't ever be called for it */ char buf[MSG_LEN]; g_snprintf(buf, MSG_LEN, "toc_rvous_accept %s %s %s", normalize(name), cookie, uid); sflap_send(g, buf, -1, TYPE_DATA); } void serv_rvous_cancel(struct gaim_connection *g, char *name, char *cookie, char *uid) { char buf[MSG_LEN]; g_snprintf(buf, MSG_LEN, "toc_rvous_cancel %s %s %s", normalize(name), cookie, uid); sflap_send(g, buf, -1, TYPE_DATA); } void send_keepalive(gpointer d) { struct gaim_connection *gc = (struct gaim_connection *)d; debug_print("sending oscar NOP\n"); if (gc->prpl && gc->prpl->keepalive) (*gc->prpl->keepalive)(gc); } void update_keepalive(struct gaim_connection *gc, gboolean on) { if (on && gc->keepalive < 0 && blist) { debug_print("allowing NOP\n"); gc->keepalive = gtk_timeout_add(60000, (GtkFunction)send_keepalive, gc); } else if (!on && gc->keepalive > -1) { debug_print("removing NOP\n"); gtk_timeout_remove(gc->keepalive); gc->keepalive = -1; } }