/*
 *  Copyright (C) 2009 Igalia S.L
 *
 *  This library is free software; you can redistribute it and/or
 *  modify it under the terms of the GNU Lesser General Public
 *  License as published by the Free Software Foundation; either
 *  version 2 of the License, or (at your option) any later version.
 *
 *  This library 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
 *  Lesser General Public License for more details.
 *
 *  You should have received a copy of the GNU Lesser General Public
 *  License along with this library; if not, write to the Free Software
 *  Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301  USA
 */

#include "config.h"
#include "DataSourceGStreamer.h"

#include <gio/gio.h>
#include <glib.h>
#include <gst/gst.h>
#include <gst/pbutils/missing-plugins.h>

static GstStaticPadTemplate src_template = GST_STATIC_PAD_TEMPLATE("src",
                                                                   GST_PAD_SRC,
                                                                   GST_PAD_ALWAYS,
                                                                   GST_STATIC_CAPS_ANY);

GST_DEBUG_CATEGORY_STATIC(webkit_data_src_debug);
#define GST_CAT_DEFAULT webkit_data_src_debug

static void webkit_data_src_uri_handler_init(gpointer g_iface,
                                             gpointer iface_data);

static void webkit_data_src_finalize(WebkitDataSrc* src);
static GstStateChangeReturn webkit_data_src_change_state(GstElement* element,
                                                         GstStateChange transition);

static const GInterfaceInfo urihandler_info = {
    webkit_data_src_uri_handler_init,
    0, 0
};


static void _do_init(GType datasrc_type)
{
    GST_DEBUG_CATEGORY_INIT(webkit_data_src_debug, "webkit_data_src", 0, "datasrc element");
    g_type_add_interface_static(datasrc_type, GST_TYPE_URI_HANDLER,
                                &urihandler_info);
}

GST_BOILERPLATE_FULL(WebkitDataSrc, webkit_data_src, GstBin, GST_TYPE_BIN, _do_init);

static void webkit_data_src_base_init(gpointer klass)
{
    GstElementClass* element_class = GST_ELEMENT_CLASS(klass);

    gst_element_class_add_pad_template(element_class,
                                       gst_static_pad_template_get(&src_template));
    gst_element_class_set_details_simple(element_class, (gchar*) "WebKit data source element",
                                         (gchar*) "Source",
                                         (gchar*) "Handles data: uris",
                                         (gchar*) "Philippe Normand <pnormand@igalia.com>");

}

static void webkit_data_src_class_init(WebkitDataSrcClass* klass)
{
    GObjectClass* oklass = G_OBJECT_CLASS(klass);
    GstElementClass* eklass = GST_ELEMENT_CLASS(klass);

    oklass->finalize = (GObjectFinalizeFunc) webkit_data_src_finalize;
    eklass->change_state = webkit_data_src_change_state;
}


static gboolean webkit_data_src_reset(WebkitDataSrc* src)
{
    GstPad* targetpad;

    if (src->kid) {
        gst_element_set_state(src->kid, GST_STATE_NULL);
        gst_bin_remove(GST_BIN(src), src->kid);
    }

    src->kid = gst_element_factory_make("giostreamsrc", "streamsrc");
    if (!src->kid) {
        GST_ERROR_OBJECT(src, "Failed to create giostreamsrc");
        return FALSE;
    }

    gst_bin_add(GST_BIN(src), src->kid);

    targetpad = gst_element_get_static_pad(src->kid, "src");
    gst_ghost_pad_set_target(GST_GHOST_PAD(src->pad), targetpad);
    gst_object_unref(targetpad);

    return TRUE;
}

static void webkit_data_src_init(WebkitDataSrc* src,
                                 WebkitDataSrcClass* g_class)
{
    GstPadTemplate* pad_template = gst_static_pad_template_get(&src_template);
    src->pad = gst_ghost_pad_new_no_target_from_template("src",
                                                         pad_template);

    gst_element_add_pad(GST_ELEMENT(src), src->pad);

    webkit_data_src_reset(src);
}

static void webkit_data_src_finalize(WebkitDataSrc* src)
{
    g_free(src->uri);

    if (src->kid) {
        GST_DEBUG_OBJECT(src, "Removing giostreamsrc element");
        gst_element_set_state(src->kid, GST_STATE_NULL);
        gst_bin_remove(GST_BIN(src), src->kid);
        src->kid = 0;
    }

    GST_CALL_PARENT(G_OBJECT_CLASS, finalize, ((GObject* )(src)));
}

