/*
 * GStreamer
 * Copyright (C) 2017 Vivia Nikolaidou <vivia@toolsonair.com>
 *
 * test-audiomixmatrix.c
 *
 * 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., 51 Franklin St, Fifth Floor,
 * Boston, MA 02110-1301, USA.
 */

#define USE_GST_VALUE_ARRAY

#ifndef USE_GST_VALUE_ARRAY
/* FIXME 2.0: suppress warnings for deprecated API such as GValueArray
 * with newer GLib versions (>= 2.31.0) */
#define GLIB_DISABLE_DEPRECATION_WARNINGS
#endif

#include <gst/gst.h>
#include <string.h>

static gboolean
message_cb (GstBus * bus, GstMessage * message, gpointer user_data)
{
  switch (GST_MESSAGE_TYPE (message)) {
    case GST_MESSAGE_ERROR:{
      GError *err = NULL;
      gchar *debug = NULL;

      gst_message_parse_error (message, &err, &debug);
      gst_printerrln ("Error message received: %s", err->message);
      gst_printerrln ("Debug info: %s", debug);
      g_error_free (err);
      g_free (debug);
    }
    case GST_MESSAGE_EOS:
      g_main_loop_quit (user_data);
      break;
    default:
      break;
  }
  return TRUE;
}

static GstPadProbeReturn
_event_received (GstPad * pad, GstPadProbeInfo * info, gpointer user_data)
{
  GstCaps *caps;
  gchar *caps_str;
  GstEvent *event = GST_EVENT (info->data);

  if (GST_EVENT_TYPE (event) != GST_EVENT_CAPS)
    return GST_PAD_PROBE_OK;

  gst_event_parse_caps (event, &caps);
  if (!gst_caps_is_fixed (caps))
    return GST_PAD_PROBE_OK;

  caps_str = gst_caps_to_string (caps);

  g_print ("Caps received on %s: %s\n",
      GST_PAD_IS_SRC (pad) ? "source" : "sink", caps_str);

  g_free (caps_str);

  return GST_PAD_PROBE_OK;
}

