/* -*- Mode: C; tab-width: 2; indent-tabs-mode: t; c-basic-offset: 2 -*- */

/* GStreamer

 * Copyright (C) <1999> Erik Walthinsen <omega@cse.ogi.edu>

 * Copyright (C) <2006> Nokia Corporation, Stefan Kost <stefan.kost@nokia.com>.

 *

 * 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.

 */

/**

 * SECTION:element-wavparse

 *

 * <refsect2>

 * <para>

 * Parse a .wav file into raw or compressed audio.

 * </para>

 * <para>

 * This element currently only supports pull based scheduling.

 * </para>

 * <title>Example launch line</title>

 * <para>

 * <programlisting>

 * gst-launch filesrc location=sine.wav ! wavparse ! audioconvert ! alsasink

 * </programlisting>

 * Read a wav file and output to the soundcard using the ALSA element. The

 * wav file is assumed to contain raw uncompressed samples.

 * </para>

 * <para>

 * <programlisting>

 * gst-launch gnomevfssrc location=http://www.example.org/sine.wav ! queue ! wavparse ! audioconvert ! alsasink

 * </programlisting>

 * Stream data from

 * </para>

 * </refsect2>

 *

 * Last reviewed on 2006-03-03 (0.10.3)

 */

#ifdef HAVE_CONFIG_H

#include "config.h"

#endif

#include "string.h"

#include "gstwavparse.h"

#include <gst/riff/riff-ids.h>

#include <gst/riff/riff-media.h>

#include <gst/riff/riff-read.h>

#ifndef __SYMBIAN32__

#include <gst/gst-i18n-plugin.h>

#else

#include "gst/gst-i18n-plugin.h"

#endif

#ifdef __SYMBIAN32__

#include <gst/gstinfo.h>

#endif

#ifndef G_MAXUINT32

#define G_MAXUINT32 0xffffffff

#endif

GST_DEBUG_CATEGORY_STATIC (wavparse_debug);

#define GST_CAT_DEFAULT (wavparse_debug)

static void gst_wavparse_base_init (gpointer g_class);

static void gst_wavparse_class_init (GstWavParseClass * klass);

static void gst_wavparse_init (GstWavParse * wavparse);

static void gst_wavparse_dispose (GObject * object);

static gboolean gst_wavparse_sink_activate (GstPad * sinkpad);

static gboolean gst_wavparse_sink_activate_pull (GstPad * sinkpad,

    gboolean active);

static gboolean gst_wavparse_send_event (GstElement * element,

    GstEvent * event);

static GstFlowReturn gst_wavparse_chain (GstPad * pad, GstBuffer * buf);

static GstStateChangeReturn gst_wavparse_change_state (GstElement * element,

    GstStateChange transition);

static gboolean gst_wavparse_pad_query (GstPad * pad, GstQuery * query);

static const GstQueryType *gst_wavparse_get_query_types (GstPad * pad);

static gboolean gst_wavparse_pad_convert (GstPad * pad,

    GstFormat src_format,

    gint64 src_value, GstFormat * dest_format, gint64 * dest_value);

static void gst_wavparse_loop (GstPad * pad);

static gboolean gst_wavparse_srcpad_event (GstPad * pad, GstEvent * event);

static void gst_wavparse_get_property (GObject * object, guint prop_id,

    GValue * value, GParamSpec * pspec);

static const GstElementDetails gst_wavparse_details =

GST_ELEMENT_DETAILS ("WAV audio demuxer",

    "Codec/Demuxer/Audio",

    "Parse a .wav file into raw audio",

    "Erik Walthinsen <omega@cse.ogi.edu>");

static GstStaticPadTemplate sink_template_factory =

//GST_STATIC_PAD_TEMPLATE ("wavparse_sink",

GST_STATIC_PAD_TEMPLATE ("sink", 

    GST_PAD_SINK,

    GST_PAD_ALWAYS,

    GST_STATIC_CAPS ("audio/x-wav")

    );

/* the pad is marked a sometimes and is added to the element when the

 * exact type is known. This makes it much easier for a static autoplugger

 * to connect the right decoder when needed.

 */

