/*

* Copyright (c) 2009 Nokia Corporation and/or its subsidiary(-ies). All rights reserved.

*

* 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., 59 Temple Place - Suite 330,

* Boston, MA 02111-1307, USA.

*

* Description:

*

*/

#include "gstreamer.h"

#include "GlibEventHandler.h"

#include <avkon.hrh>

#include <aknnotewrappers.h>

#include <stringloader.h>

#include <GSTPlayer.rsg>

#include <CAknMemorySelectionDialog.h>

#include <e32base.h>

#include <stdlib.h>

#include <mmf/server/sounddevice.h>

#include "gstplayerappview.h"

GstElement *pipeline, *source, *wavparse,*sink,*decoder,*conv,*resample,*record,*fakesink,*filesink,*encoder,*filter,*wavenc;

GstBus *bus;

GstCaps* caps;

GstState current,pending;

char carray[1024];

CGSTPlayerAppView *iGstView;

GstPad *dssinkpad;

GstCaps *dssinkcap;

GstPad *dssrcpad;

GstCaps *dssrccap;

GstStructure *str;

gboolean negcaps = FALSE;

static gboolean print_field (GQuark field, const GValue *value, gpointer pfx);

static void print_caps (const GstCaps *caps, const gchar *pfx);

static void

cb_raw_playback_handoff (GstElement *src, GstBuffer *buffer, GstPad *pad,

        gpointer user_data)

    {

    static gint readbytes = 0;

    static gboolean eofReached = FALSE;

    size_t readsize;

    gint size;

    FILE *f;

    GstCaps *bufCaps;

    if ( eofReached == TRUE )

        {

        //gst_element_set_state (pipeline, GST_STATE_NULL);

       // gst_object_unref (GST_OBJECT (pipeline));

        if ( gst_element_send_event (src, gst_event_new_eos ()) == TRUE )

            {

            g_print ("posted eos");

           }

       else

           {

            //g_print ("unable to post eos");

          }

       return;

       }

    readsize = 0;

    f = fopen (carray, "r");

    eofReached = TRUE;

    if ( fseek(f, readbytes, 0) == 0 )

        {

        readsize = fread (GST_BUFFER_DATA (buffer),1,GST_BUFFER_SIZE (buffer),f);

        eofReached = FALSE;

        GST_BUFFER_SIZE (buffer) = readsize;

        }

    fclose(f);

    size = GST_BUFFER_SIZE (buffer);

    readbytes += readsize;

    if ( (readsize < size) || (readsize == 0) )

        {

        eofReached = TRUE;

        }

    bufCaps = gst_caps_new_simple ("audio/x-raw-int",

              "width", G_TYPE_INT, 16,

              "depth", G_TYPE_INT, 16,

              "signed",G_TYPE_BOOLEAN, TRUE,

              "endianness",G_TYPE_INT, G_BYTE_ORDER,

              "rate", G_TYPE_INT, 8000,

              "channels", G_TYPE_INT, 1, NULL);

    gst_buffer_set_caps(buffer,bufCaps);

    }

static void

cb_play_mp3_handoff (GstElement *fakesrc,

        GstBuffer  *buffer,

        GstPad     *pad,

        gpointer    user_data)

{

GstCaps *bufCaps;

  static gint readbytes = 0;

  size_t readsize = 0;

  int size = GST_BUFFER_SIZE (buffer);

  FILE *f = fopen (carray, "r");

  fseek(f,readbytes,0);

  readsize = fread(GST_BUFFER_DATA (buffer),1,GST_BUFFER_SIZE (buffer),f);

  readbytes += readsize;

  GST_BUFFER_SIZE (buffer) = readsize;

  if(readsize == 0)

      {

      gst_element_send_event(fakesrc,gst_event_new_eos());

      }

  fclose(f);

}

static void

cb_record_raw_handoff (GstElement *fakesrc,

        GstBuffer  *buffer,

        GstPad     *pad,

        gpointer    user_data)

