/* $Id$ */

/***
  This file is part of gst-polyp.
 
  gst-polyp 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.1 of the
  License, or (at your option) any later version.
 
  gst-polyp 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 gst-polyp; 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 <string.h>
#include <stdio.h>

#include "polypmixer.h"

enum {
    PROP_SERVER = 1,
    PROP_DEVICE,
    PROP_DEVICE_NAME
};

GST_DEBUG_CATEGORY_EXTERN(polyp_debug);
#define GST_CAT_DEFAULT polyp_debug

static void gst_polypmixer_set_property(GObject *object, guint prop_id, const GValue *value, GParamSpec *pspec);
static void gst_polypmixer_get_property(GObject *object, guint prop_id, GValue *value, GParamSpec *pspec);
static void gst_polypmixer_finalize(GObject *object);
static GstStateChangeReturn gst_polypmixer_change_state(GstElement *element, GstStateChange transition);

static void gst_polypmixer_init_interfaces(GType type);

GST_IMPLEMENT_POLYPMIXER_CTRL_METHODS(GstPolypMixer, gst_polypmixer)
GST_IMPLEMENT_POLYPPROBE_METHODS(GstPolypMixer, gst_polypmixer)
GST_BOILERPLATE_FULL(GstPolypMixer, gst_polypmixer, GstElement, GST_TYPE_ELEMENT, gst_polypmixer_init_interfaces)

static gboolean gst_polypmixer_interface_supported(GstImplementsInterface* iface, GType interface_type) {
    GstPolypMixer *this = GST_POLYPMIXER(iface);
    
    if (interface_type == GST_TYPE_MIXER && this->mixer)
        return TRUE;

    if (interface_type == GST_TYPE_PROPERTY_PROBE && this->probe)
        return TRUE;
    
    return FALSE;
}

static void gst_polypmixer_implements_interface_init(GstImplementsInterfaceClass* klass) {
    klass->supported = gst_polypmixer_interface_supported;
}

static void gst_polypmixer_init_interfaces(GType type) {
    static const GInterfaceInfo implements_iface_info = {
        (GInterfaceInitFunc) gst_polypmixer_implements_interface_init,
        NULL,
        NULL,
    };
    static const GInterfaceInfo mixer_iface_info = {
        (GInterfaceInitFunc) gst_polypmixer_mixer_interface_init,
        NULL,
        NULL,
    };
    static const GInterfaceInfo probe_iface_info = {
        (GInterfaceInitFunc) gst_polypmixer_property_probe_interface_init,
        NULL,
        NULL,
    };
    
    g_type_add_interface_static(type, GST_TYPE_IMPLEMENTS_INTERFACE, &implements_iface_info);
    g_type_add_interface_static(type, GST_TYPE_MIXER, &mixer_iface_info);
    g_type_add_interface_static(type, GST_TYPE_PROPERTY_PROBE, &probe_iface_info);
}

static void gst_polypmixer_base_init(gpointer g_class) {

    static const GstElementDetails details =
        GST_ELEMENT_DETAILS(
                "Polypaudio Mixer",
                "Generic/Audio",
                "Control sound input and output levels for Polypaudio",
                "Lennart Poettering");

    gst_element_class_set_details(GST_ELEMENT_CLASS(g_class), &details);
}

static void gst_polypmixer_class_init(GstPolypMixerClass *g_class) {
    GstElementClass *gstelement_class = GST_ELEMENT_CLASS(g_class);
    GObjectClass *gobject_class = G_OBJECT_CLASS(g_class);
    
    gstelement_class->change_state = GST_DEBUG_FUNCPTR(gst_polypmixer_change_state);
    
    gobject_class->finalize = GST_DEBUG_FUNCPTR(gst_polypmixer_finalize);
    gobject_class->get_property = GST_DEBUG_FUNCPTR(gst_polypmixer_get_property);
    gobject_class->set_property = GST_DEBUG_FUNCPTR(gst_polypmixer_set_property);

    g_object_class_install_property(
            gobject_class,
            PROP_SERVER,
            g_param_spec_string("server", "Server", "The Polypaudio server to connect to", NULL, G_PARAM_READWRITE));

    g_object_class_install_property(
            gobject_class,
            PROP_DEVICE,
            g_param_spec_string("device", "Sink/Source", "The Polypaudio sink or source to control", NULL, G_PARAM_READWRITE));

    g_object_class_install_property(
            gobject_class,
            PROP_DEVICE_NAME,
            g_param_spec_string("device-name", "Device name", "Human-readable name of the sound device", NULL, G_PARAM_READABLE));
}

static void gst_polypmixer_init(GstPolypMixer *this, GstPolypMixerClass *g_class) {
    this->mixer = NULL;
    this->server = NULL;
    this->device = NULL;

    this->probe = gst_polypprobe_new(G_OBJECT_GET_CLASS(this), PROP_DEVICE, this->device, TRUE, TRUE);
}

static void gst_polypmixer_finalize(GObject *object) {
    GstPolypMixer *this = GST_POLYPMIXER(object);

    g_free(this->server);
    g_free(this->device);

    if (this->mixer) {
        gst_polypmixer_ctrl_free(this->mixer);
        this->mixer = NULL;
    }

    if (this->probe) {
        gst_polypprobe_free(this->probe);
        this->probe = NULL;
    }
    
    G_OBJECT_CLASS(parent_class)->finalize(object);
}

static void gst_polypmixer_set_property(
        GObject * object,
        guint prop_id,
        const GValue * value,
        GParamSpec * pspec) {
    
    GstPolypMixer *this = GST_POLYPMIXER(object);

    switch (prop_id) {
        case PROP_SERVER:
            g_free(this->server);
            this->server = g_value_dup_string(value);
            break;

        case PROP_DEVICE:
            g_free(this->device);
            this->device = g_value_dup_string(value);

            if (this->probe)
                gst_polypprobe_set_server(this->probe, this->device);
            
            break;

        default:
            G_OBJECT_WARN_INVALID_PROPERTY_ID(object, prop_id, pspec);
            break;
    }
}

static void gst_polypmixer_get_property(
        GObject * object,
        guint prop_id,
        GValue * value,
        GParamSpec * pspec) {
    
    GstPolypMixer *this = GST_POLYPMIXER(object);

    switch(prop_id) {

        case PROP_SERVER:
            g_value_set_string(value, this->server);
            break;

        case PROP_DEVICE:
            g_value_set_string(value, this->device);
            break;

        case PROP_DEVICE_NAME:

            if (this->mixer) {
                char *t = g_strdup_printf("%s - %s [%s]", this->mixer->type == GST_POLYPMIXER_SINK ? "Playback" : "Capture", this->mixer->description, this->mixer->name);
                g_value_set_string(value, t);
                g_free(t);
            } else
                g_value_set_string(value, NULL);
            
            break;
            
        default:
            G_OBJECT_WARN_INVALID_PROPERTY_ID(object, prop_id, pspec);
            break;
    }
}

static GstStateChangeReturn gst_polypmixer_change_state(GstElement *element, GstStateChange transition) {
    GstPolypMixer *this = GST_POLYPMIXER(element);
    
    switch (transition) {
        case GST_STATE_CHANGE_NULL_TO_READY:

            if (!this->mixer)
                this->mixer = gst_polypmixer_ctrl_new(this->server, this->device);
            
            break;
            
        case GST_STATE_CHANGE_READY_TO_NULL:

            if (this->mixer) {
                gst_polypmixer_ctrl_free(this->mixer);
                this->mixer = NULL;
            }
            
            break;
            
        default:
            ;
    }

    if (GST_ELEMENT_CLASS(parent_class)->change_state)
        return GST_ELEMENT_CLASS(parent_class)->change_state(element, transition);
    
    return GST_STATE_CHANGE_SUCCESS;
}