static GstStateChangeReturn webkit_data_src_change_state(GstElement* element, GstStateChange transition)
{
    GstStateChangeReturn ret = GST_STATE_CHANGE_SUCCESS;
    WebkitDataSrc* src = WEBKIT_DATA_SRC(element);

    switch (transition) {
    case GST_STATE_CHANGE_NULL_TO_READY:
        if (!src->kid) {
            gst_element_post_message(element,
                                     gst_missing_element_message_new(element, "giostreamsrc"));
            GST_ELEMENT_ERROR(src, CORE, MISSING_PLUGIN, (0), ("no giostreamsrc"));
            return GST_STATE_CHANGE_FAILURE;
        }
        break;
    default:
        break;
    }

    ret = GST_ELEMENT_CLASS(parent_class)->change_state(element, transition);
    if (G_UNLIKELY(ret == GST_STATE_CHANGE_FAILURE))
        return ret;

    // Downwards state change code should be here, after chaining up
    // to the parent class.

    return ret;
}

/*** GSTURIHANDLER INTERFACE *************************************************/

static GstURIType webkit_data_src_uri_get_type(void)
{
    return GST_URI_SRC;
}

static gchar** webkit_data_src_uri_get_protocols(void)
{
    static gchar* protocols[] = {(gchar*) "data", 0 };

    return protocols;
}

static const gchar* webkit_data_src_uri_get_uri(GstURIHandler* handler)
{
    WebkitDataSrc* src = WEBKIT_DATA_SRC(handler);

    return src->uri;
}

static gboolean webkit_data_src_uri_set_uri(GstURIHandler* handler, const gchar* uri)
{
    WebkitDataSrc* src = WEBKIT_DATA_SRC(handler);

    // URI as defined in RFC2397:
    // "data:" [ mediatype ] [ ";base64" ] "," data
    // we parse URIs like this one:
    // data:audio/3gpp;base64,AA...

    gchar** scheme_and_remains = g_strsplit(uri, ":", 2);
    gchar** mime_type_and_options = g_strsplit(scheme_and_remains[1], ";", 0);
    gint options_size = g_strv_length(mime_type_and_options);
    gchar* data = 0;
    gchar* mime_type = 0;
    gint ret = FALSE;

    // we require uris with a specified mime-type and base64-encoded
    // data. It doesn't make much sense anyway to play plain/text data
    // with very few allowed characters (as per the RFC).

    if (GST_STATE(src) >= GST_STATE_PAUSED) {
        GST_ERROR_OBJECT(src, "Element already configured. Reset it and retry");
    } else if (!options_size)
        GST_ERROR_OBJECT(src, "A mime-type is needed in %s", uri);
    else {
        mime_type = mime_type_and_options[0];
        data = mime_type_and_options[options_size-1];

        guchar* decoded_data = 0;
        gsize decoded_size;

        if (!g_str_has_prefix(data, "base64"))
            GST_ERROR_OBJECT(src, "Data has to be base64-encoded in %s", uri);
        else {
            decoded_data = g_base64_decode(data+7, &decoded_size);
            GInputStream* stream = g_memory_input_stream_new_from_data(decoded_data,
                                                                       decoded_size,
                                                                       g_free);
            g_object_set(src->kid, "stream", stream, NULL);
            g_object_unref(stream);

            if (src->uri) {
                g_free(src->uri);
                src->uri = 0;
            }

            src->uri = g_strdup(uri);
            ret = TRUE;
        }
    }

    g_strfreev(scheme_and_remains);
    g_strfreev(mime_type_and_options);
    return ret;
}

static void webkit_data_src_uri_handler_init(gpointer g_iface, gpointer iface_data)
{
    GstURIHandlerInterface* iface = (GstURIHandlerInterface *) g_iface;

    iface->get_type = webkit_data_src_uri_get_type;
    iface->get_protocols = webkit_data_src_uri_get_protocols;
    iface->get_uri = webkit_data_src_uri_get_uri;
    iface->set_uri = webkit_data_src_uri_set_uri;
}