{

  int size = GST_BUFFER_SIZE (buffer);

  //g_print ("[%u]", size);

  FILE *f = fopen (carray, "a");

  fwrite(GST_BUFFER_DATA (buffer),1,GST_BUFFER_SIZE (buffer),f);

  fclose(f);

}

static gboolean

bus_call (GstBus     *bus,

          GstMessage *msg,

          gpointer    data)

{

  switch (GST_MESSAGE_TYPE (msg)) {

    case GST_MESSAGE_EOS:

        gst_element_set_state (pipeline, GST_STATE_NULL);

        gst_object_unref (GST_OBJECT (pipeline));

      break;

    case GST_MESSAGE_ERROR: {

      gchar *debug;

      GError *err;

      gst_message_parse_error (msg, &err, &debug);

      g_free (debug);

      g_print ("Error: %s\n", err->message);

      g_error_free (err);

      break;

    }

    default:

      break;

  }

  return TRUE;

}

static void 

new_pad_cb (GstElement *wavparse, GstPad *new_pad, gpointer pipeline)

 {

   //GstElement *sink,*conv,*resample;

   gst_element_set_state ((_GstElement *)pipeline, GST_STATE_PAUSED);

   sink = gst_element_factory_make ("devsoundsink", "sink");

   conv = gst_element_factory_make ("audioconvert", "audioconvert");

  	if (!conv) {

    	g_print ("could not create \"audioconvert\" element!");

    	return;

  		}

   resample = gst_element_factory_make ("audioresample", "audioresample");

  	if (!resample) {

    	g_print ("could not create \"audioresample\" element!");

    	return ;

  		}

   gst_bin_add_many(GST_BIN (pipeline), conv, resample, sink, NULL);

  // if (!gst_element_link (wavparse, sink))

     // g_error ("link(wavparse, sink) failed!\n");

 	if(! gst_element_link_many (wavparse,conv, resample, sink, NULL))

  		g_print ("link(wavparse,conv,remaple sink) failed!\n");  

   	gst_element_set_state ((_GstElement *)pipeline, GST_STATE_PLAYING);

 }

 #define FILENAME 1024

 int GstreamerNew(TFileName filename)

 {

  size_t ret;

  ret = wcstombs(carray, (const wchar_t *)filename.PtrZ(), FILENAME);

  int file_type=0;

  	char *p;

	p = strrchr(carray, '.');

	if ((p != NULL) && (strcmp(p, ".mp3") == 0))

	{

	file_type=2;	

	}

	else if ((p != NULL) && (strcmp(p, ".wav") == 0))

	{

	file_type=1;	

	}

    else if ((p != NULL) && (strcmp(p, ".raw") == 0))

    {

    file_type=3;    

    }

    else if ((p != NULL) && (strcmp(p, ".amr") == 0))

    {

    file_type=4;    

    }

    else if ((p != NULL) && (strcmp(p, ".g711") == 0))

    {

    file_type=5;    

    }

    else if ((p != NULL) && (strcmp(p, ".g729") == 0))

    {

    file_type=6;    

    }

    else if ((p != NULL) && (strcmp(p, ".lbc") == 0))

    {

    file_type=7;    

    }

	else

		return -1;

	if(file_type==1)

	{

		gst_play_wave();

	}

	else if(file_type==2)

	{

		gst_play_mp3();

	}

    else if(file_type==3)

    {

        gst_play_raw();

    }

    else if(file_type==4)

    {

        gst_play_amr();

    }

    else if(file_type==5)

    {

        gst_play_g711();

    }

    else if(file_type==6)

    {

        gst_play_g729();

    }

    else if(file_type==7)

    {

        gst_play_ilbc();

    }

	else

	{

		return 0;

	}

 } 

int gst_play_mp3()