static GstStaticPadTemplate src_template_factory =

 //   GST_STATIC_PAD_TEMPLATE ("wavparse_src",

    GST_STATIC_PAD_TEMPLATE ("src",

    GST_PAD_SRC,

    GST_PAD_SOMETIMES,

    GST_STATIC_CAPS ("audio/x-raw-int, "

        "endianness = (int) little_endian, "

        "signed = (boolean) { true, false }, "

        "width = (int) { 8, 16, 24, 32 }, "

        "depth = (int) { 8, 16, 24, 32 }, "

        "rate = (int) [ 8000, 96000 ], "

        "channels = (int) [ 1, 8 ]; "

        "audio/mpeg, "

        "mpegversion = (int) 1, "

        "layer = (int) [ 1, 3 ], "

        "rate = (int) [ 8000, 48000 ], "

        "channels = (int) [ 1, 2 ]; "

        "audio/x-alaw, "

        "rate = (int) [ 8000, 48000 ], "

        "channels = (int) [ 1, 2 ]; "

        "audio/x-mulaw, "

        "rate = (int) [ 8000, 48000 ], " "channels = (int) [ 1, 2 ];"

        "audio/x-adpcm, "

        "layout = (string) microsoft, "

        "block_align = (int) [ 1, 8192 ], "

        "rate = (int) [ 8000, 48000 ], "

        "channels = (int) [ 1, 2 ]; "

        "audio/x-adpcm, "

        "layout = (string) dvi, "

        "block_align = (int) [ 1, 8192 ], "

        "rate = (int) [ 8000, 48000 ], " "channels = (int) [ 1, 2 ];"

        "audio/x-vnd.sony.atrac3;"

        "audio/x-dts;" "audio/x-wma, " "wmaversion = (int) [ 1, 2 ]")

    );

static GstElementClass *parent_class = NULL;

GType

gst_wavparse_get_type (void)

{

  static GType wavparse_type = 0;

  if (!wavparse_type) {

    static const GTypeInfo wavparse_info = {

      sizeof (GstWavParseClass),

      gst_wavparse_base_init,

      NULL,

      (GClassInitFunc) gst_wavparse_class_init,

      NULL,

      NULL,

      sizeof (GstWavParse),

      0,

      (GInstanceInitFunc) gst_wavparse_init,

    };

    wavparse_type =

        g_type_register_static (GST_TYPE_ELEMENT, "GstWavParse",

        &wavparse_info, 0);

  }

  return wavparse_type;

}

static void

gst_wavparse_base_init (gpointer g_class)

{

  GstElementClass *element_class = GST_ELEMENT_CLASS (g_class);

  /* register src pads */

  gst_element_class_add_pad_template (element_class,

      gst_static_pad_template_get (&sink_template_factory));

  gst_element_class_add_pad_template (element_class,

      gst_static_pad_template_get (&src_template_factory));

  gst_element_class_set_details (element_class, &gst_wavparse_details);

}

static void

gst_wavparse_class_init (GstWavParseClass * klass)

{

  GstElementClass *gstelement_class;

  GObjectClass *object_class;

  gstelement_class = (GstElementClass *) klass;

  object_class = (GObjectClass *) klass;

  parent_class = g_type_class_peek_parent (klass);

  object_class->get_property = gst_wavparse_get_property;

  object_class->dispose = gst_wavparse_dispose;

  gstelement_class->change_state = gst_wavparse_change_state;

  gstelement_class->send_event = gst_wavparse_send_event;

}

static void

gst_wavparse_dispose (GObject * object)

{

	#ifndef __SYMBIAN32__

  GST_DEBUG("WAV: Dispose\n");

  #endif

  GstWavParse *wav = GST_WAVPARSE (object);

  #ifdef __SYMBIAN32__

  GST_DEBUG("WAV: Dispose\n");

	#endif

  if (wav->adapter) {

    g_object_unref (wav->adapter);

    wav->adapter = NULL;

  }

  G_OBJECT_CLASS (parent_class)->dispose (object);

}

static void

gst_wavparse_reset (GstWavParse * wavparse)

{

  wavparse->state = GST_WAVPARSE_START;

  /* These will all be set correctly in the fmt chunk */

  wavparse->depth = 0;

  wavparse->rate = 0;

  wavparse->width = 0;

  wavparse->channels = 0;

  wavparse->blockalign = 0;

  wavparse->bps = 0;

  wavparse->offset = 0;

  wavparse->end_offset = 0;

  wavparse->dataleft = 0;

  wavparse->datasize = 0;

  wavparse->datastart = 0;

  wavparse->got_fmt = FALSE;

  wavparse->first = TRUE;

  if (wavparse->seek_event)

    gst_event_unref (wavparse->seek_event);

  wavparse->seek_event = NULL;

  /* we keep the segment info in time */

  gst_segment_init (&wavparse->segment, GST_FORMAT_TIME);

}

static void

gst_wavparse_init (GstWavParse * wavparse)

