diff --git a/src/chat_log.c b/src/chat_log.c index 78aa99d1..01e3735f 100644 --- a/src/chat_log.c +++ b/src/chat_log.c @@ -28,34 +28,55 @@ #include "chat_log.h" #include "common.h" -static FILE *chatlog; +static GHashTable *logs; static GTimeZone *tz; +static void _close_file(gpointer key, gpointer value, gpointer user_data); + void chat_log_init(void) { - GString *log_file = g_string_new(getenv("HOME")); - g_string_append(log_file, "/.profanity/log"); - create_dir(log_file->str); - g_string_append(log_file, "/chat.log"); - chatlog = fopen(log_file->str, "a"); - g_string_free(log_file, TRUE); - tz = g_time_zone_new_local(); + logs = g_hash_table_new(NULL, (GEqualFunc) g_strcmp0); } -void chat_log_chat(const char * const user, const char * const msg) +void chat_log_chat(const char * const login, char *other, + const char * const msg, chat_log_direction_t direction) { + gpointer *logpp = g_hash_table_lookup(logs, other); + FILE *logp; + + if (logpp == NULL) { + GString *log_file = g_string_new(getenv("HOME")); + g_string_append(log_file, "/.profanity/log"); + create_dir(log_file->str); + g_string_append_printf(log_file, "/%s.log", other); + logp = fopen(log_file->str, "a"); + g_string_free(log_file, TRUE); + g_hash_table_insert(logs, other, &logp); + } else { + logp = *logpp; + } + GDateTime *dt = g_date_time_new_now(tz); gchar *date_fmt = g_date_time_format(dt, "%d/%m/%Y %H:%M:%S"); - fprintf(chatlog, "%s: %s: %s\n", date_fmt, user, msg); - fflush(chatlog); + if (direction == IN) { + fprintf(logp, "%s: %s: %s\n", date_fmt, other, msg); + } else { + fprintf(logp, "%s: %s: %s\n", date_fmt, login, msg); + } + fflush(logp); g_date_time_unref(dt); } void chat_log_close(void) { - fclose(chatlog); + g_hash_table_foreach(logs, (GHFunc) _close_file, NULL); g_time_zone_unref(tz); } + +static void _close_file(gpointer key, gpointer value, gpointer user_data) +{ + fclose(value); +} diff --git a/src/chat_log.h b/src/chat_log.h index abcd00d1..1cb38746 100644 --- a/src/chat_log.h +++ b/src/chat_log.h @@ -25,8 +25,14 @@ #include +typedef enum { + IN, + OUT +} chat_log_direction_t; + void chat_log_init(void); -void chat_log_chat(const char * const user, const char * const msg); +void chat_log_chat(const char * const login, char *other, + const char * const msg, chat_log_direction_t direction); void chat_log_close(void); #endif diff --git a/src/jabber.c b/src/jabber.c index 377965e2..4e8f7244 100644 --- a/src/jabber.c +++ b/src/jabber.c @@ -169,7 +169,7 @@ void jabber_send(const char * const msg, const char * const recipient) const char *jid = xmpp_conn_get_jid(jabber_conn.conn); - chat_log_chat(jid, msg); + chat_log_chat(jid, (char *)recipient, msg, OUT); } void jabber_roster_request(void) @@ -258,8 +258,10 @@ static int _jabber_message_handler(xmpp_conn_t * const conn, char from_cpy[strlen(from) + 1]; strcpy(from_cpy, from); char *short_from = strtok(from_cpy, "/"); + const char *jid = xmpp_conn_get_jid(jabber_conn.conn); - chat_log_chat(short_from, message); + + chat_log_chat(jid, short_from, message, IN); return 1; }