{

 /* create elements */

 gboolean link_ok;

 pipeline = gst_pipeline_new ("pipeline");

 source = gst_element_factory_make ("filesrc", "filesrc");

 //sink = gst_element_factory_make ("fakesink", "sink");

 sink = gst_element_factory_make ("devsoundsink", "sink");

 caps = gst_caps_new_simple ("audio/mp3",

              "width", G_TYPE_INT, 16,

              "depth", G_TYPE_INT, 16,

              "signed",G_TYPE_BOOLEAN, TRUE,

              "endianness",G_TYPE_INT, G_BYTE_ORDER,

              "rate", G_TYPE_INT, 16000,

              "channels", G_TYPE_INT, 2, NULL);

 bus = gst_pipeline_get_bus (GST_PIPELINE (pipeline));

 gst_bus_add_watch( bus, bus_call, NULL);

 gst_object_unref (bus);

 g_object_set (G_OBJECT (source), "location", carray, NULL);

 gst_bin_add_many (GST_BIN (pipeline), source, sink, NULL);

 //gst_element_link (source, sink);

 link_ok = gst_element_link_filtered (source, sink, caps);

 gst_element_set_state (pipeline, GST_STATE_PLAYING);

 return 0;  

}

 int gst_play_wave()

 {

    /* create elements */

     if(!pipeline)

         {

         pipeline = gst_pipeline_new ("pipeline");

         bus = gst_pipeline_get_bus (GST_PIPELINE (pipeline));

         gst_bus_add_watch (bus, bus_call, NULL);

         gst_object_unref (bus);

         }

     if(!source)

         {

         source = gst_element_factory_make ("filesrc", "pavsrc");

         g_object_set (G_OBJECT (source), "location", carray, NULL);

         gst_bin_add (GST_BIN (pipeline), source);

         }

     if(!wavparse)

         {

         wavparse = gst_element_factory_make ("wavparse", "parse");

         gst_bin_add (GST_BIN (pipeline), wavparse );

         g_signal_connect (wavparse, "pad-added", G_CALLBACK (new_pad_cb),pipeline);

         }

      /* set filename property on the file source */

      if (!gst_element_link (source, wavparse))

          {

          g_print("could not link elements!");

          return -1;

          }

      gst_element_set_state (pipeline, GST_STATE_PLAYING); 

      return 0; 

 }

 int gst_record_wav()

    {

    /* create a new bin to hold the elements */

    pipeline = gst_pipeline_new("pipeline");

    record = gst_element_factory_make("devsoundsrc", "record_audio");

    if (!record)

        {

        g_print("could not create \"record\" element!");

        return -1;

        }

    filesink = gst_element_factory_make("filesink", "filesink");

    if (!filesink)

        {

        g_print("could not create \"filesink\" element!");

        return -1;

        }

    wavenc = gst_element_factory_make("wavenc", "wavencoder");

    if (!wavenc)

        {

        g_print("could not create \"wavenc\" element!");

        return -1;

        }

    _LIT(KFILENAME,"c:\\data\\test.wav");

    TFileName fn;

    fn.Append(KFILENAME);

    TInt ret;

    // char carray[FILENAME];

    ret = wcstombs(carray, (const wchar_t *)fn.PtrZ(), FILENAME);

    g_object_set(G_OBJECT (filesink), "location", carray, NULL);

    bus = gst_pipeline_get_bus(GST_PIPELINE (pipeline));

    gst_bus_add_watch(bus, bus_call, NULL);

    gst_object_unref(bus);

    /* add objects to the main pipeline */

    gst_bin_add_many(GST_BIN (pipeline),record,wavenc,filesink, NULL);

    /* link the elements */

    //gst_element_link_many(record, wavenc,filesink, NULL);

    caps = gst_caps_new_simple ("audio/x-raw-int",

              "width", G_TYPE_INT, 16,

              "depth", G_TYPE_INT, 16,

              "signed",G_TYPE_BOOLEAN, TRUE,

              "endianness",G_TYPE_INT, G_BYTE_ORDER,

              "rate", G_TYPE_INT, 16000,

              "channels", G_TYPE_INT, 1, NULL);

    gst_element_link_filtered (record, wavenc, caps);

    gst_element_link (wavenc, filesink);

    gst_caps_unref (caps);

    /* start recording */

    gst_element_set_state(pipeline, GST_STATE_PLAYING);

    return 0;

    }

 int gst_record_amr()

 {

 iGstView->DrawText(_L("Recording AMR"),KRgbRed);

   /* create a new bin to hold the elements */

  pipeline = gst_pipeline_new ("pipeline");

  //g_print ("pipeline created");

  record = gst_element_factory_make ("devsoundsrc", "record_audio"); 

 // encoder = gst_element_factory_make ("wavenc", NULL); 

  if (!record) {

    g_print ("could not create \"record\" element!");

    iGstView->DrawText(_L("Devsound src not available"),KRgbRed);

    return -1;

  }

  filesink = gst_element_factory_make("filesink", "filesink");

      if (!filesink)

          {

          g_print("could not create \"filesink\" element!");

          return -1;

          }

  caps = gst_caps_new_simple ("audio/amr",

             "width", G_TYPE_INT, 8,

             "depth", G_TYPE_INT, 8,

             "signed",G_TYPE_BOOLEAN, TRUE,

             "endianness",G_TYPE_INT, G_BYTE_ORDER,

             "rate", G_TYPE_INT,  8000,

             "channels", G_TYPE_INT, 1, NULL);

  g_object_set (G_OBJECT (record),

            "blocksize", 1280,

             NULL);

  _LIT(KFILENAME,"c:\\data\\recordtest.amr");

  TFileName fn;

  fn.Append(KFILENAME);

  TInt ret;

  ret = wcstombs(carray, (const wchar_t *)fn.PtrZ(), FILENAME);

  g_object_set(G_OBJECT (filesink), "location", carray, NULL);

  bus = gst_pipeline_get_bus (GST_PIPELINE (pipeline));

  gst_bus_add_watch (bus, bus_call, NULL);

  gst_object_unref (bus);

  /* add objects to the main pipeline */

  gst_bin_add_many(GST_BIN (pipeline),record,filesink , NULL);

  /* link the elements */

  gst_element_link_filtered (record, filesink, caps);

  gst_element_set_state (pipeline, GST_STATE_PLAYING);

  return 0;

 }

 int gst_record_g711()

  {

    /* create a new bin to hold the elements */

   pipeline = gst_pipeline_new ("pipeline");

   //g_print ("pipeline created");

   record = gst_element_factory_make ("devsoundsrc", "record_audio"); 

  // encoder = gst_element_factory_make ("wavenc", NULL); 

   if (!record) {

     g_print ("could not create \"record\" element!");

     return -1;

   }

   filesink = gst_element_factory_make("filesink", "filesink");

       if (!filesink)

           {

           g_print("could not create \"filesink\" element!");

           return -1;

           }

   caps = gst_caps_new_simple ("audio/x-alaw",

              "width", G_TYPE_INT, 8,

              "depth", G_TYPE_INT, 8,

              "signed",G_TYPE_BOOLEAN, TRUE,

              "endianness",G_TYPE_INT, G_BYTE_ORDER,

              "rate", G_TYPE_INT,  8000,

              "channels", G_TYPE_INT, 1, NULL);

   g_object_set (G_OBJECT (record),

             "blocksize", 1280,

              NULL);

   _LIT(KFILENAME,"c:\\data\\recordtest.g711");

   TFileName fn;

   fn.Append(KFILENAME);

   TInt ret;

   ret = wcstombs(carray, (const wchar_t *)fn.PtrZ(), FILENAME);

   g_object_set(G_OBJECT (filesink), "location", carray, NULL);

   bus = gst_pipeline_get_bus (GST_PIPELINE (pipeline));

   gst_bus_add_watch (bus, bus_call, NULL);

   gst_object_unref (bus);

   /* add objects to the main pipeline */

   gst_bin_add_many(GST_BIN (pipeline),record,filesink , NULL);

   /* link the elements */

   gst_element_link_filtered (record, filesink, caps);

   gst_element_set_state (pipeline, GST_STATE_PLAYING);

   return 0;

  }