/*
 * Copyright 2015 Artem Savkov <artem.savkov@gmail.com>
 *
 * 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, see <http://www.gnu.org/licenses/>.
 */
#include "discord-util.h"
#include <http_client.h>
#include <stdarg.h>
#include <inttypes.h>

void discord_debug(char *format, ...)
{
  gchar *buf;
  va_list params;
  va_start(params, format);
  buf = g_strdup_vprintf(format, params);
  va_end(params);

  if (getenv("BITLBEE_DEBUG")) {
    GDateTime *dt = g_date_time_new_now_local();
    gchar *tstr = g_date_time_format(dt, "%T");

    g_print("[%s] %s\n", tstr, buf);

    g_free(tstr);
    g_date_time_unref(dt);
  }
  g_free(buf);
}

void free_user_info(user_info *uinfo)
{
  g_free(uinfo->name);
  g_free(uinfo->id);
  g_free(uinfo);
}

void free_channel_info(channel_info *cinfo)
{
  g_free(cinfo->id);
  cinfo->id = NULL;

  g_slist_free_full(cinfo->pinned, (GDestroyNotify)g_free);
  switch (cinfo->type) {
    case CHANNEL_TEXT:
      if (cinfo->to.channel.gc != NULL) {
        imcb_chat_free(cinfo->to.channel.gc);
      }
      g_free(cinfo->to.channel.name);
      g_free(cinfo->to.channel.bci->title);
      g_free(cinfo->to.channel.bci->topic);
      g_free(cinfo->to.channel.bci);
      break;
    case CHANNEL_GROUP_PRIVATE:
      if (cinfo->to.group.gc != NULL) {
        imcb_chat_free(cinfo->to.group.gc);
      }
      g_free(cinfo->to.group.name);
      g_free(cinfo->to.group.bci->title);
      g_free(cinfo->to.group.bci->topic);
      g_free(cinfo->to.group.bci);
      g_slist_free(cinfo->to.group.users);
      break;
    default:
      g_free(cinfo->to.handle.name);
      break;
  }

  g_free(cinfo);
}

void free_server_info(server_info *sinfo)
{
  g_free(sinfo->name);
  g_free(sinfo->id);

  g_slist_free_full(sinfo->channels, (GDestroyNotify)free_channel_info);
  g_slist_free_full(sinfo->users, (GDestroyNotify)free_user_info);

  g_free(sinfo);
}

void free_gw_data(gw_data *gw)
{
  if (gw != NULL) {
    g_free(gw->addr);
    g_free(gw->path);

    g_free(gw);
  }
}

static void free_pending_req(struct http_request *req)
{
  http_close(req);
}

static void free_pending_ev(gpointer *ev)
{
  b_event_remove(GPOINTER_TO_INT(ev));
}

void free_discord_data(discord_data *dd)
{
  g_hash_table_destroy(dd->sent_message_ids);
  g_slist_free_full(dd->pending_events, (GDestroyNotify)free_pending_ev);
  g_slist_free_full(dd->pending_reqs, (GDestroyNotify)free_pending_req);
  g_slist_free_full(dd->pchannels, (GDestroyNotify)free_channel_info);
  g_slist_free_full(dd->servers, (GDestroyNotify)free_server_info);

  free_gw_data(dd->gateway);
  g_free(dd->token);
  g_free(dd->uname);
  g_free(dd->session_id);
  g_free(dd->id);

  g_free(dd);
}

static gint cmp_chan_id(const channel_info *cinfo, const char *chan_id)
{
  return g_strcmp0(cinfo->id, chan_id);
}

static gint cmp_chan_name(const channel_info *cinfo, const char *cname)
{
  gchar *ciname = NULL;
  if (cinfo->type == CHANNEL_TEXT) {
    ciname = cinfo->to.channel.name;
  } else if (cinfo->type == CHANNEL_GROUP_PRIVATE) {
    ciname = cinfo->to.group.name;
  } else {
    ciname = cinfo->to.handle.name;
  }

  return g_strcmp0(ciname, cname);
}

