/*
 * transmission-remote-gtk - A GTK RPC client to Transmission
 * Copyright (C) 2011  Alan Fitton

 * 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.,
 * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
 */

#ifdef HAVE_CONFIG_H
#include "config.h"
#endif

#include <string.h>
#include <glib-object.h>
#include <gconf/gconf-client.h>

#ifdef HAVE_LIBPROXY
#include <proxy.h>
#endif

#include "trg-client.h"
#include "trg-preferences.h"
#include "util.h"
#include "dispatch.h"

gboolean trg_client_supports_tracker_edit(trg_client * tc)
{
    return tc->session && tc->version >= 2.10;
}

trg_client *trg_init_client()
{
    trg_client *client = g_new0(trg_client, 1);

    client->gconf = gconf_client_get_default();
    client->updateMutex = g_mutex_new();
    client->activeOnlyUpdate =
        gconf_client_get_bool(client->gconf,
                              TRG_GCONF_KEY_UPDATE_ACTIVE_ONLY, NULL);
    client->pool = dispatch_init_pool(client);

    return client;
}

#define check_for_error(error) if (error) { g_error_free(error); return TRG_GCONF_SCHEMA_ERROR; }

void trg_client_set_session(trg_client * tc, JsonObject * session)
{
    if (tc->session)
        json_object_unref(tc->session);

    session_get_version(session, &tc->version);

    tc->session = session;
}

int trg_client_populate_with_settings(trg_client * tc, GConfClient * gconf)
{
    gint port;
    gchar *host;
    GError *error = NULL;
#ifdef HAVE_LIBPROXY
    pxProxyFactory *pf = NULL;
#endif

    g_free(tc->url);
    tc->url = NULL;

    g_free(tc->username);
    tc->username = NULL;

    g_free(tc->password);
    tc->password = NULL;

    port =
        gconf_client_get_int_or_default(gconf, TRG_GCONF_KEY_PORT,
                                        TRG_PORT_DEFAULT, &error);
    check_for_error(error);

    host = gconf_client_get_string(gconf, TRG_GCONF_KEY_HOSTNAME, &error);
    check_for_error(error);
    if (!host || strlen(host) < 1)
        return TRG_NO_HOSTNAME_SET;

    tc->ssl = gconf_client_get_bool(gconf, TRG_GCONF_KEY_SSL, &error);
    check_for_error(error);

    tc->url =
        g_strdup_printf("%s://%s:%d/transmission/rpc",
                        tc->ssl ? "https" : "http", host, port);
    g_free(host);

    tc->interval =
        gconf_client_get_int_or_default(gconf,
                                        TRG_GCONF_KEY_UPDATE_INTERVAL,
                                        TRG_INTERVAL_DEFAULT, &error);
    check_for_error(error);
    if (tc->interval < 1)
        tc->interval = TRG_INTERVAL_DEFAULT;

    tc->username =
        gconf_client_get_string(gconf, TRG_GCONF_KEY_USERNAME, &error);
    check_for_error(error);

    tc->password =
        gconf_client_get_string(gconf, TRG_GCONF_KEY_PASSWORD, &error);
    check_for_error(error);

    g_free(tc->proxy);
    tc->proxy = NULL;

#ifdef HAVE_LIBPROXY
    if ((pf = px_proxy_factory_new())) {
        char **proxies = px_proxy_factory_get_proxies(pf, tc->url);
        int i;

        for (i = 0; proxies[i]; i++) {
            if (g_str_has_prefix(proxies[i], "http")) {
                g_free(tc->proxy);
                tc->proxy = proxies[i];
            } else {
                g_free(proxies[i]);
            }
        }

        g_free(proxies);
        px_proxy_factory_free(pf);
    }
#endif

    return 0;
}