/* Gnome-Streamer
 * Copyright (C) <1999> Erik Walthinsen <omega@cse.ogi.edu>
 *
 * This library is free software; you can redistribute it and/or
 * modify it under the terms of the GNU Library 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
 * Library General Public License for more details.
 *
 * You should have received a copy of the GNU Library General Public
 * License along with this library; if not, write to the
 * Free Software Foundation, Inc., 59 Temple Place - Suite 330,
 * Boston, MA 02111-1307, USA.
 */

/* 2001/04/03 - Updated parseau to use caps nego
 *              Zaheer Merali <zaheer@grid9.net
 */

#include <stdlib.h>
#include <string.h>

#include <gstparseau.h>


/* elementfactory information */
static GstElementDetails gst_parseau_details = {
  ".au parser",
  "Parser/Audio",
  "Parse an .au file into raw audio",
  VERSION,
  "Erik Walthinsen <omega@cse.ogi.edu>",
  "(C) 1999",
};

static GstCaps*
au_typefind (GstBuffer *buf, gpointer private)
{
  GstCaps *new = NULL;
  gulong *head = (gulong *) GST_BUFFER_DATA (buf);

  if (*head == 0x2e736e64 || *head == 0x646e732e)
    new = gst_caps_new ("au_typefind", "audio/au", NULL);

  return new;
}

/* typefactory for 'au' */
static GstTypeDefinition audefinition = {
  "parseau_audio/au",
  "audio/au",
  ".au",
  au_typefind,
};

GST_PADTEMPLATE_FACTORY (sink_factory_templ,
  "sink",
  GST_PAD_SINK,
  GST_PAD_ALWAYS,
  GST_CAPS_NEW (
    "auparse_sink",
    "audio/au",
    NULL
  )
)


GST_PADTEMPLATE_FACTORY (src_factory_templ,
  "src",
  GST_PAD_SRC,
  GST_PAD_ALWAYS,
  GST_CAPS_NEW (
    "auparse_src",
    "audio/raw",
      "format",     GST_PROPS_STRING ("int"),
      //"law",        GST_PROPS_INT_RANGE (0, 2),
      "law",        GST_PROPS_INT (0),
      "endianness", GST_PROPS_INT (G_BYTE_ORDER),
      "signed",     GST_PROPS_LIST(
		      GST_PROPS_BOOLEAN (FALSE),
		      GST_PROPS_BOOLEAN (TRUE)
	  	    ),
      "width",      GST_PROPS_LIST(
		      GST_PROPS_INT (8),
		      GST_PROPS_INT (16)
		    ),
      "depth",      GST_PROPS_LIST(
		      GST_PROPS_INT (8),
		      GST_PROPS_INT (16)
		    ),
      "rate",       GST_PROPS_INT_RANGE (8000,48000),
      "channels",   GST_PROPS_INT_RANGE (1, 2)
  )
)

/* ParseAu signals and args */
enum {
  /* FILL ME */
  LAST_SIGNAL
};

enum {
  ARG_0,
  /* FILL ME */
};

static void 	gst_parseau_class_init		(GstParseAuClass *klass);
static void 	gst_parseau_init		(GstParseAu *parseau);

static void 	gst_parseau_chain		(GstPad *pad,GstBuffer *buf);

static GstElementClass *parent_class = NULL;
//static guint gst_parseau_signals[LAST_SIGNAL] = { 0 };

GType
gst_parseau_get_type (void) 
{
  static GType parseau_type = 0;

  if (!parseau_type) {
    static const GTypeInfo parseau_info = {
      sizeof(GstParseAuClass),      NULL,
      NULL,
      (GClassInitFunc) gst_parseau_class_init,
      NULL,
      NULL,
      sizeof(GstParseAu),
      0,
      (GInstanceInitFunc) gst_parseau_init,
    };
    parseau_type = g_type_register_static (GST_TYPE_ELEMENT, "GstParseAu", &parseau_info, 0);
  }
  return parseau_type;
}

static void
gst_parseau_class_init (GstParseAuClass *klass) 
{
  GstElementClass *gstelement_class;

  gstelement_class = (GstElementClass*) klass;

  parent_class = g_type_class_ref (GST_TYPE_ELEMENT);
}

static void 
gst_parseau_init (GstParseAu *parseau) 
{
  parseau->sinkpad = gst_pad_new_from_template (
		  GST_PADTEMPLATE_GET (sink_factory_templ), "sink");
  gst_pad_set_caps (parseau->sinkpad, gst_pad_get_padtemplate_caps (parseau->sinkpad));
  gst_element_add_pad (GST_ELEMENT (parseau), parseau->sinkpad);
  gst_pad_set_chain_function (parseau->sinkpad, gst_parseau_chain);

  parseau->srcpad = gst_pad_new_from_template (
		  GST_PADTEMPLATE_GET (src_factory_templ), "src");
  gst_element_add_pad (GST_ELEMENT (parseau), parseau->srcpad);

  parseau->offset = 0;
  parseau->size = 0;
  parseau->encoding = 0;
  parseau->frequency = 0;
  parseau->channels = 0;
}