static gint cmp_chan_fname(const channel_info *cinfo, const char *cname)
{
  gchar *ciname = NULL;
  if (cinfo->type == CHANNEL_TEXT) {
    ciname = cinfo->to.channel.bci->title;
  } else if (cinfo->type == CHANNEL_GROUP_PRIVATE) {
    ciname = cinfo->to.group.bci->title;
  }

  return g_strcmp0(ciname, cname);
}

static gint cmp_chan_name_ignorecase(const channel_info *cinfo,
                                     const char *cname)
{
  gchar *cfn1 = NULL;
  if (cinfo->type == CHANNEL_TEXT) {
    cfn1 = g_utf8_casefold(cinfo->to.channel.name, -1);
  } else if (cinfo->type == CHANNEL_GROUP_PRIVATE) {
    cfn1 = g_utf8_casefold(cinfo->to.group.name, -1);
  } else {
    cfn1 = g_utf8_casefold(cinfo->to.handle.name, -1);
  }

  gchar *cfn2 = g_utf8_casefold(cname, -1);
  gint result = g_strcmp0(cfn1, cfn2);

  g_free(cfn1);
  g_free(cfn2);
  return result;
}

static gint cmp_user_id(const user_info *uinfo, const char *user_id)
{
  return g_strcmp0(uinfo->id, user_id);
}

static gint cmp_user_name(const user_info *uinfo, const char *uname)
{
  return g_strcmp0(uinfo->name, uname);
}

static gint cmp_user_name_ignorecase(const user_info *uinfo, const char *uname)
{
  gchar *cfn1 = g_utf8_casefold(uinfo->name, -1);
  gchar *cfn2 = g_utf8_casefold(uname, -1);
  gint result = g_strcmp0(cfn1, cfn2);

  g_free(cfn1);
  g_free(cfn2);
  return result;
}

static gint cmp_irc_user_name(const user_info *uinfo, const char *uname)
{
  gint result = -1;
  irc_user_t *iu = (irc_user_t*)uinfo->user->ui_data;

  if (iu != NULL) {
    result = g_strcmp0(iu->nick, uname);
  }
  return result;
}

static gint cmp_irc_user_name_ignorecase(const user_info *uinfo, const char *uname)
{
  gint result = -1;
  irc_user_t *iu = (irc_user_t*)uinfo->user->ui_data;

  if (iu != NULL) {
    gchar *cfn1 = g_utf8_casefold(iu->nick, -1);
    gchar *cfn2 = g_utf8_casefold(uname, -1);

    result = g_strcmp0(cfn1, cfn2);

    g_free(cfn1);
    g_free(cfn2);
  }

  return result;
}

static gint cmp_server_id(const server_info *sinfo, const char *server_id)
{
  return g_strcmp0(sinfo->id, server_id);
}

server_info *get_server_by_id(discord_data *dd, const char *server_id)
{
  GSList *sl = g_slist_find_custom(dd->servers, server_id,
                                   (GCompareFunc)cmp_server_id);

  return sl == NULL ?  NULL : sl->data;
}

channel_info *get_channel(discord_data *dd, const char *channel_id,
                          const char *server_id, search_t type)
{
  GSList *cl = NULL;
  GCompareFunc sfunc = NULL;

  switch(type) {
    case SEARCH_ID:
      sfunc = (GCompareFunc)cmp_chan_id;
      break;
    case SEARCH_NAME:
      sfunc = (GCompareFunc)cmp_chan_name;
      break;
    case SEARCH_NAME_IGNORECASE:
      sfunc = (GCompareFunc)cmp_chan_name_ignorecase;
      break;
    case SEARCH_FNAME:
      sfunc = (GCompareFunc)cmp_chan_fname;
      break;
    default:
      return NULL;
  }

  cl = g_slist_find_custom(dd->pchannels, channel_id, sfunc);

  if (cl == NULL) {
    if (server_id != NULL) {
      server_info *sinfo = get_server_by_id(dd, server_id);
      cl = g_slist_find_custom(sinfo->channels, channel_id, sfunc);
    } else {
      for (GSList *sl = dd->servers; sl; sl = g_slist_next(sl)) {
        server_info *sinfo = sl->data;
        cl = g_slist_find_custom(sinfo->channels, channel_id, sfunc);
        if (cl != NULL) {
          break;
        }
      }
    }
  }

  return cl == NULL ?  NULL : cl->data;
}