int
main (int argc, char **argv)
{
  GstElement *audiotestsrc, *capsfilter, *audiomixmatrix, *audioconvert, *sink;
  GstPad *srcpad, *sinkpad;
  GstBus *bus;
  GMainLoop *loop;
  GstCaps *caps;
  GValue v2 = G_VALUE_INIT;
  GValue v3 = G_VALUE_INIT;
  GstElement *pipeline;
#ifdef USE_GST_VALUE_ARRAY
  GValue v = G_VALUE_INIT;
  gchar *serialized_matrix;
#else
  GValueArray *a, *ra;
#endif

  gst_init (&argc, &argv);

  audiotestsrc = gst_element_factory_make ("audiotestsrc", "audiotestsrc");
  capsfilter = gst_element_factory_make ("capsfilter", "capsfilter");
  caps =
      gst_caps_from_string
      ("audio/x-raw,channels=4,channel-mask=(bitmask)0,format=S32LE");
  g_object_set (capsfilter, "caps", caps, NULL);
  gst_caps_unref (caps);
  audiomixmatrix =
      gst_element_factory_make ("audiomixmatrix", "audiomixmatrix");
  g_object_set (audiomixmatrix, "in-channels", 4, NULL);
  g_object_set (audiomixmatrix, "out-channels", 2, NULL);
  g_object_set (audiomixmatrix, "channel-mask", 3, NULL);
  /* So the serialized matrix will be: < < 1, 0, 0, 0 >, < 0, 1, 0, 0 > > */
#ifdef USE_GST_VALUE_ARRAY
  g_value_init (&v, GST_TYPE_ARRAY);
  g_value_init (&v2, GST_TYPE_ARRAY);
  g_value_init (&v3, G_TYPE_DOUBLE);
  g_value_set_double (&v3, 1);
  gst_value_array_append_value (&v2, &v3);
  g_value_unset (&v3);
  g_value_init (&v3, G_TYPE_DOUBLE);
  g_value_set_double (&v3, 0);
  gst_value_array_append_value (&v2, &v3);
  g_value_unset (&v3);
  g_value_init (&v3, G_TYPE_DOUBLE);
  g_value_set_double (&v3, 0);
  gst_value_array_append_value (&v2, &v3);
  g_value_unset (&v3);
  g_value_init (&v3, G_TYPE_DOUBLE);
  g_value_set_double (&v3, 0);
  gst_value_array_append_value (&v2, &v3);
  g_value_unset (&v3);
  gst_value_array_append_value (&v, &v2);
  g_value_unset (&v2);
  g_value_init (&v2, GST_TYPE_ARRAY);
  g_value_init (&v3, G_TYPE_DOUBLE);
  g_value_set_double (&v3, 0);
  gst_value_array_append_value (&v2, &v3);
  g_value_unset (&v3);
  g_value_init (&v3, G_TYPE_DOUBLE);
  g_value_set_double (&v3, 1);
  gst_value_array_append_value (&v2, &v3);
  g_value_unset (&v3);
  g_value_init (&v3, G_TYPE_DOUBLE);
  g_value_set_double (&v3, 0);
  gst_value_array_append_value (&v2, &v3);
  g_value_unset (&v3);
  g_value_init (&v3, G_TYPE_DOUBLE);
  g_value_set_double (&v3, 0);
  gst_value_array_append_value (&v2, &v3);
  g_value_unset (&v3);
  gst_value_array_append_value (&v, &v2);
  g_value_unset (&v2);
  g_object_set_property (G_OBJECT (audiomixmatrix), "matrix", &v);
  /* Alternatively: gst_util_set_object_arg (audiomixmatrix, "matrix", "< < 1, 0> ..."); */
  serialized_matrix = gst_value_serialize (&v);
  gst_printerrln ("Serialized matrix: %s", serialized_matrix);
  g_free (serialized_matrix);
  g_value_unset (&v);
#else
  a = g_value_array_new (4);
  ra = g_value_array_new (2);
  g_value_init (&v2, G_TYPE_VALUE_ARRAY);
  g_value_init (&v3, G_TYPE_DOUBLE);
  g_value_set_double (&v3, 1);
  g_value_array_append (ra, &v3);
  g_value_unset (&v3);
  g_value_init (&v3, G_TYPE_DOUBLE);
  g_value_set_double (&v3, 0);
  g_value_array_append (ra, &v3);
  g_value_unset (&v3);
  g_value_init (&v3, G_TYPE_DOUBLE);
  g_value_set_double (&v3, 0);
  g_value_array_append (ra, &v3);
  g_value_unset (&v3);
  g_value_init (&v3, G_TYPE_DOUBLE);
  g_value_set_double (&v3, 0);
  g_value_array_append (ra, &v3);
  g_value_unset (&v3);
  g_value_take_boxed (&v2, ra);
  g_value_array_append (a, &v2);
  g_value_unset (&v2);
  ra = g_value_array_new (2);
  g_value_init (&v2, G_TYPE_VALUE_ARRAY);
  g_value_init (&v3, G_TYPE_DOUBLE);
  g_value_set_double (&v3, 0);
  g_value_array_append (ra, &v3);
  g_value_unset (&v3);
  g_value_init (&v3, G_TYPE_DOUBLE);
  g_value_set_double (&v3, 1);
  g_value_array_append (ra, &v3);
  g_value_unset (&v3);
  g_value_init (&v3, G_TYPE_DOUBLE);
  g_value_set_double (&v3, 0);
  g_value_array_append (ra, &v3);
  g_value_unset (&v3);
  g_value_init (&v3, G_TYPE_DOUBLE);
  g_value_set_double (&v3, 0);
  g_value_array_append (ra, &v3);
  g_value_unset (&v3);
  g_value_take_boxed (&v2, ra);
  g_value_array_append (a, &v2);
  g_value_unset (&v2);
  g_object_set (G_OBJECT (audiomixmatrix), "matrix-value-array", a, NULL);
  g_value_array_free (a);
#endif
  audioconvert = gst_element_factory_make ("audioconvert", "audioconvert");
  sink = gst_element_factory_make ("autoaudiosink", "sink");
  pipeline = gst_pipeline_new ("pipe");
  gst_bin_add_many (GST_BIN (pipeline), audiotestsrc, capsfilter,
      audiomixmatrix, audioconvert, sink, NULL);
  gst_element_link_many (audiotestsrc, capsfilter,
      audiomixmatrix, audioconvert, sink, NULL);

  srcpad = gst_element_get_static_pad (audiomixmatrix, "src");
  gst_pad_add_probe (srcpad, GST_PAD_PROBE_TYPE_EVENT_DOWNSTREAM,
      _event_received, NULL, NULL);
  gst_object_unref (srcpad);
  sinkpad = gst_element_get_static_pad (audiomixmatrix, "sink");
  gst_pad_add_probe (sinkpad, GST_PAD_PROBE_TYPE_EVENT_DOWNSTREAM,
      _event_received, NULL, NULL);
  gst_object_unref (sinkpad);

  if (gst_element_set_state (pipeline, GST_STATE_PLAYING) ==
      GST_STATE_CHANGE_FAILURE) {
    g_printerr ("ERROR: Could not change state in pipeline!\n");
    gst_object_unref (pipeline);
    return 1;
  }

  bus = gst_pipeline_get_bus (GST_PIPELINE (pipeline));
  loop = g_main_loop_new (NULL, FALSE);
  gst_bus_add_signal_watch (bus);
  g_signal_connect (G_OBJECT (bus), "message", G_CALLBACK (message_cb), loop);
  g_main_loop_run (loop);

  gst_element_set_state (pipeline, GST_STATE_NULL);
  gst_object_unref (bus);
  gst_object_unref (pipeline);


  return 0;

}