{

  gst_wavparse_reset (wavparse);

  /* sink */

  wavparse->sinkpad =

      gst_pad_new_from_static_template (&sink_template_factory, "sink");

  gst_pad_set_activate_function (wavparse->sinkpad,

      GST_DEBUG_FUNCPTR (gst_wavparse_sink_activate));

  gst_pad_set_activatepull_function (wavparse->sinkpad,

      GST_DEBUG_FUNCPTR (gst_wavparse_sink_activate_pull));

  gst_pad_set_chain_function (wavparse->sinkpad,

      GST_DEBUG_FUNCPTR (gst_wavparse_chain));

  gst_element_add_pad (GST_ELEMENT (wavparse), wavparse->sinkpad);

  /* src, will be created later */

  wavparse->srcpad = NULL;

}

static void

gst_wavparse_destroy_sourcepad (GstWavParse * wavparse)

{

  if (wavparse->srcpad) {

    gst_element_remove_pad (GST_ELEMENT (wavparse), wavparse->srcpad);

    wavparse->srcpad = NULL;

  }

}

static void

gst_wavparse_create_sourcepad (GstWavParse * wavparse)

{

  /* destroy previous one */

  gst_wavparse_destroy_sourcepad (wavparse);

  /* source */

  wavparse->srcpad =

      gst_pad_new_from_static_template (&src_template_factory, "src");

  gst_pad_use_fixed_caps (wavparse->srcpad);

  gst_pad_set_query_type_function (wavparse->srcpad,

      GST_DEBUG_FUNCPTR (gst_wavparse_get_query_types));

  gst_pad_set_query_function (wavparse->srcpad,

      GST_DEBUG_FUNCPTR (gst_wavparse_pad_query));

  gst_pad_set_event_function (wavparse->srcpad,

      GST_DEBUG_FUNCPTR (gst_wavparse_srcpad_event));

  GST_DEBUG_OBJECT (wavparse, "srcpad created");

}

static void

gst_wavparse_get_property (GObject * object,

    guint prop_id, GValue * value, GParamSpec * pspec)

{

  GstWavParse *wavparse;

  wavparse = GST_WAVPARSE (object);

  switch (prop_id) {

    default:

      break;

  }

}

#if 0

static void

gst_wavparse_parse_adtl (GstWavParse * wavparse, int len)