user_info *get_user(discord_data *dd, const char *uname,
                    const char *server_id, search_t type)
{
  GSList *ul = NULL;
  GCompareFunc sfunc = NULL;

  switch(type) {
    case SEARCH_ID:
      sfunc = (GCompareFunc)cmp_user_id;
      break;
    case SEARCH_NAME:
      sfunc = (GCompareFunc)cmp_user_name;
      break;
    case SEARCH_NAME_IGNORECASE:
      sfunc = (GCompareFunc)cmp_user_name_ignorecase;
      break;
    case SEARCH_IRC_USER_NAME:
      sfunc = (GCompareFunc)cmp_irc_user_name;
      break;
    case SEARCH_IRC_USER_NAME_IGNORECASE:
      sfunc = (GCompareFunc)cmp_irc_user_name_ignorecase;
      break;
    default:
      return NULL;
  }

  if (server_id != NULL) {
    server_info *sinfo = get_server_by_id(dd, server_id);
    ul = g_slist_find_custom(sinfo->users, uname, sfunc);
  } else {
    for (GSList *sl = dd->servers; sl; sl = g_slist_next(sl)) {
      server_info *sinfo = sl->data;
      ul = g_slist_find_custom(sinfo->users, uname, sfunc);
      if (ul != NULL) {
        break;
      }
    }
  }

  return ul == NULL ?  NULL : ul->data;
}

char *discord_canonize_name(const char *name)
{
  return str_reject_chars(g_strdup(name), "@+ ", '_');
}

static gboolean discord_escape(const GMatchInfo *match, GString *result,
                               gpointer user_data)
{
  gchar *mstring = g_match_info_fetch(match, 0);
  gchar *r = g_strdup_printf("\\%s", mstring);
  result = g_string_append(result, r);
  g_free(r);
  g_free(mstring);

  return FALSE;
}

char *discord_escape_string(const char *msg)
{
  GRegex *escregex = g_regex_new("[\\\\\"]", 0, 0, NULL);
  char *nmsg = NULL;
  char *emsg = g_regex_replace_eval(escregex, msg, -1, 0, 0,
                                     discord_escape, NULL, NULL);
  g_regex_unref(escregex);

  escregex = g_regex_new("\t", 0, 0, NULL);
  nmsg = g_regex_replace_literal(escregex, emsg, -1, 0, "\\t", 0, NULL);

  g_free(emsg);
  emsg = nmsg;

  g_regex_unref(escregex);
  escregex = g_regex_new("[\r\n]+", 0, 0, NULL);
  nmsg = g_regex_replace_literal(escregex, emsg, -1, 0, "\\r\\n", 0, NULL);

  g_free(emsg);
  emsg = nmsg;

  g_regex_unref(escregex);

  return emsg;
}

char *discord_utf8_strndup(const char *str, size_t n)
{
  if (g_utf8_strlen(str, -1) <= n) {
    return g_strdup(str);
  }

  return g_strndup(str, g_utf8_offset_to_pointer(str, n) - str);
}

time_t parse_iso_8601(const char *timestamp)
{
#if GLIB_CHECK_VERSION(2,56,0)
  if (!timestamp) return 0;
  GDateTime *dt = g_date_time_new_from_iso8601(timestamp, NULL);
  if (!dt) return 0;
  gint64 unix = g_date_time_to_unix(dt);
  g_date_time_unref(dt);
  return unix;
#else
  GTimeVal gt;
  if (!timestamp) return 0;
  if (!g_time_val_from_iso8601(timestamp, &gt)) return 0;
  return gt.tv_sec;
#endif
}