static void 
gst_parseau_chain (GstPad *pad, GstBuffer *buf) 
{
  GstParseAu *parseau;
  gchar *data;
  glong size;
  GstCaps* tempcaps;

  g_return_if_fail (pad != NULL);
  g_return_if_fail (GST_IS_PAD (pad));
  g_return_if_fail (buf != NULL);

  parseau = GST_PARSEAU (gst_pad_get_parent (pad));
  
  GST_DEBUG (0, "gst_parseau_chain: got buffer in '%s'\n",
          gst_element_get_name (GST_ELEMENT (parseau)));

  data = GST_BUFFER_DATA (buf);
  size = GST_BUFFER_SIZE (buf);

  /* if we haven't seen any data yet... */
  if (parseau->size == 0) {
    GstBuffer *newbuf;
    gulong *head = (gulong *)data;

    /* normal format is big endian (au is a Sparc format) */
    if (GULONG_FROM_BE (*(head++)) == 0x2e736e64) {
      parseau->le = 0;
      parseau->offset 		= GULONG_FROM_BE (*(head++));
      parseau->size 		= GULONG_FROM_BE (*(head++));
      parseau->encoding 	= GULONG_FROM_BE (*(head++));
      parseau->frequency 	= GULONG_FROM_BE (*(head++));
      parseau->channels 	= GULONG_FROM_BE (*(head++));

    /* but I wouldn't be surprised by a little endian version */
    } else if (GULONG_FROM_LE (*(head++)) == 0x2e736e64) {
      parseau->le = 1;
      parseau->offset 		= GULONG_FROM_LE(*(head++));
      parseau->size 		= GULONG_FROM_LE(*(head++));
      parseau->encoding 	= GULONG_FROM_LE(*(head++));
      parseau->frequency 	= GULONG_FROM_LE(*(head++));
      parseau->channels 	= GULONG_FROM_LE(*(head++));

    } else {
      g_warning ("help, dunno what I'm looking at!\n");
      gst_buffer_unref(buf);
      return;
    }

    g_print ("offset %ld, size %ld, encoding %ld, frequency %ld, channels %ld\n",
             parseau->offset,parseau->size,parseau->encoding,
             parseau->frequency,parseau->channels);
    GST_DEBUG (0, "offset %ld, size %ld, encoding %ld, frequency %ld, channels %ld\n",
             parseau->offset,parseau->size,parseau->encoding,
             parseau->frequency,parseau->channels);

    tempcaps = gst_caps_copy (gst_pad_get_padtemplate_caps (parseau->srcpad));
    
    gst_caps_set (tempcaps, "format", GST_PROPS_STRING ("int"));
    gst_caps_set (tempcaps, "rate", GST_PROPS_INT (parseau->frequency));
    gst_caps_set (tempcaps, "channels", GST_PROPS_INT (parseau->channels));

    switch (parseau->encoding) {
      case 1:
	gst_caps_set (tempcaps, "law", GST_PROPS_INT (1));
	gst_caps_set (tempcaps, "depth", GST_PROPS_INT (8));
        gst_caps_set (tempcaps, "width", GST_PROPS_INT (8));
        gst_caps_set (tempcaps, "signed", GST_PROPS_BOOLEAN (FALSE));
	break;
      case 2:
	gst_caps_set (tempcaps, "law", GST_PROPS_INT (0));
	gst_caps_set (tempcaps, "depth", GST_PROPS_INT (8));
	gst_caps_set (tempcaps, "width", GST_PROPS_INT (8));
	gst_caps_set (tempcaps, "signed", GST_PROPS_BOOLEAN (TRUE));
	break;
      case 3:
	gst_caps_set (tempcaps, "law", GST_PROPS_INT (0));
	gst_caps_set (tempcaps, "depth", GST_PROPS_INT (16));
	gst_caps_set (tempcaps, "width", GST_PROPS_INT (16));
	gst_caps_set (tempcaps, "signed", GST_PROPS_BOOLEAN (TRUE));
	break;
      default:
	g_warning ("help!, dont know how to deal with this format yet\n");
	return;
    }

    gst_pad_set_caps (parseau->srcpad, tempcaps);

    newbuf = gst_buffer_new ();
    GST_BUFFER_DATA (newbuf) = (gpointer) malloc (size-(parseau->offset));
    memcpy (GST_BUFFER_DATA (newbuf), data+24, size-(parseau->offset));
    GST_BUFFER_SIZE (newbuf) = size-(parseau->offset);

    gst_buffer_unref (buf);

    gst_pad_push (parseau->srcpad, newbuf);
    return;
  }


  gst_pad_push (parseau->srcpad, buf);
}


static gboolean
plugin_init (GModule *module, GstPlugin *plugin)
{
  GstElementFactory *factory;
  GstTypeFactory *type;

  /* create the plugin structure */
  /* create an elementfactory for the parseau element and list it */
  factory = gst_elementfactory_new ("parseau", GST_TYPE_PARSEAU,
                                    &gst_parseau_details);
  g_return_val_if_fail (factory != NULL, FALSE);

  gst_elementfactory_add_padtemplate (factory, GST_PADTEMPLATE_GET (sink_factory_templ));
  gst_elementfactory_add_padtemplate (factory, GST_PADTEMPLATE_GET (src_factory_templ));

  type = gst_typefactory_new (&audefinition);

  gst_plugin_add_feature (plugin, GST_PLUGIN_FEATURE (factory));
  gst_plugin_add_feature (plugin, GST_PLUGIN_FEATURE (type));

  return TRUE;
}

GstPluginDesc plugin_desc = {
  GST_VERSION_MAJOR,
  GST_VERSION_MINOR,
  "parseau",
  plugin_init
};