{

  guint32 got_bytes;

  GstByteStream *bs = wavparse->bs;

  gst_riff_chunk *temp_chunk, chunk;

  guint8 *tempdata;

  struct _gst_riff_labl labl, *temp_labl;

  struct _gst_riff_ltxt ltxt, *temp_ltxt;

  struct _gst_riff_note note, *temp_note;

  char *label_name;

  GstProps *props;

  GstPropsEntry *entry;

  GstCaps *new_caps;

  GList *caps = NULL;

  props = wavparse->metadata->properties;

  while (len > 0) {

    got_bytes =

        gst_bytestream_peek_bytes (bs, &tempdata, sizeof (gst_riff_chunk));

    if (got_bytes != sizeof (gst_riff_chunk)) {

      return;

    }

    temp_chunk = (gst_riff_chunk *) tempdata;

    chunk.id = GUINT32_FROM_LE (temp_chunk->id);

    chunk.size = GUINT32_FROM_LE (temp_chunk->size);

    if (chunk.size == 0) {

      gst_bytestream_flush (bs, sizeof (gst_riff_chunk));

      len -= sizeof (gst_riff_chunk);

      continue;

    }

    switch (chunk.id) {

      case GST_RIFF_adtl_labl:

        got_bytes =

            gst_bytestream_peek_bytes (bs, &tempdata,

            sizeof (struct _gst_riff_labl));

        if (got_bytes != sizeof (struct _gst_riff_labl)) {

          return;

        }

        temp_labl = (struct _gst_riff_labl *) tempdata;

        labl.id = GUINT32_FROM_LE (temp_labl->id);

        labl.size = GUINT32_FROM_LE (temp_labl->size);

        labl.identifier = GUINT32_FROM_LE (temp_labl->identifier);

        gst_bytestream_flush (bs, sizeof (struct _gst_riff_labl));

        len -= sizeof (struct _gst_riff_labl);

        got_bytes = gst_bytestream_peek_bytes (bs, &tempdata, labl.size - 4);

        if (got_bytes != labl.size - 4) {

          return;

        }

        label_name = (char *) tempdata;

        gst_bytestream_flush (bs, ((labl.size - 4) + 1) & ~1);

        len -= (((labl.size - 4) + 1) & ~1);

        new_caps = gst_caps_new ("label",

            "application/x-gst-metadata",

            gst_props_new ("identifier", G_TYPE_INT (labl.identifier),

                "name", G_TYPE_STRING (label_name), NULL));

        if (gst_props_get (props, "labels", &caps, NULL)) {

          caps = g_list_append (caps, new_caps);

        } else {

          caps = g_list_append (NULL, new_caps);

          entry = gst_props_entry_new ("labels", GST_PROPS_GLIST (caps));

          gst_props_add_entry (props, entry);

        }

        break;

      case GST_RIFF_adtl_ltxt:

        got_bytes =

            gst_bytestream_peek_bytes (bs, &tempdata,

            sizeof (struct _gst_riff_ltxt));

        if (got_bytes != sizeof (struct _gst_riff_ltxt)) {

          return;

        }

        temp_ltxt = (struct _gst_riff_ltxt *) tempdata;

        ltxt.id = GUINT32_FROM_LE (temp_ltxt->id);

        ltxt.size = GUINT32_FROM_LE (temp_ltxt->size);

        ltxt.identifier = GUINT32_FROM_LE (temp_ltxt->identifier);

        ltxt.length = GUINT32_FROM_LE (temp_ltxt->length);

        ltxt.purpose = GUINT32_FROM_LE (temp_ltxt->purpose);

        ltxt.country = GUINT16_FROM_LE (temp_ltxt->country);

        ltxt.language = GUINT16_FROM_LE (temp_ltxt->language);

        ltxt.dialect = GUINT16_FROM_LE (temp_ltxt->dialect);

        ltxt.codepage = GUINT16_FROM_LE (temp_ltxt->codepage);

        gst_bytestream_flush (bs, sizeof (struct _gst_riff_ltxt));

        len -= sizeof (struct _gst_riff_ltxt);

        if (ltxt.size - 20 > 0) {

          got_bytes = gst_bytestream_peek_bytes (bs, &tempdata, ltxt.size - 20);

          if (got_bytes != ltxt.size - 20) {

            return;

          }

          gst_bytestream_flush (bs, ((ltxt.size - 20) + 1) & ~1);

          len -= (((ltxt.size - 20) + 1) & ~1);

          label_name = (char *) tempdata;

        } else {

          label_name = "";

        }

        new_caps = gst_caps_new ("ltxt",

            "application/x-gst-metadata",

            gst_props_new ("identifier", G_TYPE_INT (ltxt.identifier),

                "name", G_TYPE_STRING (label_name),

                "length", G_TYPE_INT (ltxt.length), NULL));

        if (gst_props_get (props, "ltxts", &caps, NULL)) {

          caps = g_list_append (caps, new_caps);

        } else {

          caps = g_list_append (NULL, new_caps);

          entry = gst_props_entry_new ("ltxts", GST_PROPS_GLIST (caps));

          gst_props_add_entry (props, entry);

        }

        break;

      case GST_RIFF_adtl_note:

        got_bytes =

            gst_bytestream_peek_bytes (bs, &tempdata,

            sizeof (struct _gst_riff_note));

        if (got_bytes != sizeof (struct _gst_riff_note)) {

          return;

        }

        temp_note = (struct _gst_riff_note *) tempdata;

        note.id = GUINT32_FROM_LE (temp_note->id);

        note.size = GUINT32_FROM_LE (temp_note->size);

        note.identifier = GUINT32_FROM_LE (temp_note->identifier);

        gst_bytestream_flush (bs, sizeof (struct _gst_riff_note));

        len -= sizeof (struct _gst_riff_note);

        got_bytes = gst_bytestream_peek_bytes (bs, &tempdata, note.size - 4);

        if (got_bytes != note.size - 4) {

          return;

        }

        gst_bytestream_flush (bs, ((note.size - 4) + 1) & ~1);

        len -= (((note.size - 4) + 1) & ~1);

        label_name = (char *) tempdata;

        new_caps = gst_caps_new ("note",

            "application/x-gst-metadata",

            gst_props_new ("identifier", G_TYPE_INT (note.identifier),

                "name", G_TYPE_STRING (label_name), NULL));

        if (gst_props_get (props, "notes", &caps, NULL)) {

          caps = g_list_append (caps, new_caps);

        } else {

          caps = g_list_append (NULL, new_caps);

          entry = gst_props_entry_new ("notes", GST_PROPS_GLIST (caps));

          gst_props_add_entry (props, entry);

        }

        break;

      default:

        g_print ("Unknown chunk: %" GST_FOURCC_FORMAT "\n",

            GST_FOURCC_ARGS (chunk.id));

        return;

    }

  }

  g_object_notify (G_OBJECT (wavparse), "metadata");

}

static void

gst_wavparse_parse_cues (GstWavParse * wavparse, int len)

{

  guint32 got_bytes;

  GstByteStream *bs = wavparse->bs;

  struct _gst_riff_cue *temp_cue, cue;

  struct _gst_riff_cuepoints *points;

  guint8 *tempdata;

  int i;

  GList *cues = NULL;

  GstPropsEntry *entry;

  while (len > 0) {

    int required;